Python DSL reference source >> target | target << source | source.priority_task_pool_call(target, ...)

Stream connections and links

Build graph relationships directly between Stream objects and add persisted delivery settings only when they differ from service defaults.

When to use

Use operators for every graph edge; call a typed semantic method only when delivery differs from the service default.

source >> target assigns the target primary source.
target << source appends a source to a multi-input operator.
target.from_sources(a, b, c) replaces the complete multi-source list.
function_call, task_pool_call, priority_task_pool_call, and parallel_call register typed delivery properties on an existing edge.
source.on_error(error_stream) assigns the dedicated Error stream relationship.
If link semantics equal the service default, the YAML-to-Python importer omits the redundant link call.

Each method accepts only settings valid for that delivery strategy.

PropertyTypeDescription

function_call(target, async_=None)FunctionCall

Direct call with optional asynchronous behavior.

task_pool_call(target, pool=...)TaskPool

Dispatch through a registered Pool object.

priority_task_pool_call(target, pool=..., priority=...)PriorityTaskPool

Dispatch through a Pool with explicit integer priority.

parallel_call(target)ParallelCall

Dispatch the target as a parallel branch.

split >> process
split.priority_task_pool_call(process, pool=workers, priority=7)

process >> processing_error
process.on_error(processing_error)