(chain, inputs, timeout)
| 92 | } |
| 93 | |
| 94 | def fake_invoke_with_timeout(chain, inputs, timeout): |
| 95 | if isinstance(chain, RunnableParallel): |
| 96 | return { |
| 97 | "chunk1": {"content": "answer for chunk 1"}, |
| 98 | "chunk2": {"content": "answer for chunk 2"}, |
| 99 | } |
| 100 | if "context" in inputs and "question" in inputs: |
| 101 | return {"content": "merged final answer"} |
| 102 | return {"content": "single answer"} |
| 103 | |
| 104 | dummy_node_with_pipe.invoke_with_timeout = fake_invoke_with_timeout |
| 105 | output_state = dummy_node_with_pipe.execute(state) |
nothing calls this directly
no outgoing calls
no test coverage detected