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):