Skip to content
beam-agents
GitHub

dataclass

RunAgentOutputs

beam_agents.core.transform.RunAgentOutputs

RunAgentOutputs(output: 'beam.pvalue.PCollection', intents: 'beam.pvalue.PCollection', traces: 'beam.pvalue.PCollection', errors: 'beam.pvalue.PCollection', snapshots: 'beam.pvalue.PCollection', dead_letter: 'beam.pvalue.PCollection | None' = None) -> None

Docstring

RunAgent's named outputs: main, the three tagged streams, and the intents dead-letter branch.

dead_letter is None unless intents_to resolved to a WriteIntents outbox writer (a kafka:///pubsub:// scheme). It is always exposed here, whether or not errors_to is also set, so a caller can consume it directly instead of it being silently dropped by Beam as an unconsumed PCollection when errors_to is unset.

src/beam_agents/core/transform.py:601

Members

6 declared on RunAgentOutputs

Introspected from the class itself. A member with no docstring is shown as having none rather than described from its name.

  • dead_letter: beam.pvalue.PCollection | None

    No docstring.

  • errors

    field

    errors: beam.pvalue.PCollection

    No docstring.

  • intents

    field

    intents: beam.pvalue.PCollection

    No docstring.

  • output

    field

    output: beam.pvalue.PCollection

    No docstring.

  • snapshots: beam.pvalue.PCollection

    No docstring.

  • traces

    field

    traces: beam.pvalue.PCollection

    No docstring.