()
| 384 | |
| 385 | #[tokio::test] |
| 386 | async fn test_workflow_context() { |
| 387 | let mut context = WorkflowContext::new(WorkflowId::new()); |
| 388 | let node_id = NodeId::from_string("test_node").unwrap(); |
| 389 | |
| 390 | let output = json!({ |
| 391 | "result": "success", |
| 392 | "value": 42 |
| 393 | }); |
| 394 | |
| 395 | context |
| 396 | .node_outputs |
| 397 | .insert(node_id.to_string(), output.clone()); |
| 398 | let stored = context.node_outputs.get(&node_id.to_string()).unwrap(); |
| 399 | assert_eq!(stored, &output); |
| 400 | } |
| 401 | |
| 402 | #[tokio::test] |
| 403 | async fn test_workflow_builder() { |