Skip to content

symfonic.agent.facade_dispatch

facade_dispatch

The one non-streaming facade dispatch path.

dispatch async 

dispatch(kernel: Any, prepare: Callable[[str, type[BaseModel] | None], InvocationPlan], request: TurnRequest, output_type: type[BaseModel] | None, capabilities: tuple[Any, ...]) -> AgentResult[Any]

Prepare once and send every non-streaming request through the kernel.

Source code in src/symfonic/agent/facade_dispatch.py 
14
15
16
17
18
19
20
21
22
23
24
25
26
27
28
29
30
31
async def dispatch(
    kernel: Any,
    prepare: Callable[[str, type[BaseModel] | None], InvocationPlan],
    request: TurnRequest,
    output_type: type[BaseModel] | None,
    capabilities: tuple[Any, ...],
) -> AgentResult[Any]:
    """Prepare once and send every non-streaming request through the kernel."""
    from symfonic.agent.facade_args import receipt_capability

    _refuse_fenced_history(request, capabilities)
    memory = receipt_capability(capabilities)
    plan = prepare(request.prompt, output_type)
    if memory is not None:
        from symfonic.agent.receipt_dispatch import run

        return await run(plan, request, memory)
    return await kernel.run(plan, request)

stream 

stream(kernel: Any, prepare: Callable[[str, type[BaseModel] | None], InvocationPlan], request: TurnRequest, output_type: type[BaseModel] | None, capabilities: tuple[Any, ...]) -> AsyncIterator[AgentEvent]

Prepare once and hand the request to the shared streaming kernel.

Source code in src/symfonic/agent/facade_dispatch.py 
34
35
36
37
38
39
40
41
42
43
44
45
46
47
48
49
50
51
def stream(
    kernel: Any,
    prepare: Callable[[str, type[BaseModel] | None], InvocationPlan],
    request: TurnRequest,
    output_type: type[BaseModel] | None,
    capabilities: tuple[Any, ...],
) -> AsyncIterator[AgentEvent]:
    """Prepare once and hand the request to the shared streaming kernel."""
    from symfonic.agent.facade_args import receipt_capability

    _refuse_fenced_history(request, capabilities)
    memory = receipt_capability(capabilities)
    plan = prepare(request.prompt, output_type)
    if memory is not None:
        from symfonic.agent.receipt_dispatch import stream as receipt_stream

        return receipt_stream(plan, request, memory)
    return kernel.stream(plan, request)