ahmet-test
Ahmet Gedemenli 2023-01-13 01:31:38 +03:00
parent 28ed013a91
commit d95e0f0659
1 changed files with 3 additions and 10 deletions

View File

@ -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,
SendMetadataCommandListToWorkerListInCoordinatedTransaction(workerNodeList,
CitusExtensionOwnerName(),
ddlCommands);
}
/*
* We do this after creating the objects on the workers, we make sure