plan + fmt

2026-06-02 17:06:03 +07:00
parent 19f6fa3e40
commit 5c11aa7cc8
27 changed files with 1273 additions and 3 deletions
@@ -54,9 +54,7 @@ class WorkflowRuntimeService:
            spec: NodeSpec[Any, Any] = self.source_catalog.get_qualified_spec(
                qualified_name
            )
-            node_defs[qualified_name] = spec.to_node_def().model_copy(
-                update={"name": qualified_name}
-            )
+            node_defs[qualified_name] = spec.to_node_def()

        nodes = []
        for node in plan.nodes: