art-dag/celery
1
0
Fork 0
Code Issues Pull Requests Actions Packages Projects Releases Wiki Activity

Fix DAG output attribute: output -> output_id

Browse Source 
The artdag library DAG class uses output_id not output.

Co-Authored-By: Claude Opus 4.5 <noreply@anthropic.com>
This commit is contained in:
gilesb
2026-01-11 19:10:42 +00:00
parent ab2f65e14d
commit 0f18e5de8d
1 changed files with 4 additions and 4 deletions
Download Patch File Download Diff File Expand all files Collapse all files

8
legacy_tasks.py
View File

@@ -365,7 +365,7 @@ def execute_dag(self, dag_json: str, run_id: str = None) -> dict:
# Get output hash from the output node # Get output hash from the output node
if result.output_path and result.output_path.exists(): if result.output_path and result.output_path.exists():
output_hash = file_hash(result.output_path) 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) # Store output in database (for L2 to query IPFS CID)
import asyncio 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") content_hash = node.config.get("content_hash")
if content_hash: if content_hash:
input_hashes.append(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]) intermediate_hashes.append(node_hashes[node_id])
if input_hashes: 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(), "rendered_at": datetime.now(timezone.utc).isoformat(),
"output": { "output": {
"content_hash": output_hash, "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, "inputs": input_hashes_for_provenance,
"dag": dag_json, # Full DAG definition "dag": dag_json, # Full DAG definition
@@ -471,7 +471,7 @@ def execute_dag(self, dag_json: str, run_id: str = None) -> dict:
"success": True, "success": True,
"run_id": run_id, "run_id": run_id,
"output_hash": output_hash, "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, "output_path": str(result.output_path) if result.output_path else None,
"execution_time": result.execution_time, "execution_time": result.execution_time,
"nodes_executed": result.nodes_executed, "nodes_executed": result.nodes_executed,