Skip to content

Commit b8bcc3c

Browse files
committed
fix(upgrade): use timestamps of partners at layers > 2
1 parent e62390a commit b8bcc3c

File tree

2 files changed

+9
-2
lines changed

2 files changed

+9
-2
lines changed

pychunkedgraph/__init__.py

Lines changed: 1 addition & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -1 +1 @@
1-
__version__ = "3.0.7"
1+
__version__ = "3.0.8"

pychunkedgraph/ingest/upgrade/parent_layer.py

Lines changed: 8 additions & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -66,7 +66,14 @@ def _populate_cx_edges_with_timestamps(
6666
for node, node_ts in zip(nodes, nodes_ts):
6767
CX_EDGES[node] = {}
6868
timestamps = timestamps_d[node]
69-
timestamps.add(node_ts)
69+
cx_edges_d_node_ts = _get_cx_edges_at_timestamp(node, response, node_ts)
70+
71+
edges = np.concatenate([empty_2d] + list(cx_edges_d_node_ts.values()))
72+
partner_parent_ts_d = get_parent_timestamps(cg, edges[:, 1])
73+
for v in partner_parent_ts_d.values():
74+
timestamps.update(v)
75+
CX_EDGES[node][node_ts] = cx_edges_d_node_ts
76+
7077
for ts in sorted(timestamps):
7178
if ts < earliest_ts:
7279
ts = earliest_ts

0 commit comments

Comments
 (0)