D7464.diff
No OneTemporary
Actions

Size

986 B

Subscribers

None

D7464.diff
View Options

	diff --git a/swh/dataset/journalprocessor.py b/swh/dataset/journalprocessor.py
	--- a/swh/dataset/journalprocessor.py
	+++ b/swh/dataset/journalprocessor.py
	@@ -255,7 +255,7 @@
	tqdm.tqdm(
	executor.map(fetch_insert_partition_id, partitions.keys()),
	total=len(partitions),
	- desc=" - Partition offsets",
	+ desc=" - Offset",
	)
	)
	client.close()
	@@ -304,8 +304,8 @@
	d = {}
	active_workers = self.processes
	offset_diff = sum((hi - lo) for lo, hi in self.offsets.values())
	- desc = f" - Export ({self.obj_type})"
	- with tqdm.tqdm(total=offset_diff, desc=desc) as pbar:
	+ desc = " - Export"
	+ with tqdm.tqdm(total=offset_diff, desc=desc, unit_scale=True) as pbar:
	while active_workers:
	item = queue.get()
	if item is None: