Configured Workflow Alerts

A tiny two-stage workflow that relies on the dependency's built-in configuration system to route logs and send failure notifications. The runtime should hand the dependency a standard config file (ini/toml) to decide where logs go, how they are prefixed, and who receives alerts—no custom parsing or manual email/log wiring.

Capabilities

Loads runtime config from file

• Running main with a config path feeds that file into the dependency's config loader so scheduler address, log destination, and notification recipients all come from config before tasks execute, and returns success when both stages pass. @test

Writes task logs via configured logger

• With a config specifying a log file and prefix, the workflow writes start/end messages for each stage to that file using the configured prefix. @test

Sends notification on controlled failure

• When the second stage raises a deliberate error and notifications are enabled in config, the run fails and a notification is emitted containing the failing stage name and error message to the configured recipient. @test

Implementation

@generates

API

def main(config_path: str | None = None) -> int:
    """
    Executes a two-stage workflow controlled by a config file.
    Returns 0 on success, non-zero when a stage fails.
    """

Dependencies { .dependencies }

luigi { .dependency }

Workflow orchestration with configuration-driven logging and notification support.