Directories
¶
| Path | Synopsis |
|---|---|
|
Child runs: a parent task fans out to per-item child runs, and the lineage is visible through Execution/Runs.
|
Child runs: a parent task fans out to per-item child runs, and the lineage is visible through Execution/Runs. |
|
Cron and delayed triggers: a task that runs on a schedule, plus one-off delayed runs, cancellable while waiting.
|
Cron and delayed triggers: a task that runs on a schedule, plus one-off delayed runs, cancellable while waiting. |
|
A workflow DAG: charge, then ship, then notify — with data flowing from step to step via dependency outputs.
|
A workflow DAG: charge, then ship, then notify — with data flowing from step to step via dependency outputs. |
|
DAG visualization: run a workflow, then emit its current step graph as JSON and as a standalone SVG file.
|
DAG visualization: run a workflow, then emit its current step graph as JSON and as a standalone SVG file. |
|
Durable execution: a task that sleeps and waits for an event without holding a worker slot, resuming where it left off with side effects that run exactly once.
|
Durable execution: a task that sleeps and waits for an event without holding a worker slot, resuming where it left off with side effects that run exactly once. |
|
ELT DAG visualization: build an extract -> transform -> stage -> load pipeline (parallel per-shard fan-out, a per-shard series chain, a fan-in, and per-partition child workflows), run it, then save the run's step graph as dag.json and dag.svg.
|
ELT DAG visualization: build an extract -> transform -> stage -> load pipeline (parallel per-shard fan-out, a per-shard series chain, a fan-in, and per-partition child workflows), run it, then save the run's step graph as dag.json and dag.svg. |
|
Grouped ELT DAG: four groups — extract, transform, load, report — where each group fans out into parallel steps, the next group runs only after the previous group (declared once with After), and a step may depend on a sibling in its own group.
|
Grouped ELT DAG: four groups — extract, transform, load, report — where each group fans out into parallel steps, the next group runs only after the previous group (declared once with After), and a step may depend on a sibling in its own group. |
|
Prototype: ELT groups as nested (child) workflows.
|
Prototype: ELT groups as nested (child) workflows. |
|
In-process events: emit an event and every bound task runs with the event payload as its input.
|
In-process events: emit an event and every bound task runs with the event payload as its input. |
|
Live introspection: watch a slow workflow's state change in real time while it keeps executing — nothing is paused or slowed down.
|
Live introspection: watch a slow workflow's state change in real time while it keeps executing — nothing is paused or slowed down. |
|
Simplest possible quacker app: define a task, enqueue it, await the result.
|
Simplest possible quacker app: define a task, enqueue it, await the result. |
Click to show internal directories.
Click to hide internal directories.