Merge 45836bc513
into be65a8ec01
commit
2ba188910a
|
@ -0,0 +1 @@
|
|||
Added additional debug logging to MultiWriterIdGenerator.__init__ and get_cache_dict.
|
|
@ -2386,6 +2386,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
|
||||
|
||||
|
|
|
@ -460,6 +460,9 @@ class MultiWriterIdGenerator(AbstractStreamIdGenerator):
|
|||
# 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,
|
||||
|
|
Loading…
Reference in New Issue