Package-level declarations

The base class for units of work in a workflow graph. A Workflow is itself a node, so graphs nest, and every agent is one too.

Thrown by com.google.adk.kt.agents.Context.runNode when the dispatched child fails: error is the child's failure and errorNodePath the path of the node that failed.

A connection between two nodes.

A chain of edges for Java callers, positioned at a node. EdgesBuilder.from starts a chain, and each call adds the same edges as the edges DSL function of the same name and continues from its target.

The receiver that collects the edges declared in an edges or workflow block. A node is identified by its instance, so create each node once and reuse it. To add a tool as a step, convert it once with asNode and reuse that node.

A block that declares edges or routes on a T builder. In Kotlin, pass a lambda with the builder as its receiver. In Java, pass a lambda that takes the builder as an argument, with no Unit to return.

A workflow Node backed by a suspending function that may emit progress Events and returns an output of type O. Its schemas inferred from I and O only describe it; an explicit schema passed to node is also enforced.

A workflow graph failed validation. Raised when the graph is built, not when it runs.

Waits for every predecessor to complete, then outputs their outputs keyed by predecessor name.

A unit of work in a workflow graph.

Bundles a node's retry policy and execution timeout. A null timeout imposes no limit, so an attempt is then bounded only by any ambient deadline. Validation lives here, so every Node implementation inherits it.

A node failure that reports under a typeName other than this class's own, so a failure raised in one ADK implementation is matched by the same name in another.

Nodes grouped by nodes(...) or a fan-out then, which EdgesBuilder.joinTo connects to a JoinNode.

A chain of edges for Java callers, positioned at a NodeGroup from a fan-out or EdgesBuilder.from.

Identifies the workflow-node activation that emitted an com.google.adk.kt.events.Event; null outside a workflow.

Raised when a node's runtime input fails validation. Reports typeName = "NodeInputValidationError".

A node exceeded its configured timeout. An ordinary exception, so a timed-out node is still eligible for retry.

An edge started by EdgesBuilder.on, which has a source and its routes but no target yet. EdgesBuilder.then completes it.

A chain of edges for Java callers, positioned at a routed edge started by EdgeChain.on; then completes it.

A node's request for user input, which pauses the workflow until a matching response arrives.

How a node is retried when it raises.

A value on a workflow edge, and the value a node emits to select which of its outgoing edges are followed. An edge fires when the value it carries matches one the node emitted.

The receiver of an EdgesBuilder.route block, which maps each route the source node may emit to a target node, written on("billing") then billing or "billing" then billing. Mapping one route to several nodes fans out on that route.

A routing-map entry started by RouteMapBuilder.on whose routes have no target yet. then completes it.

Routes that select a single edge, which fires once when its source emits any of them. Separate edges to the same target would fire once each. Build one with anyOf(...) in the workflow DSL.

Marks where a graph starts. Never runs: the scheduler seeds its successors directly.

A graph of nodes, and a Node itself, so graphs nest: a workflow drops into another workflow wherever an ordinary node goes.

Thrown when a workflow or node configuration is invalid.

Returns a workflow node that runs this tool as a fixed step: the predecessor's output becomes the tool's arguments, and the tool's result becomes the node's output.

Returns the edges declared by block for a Workflow; workflow builds both in one step.

Creates a FunctionNode that runs block on an input of type I and returns an output of type O, emitting progress Events through its FlowCollector receiver. Schemas inferred from I and O describe the node, while an explicit inputSchema or outputSchema is also enforced on every run.

Wraps node so it runs concurrently on each item of a list input and returns the results in input order. node's configuration applies to each item's run.

Creates a FunctionNode that runs block concurrently on each item of a list input and returns the results as a List of O in input order. A non-list input runs as one item.

Builds a Workflow from the edges block declares.