--- a/src/backend/replication/logical/tablesync.c
+++ b/src/backend/replication/logical/tablesync.c
@@ -1529,10 +1529,30 @@ copy_table_done:
        SpinLockRelease(&MyLogicalRepWorker->relmutex);

        /*
-        * Finally, wait until the leader apply worker tells us to catch up