Gust.DAG.Run.Trigger.Requeue (gust v0.1.26)
Resets tasks and runs, then re-queues them for execution.
Provides helpers to reset an entire run or a downstream branch of tasks, update
run status to :enqueued, and broadcast the corresponding PubSub events. It
also handles dispatching runs when the DAG is enabled.
Summary
Functions
Callback implementation for Gust.DAG.Run.Trigger.dispatch_all_runs/1.
Callback implementation for Gust.DAG.Run.Trigger.dispatch_run/1.
Callback implementation for Gust.DAG.Run.Trigger.reset_run/1.
Callback implementation for Gust.DAG.Run.Trigger.reset_task/2.
Functions
Callback implementation for Gust.DAG.Run.Trigger.dispatch_all_runs/1.
Callback implementation for Gust.DAG.Run.Trigger.dispatch_run/1.
Callback implementation for Gust.DAG.Run.Trigger.reset_run/1.
Callback implementation for Gust.DAG.Run.Trigger.reset_task/2.