diff --git a/src/backend/distributed/metadata/metadata_sync.c b/src/backend/distributed/metadata/metadata_sync.c
index d83706535..6db3ce28e 100644
--- a/src/backend/distributed/metadata/metadata_sync.c
+++ b/src/backend/distributed/metadata/metadata_sync.c
@@ -3904,7 +3904,7 @@ citus_internal_database_command(PG_FUNCTION_ARGS)
 	CheckCitusVersion(ERROR);
 	if (!ShouldSkipMetadataChecks())
 	{
-		EnsureCoordinatorInitiatedOperation();
+		EnsureCitusInitiatedOperation();
 	}
 	PG_ENSURE_ARGNOTNULL(0, "database command");