A unit of work that can be invoked, batched, streamed, transformed and composed.
runnables.base.RunnableBinding
Wrap a runnable with additional functionality.
runnables.base.RunnableBindingBase
A runnable that delegates calls to another runnable with a set of kwargs.
runnables.base.RunnableEach
A runnable that delegates calls to another runnable with each element of the input sequence.
runnables.base.RunnableEachBase
A runnable that delegates calls to another runnable with each element of the input sequence.
runnables.base.RunnableGenerator(transform)
A runnable that runs a generator function.
runnables.base.RunnableLambda(func[, afunc])
RunnableLambda converts a python callable into a Runnable.
runnables.base.RunnableMap
alias of RunnableParallel
runnables.base.RunnableParallel
A runnable that runs a mapping of runnables in parallel, and returns a mapping of their outputs.
runnables.base.RunnableSequence
A sequence of runnables, where the output of each is the input of the next.
runnables.base.RunnableSerializable
A Runnable that can be serialized to JSON.
runnables.branch.RunnableBranch
A Runnable that selects which branch to run based on a condition.
runnables.config.EmptyDict
Empty dict type.
runnables.config.RunnableConfig
Configuration for a Runnable.
runnables.configurable.DynamicRunnable
A Serializable Runnable that can be dynamically configured.
runnables.configurable.RunnableConfigurableAlternatives
A Runnable that can be dynamically configured.
runnables.configurable.RunnableConfigurableFields
A Runnable that can be dynamically configured.
runnables.configurable.StrEnum(value[, ...])
A string enum.
runnables.fallbacks.RunnableWithFallbacks
A Runnable that can fallback to other Runnables if it fails.