diff --git a/src/backend/distributed/transaction/backend_data.c b/src/backend/distributed/transaction/backend_data.c
index 5d16b92b7..3de8e80f3 100644
--- a/src/backend/distributed/transaction/backend_data.c
+++ b/src/backend/distributed/transaction/backend_data.c
@@ -867,6 +867,7 @@ AssignDistributedTransactionId(void)
 void
 AssignGlobalPID(void)
 {
+	elog(WARNING, "AssignGlobalPID");
 	uint64 globalPID = INVALID_CITUS_INTERNAL_BACKEND_GPID;
 	bool distributedCommandOriginator = false;
 
@@ -901,6 +902,7 @@ AssignGlobalPID(void)
 void
 SetBackendDataGlobalPID(uint64 globalPID)
 {
+	elog(WARNING, "SetBackendDataGlobalPID");
 	SpinLockAcquire(&MyBackendData->mutex);
 
 	MyBackendData->globalPID = globalPID;
diff --git a/src/test/regress/spec/isolation_get_distributed_wait_queries_mx.spec b/src/test/regress/spec/isolation_get_distributed_wait_queries_mx.spec
index 03512f343..d29b4cdb7 100644
--- a/src/test/regress/spec/isolation_get_distributed_wait_queries_mx.spec
+++ b/src/test/regress/spec/isolation_get_distributed_wait_queries_mx.spec
@@ -166,7 +166,7 @@ step "s3-select-distributed-waiting-queries"
 // only works for the coordinator
 step "s3-show-actual-gpids"
 {
-	SELECT global_pid > 0 as gpid_exists, query FROM citus_stat_activity WHERE state = 'active' AND query IN (SELECT blocked_statement FROM citus_lock_waits UNION SELECT current_statement_in_blocking_process FROM citus_lock_waits) ORDER BY 1 DESC;
+	SELECT global_pid > 0 as gpid_exists, global_pid, query FROM citus_stat_activity WHERE state = 'active' AND query IN (SELECT blocked_statement FROM citus_lock_waits UNION SELECT current_statement_in_blocking_process FROM citus_lock_waits) ORDER BY 1 DESC;
 }
 
 // session s1 and s4 executes the commands on the same worker node