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

Stream connections and links — Python Architecture DSL

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 relationship and returns source. The equivalent source | error_stream returns the Error stream and can continue a recovery chain.
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 an optional ordering flag; it does not enqueue work or create a separate task.

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