diff --git a/src/backend/distributed/operations/shard_cleaner.c b/src/backend/distributed/operations/shard_cleaner.c
index 8b852695a..a38e3b801 100644
--- a/src/backend/distributed/operations/shard_cleaner.c
+++ b/src/backend/distributed/operations/shard_cleaner.c
@@ -453,7 +453,17 @@ InsertCleanupRecordInSubtransaction(CleanupObjectType objectType, char *objectNa
 					 quote_literal_cstr(objectName),
 					 nodeGroupId);
 
-	ExecuteRebalancerCommandInSeparateTransaction(command->data);
+	int connectionFlag = FORCE_NEW_CONNECTION;
+	char *userName= CitusExtensionOwnerName();
+	MultiConnection *connection = GetNodeUserDatabaseConnection(connectionFlag,
+																LocalHostName,
+																PostPortNumber,
+																userName,
+																NULL);
+
+	ExecuteCriticalRemoteCommand(connection, command->data);
+	CloseConnection(connection);
+
 }