examples/

directory
v1.4.0 Latest Latest
Warning

This package is not in the latest version of its module.

Go to latest
Published: Oct 8, 2026 License: MIT

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.

Jump to

Keyboard shortcuts

? : This menu
/ : Search site
f or F : Jump to
y or Y : Canonical URL