experimental push stopped flows downstream

cylc · Jul 31, 2020 · a87c846 · a87c846
1 parent 92f2282
commit a87c846
Show file tree

Hide file tree

Showing 2 changed files with 8 additions and 0 deletions.
diff --git a/cylc/uiserver/data_store_mgr.py b/cylc/uiserver/data_store_mgr.py
@@ -90,6 +90,11 @@ async def sync_workflow(self, w_id, *args, **kwargs):
         )
         await self.entire_workflow_update(ids=[w_id])
 
+    async def register_workflow(self, w_id):
+        flow = deepcopy(DATA_TEMPLATE)
+        flow['status'] = 'stopped'
+        self.data[w_id] = flow
+
     def purge_workflow(self, w_id):
         """Purge the manager of a workflow's subscription and data."""
         if w_id in self.w_subs:

diff --git a/cylc/uiserver/workflows_mgr.py b/cylc/uiserver/workflows_mgr.py
@@ -146,6 +146,9 @@ async def gather_workflows(self):
                 if wid in active_before:
                     self.active.pop(wid)
                 if wid not in inactive_before:
+                    await self.uiserver.data_store_mgr.register_workflow(
+                        wid
+                    )
                     self.inactive.add(wid)
                 continue