From 24c0db69107dacce058537a43f55ca57821aefc1 Mon Sep 17 00:00:00 2001 From: =?UTF-8?q?Cle=CC=81ment=20Doumouro?= Date: Wed, 3 Jan 2024 09:52:50 +0100 Subject: [PATCH] fix: don't nack already nacked tasks --- neo4j-app/neo4j_app/icij_worker/worker/worker.py | 3 ++- 1 file changed, 2 insertions(+), 1 deletion(-) diff --git a/neo4j-app/neo4j_app/icij_worker/worker/worker.py b/neo4j-app/neo4j_app/icij_worker/worker/worker.py index e0681ac7..b7cbaf53 100644 --- a/neo4j-app/neo4j_app/icij_worker/worker/worker.py +++ b/neo4j-app/neo4j_app/icij_worker/worker/worker.py @@ -162,7 +162,6 @@ async def acknowledgment_cm(self, task: Task, project: str): await self.save_error(error=task_error, task=task, project=project) await self.negatively_acknowledge(task, project, requeue=False) raise fatal_error - self._current = None self.info('Task(id="%s") successful !', task.id) @final @@ -170,6 +169,7 @@ async def acknowledge(self, task: Task, project: str): completed_at = datetime.now() self.info('Task(id="%s") acknowledging...', task.id) await self._acknowledge(task, project, completed_at) + self._current = None self.info('Task(id="%s") acknowledged', task.id) self.debug('Task(id="%s") publishing acknowledgement event', task.id) event = TaskEvent( @@ -197,6 +197,7 @@ async def negatively_acknowledge( requeue, ) nacked = await self._negatively_acknowledge(task, project, requeue=requeue) + self._current = None self.info("Task(id=%s) negatively acknowledged (requeue=%s)!", task.id, requeue) return nacked