diff --git a/src/backend/distributed/commands/database.c b/src/backend/distributed/commands/database.c
index 78534fef3..54633e97c 100644
--- a/src/backend/distributed/commands/database.c
+++ b/src/backend/distributed/commands/database.c
@@ -512,7 +512,7 @@ PreprocessCreateDatabaseStmt(Node *node, const char *queryString,
 	WorkerNode *workerNode = NULL;
 	foreach_ptr(workerNode, allNodes)
 	{
-		InsertCleanupRecordInSubtransaction(
+		InsertCleanupRecordOutsideTransaction(
 			CLEANUP_OBJECT_DATABASE,
 			pstrdup(quote_identifier(tempDatabaseName)),
 			workerNode->groupId,