D
Digdag Workflow Graph etl_pipeline
🔍
Summary Tasks 10 TD 6 Inputs 7 Outputs 6 _error _parallel retry
etl_pipeline etl_pipeline  (schedule: 0 2 * * * America/Los_Angeles) cluster_etl_pipeline/stage_all parallel etl_pipeline__root etl_pipeline etl_pipeline/extract_source_data 📊 extract_source_data [td>] etl_pipeline__root->etl_pipeline/extract_source_data etl_pipeline/extract_users 📊 extract_users [td>] etl_pipeline/extract_source_data->etl_pipeline/extract_users etl_pipeline/+stage_all/stage_events 📊 stage_events [td>] etl_pipeline/extract_users->etl_pipeline/+stage_all/stage_events etl_pipeline/+stage_all/stage_users 📊 stage_users [td>] etl_pipeline/extract_users->etl_pipeline/+stage_all/stage_users etl_pipeline/create_golden_table 📊 create_golden_table [td>] etl_pipeline/+stage_all/stage_events->etl_pipeline/create_golden_table etl_pipeline/+stage_all/stage_users->etl_pipeline/create_golden_table etl_pipeline/data_quality_check 📊 data_quality_check [td>] etl_pipeline/create_golden_table->etl_pipeline/data_quality_check etl_pipeline/export_to_s3 💻 export_to_s3 [sh>] etl_pipeline/data_quality_check->etl_pipeline/export_to_s3 etl_pipeline/export_to_s3->etl_pipeline/export_to_s3 retry etl_pipeline/+export_to_s3/_error [ERROR] export_to_s3 _error etl_pipeline/export_to_s3->etl_pipeline/+export_to_s3/_error _error etl_pipeline/send_success_notification send_success_notification [http_call>] etl_pipeline/export_to_s3->etl_pipeline/send_success_notification etl_pipeline/+export_to_s3/_error/notify_export_failure 📢 notify_export_failure [echo>] etl_pipeline/+export_to_s3/_error->etl_pipeline/+export_to_s3/_error/notify_export_failure
Guided Tour