diff --git a/src/backend/distributed/transaction/worker_transaction.c b/src/backend/distributed/transaction/worker_transaction.c
index 5880fdba7..4d1f564a6 100644
--- a/src/backend/distributed/transaction/worker_transaction.c
+++ b/src/backend/distributed/transaction/worker_transaction.c
@@ -340,17 +340,7 @@ SendCommandListToWorkerOutsideTransaction(const char *nodeName, int32 nodePort,
 																	  nodeName, nodePort,
 																	  nodeUser, NULL);
 
-	MarkRemoteTransactionCritical(workerConnection);
-	RemoteTransactionBegin(workerConnection);
-
-	/* iterate over the commands and execute them in the same connection */
-	const char *commandString = NULL;
-	foreach_ptr(commandString, commandList)
-	{
-		ExecuteCriticalRemoteCommand(workerConnection, commandString);
-	}
-
-	RemoteTransactionCommit(workerConnection);
+	SendCommandListToWorkerInSeparateTransaction(workerConnection, commandList);
 	CloseConnection(workerConnection);
 }