diff options
Diffstat (limited to 'src/backend/replication/logical/applyparallelworker.c')
| -rw-r--r-- | src/backend/replication/logical/applyparallelworker.c | 4 |
1 files changed, 4 insertions, 0 deletions
diff --git a/src/backend/replication/logical/applyparallelworker.c b/src/backend/replication/logical/applyparallelworker.c index 45186837795..ee7a18137fc 100644 --- a/src/backend/replication/logical/applyparallelworker.c +++ b/src/backend/replication/logical/applyparallelworker.c @@ -873,6 +873,8 @@ ParallelApplyWorkerMain(Datum main_arg) int worker_slot = DatumGetInt32(main_arg); char originname[NAMEDATALEN]; + InitializingApplyWorker = true; + /* Setup signal handling. */ pqsignal(SIGHUP, SignalHandlerForConfigReload); pqsignal(SIGINT, SignalHandlerForShutdownRequest); @@ -940,6 +942,8 @@ ParallelApplyWorkerMain(Datum main_arg) InitializeApplyWorker(); + InitializingApplyWorker = false; + /* Setup replication origin tracking. */ StartTransactionCommand(); ReplicationOriginNameForLogicalRep(MySubscription->oid, InvalidOid, |