Debug output chain nodes with full inputs
All checks were successful
Build and Push Docker Image / build (push) Successful in 4m3s
All checks were successful
Build and Push Docker Image / build (push) Successful in 4m3s
🤖 Generated with [Claude Code](https://claude.com/claude-code) Co-Authored-By: Claude Opus 4.5 <noreply@anthropic.com>
This commit is contained in:
17
handler.py
17
handler.py
@@ -446,17 +446,16 @@ def handler(job: dict) -> dict:
|
|||||||
# Inject parameters into workflow
|
# Inject parameters into workflow
|
||||||
workflow = inject_wan22_params(workflow, params)
|
workflow = inject_wan22_params(workflow, params)
|
||||||
|
|
||||||
# Debug: print key nodes to verify connections
|
# Debug: print output chain nodes to verify connections
|
||||||
print("=== Workflow Debug ===")
|
print("=== Workflow Output Chain ===")
|
||||||
for node_id in ["117", "116", "115", "158", "140", "156", "144", "145"]:
|
# Check the output chain: 117 <- 116 <- 115 <- 158 <- 140
|
||||||
|
for node_id in ["117", "116", "115"]:
|
||||||
if node_id in workflow:
|
if node_id in workflow:
|
||||||
node = workflow[node_id]
|
node = workflow[node_id]
|
||||||
print(f"Node {node_id} ({node['class_type']}):")
|
print(f"Node {node_id} ({node['class_type']}): {node['inputs']}")
|
||||||
for k, v in node['inputs'].items():
|
else:
|
||||||
if isinstance(v, list):
|
print(f"Node {node_id}: MISSING FROM WORKFLOW!")
|
||||||
print(f" {k}: -> node {v[0]} slot {v[1]}")
|
print(f"Total nodes in workflow: {len(workflow)}")
|
||||||
else:
|
|
||||||
print(f" {k}: {repr(v)[:50]}")
|
|
||||||
|
|
||||||
# Queue workflow
|
# Queue workflow
|
||||||
client_id = uuid.uuid4().hex
|
client_id = uuid.uuid4().hex
|
||||||
|
|||||||
Reference in New Issue
Block a user