CallbackRouter

Base classes

Name	Children	Inherits
AgentRouter llmling_agent.delegation.router Base class for routing messages between agents.	CallbackRouter RuleRouter	object
Generic typing Abstract base class for generic types.	Protocol IO _IteratorToAsyncIterator UpdatableLRU _Registry Protocol LazyLocalNamespace PydanticDescriptorProxy Decorator MockCoreSchema MockValSer ...	object

⋔ Inheritance diagram

graph TD
  94350422104288["router.CallbackRouter"]
  94350422103296["router.AgentRouter"]
  140709601677504["builtins.object"]
  94350360566400["typing.Generic"]
  94350422103296 --> 94350422104288
  140709601677504 --> 94350422103296
  94350360566400 --> 94350422104288
  140709601677504 --> 94350360566400

🛈 DocStrings

Bases: AgentRouter

Router using callback function for decisions.

Source code in src/llmling_agent/delegation/router.py

class CallbackRouter[TMessage](AgentRouter):
    """Router using callback function for decisions."""

    def __init__(
        self,
        pool: AgentPool,
        decision_callback: DecisionCallback[TMessage],
    ):
        self.pool = pool
        self.decision_callback = decision_callback

    async def decide(self, message: TMessage) -> Decision:
        """Execute callback and handle sync/async appropriately."""
        result = self.decision_callback(message, self.pool, self)
        if inspect.isawaitable(result):
            return await result
        return result

decide async

decide(message: TMessage) -> Decision

Execute callback and handle sync/async appropriately.

Source code in src/llmling_agent/delegation/router.py

async def decide(self, message: TMessage) -> Decision:
    """Execute callback and handle sync/async appropriately."""
    result = self.decision_callback(message, self.pool, self)
    if inspect.isawaitable(result):
        return await result
    return result

Show source on GitHub