subflow_workflow

Overview ¶

Package main demonstrates dynamic subflow task generation in dureq workflows.

Scenario: A data pipeline that fetches items, then dynamically generates one processing task per item at runtime.

fetch_items → generate_tasks(subflow) → [process_item_1, process_item_2, ...] → aggregate

The generate_tasks handler returns a list of WorkflowTasks at runtime, which the orchestrator injects into the running workflow. The aggregate task runs after all dynamically generated tasks complete.