diff --git a/src/backend/distributed/commands/create_distributed_table.c b/src/backend/distributed/commands/create_distributed_table.c
index b86126463..a805a19ec 100644
--- a/src/backend/distributed/commands/create_distributed_table.c
+++ b/src/backend/distributed/commands/create_distributed_table.c
@@ -98,7 +98,7 @@
  * once every LOG_PER_TUPLE_AMOUNT, the copy will be logged.
  */
 #define LOG_PER_TUPLE_AMOUNT 1000000
-#define WORKER_MODIFY_IDENTITY_COMMAND "SELECT worker_modify_identity_columns(%s)"
+#define WORKER_MODIFY_IDENTITY_COMMAND "SELECT pg_catalog.worker_modify_identity_columns(%s)"
 
 /* local function forward declarations */
 static void CreateDistributedTableConcurrently(Oid relationId,
diff --git a/src/backend/distributed/sql/downgrades/citus--11.3-1--11.2-1.sql b/src/backend/distributed/sql/downgrades/citus--11.3-1--11.2-1.sql
index 5d35221f1..2a131c2fa 100644
--- a/src/backend/distributed/sql/downgrades/citus--11.3-1--11.2-1.sql
+++ b/src/backend/distributed/sql/downgrades/citus--11.3-1--11.2-1.sql
@@ -1,2 +1,2 @@
 -- citus--11.3-1--11.2-1
-DROP FUNCTION IF EXISTS worker_modify_identity_columns(regclass);
+DROP FUNCTION IF EXISTS pg_catalog.worker_modify_identity_columns(regclass);
diff --git a/src/backend/distributed/sql/udfs/worker_modify_identity_columns/11.3-1.sql b/src/backend/distributed/sql/udfs/worker_modify_identity_columns/11.3-1.sql
index 9ab3891a3..8c85f2ad1 100644
--- a/src/backend/distributed/sql/udfs/worker_modify_identity_columns/11.3-1.sql
+++ b/src/backend/distributed/sql/udfs/worker_modify_identity_columns/11.3-1.sql
@@ -1,7 +1,7 @@
-CREATE OR REPLACE FUNCTION worker_modify_identity_columns(regclass)
+CREATE OR REPLACE FUNCTION pg_catalog.worker_modify_identity_columns(regclass)
     RETURNS VOID
     LANGUAGE C STRICT
     AS 'MODULE_PATHNAME', $$worker_modify_identity_columns$$;
-COMMENT ON FUNCTION worker_modify_identity_columns(regclass)
+COMMENT ON FUNCTION pg_catalog.worker_modify_identity_columns(regclass)
     IS 'modify identity columns to produce globally unique values';
 
diff --git a/src/backend/distributed/sql/udfs/worker_modify_identity_columns/latest.sql b/src/backend/distributed/sql/udfs/worker_modify_identity_columns/latest.sql
index 9ab3891a3..8c85f2ad1 100644
--- a/src/backend/distributed/sql/udfs/worker_modify_identity_columns/latest.sql
+++ b/src/backend/distributed/sql/udfs/worker_modify_identity_columns/latest.sql
@@ -1,7 +1,7 @@
-CREATE OR REPLACE FUNCTION worker_modify_identity_columns(regclass)
+CREATE OR REPLACE FUNCTION pg_catalog.worker_modify_identity_columns(regclass)
     RETURNS VOID
     LANGUAGE C STRICT
     AS 'MODULE_PATHNAME', $$worker_modify_identity_columns$$;
-COMMENT ON FUNCTION worker_modify_identity_columns(regclass)
+COMMENT ON FUNCTION pg_catalog.worker_modify_identity_columns(regclass)
     IS 'modify identity columns to produce globally unique values';