D
Digdag Workflow Graph adhoc_analysis
🔍
Summary Tasks 13 TD 3 Inputs 2 Outputs 3 _parallel
adhoc_analysis adhoc_analysis cluster_adhoc_analysis/parallel_analysis parallel adhoc_analysis__root adhoc_analysis adhoc_analysis/prepare_data 📊 prepare_data [td>] adhoc_analysis__root->adhoc_analysis/prepare_data adhoc_analysis/segment_analysis 🔄 segment_analysis [for_each>] adhoc_analysis/prepare_data->adhoc_analysis/segment_analysis adhoc_analysis/segment_analysis->adhoc_analysis/segment_analysis for_each> adhoc_analysis/+segment_analysis/_do [DO] segment_analysis _do adhoc_analysis/segment_analysis->adhoc_analysis/+segment_analysis/_do _do adhoc_analysis/+parallel_analysis/analyze_trends 🐍 analyze_trends [py>] adhoc_analysis/segment_analysis->adhoc_analysis/+parallel_analysis/analyze_trends adhoc_analysis/+parallel_analysis/generate_report 🐍 generate_report [py>] adhoc_analysis/segment_analysis->adhoc_analysis/+parallel_analysis/generate_report adhoc_analysis/+parallel_analysis/export_results 💻 export_results [sh>] adhoc_analysis/segment_analysis->adhoc_analysis/+parallel_analysis/export_results adhoc_analysis/+segment_analysis/_do/analyze_segment 📊 analyze_segment [td>] adhoc_analysis/+segment_analysis/_do->adhoc_analysis/+segment_analysis/_do/analyze_segment adhoc_analysis/conditional_publish ❓ conditional_publish [if>] adhoc_analysis/+parallel_analysis/analyze_trends->adhoc_analysis/conditional_publish adhoc_analysis/+parallel_analysis/generate_report->adhoc_analysis/conditional_publish adhoc_analysis/+parallel_analysis/export_results->adhoc_analysis/conditional_publish adhoc_analysis/+conditional_publish/_do [DO] conditional_publish _do adhoc_analysis/conditional_publish->adhoc_analysis/+conditional_publish/_do _do adhoc_analysis/+conditional_publish/_else_do [ELSE] conditional_publish _else_do adhoc_analysis/conditional_publish->adhoc_analysis/+conditional_publish/_else_do _else_do adhoc_analysis/consolidate_results 📊 consolidate_results [td>] adhoc_analysis/conditional_publish->adhoc_analysis/consolidate_results adhoc_analysis/+conditional_publish/_do/publish_report 💻 publish_report [sh>] adhoc_analysis/+conditional_publish/_do->adhoc_analysis/+conditional_publish/_do/publish_report adhoc_analysis/+conditional_publish/_else_do/skip_publish 📢 skip_publish [echo>] adhoc_analysis/+conditional_publish/_else_do->adhoc_analysis/+conditional_publish/_else_do/skip_publish adhoc_analysis/notify_completion 📢 notify_completion [echo>] adhoc_analysis/consolidate_results->adhoc_analysis/notify_completion adhoc_analysis/cleanup_temp cleanup_temp [rb>] adhoc_analysis/notify_completion->adhoc_analysis/cleanup_temp
Guided Tour