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