Class Workflow

java.lang.Object

com.google.adk.workflow.BaseNode

com.google.adk.workflow.Workflow

All Implemented Interfaces:

Node

@Experimental
public final class Workflow
extends BaseNode

A graph of nodes that is itself a node, so a workflow can go wherever a node can, including in another workflow.

Nested Class Summary

Nested Classes

Modifier and Type	Class	Description
static final class	Workflow.Builder	Builder for Workflow.

Method Summary

Modifier and Type	Method	Description
static Workflow.Builder	builder()
com.google.common.collect.ImmutableList<Edge>	edges()	Returns the edges of the workflow's graph.
Optional<Integer>	maxConcurrency()	Returns the maximum number of nodes the workflow runs at once, or empty if there is no limit.
io.reactivex.rxjava3.core.Flowable<?>	runNode(Context context, @Nullable Object nodeInput)	Runs the node on nodeInput, the output it receives from its predecessors.

Methods inherited from class BaseNode

config, description, inputSchema, name, outputSchema, rerunOnResume, stateSchema, waitForOutput

Modifier and Type	Method	Description
NodeConfig	config()	Returns the node's retry policy and execution timeout.
String	description()	Returns what the node does, for humans and for a model that may call it.
Optional<com.google.genai.types.Schema>	inputSchema()	Returns the schema the node's input must match.
final String	name()	Returns the name that identifies the node within its graph.
Optional<com.google.genai.types.Schema>	outputSchema()	Returns the schema that the node's output value must match.
boolean	rerunOnResume()	Returns true if a resumed node runs again from scratch, rather than completing with the resuming answer as its output.
Optional<com.google.genai.types.Schema>	stateSchema()	Returns the schema declaring the state keys the node uses.
boolean	waitForOutput()	Returns true if the node stays re-triggerable until it produces an output or a route, instead of completing when its run completes.

Methods inherited from class Object

clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait

Methods inherited from interface Node

requiresAllPredecessors

Modifier and Type	Method	Description
default boolean	requiresAllPredecessors()	Returns true if the node runs only once every predecessor has completed, receiving all their outputs keyed by node name, as a fan-in node does.

Method Details

builder

public static Workflow.Builder builder()

edges

public com.google.common.collect.ImmutableList<Edge> edges()

Returns the edges of the workflow's graph.

maxConcurrency

public Optional<Integer> maxConcurrency()

Returns the maximum number of nodes the workflow runs at once, or empty if there is no limit.

runNode

public io.reactivex.rxjava3.core.Flowable<?> runNode(Context context,
 @Nullable Object nodeInput)

Description copied from interface: Node

Runs the node on nodeInput, the output it receives from its predecessors.

An emitted Event passes through, and any other emitted value becomes the node's output (at most one per run); emit nothing for no output, since RxJava forbids null. The wildcard lets an implementation return a Flowable of its own type.