Add schema name to worker_modify_identity_columns UDF

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,

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);

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';
 

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';