hydromodpy.workflow

Composable workflow layer for HydroModPy simulation pipelines.

This package extracts the business logic from launchers into reusable steps and pipelines, so that a single logic path serves TOML-driven, programmatic (Simulation), and calibration usage modes.

Public API

WorkflowContext

Extended run state with result-store lifecycle support.

Modules

context	Workflow context - re-export from canonical location.
dag	Workflow DAG built from declared step dependencies.
dispatch	Workflow dispatch helpers.
events	Event-stream writer over workflow_events.
heartbeat	Background heartbeat for live simulations.
internals	Workflow internals - low-level orchestration primitives.
journal	Append-only journal over workflow_steps in the project catalog.
launcher_protocol	Launcher Protocol for simulation orchestration backends.
orchestrator	Canonical simulation pipeline.
parallel	Sweep orchestration and worker-pool helpers.
phases	Shared Project/Pipeline phase contract.
pipelines	Predefined step sequences (pipelines) for common workflows.
resume	Resume planner driven by the workflow_steps journal.
runner	Pipeline orchestrator.
site_selection	Lightweight workflow entry points for site selection.
site_selection_data	Data-layer adapters used by site-selection workflows.
steps	Workflow steps - one module per pipeline concern.