D1252.diff
No OneTemporary
Actions

Size

805 B

Subscribers

None

D1252.diff
View Options

	diff --git a/swh/scheduler/celery_backend/listener.py b/swh/scheduler/celery_backend/listener.py
	--- a/swh/scheduler/celery_backend/listener.py
	+++ b/swh/scheduler/celery_backend/listener.py
	@@ -89,8 +89,6 @@
	for message in messages:
	if not message.acknowledged:
	message.ack()
	- else:
	- logger.info('message already acknowledged: %s', message)
	actions['queue'] = []
	actions['last_send'] = utcnow()

	@@ -102,8 +100,6 @@
	logger.debug('event: %s %s', event['type'], event.get('name', 'N/A'))
	if not message.acknowledged:
	message.ack()
	- else:
	- logger.info('message already acknowledged: %s', message)
	try_perform_actions()

	def task_started(event, message):