D1777.id6146.diff
No OneTemporary
Actions

Size

1 KB

Subscribers

None

D1777.id6146.diff
View Options

	diff --git a/swh/journal/cli.py b/swh/journal/cli.py
	--- a/swh/journal/cli.py
	+++ b/swh/journal/cli.py
	@@ -7,6 +7,7 @@
	import logging
	import mmap
	import os
	+import time

	import click

	@@ -97,9 +98,13 @@

	try:
	nb_messages = 0
	+ last_log_time = 0
	while not max_messages or nb_messages < max_messages:
	nb_messages += client.process(worker_fn)
	- logger.info('Processed %d messages.' % nb_messages)
	+ if time.time() - last_log_time >= 60:
	+ # Log at most once per minute.
	+ logger.info('Processed %d messages.' % nb_messages)
	+ last_log_time = time.time()
	except KeyboardInterrupt:
	ctx.exit(0)
	else:
	@@ -214,9 +219,13 @@

	try:
	nb_messages = 0
	+ last_log_time = 0
	while not max_messages or nb_messages < max_messages:
	nb_messages += client.process(worker_fn)
	- logger.info('Processed %d messages.' % nb_messages)
	+ if time.time() - last_log_time >= 60:
	+ # Log at most once per minute.
	+ logger.info('Processed %d messages.' % nb_messages)
	+ last_log_time = time.time()
	except KeyboardInterrupt:
	ctx.exit(0)
	else: