module documentation
Workflow-side wrappers for executing LangGraph nodes inline in a workflow.
| Function | wrap |
Wrap a function as a workflow-side LangGraph node. |
def wrap_workflow(func:
Callable[, *, streaming_topic: str | None = None) -> Callable[:
(source)
ΒΆ
Wrap a function as a workflow-side LangGraph node.
Mirrors wrap_activity: the outer wrapper resolves a stream
writer and passes it to an inner run that invokes the user
function with the writer installed. Workflow-side nodes publish
synchronously to the in-workflow WorkflowStream (no signal
round-trip); activity-side nodes go through WorkflowStreamClient.