D
Digdag Workflow Graph daily_processing
🔍
Summary Tasks 7 TD 2 Inputs 2 Outputs 2
daily_processing daily_processing  (schedule: 0 2 * * * UTC) daily_processing__root daily_processing daily_processing/extract_data 📊 extract_data [td>] daily_processing__root->daily_processing/extract_data daily_processing/transform_data 📊 transform_data [td>] daily_processing/extract_data->daily_processing/transform_data daily_processing/validate_output ❓ validate_output [if>] daily_processing/transform_data->daily_processing/validate_output daily_processing/+validate_output/_do [DO] validate_output _do daily_processing/validate_output->daily_processing/+validate_output/_do _do daily_processing/+validate_output/_else_do [ELSE] validate_output _else_do daily_processing/validate_output->daily_processing/+validate_output/_else_do _else_do daily_processing/load_to_warehouse 💻 load_to_warehouse [sh>] daily_processing/validate_output->daily_processing/load_to_warehouse daily_processing/+validate_output/_do/run_validation 💻 run_validation [sh>] daily_processing/+validate_output/_do->daily_processing/+validate_output/_do/run_validation daily_processing/+validate_output/_else_do/skip_validation 📢 skip_validation [echo>] daily_processing/+validate_output/_else_do->daily_processing/+validate_output/_else_do/skip_validation daily_processing/send_notification 📢 send_notification [echo>] daily_processing/load_to_warehouse->daily_processing/send_notification
Guided Tour