Skip to content
This repository was archived by the owner on Mar 6, 2026. It is now read-only.

Commit 151b6e4

Browse files
pslavovivanovyordan
authored andcommitted
Improve logging when starting logical decoding
1 parent 8e385c3 commit 151b6e4

1 file changed

Lines changed: 2 additions & 1 deletion

File tree

tap_postgres/sync_strategies/logical_replication.py

Lines changed: 2 additions & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -436,7 +436,8 @@ def sync_tables(conn_info, logical_streams, state, end_lsn):
436436

437437
conn = post_db.open_connection(conn_info, True)
438438
with conn.cursor() as cur:
439-
LOGGER.info("Starting Logical Replication for %s(%s): %s -> %s. poll_total_seconds: %s", list(map(lambda s: s['tap_stream_id'], logical_streams)), slot, start_lsn, end_lsn, poll_total_seconds)
439+
LOGGER.info("Starting Logical Replication from slot %s: %s -> %s. poll_total_seconds: %s", slot, start_lsn, end_lsn, poll_total_seconds)
440+
LOGGER.info("Starting at bookmark: %s", list(map(lambda s: s['tap_stream_id'], logical_streams)))
440441

441442
replication_params = {"slot_name": slot,
442443
"decode": True,

0 commit comments

Comments
 (0)