Improve logging of replication (#16309)

pull/16311/head
Erik Johnston 2023-09-13 10:51:50 +01:00 committed by GitHub
parent 48387c56f1
commit ab13fb08bf
No known key found for this signature in database
GPG Key ID: 4AEE18F83AFDEB23
3 changed files with 8 additions and 2 deletions

1
changelog.d/16309.misc Normal file
View File

@ -0,0 +1 @@
Small improvements to logging in replication code.

View File

@ -644,7 +644,7 @@ class ReplicationCommandHandler:
[stream.parse_row(row) for row in rows],
)
logger.info("Caught up with stream '%s' to %i", stream_name, cmd.new_token)
logger.info("Caught up with stream '%s' to %i", stream_name, cmd.new_token)
# We've now caught up to position sent to us, notify handler.
await self._replication_data_handler.on_position(

View File

@ -191,7 +191,12 @@ class ReplicationStreamer:
if updates:
logger.info(
"Streaming: %s -> %s", stream.NAME, updates[-1][0]
"Streaming: %s -> %s (limited: %s, updates: %s, max token: %s)",
stream.NAME,
updates[-1][0],
limited,
len(updates),
current_token,
)
stream_updates_counter.labels(stream.NAME).inc(len(updates))