Added logs in MultiWriterIdGenerator.__init__() and get_cache_dict.

This commit is contained in:
prajjawal05 2023-08-22 01:57:31 -04:00
parent d6ae4041a4
commit cdbd249e88
2 changed files with 5 additions and 1 deletions

View File

@ -2395,6 +2395,7 @@ class DatabasePool:
min_val = min(cache.values()) + 1
else:
min_val = max_value
logger.debug("Calling get_cache_dict %s: %s", table, sql)
return cache, min_val

View File

@ -432,7 +432,10 @@ class MultiWriterIdGenerator(AbstractStreamIdGenerator):
# write to the stream. In which case, let's pre-seed our own
# position with the current minimum.
self._current_positions[self._instance_name] = self._persisted_upto_position
table_string = "\n".join(", ".join(row) for row in tables)
logger.debug(f"{table_string}")
def _load_current_ids(
self,
db_conn: LoggingDatabaseConnection,