Clearer breakdown

This commit is contained in:
Tat Dat Duong
2025-03-19 14:22:25 +01:00
parent 4b1d6d2aeb
commit 8ffe9634b7
+2 -2
View File
@@ -1482,7 +1482,7 @@ class Pregel(PregelProtocol):
**checkpoint_metadata,
"source": "update",
"step": step + 1,
"writes": {k: v for k, v in valid_updates},
"writes": {as_node: values for as_node, values in valid_updates},
"parents": saved.metadata.get("parents", {}) if saved else {},
},
get_new_channel_versions(
@@ -1820,7 +1820,7 @@ class Pregel(PregelProtocol):
**checkpoint_metadata,
"source": "update",
"step": step + 1,
"writes": {k: v for k, v in valid_updates},
"writes": {as_node: values for as_node, values in valid_updates},
"parents": saved.metadata.get("parents", {}) if saved else {},
},
get_new_channel_versions(