From d95e0f06593cb70e6857a361125c3dbcf21e699b Mon Sep 17 00:00:00 2001 From: Ahmet Gedemenli Date: Fri, 13 Jan 2023 01:31:38 +0300 Subject: [PATCH] test --- src/backend/distributed/commands/dependencies.c | 13 +++---------- 1 file changed, 3 insertions(+), 10 deletions(-) diff --git a/src/backend/distributed/commands/dependencies.c b/src/backend/distributed/commands/dependencies.c index 87491a4f5..7b5b05fe6 100644 --- a/src/backend/distributed/commands/dependencies.c +++ b/src/backend/distributed/commands/dependencies.c @@ -114,16 +114,9 @@ EnsureDependenciesExistOnAllNodes(const ObjectAddress *target) dependency->objectSubId, ExclusiveLock); } - WorkerNode *workerNode = NULL; - foreach_ptr(workerNode, workerNodeList) - { - const char *nodeName = workerNode->workerName; - uint32 nodePort = workerNode->workerPort; - - SendCommandListToWorkerOutsideTransaction(nodeName, nodePort, - CitusExtensionOwnerName(), - ddlCommands); - } + SendMetadataCommandListToWorkerListInCoordinatedTransaction(workerNodeList, + CitusExtensionOwnerName(), + ddlCommands); /* * We do this after creating the objects on the workers, we make sure