From 0f18e5de8d4f4fbebe838af731dab352f2cb84ce Mon Sep 17 00:00:00 2001 From: gilesb Date: Sun, 11 Jan 2026 19:10:42 +0000 Subject: [PATCH] Fix DAG output attribute: output -> output_id The artdag library DAG class uses output_id not output. Co-Authored-By: Claude Opus 4.5 --- legacy_tasks.py | 8 ++++---- 1 file changed, 4 insertions(+), 4 deletions(-) diff --git a/legacy_tasks.py b/legacy_tasks.py index e9d71f9..72405f0 100644 --- a/legacy_tasks.py +++ b/legacy_tasks.py @@ -365,7 +365,7 @@ def execute_dag(self, dag_json: str, run_id: str = None) -> dict: # Get output hash from the output node if result.output_path and result.output_path.exists(): output_hash = file_hash(result.output_path) - output_ipfs_cid = node_ipfs_cids.get(dag.output) + output_ipfs_cid = node_ipfs_cids.get(dag.output_id) # Store output in database (for L2 to query IPFS CID) import asyncio @@ -408,7 +408,7 @@ def execute_dag(self, dag_json: str, run_id: str = None) -> dict: content_hash = node.config.get("content_hash") if content_hash: input_hashes.append(content_hash) - elif node_id != dag.output and node_id in node_hashes: + elif node_id != dag.output_id and node_id in node_hashes: intermediate_hashes.append(node_hashes[node_id]) if input_hashes: @@ -438,7 +438,7 @@ def execute_dag(self, dag_json: str, run_id: str = None) -> dict: "rendered_at": datetime.now(timezone.utc).isoformat(), "output": { "content_hash": output_hash, - "ipfs_cid": node_ipfs_cids.get(dag.output) if dag.output else None, + "ipfs_cid": node_ipfs_cids.get(dag.output_id) if dag.output_id else None, }, "inputs": input_hashes_for_provenance, "dag": dag_json, # Full DAG definition @@ -471,7 +471,7 @@ def execute_dag(self, dag_json: str, run_id: str = None) -> dict: "success": True, "run_id": run_id, "output_hash": output_hash, - "output_ipfs_cid": node_ipfs_cids.get(dag.output) if dag.output else None, + "output_ipfs_cid": node_ipfs_cids.get(dag.output_id) if dag.output_id else None, "output_path": str(result.output_path) if result.output_path else None, "execution_time": result.execution_time, "nodes_executed": result.nodes_executed,