fix reversed data-store edge source-target (#5156)

Co-authored-by: David Sutherland <davidwollow@gmail.com>
cylc · Sep 26, 2022 · b1d45ea · b1d45ea
1 parent c4809c5
commit b1d45ea
Showing 1 changed file with 12 additions and 5 deletions.
diff --git a/cylc/flow/data_store_mgr.py b/cylc/flow/data_store_mgr.py
@@ -733,11 +733,18 @@ def _expand_graph_window(
                 and e_id not in self.added[EDGES]
                 and edge_distance <= self.n_edge_distance
             ):
-                self.added[EDGES][e_id] = PbEdge(
-                    id=e_id,
-                    source=s_tokens.id,
-                    target=t_tokens.id
-                )
+                if is_parent:
+                    self.added[EDGES][e_id] = PbEdge(
+                        id=e_id,
+                        source=t_tokens.id,
+                        target=s_tokens.id
+                    )
+                else:
+                    self.added[EDGES][e_id] = PbEdge(
+                        id=e_id,
+                        source=s_tokens.id,
+                        target=t_tokens.id
+                    )
                 # Add edge id to node field for resolver reference
                 self.updated[TASK_PROXIES].setdefault(
                     t_tokens.id,