Fix

2026-08-22 23:52:23 +02:00 · 2024-11-15 17:05:18 -08:00
parent 36e49eb190
commit 973ad76a58
1 changed files with 2 additions and 2 deletions
@@ -946,7 +946,7 @@ class Pregel(PregelProtocol):
                    create_checkpoint(checkpoint, None, step),
                    {
                        **checkpoint_metadata,
-                        "source": "fork",
+                        "source": "update",
                        "step": step + 1,
                        "writes": {},
                        "parents": saved.metadata.get("parents", {}) if saved else {},
@@ -1226,7 +1226,7 @@ class Pregel(PregelProtocol):
                    next_checkpoint,
                    {
                        **checkpoint_metadata,
-                        "source": "update",
+                        "source": "fork",
                        "step": step + 1,
                        "writes": {},
                        "parents": saved.metadata.get("parents", {}) if saved else {},