D5908.id21205.diff
No OneTemporary
Actions

Size

1 KB

Subscribers

None

D5908.id21205.diff
View Options

	diff --git a/swh/counters/journal_client.py b/swh/counters/journal_client.py
	--- a/swh/counters/journal_client.py
	+++ b/swh/counters/journal_client.py
	@@ -7,11 +7,11 @@

	import msgpack

	-from swh.counters.redis import Redis
	+from swh.counters.interface import CountersInterface


	def process_journal_messages(
	- messages: Dict[str, Dict[bytes, bytes]], *, counters: Redis
	+ messages: Dict[str, Dict[bytes, bytes]], *, counters: CountersInterface
	) -> None:
	"""Count the number of different values of an object's property.
	It allow for example to count the persons inside the
	@@ -27,7 +27,7 @@
	process_releases(messages["release"], counters)


	-def process_revisions(revisions: Dict[bytes, bytes], counters: Redis):
	+def process_revisions(revisions: Dict[bytes, bytes], counters: CountersInterface):
	"""Count the number of different authors and committers on the
	revisions (in the person collection)"""
	persons = set()
	@@ -39,7 +39,7 @@
	counters.add("person", list(persons))


	-def process_releases(releases: Dict[bytes, bytes], counters: Redis):
	+def process_releases(releases: Dict[bytes, bytes], counters: CountersInterface):
	"""Count the number of different authors on the
	releases (in the person collection)"""
	persons = set()