diff --git a/src/backend/distributed/operations/worker_shard_copy.c b/src/backend/distributed/operations/worker_shard_copy.c
index ce00a2e73..2178c6186 100644
--- a/src/backend/distributed/operations/worker_shard_copy.c
+++ b/src/backend/distributed/operations/worker_shard_copy.c
@@ -288,6 +288,9 @@ ShardCopyDestReceiverStartup(DestReceiver *dest, int operation, TupleDesc
 }
 
 
+/* CreateReplicationOriginIfNotExists creates a replication origin if it does
+ * not already exist already. To make the origin id unique for different nodes,
+ * origin node's id is appended to the prefix citus_cdc_.*/
 static void
 CreateReplicationOriginIfNotExists(ShardCopyDestReceiver *dest)
 {