diff --git a/src/backend/distributed/connection/connection_management.c b/src/backend/distributed/connection/connection_management.c index 2696ce94d..175b60c52 100644 --- a/src/backend/distributed/connection/connection_management.c +++ b/src/backend/distributed/connection/connection_management.c @@ -581,6 +581,8 @@ EnsureAndGetHealthyConnections(dlist_head *connections) (transaction->transactionCritical || !dlist_is_empty(&connection->referencedPlacements))) { + CHECK_FOR_INTERRUPTS(); + ReportConnectionError(connection, ERROR); /*