diff options
Diffstat (limited to 'src/backend/replication/logical/worker.c')
| -rw-r--r-- | src/backend/replication/logical/worker.c | 7 |
1 files changed, 7 insertions, 0 deletions
diff --git a/src/backend/replication/logical/worker.c b/src/backend/replication/logical/worker.c index dbf88c95531..879309b316c 100644 --- a/src/backend/replication/logical/worker.c +++ b/src/backend/replication/logical/worker.c @@ -331,6 +331,9 @@ static TransactionId stream_xid = InvalidTransactionId; */ static uint32 parallel_stream_nchanges = 0; +/* Are we initializing a apply worker? */ +bool InitializingApplyWorker = false; + /* * We enable skipping all data modification changes (INSERT, UPDATE, etc.) for * the subscription if the remote transaction's finish LSN matches the subskiplsn. @@ -4526,6 +4529,8 @@ ApplyWorkerMain(Datum main_arg) WalRcvStreamOptions options; int server_version; + InitializingApplyWorker = true; + /* Attach to slot */ logicalrep_worker_attach(worker_slot); @@ -4548,6 +4553,8 @@ ApplyWorkerMain(Datum main_arg) InitializeApplyWorker(); + InitializingApplyWorker = false; + /* Connect to the origin and start the replication. */ elog(DEBUG1, "connecting to publisher using connection string \"%s\"", MySubscription->conninfo); |