D6233.id22615.diff
No OneTemporary
Actions

Size

902 B

Subscribers

None

D6233.id22615.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
	@@ -89,6 +89,7 @@

	if offset >= self.offset_ranges[partition_id][1] - 1:
	if partition_id in self.assignment:
	+ self.progress_queue.put({partition_id: offset})
	self.assignment = [
	pid for pid in self.assignment if pid != partition_id
	]
	@@ -248,7 +249,7 @@
	active_workers -= 1
	continue
	d.update(item)
	- progress = sum(n - self.offsets[p][0] for p, n in d.items())
	+ progress = sum(n + 1 - self.offsets[p][0] for p, n in d.items())
	pbar.set_postfix(
	active_workers=active_workers, total_workers=self.processes
	)