Struct ScopedRunWatcher 

pub struct ScopedRunWatcher { /* private fields */ }

PipelineWatcher proxy that forwards lifecycle events to a run’s slot.

A ScopedRunWatcher is constructed by DefaultPipelineRunRegistry:: watcher_for(run_id) and injected into the TaskContext before calling the work future. Library functions that call watcher.on_pipeline_run_started etc. automatically publish events and write durable rows without knowing about the registry.

Repository write failures

A repository write failure does not abort the pipeline — it is logged via tracing::warn! and execution continues. This matches Python’s behaviour where DB failures are non-fatal.

Implementations

impl ScopedRunWatcher

pub fn new( run_id: Uuid, sink: PerRunSink, db: Arc<dyn PipelineRunRepository>, ) -> ScopedRunWatcher

Trait Implementations

impl PipelineWatcher for ScopedRunWatcher

fn on_pipeline<'life0, 'async_trait>( &'life0 self, _pipeline_id: Uuid, _status: PipelineStatus, ) -> Pin<Box<dyn Future<Output = ()> + Send + 'async_trait>>

where 'life0: 'async_trait, ScopedRunWatcher: 'async_trait,

fn on_task<'life0, 'life1, 'async_trait>( &'life0 self, _pipeline_id: Uuid, _task_index: usize, _task_name: Option<&'life1 str>, _total_tasks: usize, _status: TaskStatus, ) -> Pin<Box<dyn Future<Output = ()> + Send + 'async_trait>>

where 'life0: 'async_trait, 'life1: 'async_trait, ScopedRunWatcher: 'async_trait,

fn on_pipeline_run_initiated<'life0, 'life1, 'async_trait>( &'life0 self, run: &'life1 PipelineRunInfo, ) -> Pin<Box<dyn Future<Output = ()> + Send + 'async_trait>>

where 'life0: 'async_trait, 'life1: 'async_trait, ScopedRunWatcher: 'async_trait,

Called before any task runs. Persists the initial INITIATED row in the Python lifecycle. Default no-op — watchers that don’t persist runs can ignore this.

fn on_pipeline_run_started<'life0, 'life1, 'async_trait>( &'life0 self, run: &'life1 PipelineRunInfo, ) -> Pin<Box<dyn Future<Output = ()> + Send + 'async_trait>>

where 'life0: 'async_trait, 'life1: 'async_trait, ScopedRunWatcher: 'async_trait,

Called when the pipeline run is first created (before any tasks).

fn on_pipeline_run_completed<'life0, 'life1, 'async_trait>( &'life0 self, run: &'life1 PipelineRunInfo, _output_count: usize, ) -> Pin<Box<dyn Future<Output = ()> + Send + 'async_trait>>

where 'life0: 'async_trait, 'life1: 'async_trait, ScopedRunWatcher: 'async_trait,

Called after all tasks complete successfully.

fn on_payload_field<'life0, 'life1, 'async_trait>( &'life0 self, run_id: Uuid, key: &'life1 str, value: Value, ) -> Pin<Box<dyn Future<Output = ()> + Send + 'async_trait>>

where 'life0: 'async_trait, 'life1: 'async_trait, ScopedRunWatcher: 'async_trait,

Tasks emit run-scoped key/value payload via this hook. Default no-op.

fn on_pipeline_run_errored<'life0, 'life1, 'life2, 'async_trait>( &'life0 self, run: &'life1 PipelineRunInfo, error: &'life2 str, ) -> Pin<Box<dyn Future<Output = ()> + Send + 'async_trait>>

where 'life0: 'async_trait, 'life1: 'async_trait, 'life2: 'async_trait, ScopedRunWatcher: 'async_trait,

Called when the pipeline run fails.

fn on_task_started<'life0, 'life1, 'life2, 'async_trait>( &'life0 self, _run: &'life1 PipelineRunInfo, _task_name: &'life2 str, _task_index: usize, ) -> Pin<Box<dyn Future<Output = ()> + Send + 'async_trait>>

where 'life0: 'async_trait, 'life1: 'async_trait, 'life2: 'async_trait, Self: 'async_trait,

Called when a task begins execution.

fn on_task_completed<'life0, 'life1, 'life2, 'async_trait>( &'life0 self, _run: &'life1 PipelineRunInfo, _task_name: &'life2 str, _result_count: usize, ) -> Pin<Box<dyn Future<Output = ()> + Send + 'async_trait>>

where 'life0: 'async_trait, 'life1: 'async_trait, 'life2: 'async_trait, Self: 'async_trait,

Called when a task completes successfully.

fn on_task_errored<'life0, 'life1, 'life2, 'life3, 'async_trait>( &'life0 self, _run: &'life1 PipelineRunInfo, _task_name: &'life2 str, _error: &'life3 str, ) -> Pin<Box<dyn Future<Output = ()> + Send + 'async_trait>>

where 'life0: 'async_trait, 'life1: 'async_trait, 'life2: 'async_trait, 'life3: 'async_trait, Self: 'async_trait,

Called when a task fails (after retries exhausted).