State | Dag Id | Task Id | Execution Date | Operator | Start Date | End Date | Duration | Job Id | Hostname | Unixname | Priority Weight | Queue | Queued Dttm | Try Number | Pool | Log Url | ||
---|---|---|---|---|---|---|---|---|---|---|---|---|---|---|---|---|---|---|
success | campaign-flow-job_v002 | trigger_dagrun_booking-processing-job_v002 |
|
TriggerDagRunOperator |
|
|
|
airflow | 1 | default |
|
1 | default_pool | |||||
success | campaign-flow-job_v002 | check_cluster_status |
|
EmrJobFlowSensor |
|
|
|
airflow | 3 | default |
|
1 | default_pool | |||||
success | campaign-flow-job_v002 | trigger_dagrun_campaign-history-job_v002 |
|
TriggerDagRunOperator |
|
|
|
airflow | 1 | default |
|
1 | default_pool | |||||
success | campaign-flow-job_v002 | trigger_dagrun_booking-processing-job_v002 |
|
TriggerDagRunOperator |
|
|
|
airflow | 1 | default |
|
1 | default_pool | |||||
success | campaign-flow-job_v002 | check_cluster_status |
|
EmrJobFlowSensor |
|
|
|
airflow | 3 | default |
|
1 | default_pool | |||||
success | campaign-flow-job_v002 | trigger_dagrun_campaign-history-job_v002 |
|
TriggerDagRunOperator |
|
|
|
airflow | 1 | default |
|
1 | default_pool | |||||
success | campaign-flow-job_v002 | trigger_dagrun_booking-processing-job_v002 |
|
TriggerDagRunOperator |
|
|
|
airflow | 1 | default |
|
1 | default_pool | |||||
success | campaign-flow-job_v002 | check_cluster_status |
|
EmrJobFlowSensor |
|
|
|
airflow | 3 | default |
|
1 | default_pool | |||||
success | campaign-flow-job_v002 | trigger_dagrun_campaign-history-job_v002 |
|
TriggerDagRunOperator |
|
|
|
airflow | 1 | default |
|
1 | default_pool | |||||
success | campaign-flow-job_v002 | trigger_dagrun_booking-processing-job_v002 |
|
TriggerDagRunOperator |
|
|
|
airflow | 1 | default |
|
1 | default_pool | |||||
success | campaign-flow-job_v002 | check_cluster_status |
|
EmrJobFlowSensor |
|
|
|
airflow | 3 | default |
|
1 | default_pool | |||||
success | campaign-flow-job_v002 | trigger_dagrun_booking-processing-job_v002 |
|
TriggerDagRunOperator |
|
|
|
airflow | 1 | default |
|
1 | default_pool | |||||
success | campaign-flow-job_v002 | check_cluster_status |
|
EmrJobFlowSensor |
|
|
|
airflow | 3 | default |
|
1 | default_pool | |||||
success | campaign-flow-job_v002 | trigger_dagrun_campaign-history-job_v002 |
|
TriggerDagRunOperator |
|
|
|
airflow | 1 | default |
|
1 | default_pool | |||||
success | campaign-flow-job_v002 | trigger_dagrun_booking-processing-job_v002 |
|
TriggerDagRunOperator |
|
|
|
airflow | 1 | default |
|
1 | default_pool | |||||
success | campaign-flow-job_v002 | check_cluster_status |
|
EmrJobFlowSensor |
|
|
|
airflow | 3 | default |
|
1 | default_pool | |||||
success | campaign-flow-job_v002 | trigger_dagrun_campaign-history-job_v002 |
|
TriggerDagRunOperator |
|
|
|
airflow | 1 | default |
|
1 | default_pool | |||||
success | campaign-flow-job_v002 | trigger_dagrun_booking-processing-job_v002 |
|
TriggerDagRunOperator |
|
|
|
airflow | 1 | default |
|
1 | default_pool | |||||
success | campaign-flow-job_v002 | check_cluster_status |
|
EmrJobFlowSensor |
|
|
|
airflow | 3 | default |
|
1 | default_pool | |||||
success | campaign-flow-job_v002 | trigger_dagrun_campaign-history-job_v002 |
|
TriggerDagRunOperator |
|
|
|
airflow | 1 | default |
|
1 | default_pool | |||||
success | campaign-flow-job_v002 | trigger_dagrun_booking-processing-job_v002 |
|
TriggerDagRunOperator |
|
|
|
airflow | 1 | default |
|
1 | default_pool | |||||
success | campaign-flow-job_v002 | check_cluster_status |
|
EmrJobFlowSensor |
|
|
|
airflow | 3 | default |
|
1 | default_pool | |||||
success | campaign-flow-job_v002 | trigger_dagrun_campaign-history-job_v002 |
|
TriggerDagRunOperator |
|
|
|
airflow | 1 | default |
|
1 | default_pool | |||||
success | campaign-flow-job_v002 | trigger_dagrun_booking-processing-job_v002 |
|
TriggerDagRunOperator |
|
|
|
airflow | 1 | default |
|
1 | default_pool | |||||
success | campaign-flow-job_v002 | trigger_dagrun_campaign-history-job_v002 |
|
TriggerDagRunOperator |
|
|
|
airflow | 1 | default |
|
1 | default_pool | |||||
success | campaign-flow-job_v002 | trigger_dagrun_booking-processing-job_v002 |
|
TriggerDagRunOperator |
|
|
|
airflow | 1 | default |
|
1 | default_pool | |||||
success | campaign-flow-job_v002 | check_cluster_status |
|
EmrJobFlowSensor |
|
|
|
airflow | 3 | default |
|
1 | default_pool | |||||
success | campaign-flow-job_v002 | trigger_dagrun_campaign-history-job_v002 |
|
TriggerDagRunOperator |
|
|
|
airflow | 1 | default |
|
1 | default_pool | |||||
success | campaign-flow-job_v002 | trigger_dagrun_booking-processing-job_v002 |
|
TriggerDagRunOperator |
|
|
|
airflow | 1 | default |
|
1 | default_pool | |||||
success | campaign-flow-job_v002 | check_cluster_status |
|
EmrJobFlowSensor |
|
|
|
airflow | 3 | default |
|
1 | default_pool | |||||
success | campaign-flow-job_v002 | trigger_dagrun_campaign-history-job_v002 |
|
TriggerDagRunOperator |
|
|
|
airflow | 1 | default |
|
1 | default_pool | |||||
success | campaign-flow-job_v002 | trigger_dagrun_booking-processing-job_v002 |
|
TriggerDagRunOperator |
|
|
|
airflow | 1 | default |
|
1 | default_pool | |||||
success | campaign-flow-job_v002 | check_cluster_status |
|
EmrJobFlowSensor |
|
|
|
airflow | 3 | default |
|
1 | default_pool | |||||
success | campaign-flow-job_v002 | trigger_dagrun_campaign-history-job_v002 |
|
TriggerDagRunOperator |
|
|
|
airflow | 1 | default |
|
1 | default_pool | |||||
success | campaign-flow-job_v002 | trigger_dagrun_booking-processing-job_v002 |
|
TriggerDagRunOperator |
|
|
|
airflow | 1 | default |
|
1 | default_pool | |||||
success | campaign-flow-job_v002 | check_cluster_status |
|
EmrJobFlowSensor |
|
|
|
airflow | 3 | default |
|
1 | default_pool | |||||
success | campaign-flow-job_v002 | trigger_dagrun_campaign-history-job_v002 |
|
TriggerDagRunOperator |
|
|
|
airflow | 1 | default |
|
1 | default_pool | |||||
success | campaign-flow-job_v002 | trigger_dagrun_booking-processing-job_v002 |
|
TriggerDagRunOperator |
|
|
|
airflow | 1 | default |
|
1 | default_pool | |||||
success | campaign-flow-job_v002 | trigger_dagrun_campaign-history-job_v002 |
|
TriggerDagRunOperator |
|
|
|
airflow | 1 | default |
|
1 | default_pool | |||||
success | campaign-flow-job_v002 | trigger_dagrun_booking-processing-job_v002 |
|
TriggerDagRunOperator |
|
|
|
airflow | 1 | default |
|
1 | default_pool | |||||
success | campaign-flow-job_v002 | trigger_dagrun_campaign-history-job_v002 |
|
TriggerDagRunOperator |
|
|
|
airflow | 1 | default |
|
1 | default_pool | |||||
success | campaign-flow-job_v002 | trigger_dagrun_booking-processing-job_v002 |
|
TriggerDagRunOperator |
|
|
|
airflow | 1 | default |
|
1 | default_pool | |||||
success | campaign-flow-job_v002 | check_cluster_status |
|
EmrJobFlowSensor |
|
|
|
airflow | 3 | default |
|
1 | default_pool | |||||
success | campaign-flow-job_v002 | trigger_dagrun_campaign-history-job_v002 |
|
TriggerDagRunOperator |
|
|
|
airflow | 1 | default |
|
1 | default_pool | |||||
success | campaign-flow-job_v002 | trigger_dagrun_booking-processing-job_v002 |
|
TriggerDagRunOperator |
|
|
|
airflow | 1 | default |
|
1 | default_pool | |||||
success | campaign-flow-job_v002 | check_cluster_status |
|
EmrJobFlowSensor |
|
|
|
airflow | 3 | default |
|
1 | default_pool | |||||
success | campaign-flow-job_v002 | trigger_dagrun_campaign-history-job_v002 |
|
TriggerDagRunOperator |
|
|
|
airflow | 1 | default |
|
1 | default_pool | |||||
success | campaign-flow-job_v002 | trigger_dagrun_booking-processing-job_v002 |
|
TriggerDagRunOperator |
|
|
|
airflow | 1 | default |
|
1 | default_pool | |||||
success | campaign-flow-job_v002 | trigger_dagrun_campaign-history-job_v002 |
|
TriggerDagRunOperator |
|
|
|
airflow | 1 | default |
|
1 | default_pool | |||||
success | campaign-flow-job_v002 | trigger_dagrun_booking-processing-job_v002 |
|
TriggerDagRunOperator |
|
|
|
airflow | 1 | default |
|
1 | default_pool | |||||
success | campaign-flow-job_v002 | check_cluster_status |
|
EmrJobFlowSensor |
|
|
|
airflow | 3 | default |
|
1 | default_pool | |||||
success | campaign-flow-job_v002 | trigger_dagrun_campaign-history-job_v002 |
|
TriggerDagRunOperator |
|
|
|
airflow | 1 | default |
|
1 | default_pool | |||||
success | campaign-flow-job_v002 | trigger_dagrun_booking-processing-job_v002 |
|
TriggerDagRunOperator |
|
|
|
airflow | 1 | default |
|
1 | default_pool | |||||
success | campaign-flow-job_v002 | check_cluster_status |
|
EmrJobFlowSensor |
|
|
|
airflow | 3 | default |
|
1 | default_pool | |||||
success | campaign-flow-job_v002 | trigger_dagrun_campaign-history-job_v002 |
|
TriggerDagRunOperator |
|
|
|
airflow | 1 | default |
|
1 | default_pool | |||||
success | campaign-flow-job_v002 | trigger_dagrun_booking-processing-job_v002 |
|
TriggerDagRunOperator |
|
|
|
airflow | 1 | default |
|
1 | default_pool | |||||
success | campaign-flow-job_v002 | check_cluster_status |
|
EmrJobFlowSensor |
|
|
|
airflow | 3 | default |
|
1 | default_pool | |||||
success | campaign-flow-job_v002 | trigger_dagrun_campaign-history-job_v002 |
|
TriggerDagRunOperator |
|
|
|
airflow | 1 | default |
|
1 | default_pool | |||||
success | campaign-flow-job_v002 | trigger_dagrun_booking-processing-job_v002 |
|
TriggerDagRunOperator |
|
|
|
airflow | 1 | default |
|
1 | default_pool | |||||
success | campaign-flow-job_v002 | check_cluster_status |
|
EmrJobFlowSensor |
|
|
|
airflow | 3 | default |
|
1 | default_pool | |||||
success | campaign-flow-job_v002 | trigger_dagrun_campaign-history-job_v002 |
|
TriggerDagRunOperator |
|
|
|
airflow | 1 | default |
|
1 | default_pool | |||||
success | campaign-flow-job_v002 | trigger_dagrun_booking-processing-job_v002 |
|
TriggerDagRunOperator |
|
|
|
airflow | 1 | default |
|
1 | default_pool | |||||
success | campaign-flow-job_v002 | trigger_dagrun_campaign-history-job_v002 |
|
TriggerDagRunOperator |
|
|
|
airflow | 1 | default |
|
1 | default_pool | |||||
success | campaign-flow-job_v002 | trigger_dagrun_booking-processing-job_v002 |
|
TriggerDagRunOperator |
|
|
|
airflow | 1 | default |
|
1 | default_pool | |||||
success | campaign-flow-job_v002 | trigger_dagrun_campaign-history-job_v002 |
|
TriggerDagRunOperator |
|
|
|
airflow | 1 | default |
|
1 | default_pool | |||||
success | campaign-flow-job_v002 | trigger_dagrun_booking-processing-job_v002 |
|
TriggerDagRunOperator |
|
|
|
airflow | 1 | default |
|
1 | default_pool | |||||
success | campaign-flow-job_v002 | check_cluster_status |
|
EmrJobFlowSensor |
|
|
|
airflow | 3 | default |
|
1 | default_pool | |||||
success | campaign-flow-job_v002 | check_cluster_status |
|
EmrJobFlowSensor |
|
|
|
airflow | 3 | default |
|
1 | default_pool | |||||
success | campaign-flow-job_v002 | trigger_dagrun_campaign-history-job_v002 |
|
|
|
|
airflow | 1 | default |
|
1 | default_pool | ||||||
success | campaign-flow-job_v002 | trigger_dagrun_booking-processing-job_v002 |
|
|
|
|
airflow | 1 | default |
|
1 | default_pool | ||||||
success | campaign-flow-job_v002 | trigger_dagrun_campaign-history-job_v002 |
|
|
|
|
airflow | 1 | default |
|
1 | default_pool | ||||||
success | campaign-flow-job_v002 | trigger_dagrun_booking-processing-job_v002 |
|
|
|
|
airflow | 1 | default |
|
1 | default_pool | ||||||
success | campaign-flow-job_v002 | check_cluster_status |
|
|
|
|
airflow | 3 | default |
|
1 | default_pool | ||||||
success | campaign-flow-job_v002 | trigger_dagrun_campaign-history-job_v002 |
|
|
|
|
airflow | 1 | default |
|
1 | default_pool | ||||||
success | campaign-flow-job_v002 | trigger_dagrun_booking-processing-job_v002 |
|
|
|
|
airflow | 1 | default |
|
1 | default_pool | ||||||
success | campaign-flow-job_v002 | check_cluster_status |
|
|
|
|
airflow | 3 | default |
|
1 | default_pool | ||||||
success | campaign-flow-job_v002 | trigger_dagrun_campaign-history-job_v002 |
|
|
|
|
airflow | 1 | default |
|
1 | default_pool | ||||||
success | campaign-flow-job_v002 | trigger_dagrun_booking-processing-job_v002 |
|
|
|
|
airflow | 1 | default |
|
1 | default_pool | ||||||
success | campaign-flow-job_v002 | trigger_dagrun_campaign-history-job_v002 |
|
TriggerDagRunOperator |
|
|
|
airflow | 1 | default |
|
1 | default_pool | |||||
success | campaign-flow-job_v002 | trigger_dagrun_booking-processing-job_v002 |
|
TriggerDagRunOperator |
|
|
|
airflow | 1 | default |
|
1 | default_pool | |||||
success | campaign-flow-job_v002 | trigger_dagrun_booking-processing-job_v002 |
|
TriggerDagRunOperator |
|
|
|
airflow | 1 | default |
|
1 | default_pool | |||||
success | campaign-flow-job_v002 | trigger_dagrun_campaign-history-job_v002 |
|
TriggerDagRunOperator |
|
|
|
airflow | 1 | default |
|
1 | default_pool | |||||
success | campaign-flow-job_v002 | trigger_dagrun_booking-processing-job_v002 |
|
TriggerDagRunOperator |
|
|
0:00:00.468623 | 395984 |
|
airflow | 1 | default |
|
2 | default_pool | |||
success | campaign-flow-job_v002 | trigger_dagrun_campaign-history-job_v002 |
|
TriggerDagRunOperator |
|
|
0:00:00.410190 | 395983 |
|
airflow | 1 | default |
|
2 | default_pool | |||
success | campaign-flow-job_v002 | check_cluster_status |
|
EmrJobFlowSensor |
|
|
0:10:01.846294 | 395976 |
|
airflow | 3 | default |
|
2 | default_pool | |||
success | campaign-flow-job_v002 | create_cluster_and_add_emr_steps |
|
EmrCreateJobFlowOperator |
|
|
0:00:01.012832 | 395974 |
|
airflow | 4 | default |
|
2 | default_pool | |||
success | campaign-flow-job_v002 | create_emr_steps |
|
PythonOperator |
|
|
0:00:00.886615 | 395972 |
|
airflow | 5 | default |
|
2 | default_pool | |||
success | campaign-flow-job_v002 | trigger_dagrun_booking-processing-job_v002 |
|
TriggerDagRunOperator |
|
|
0:00:00.457456 | 395960 |
|
airflow | 1 | default |
|
2 | default_pool | |||
success | campaign-flow-job_v002 | trigger_dagrun_campaign-history-job_v002 |
|
TriggerDagRunOperator |
|
|
0:00:00.390163 | 395959 |
|
airflow | 1 | default |
|
2 | default_pool | |||
success | campaign-flow-job_v002 | check_cluster_status |
|
EmrJobFlowSensor |
|
|
0:10:02.332753 | 395952 |
|
airflow | 3 | default |
|
2 | default_pool | |||
success | campaign-flow-job_v002 | create_cluster_and_add_emr_steps |
|
EmrCreateJobFlowOperator |
|
|
0:00:00.951905 | 395950 |
|
airflow | 4 | default |
|
2 | default_pool | |||
success | campaign-flow-job_v002 | create_emr_steps |
|
PythonOperator |
|
|
0:00:01.758608 | 395948 |
|
airflow | 5 | default |
|
2 | default_pool | |||
success | campaign-flow-job_v002 | trigger_dagrun_booking-processing-job_v002 |
|
TriggerDagRunOperator |
|
|
0:00:00.489234 | 395937 |
|
airflow | 1 | default |
|
2 | default_pool | |||
success | campaign-flow-job_v002 | trigger_dagrun_campaign-history-job_v002 |
|
TriggerDagRunOperator |
|
|
0:00:00.401821 | 395936 |
|
airflow | 1 | default |
|
2 | default_pool | |||
success | campaign-flow-job_v002 | check_cluster_status |
|
EmrJobFlowSensor |
|
|
0:10:01.806660 | 395929 |
|
airflow | 3 | default |
|
2 | default_pool | |||
success | campaign-flow-job_v002 | create_cluster_and_add_emr_steps |
|
EmrCreateJobFlowOperator |
|
|
0:00:00.922066 | 395927 |
|
airflow | 4 | default |
|
2 | default_pool | |||
success | campaign-flow-job_v002 | create_emr_steps |
|
PythonOperator |
|
|
0:00:00.920223 | 395925 |
|
airflow | 5 | default |
|
2 | default_pool | |||
success | campaign-flow-job_v002 | trigger_dagrun_booking-processing-job_v002 |
|
TriggerDagRunOperator |
|
|
0:00:00.474050 | 395914 |
|
airflow | 1 | default |
|
2 | default_pool | |||
success | campaign-flow-job_v002 | trigger_dagrun_campaign-history-job_v002 |
|
TriggerDagRunOperator |
|
|
0:00:00.406002 | 395913 |
|
airflow | 1 | default |
|
2 | default_pool | |||
success | campaign-flow-job_v002 | check_cluster_status |
|
EmrJobFlowSensor |
|
|
0:10:01.661781 | 395906 |
|
airflow | 3 | default |
|
2 | default_pool |