D1904.id6401.diff
No OneTemporary
Actions

Size

857 B

Subscribers

None

D1904.id6401.diff
View Options

	diff --git a/swh/journal/backfill.py b/swh/journal/backfill.py
	--- a/swh/journal/backfill.py
	+++ b/swh/journal/backfill.py
	@@ -368,6 +368,13 @@
	yield record


	+def _format_range_bound(bound):
	+ if isinstance(bound, bytes):
	+ return bound.hex()
	+ else:
	+ return str(bound)
	+
	+
	MANDATORY_KEYS = ['brokers', 'storage_dbconn', 'prefix', 'client_id']


	@@ -438,7 +445,8 @@
	for range_start, range_end in RANGE_GENERATORS[object_type](
	start_object, end_object):
	logger.info('Processing %s range %s to %s', object_type,
	- range_start, range_end)
	+ _format_range_bound(range_start),
	+ _format_range_bound(range_end))

	for obj in fetch(
	db, object_type, start=range_start, end=range_end,