Datastore fix for removed taskdef.

cylc · Aug 14, 2022 · e8c2b1e · e8c2b1e
1 parent 138ec26
commit e8c2b1e
Showing 1 changed file with 6 additions and 3 deletions.
diff --git a/cylc/flow/data_store_mgr.py b/cylc/flow/data_store_mgr.py
@@ -818,12 +818,15 @@ def generate_ghost_task(self, tp_id, itask, is_parent=False):
         if is_orphan:
             self.generate_orphan_task(itask)
 
-        # Most the time the definition node will be in the store,
-        # so use try/except.
+        # Most of the time the definition node will be in the store,
         try:
             task_def = self.data[self.workflow_id][TASKS][t_id]
         except KeyError:
-            task_def = self.added[TASKS][t_id]
+            try:
+                task_def = self.added[TASKS][t_id]
+            except KeyError:
+                # Task removed from workflow definition.
+                return False
 
         update_time = time()
         tp_stamp = f'{tp_id}@{update_time}'