Set worker status to Idle after applying

Andrei Kruchinin · Andrei Kruchinin · commit f3947bf59b60 · 2022-11-25T13:18:27.000+05:00
diff --git a/src/ddl.c b/src/ddl.c
@@ -1629,7 +1629,7 @@ MtmDDLResetApplyState()
 	DDLApplyInProgress = false;
 	/* the memory it points to is about to go away */
 	debug_query_string = NULL;
-	pgstat_report_activity(STATE_RUNNING, NULL);
+	pgstat_report_activity(STATE_IDLE, "");
 }
 
 
diff --git a/src/pglogical_apply.c b/src/pglogical_apply.c
@@ -385,7 +385,7 @@ process_remote_message(StringInfo s, MtmReceiverWorkerContext *rwctx)
 				MtmApplyDDLMessage(messageBody, false);
 				CommitTransactionCommand();
 
-				pgstat_report_activity(STATE_RUNNING, NULL);
+				pgstat_report_activity(STATE_IDLE, "");
 				standalone = true;
 				break;
 			}
@@ -396,7 +396,7 @@ process_remote_message(StringInfo s, MtmReceiverWorkerContext *rwctx)
 				pfree(activity);
 				mtm_log(MtmApplyMessage, "executing tx DDL message %s", messageBody);
 				MtmApplyDDLMessage(messageBody, true);
-				pgstat_report_activity(STATE_RUNNING, NULL);
+				pgstat_report_activity(STATE_IDLE, "");
 				break;
 			}
 		case 'L':

Original file line number	Diff line number	Diff line change
`@@ -1629,7 +1629,7 @@ MtmDDLResetApplyState()`
`1629`	`1629`	`DDLApplyInProgress = false;`
`1630`	`1630`	`/* the memory it points to is about to go away */`
`1631`	`1631`	`debug_query_string = NULL;`
`1632`		`- pgstat_report_activity(STATE_RUNNING, NULL);`
	`1632`	`+ pgstat_report_activity(STATE_IDLE, "");`
`1633`	`1633`	`}`
`1634`	`1634`
`1635`	`1635`