Skip to content

Commit 65f48bc

Browse files
committed
fix basebackup key cleanup
1 parent aa620dc commit 65f48bc

File tree

1 file changed

+1
-1
lines changed

1 file changed

+1
-1
lines changed

Diff for: src/pglogical_apply.c

+1-1
Original file line numberDiff line numberDiff line change
@@ -1597,7 +1597,7 @@ MtmExecutor(void* work, size_t size, MtmReceiverContext *receiver_ctx)
15971597
PushActiveSnapshot(GetTransactionSnapshot());
15981598

15991599
rc = SPI_execute("delete from mtm.config where key='basebackup'", false, 0);
1600-
if (rc != SPI_OK_INSERT)
1600+
if (rc != SPI_OK_DELETE)
16011601
mtm_log(ERROR, "Failed to load node list");
16021602

16031603
if (SPI_finish() != SPI_OK_FINISH)

0 commit comments

Comments
 (0)