D2205.id7665.diff
No OneTemporary
Actions

Size

514 B

Subscribers

None

D2205.id7665.diff
View Options

	diff --git a/swh/journal/client.py b/swh/journal/client.py
	--- a/swh/journal/client.py
	+++ b/swh/journal/client.py
	@@ -171,10 +171,11 @@
	self.value_deserializer(message.value())
	)

	- if nb_messages:
	- worker_fn(dict(objects))
	+ if objects:
	+ worker_fn(dict(objects))
	+ objects.clear()

	- self.consumer.commit()
	+ self.consumer.commit()
	return nb_messages

	def close(self):

File Metadata

Mime Type: text/plain
Expires: Jun 3 2025, 6:46 PM (14 w, 1 d ago)
Storage Engine: blob
Storage Format: Raw Data
Storage Handle: 3217783

Event Timeline