Tidy

Author: MetRonnie

cylc/flow/data_store_mgr.py

@@ -570,7 +570,7 @@ def __init__(self, schd, n_edge_distance=1):
         self.n_window_completed_walks = set()
         self.n_window_depths = {}
         self.update_window_depths = False
-        self.db_load_task_proxies = {}
+        self.db_load_task_proxies: Dict[str, Tuple[TaskProxy, bool]] = {}
         self.family_pruned_ids = set()
         self.prune_trigger_nodes = {}
         self.prune_flagged_nodes = set()
@@ -1527,12 +1527,10 @@ def apply_task_proxy_db_history(self):
                     # added to an already-spawned task before restart.)
 
         # Extract info from itasks to data-store.
-        for task_info in self.db_load_task_proxies.values():
+        for itask, _is_parent in self.db_load_task_proxies.values():
             self._process_internal_task_proxy(
-                task_info[0],
-                self.added[TASK_PROXIES][
-                    self.id_.duplicate(task_info[0].tokens).id
-                ]
+                itask,
+                self.added[TASK_PROXIES][self.id_.duplicate(itask.tokens).id]
             )
 
         # Batch load jobs from DB.

tests/integration/test_reload.py

@@ -46,16 +46,7 @@ async def test_reload_waits_for_pending_tasks(
     See https://github.com/cylc/cylc-flow/issues/5107
     """
     # a simple workflow with a single task
-    id_ = flow({
-        'scheduling': {
-            'graph': {
-                'R1': 'foo',
-            },
-        },
-        'runtime': {
-            'foo': {},
-        },
-    })
+    id_ = flow('foo')
     schd = scheduler(id_, paused_start=False)
 
     # we will artificially push the task through these states
@@ -270,7 +261,6 @@ async def test_reload_global_platform_group(
 
     # Task using the platform group
     conf = {
-        'scheduler': {'allow implicit tasks': True},
         'scheduling': {'graph': {'R1': 'one'}},
         'runtime': {
             'one': {