diff --git a/src/blueapi/worker/task_worker.py b/src/blueapi/worker/task_worker.py
index 9da569f0c..219a1c1ca 100644
--- a/src/blueapi/worker/task_worker.py
+++ b/src/blueapi/worker/task_worker.py
@@ -475,7 +475,7 @@ def process_task():
 
         if self._current is not None:
             self._current.is_complete = True
-            self._pending_tasks.pop(self._current.task_id)
+            self._pending_tasks.pop(self._current.task_id, None)
             self._completed_tasks[self._current.task_id] = self._current
         self._report_status()
         self._errors.clear()