Task Instances

Reset Filters
  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 check_cluster_status 2023-03-15T15:00:00+00:00 EmrJobFlowSensor 2023-03-15T16:02:11.490018+00:00 2023-03-15T16:12:13.828814+00:00 0:10:02.338796 354050 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2023-03-15T16:02:08.970675+00:00 2 default_pool
success campaign-flow-job_v002 create_cluster_and_add_emr_steps 2023-03-15T15:00:00+00:00 EmrCreateJobFlowOperator 2023-03-15T16:01:49.421824+00:00 2023-03-15T16:01:50.366862+00:00 0:00:00.945038 354048 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 4 default 2023-03-15T16:01:46.947219+00:00 2 default_pool
success campaign-flow-job_v002 create_emr_steps 2023-03-15T15:00:00+00:00 PythonOperator 2023-03-15T16:01:29.748742+00:00 2023-03-15T16:01:32.865034+00:00 0:00:03.116292 354046 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 5 default 2023-03-15T16:01:26.927454+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_booking-processing-job_v002 2023-03-15T14:00:00+00:00 TriggerDagRunOperator 2023-03-15T15:28:07.279447+00:00 2023-03-15T15:28:07.816286+00:00 0:00:00.536839 354038 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2023-03-15T15:28:04.619643+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_campaign-history-job_v002 2023-03-15T14:00:00+00:00 TriggerDagRunOperator 2023-03-15T15:28:07.131316+00:00 2023-03-15T15:28:07.651536+00:00 0:00:00.520220 354037 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2023-03-15T15:28:04.619671+00:00 2 default_pool
success campaign-flow-job_v002 check_cluster_status 2023-03-15T14:00:00+00:00 EmrJobFlowSensor 2023-03-15T15:17:58.752253+00:00 2023-03-15T15:28:00.611510+00:00 0:10:01.859257 354033 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2023-03-15T15:17:56.323729+00:00 2 default_pool
success campaign-flow-job_v002 create_cluster_and_add_emr_steps 2023-03-15T14:00:00+00:00 EmrCreateJobFlowOperator 2023-03-15T15:17:36.618100+00:00 2023-03-15T15:17:37.505594+00:00 0:00:00.887494 354030 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 4 default 2023-03-15T15:17:34.275851+00:00 2 default_pool
success campaign-flow-job_v002 create_emr_steps 2023-03-15T14:00:00+00:00 PythonOperator 2023-03-15T15:17:16.539076+00:00 2023-03-15T15:17:19.546123+00:00 0:00:03.007047 354027 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 5 default 2023-03-15T15:17:14.266767+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_campaign-history-job_v002 2023-03-15T13:00:00+00:00 TriggerDagRunOperator 2023-03-15T14:10:16.196920+00:00 2023-03-15T14:10:16.706493+00:00 0:00:00.509573 354018 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2023-03-15T14:10:13.902433+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_booking-processing-job_v002 2023-03-15T13:00:00+00:00 TriggerDagRunOperator 2023-03-15T14:10:16.147200+00:00 2023-03-15T14:10:16.629443+00:00 0:00:00.482243 354017 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2023-03-15T14:10:13.902400+00:00 2 default_pool
success campaign-flow-job_v002 check_cluster_status 2023-03-15T13:00:00+00:00 EmrJobFlowSensor 2023-03-15T14:00:56.254512+00:00 2023-03-15T14:09:57.970605+00:00 0:09:01.716093 354010 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2023-03-15T14:00:53.844246+00:00 2 default_pool
success campaign-flow-job_v002 create_cluster_and_add_emr_steps 2023-03-15T13:00:00+00:00 EmrCreateJobFlowOperator 2023-03-15T14:00:34.245854+00:00 2023-03-15T14:00:35.070013+00:00 0:00:00.824159 354008 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 4 default 2023-03-15T14:00:31.785993+00:00 2 default_pool
success campaign-flow-job_v002 create_emr_steps 2023-03-15T13:00:00+00:00 PythonOperator 2023-03-15T14:00:12.150119+00:00 2023-03-15T14:00:16.096727+00:00 0:00:03.946608 354006 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 5 default 2023-03-15T14:00:09.817567+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_campaign-history-job_v002 2023-03-15T12:00:00+00:00 TriggerDagRunOperator 2023-03-15T13:11:31.420438+00:00 2023-03-15T13:11:31.895063+00:00 0:00:00.474625 353998 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2023-03-15T13:11:28.721325+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_booking-processing-job_v002 2023-03-15T12:00:00+00:00 TriggerDagRunOperator 2023-03-15T13:11:31.080103+00:00 2023-03-15T13:11:31.691262+00:00 0:00:00.611159 353997 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2023-03-15T13:11:28.721291+00:00 2 default_pool
success campaign-flow-job_v002 check_cluster_status 2023-03-15T12:00:00+00:00 EmrJobFlowSensor 2023-03-15T13:01:07.659672+00:00 2023-03-15T13:11:09.401769+00:00 0:10:01.742097 353991 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2023-03-15T13:01:05.274982+00:00 2 default_pool
success campaign-flow-job_v002 create_cluster_and_add_emr_steps 2023-03-15T12:00:00+00:00 EmrCreateJobFlowOperator 2023-03-15T13:00:45.940483+00:00 2023-03-15T13:00:46.763953+00:00 0:00:00.823470 353989 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 4 default 2023-03-15T13:00:43.312438+00:00 2 default_pool
success campaign-flow-job_v002 create_emr_steps 2023-03-15T12:00:00+00:00 PythonOperator 2023-03-15T13:00:23.446698+00:00 2023-03-15T13:00:27.397138+00:00 0:00:03.950440 353987 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 5 default 2023-03-15T13:00:21.230914+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_campaign-history-job_v002 2023-03-15T11:00:00+00:00 TriggerDagRunOperator 2023-03-15T12:17:00.785928+00:00 2023-03-15T12:17:01.449841+00:00 0:00:00.663913 353978 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2023-03-15T12:16:57.728858+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_booking-processing-job_v002 2023-03-15T11:00:00+00:00 TriggerDagRunOperator 2023-03-15T12:17:00.546904+00:00 2023-03-15T12:17:01.157623+00:00 0:00:00.610719 353977 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2023-03-15T12:16:57.728825+00:00 2 default_pool
success campaign-flow-job_v002 check_cluster_status 2023-03-15T11:00:00+00:00 EmrJobFlowSensor 2023-03-15T12:04:19.064056+00:00 2023-03-15T12:14:20.809823+00:00 0:10:01.745767 353970 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2023-03-15T12:04:16.811090+00:00 2 default_pool
success campaign-flow-job_v002 create_cluster_and_add_emr_steps 2023-03-15T11:00:00+00:00 EmrCreateJobFlowOperator 2023-03-15T12:03:59.361247+00:00 2023-03-15T12:04:00.776973+00:00 0:00:01.415726 353968 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 4 default 2023-03-15T12:03:56.791669+00:00 2 default_pool
success campaign-flow-job_v002 create_emr_steps 2023-03-15T11:00:00+00:00 PythonOperator 2023-03-15T12:03:37.069084+00:00 2023-03-15T12:03:41.084331+00:00 0:00:04.015247 353966 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 5 default 2023-03-15T12:03:34.751659+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_campaign-history-job_v002 2023-03-15T10:00:00+00:00 TriggerDagRunOperator 2023-03-15T11:35:20.498096+00:00 2023-03-15T11:35:21.048527+00:00 0:00:00.550431 353959 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2023-03-15T11:35:18.082992+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_booking-processing-job_v002 2023-03-15T10:00:00+00:00 TriggerDagRunOperator 2023-03-15T11:35:20.433262+00:00 2023-03-15T11:35:20.892601+00:00 0:00:00.459339 353958 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2023-03-15T11:35:18.082942+00:00 2 default_pool
success campaign-flow-job_v002 check_cluster_status 2023-03-15T10:00:00+00:00 EmrJobFlowSensor 2023-03-15T11:00:52.112122+00:00 2023-03-15T11:09:54.079222+00:00 0:09:01.967100 353950 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2023-03-15T11:00:49.540345+00:00 2 default_pool
success campaign-flow-job_v002 create_cluster_and_add_emr_steps 2023-03-15T10:00:00+00:00 EmrCreateJobFlowOperator 2023-03-15T11:00:31.964410+00:00 2023-03-15T11:00:33.619450+00:00 0:00:01.655040 353948 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 4 default 2023-03-15T11:00:29.475272+00:00 2 default_pool
success campaign-flow-job_v002 create_emr_steps 2023-03-15T10:00:00+00:00 PythonOperator 2023-03-15T11:00:09.943676+00:00 2023-03-15T11:00:13.895181+00:00 0:00:03.951505 353946 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 5 default 2023-03-15T11:00:07.456031+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_booking-processing-job_v002 2023-03-15T09:00:00+00:00 TriggerDagRunOperator 2023-03-15T10:11:06.692281+00:00 2023-03-15T10:11:07.175561+00:00 0:00:00.483280 353936 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2023-03-15T10:11:03.814309+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_campaign-history-job_v002 2023-03-15T09:00:00+00:00 TriggerDagRunOperator 2023-03-15T10:11:06.461832+00:00 2023-03-15T10:11:06.972843+00:00 0:00:00.511011 353935 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2023-03-15T10:11:03.814351+00:00 2 default_pool
success campaign-flow-job_v002 check_cluster_status 2023-03-15T09:00:00+00:00 EmrJobFlowSensor 2023-03-15T10:00:51.592482+00:00 2023-03-15T10:10:53.878182+00:00 0:10:02.285700 353927 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2023-03-15T10:00:49.163419+00:00 2 default_pool
success campaign-flow-job_v002 create_cluster_and_add_emr_steps 2023-03-15T09:00:00+00:00 EmrCreateJobFlowOperator 2023-03-15T10:00:31.457812+00:00 2023-03-15T10:00:32.312113+00:00 0:00:00.854301 353925 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 4 default 2023-03-15T10:00:29.147812+00:00 2 default_pool
success campaign-flow-job_v002 create_emr_steps 2023-03-15T09:00:00+00:00 PythonOperator 2023-03-15T10:00:09.544771+00:00 2023-03-15T10:00:13.575084+00:00 0:00:04.030313 353923 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 5 default 2023-03-15T10:00:07.129467+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_campaign-history-job_v002 2023-03-15T08:00:00+00:00 TriggerDagRunOperator 2023-03-15T09:12:02.896315+00:00 2023-03-15T09:12:03.645660+00:00 0:00:00.749345 353912 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2023-03-15T09:11:59.178183+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_booking-processing-job_v002 2023-03-15T08:00:00+00:00 TriggerDagRunOperator 2023-03-15T09:12:01.629896+00:00 2023-03-15T09:12:02.151815+00:00 0:00:00.521919 353911 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2023-03-15T09:11:59.178144+00:00 2 default_pool
success campaign-flow-job_v002 check_cluster_status 2023-03-15T08:00:00+00:00 EmrJobFlowSensor 2023-03-15T09:00:53.945173+00:00 2023-03-15T09:10:56.210362+00:00 0:10:02.265189 353906 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2023-03-15T09:00:51.327961+00:00 2 default_pool
success campaign-flow-job_v002 create_cluster_and_add_emr_steps 2023-03-15T08:00:00+00:00 EmrCreateJobFlowOperator 2023-03-15T09:00:32.218542+00:00 2023-03-15T09:00:33.595394+00:00 0:00:01.376852 353904 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 4 default 2023-03-15T09:00:29.305949+00:00 2 default_pool
success campaign-flow-job_v002 create_emr_steps 2023-03-15T08:00:00+00:00 PythonOperator 2023-03-15T09:00:08.126677+00:00 2023-03-15T09:00:13.828178+00:00 0:00:05.701501 353902 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 5 default 2023-03-15T09:00:05.327928+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_campaign-history-job_v002 2023-03-15T07:00:00+00:00 TriggerDagRunOperator 2023-03-15T08:10:55.736534+00:00 2023-03-15T08:10:56.319062+00:00 0:00:00.582528 353893 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2023-03-15T08:10:52.501124+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_booking-processing-job_v002 2023-03-15T07:00:00+00:00 TriggerDagRunOperator 2023-03-15T08:10:55.414482+00:00 2023-03-15T08:10:55.880089+00:00 0:00:00.465607 353892 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2023-03-15T08:10:52.501086+00:00 2 default_pool
success campaign-flow-job_v002 check_cluster_status 2023-03-15T07:00:00+00:00 EmrJobFlowSensor 2023-03-15T08:02:37.228762+00:00 2023-03-15T08:10:38.822205+00:00 0:08:01.593443 353886 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2023-03-15T08:02:34.849945+00:00 2 default_pool
success campaign-flow-job_v002 create_cluster_and_add_emr_steps 2023-03-15T07:00:00+00:00 EmrCreateJobFlowOperator 2023-03-15T08:00:31.313050+00:00 2023-03-15T08:00:32.190060+00:00 0:00:00.877010 353883 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 4 default 2023-03-15T08:00:28.821945+00:00 2 default_pool
success campaign-flow-job_v002 create_emr_steps 2023-03-15T07:00:00+00:00 PythonOperator 2023-03-15T08:00:09.059795+00:00 2023-03-15T08:00:13.035202+00:00 0:00:03.975407 353881 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 5 default 2023-03-15T08:00:06.809565+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_campaign-history-job_v002 2023-03-15T06:00:00+00:00 TriggerDagRunOperator 2023-03-15T07:12:38.108228+00:00 2023-03-15T07:12:38.626389+00:00 0:00:00.518161 353870 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2023-03-15T07:12:35.502850+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_booking-processing-job_v002 2023-03-15T06:00:00+00:00 TriggerDagRunOperator 2023-03-15T07:12:37.967334+00:00 2023-03-15T07:12:38.450019+00:00 0:00:00.482685 353869 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2023-03-15T07:12:35.502820+00:00 2 default_pool
success campaign-flow-job_v002 check_cluster_status 2023-03-15T06:00:00+00:00 EmrJobFlowSensor 2023-03-15T07:02:28.624547+00:00 2023-03-15T07:12:30.483771+00:00 0:10:01.859224 353862 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2023-03-15T07:02:26.327887+00:00 2 default_pool
success campaign-flow-job_v002 create_cluster_and_add_emr_steps 2023-03-15T06:00:00+00:00 EmrCreateJobFlowOperator 2023-03-15T07:02:06.510276+00:00 2023-03-15T07:02:07.383547+00:00 0:00:00.873271 353860 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 4 default 2023-03-15T07:02:04.278408+00:00 2 default_pool
success campaign-flow-job_v002 create_emr_steps 2023-03-15T06:00:00+00:00 PythonOperator 2023-03-15T07:01:45.179877+00:00 2023-03-15T07:01:50.594072+00:00 0:00:05.414195 353858 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 5 default 2023-03-15T07:01:42.259211+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_campaign-history-job_v002 2023-03-15T05:00:00+00:00 TriggerDagRunOperator 2023-03-15T06:14:37.860036+00:00 2023-03-15T06:14:38.413497+00:00 0:00:00.553461 353848 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2023-03-15T06:14:35.139049+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_booking-processing-job_v002 2023-03-15T05:00:00+00:00 TriggerDagRunOperator 2023-03-15T06:14:37.609466+00:00 2023-03-15T06:14:38.155139+00:00 0:00:00.545673 353847 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2023-03-15T06:14:35.139019+00:00 2 default_pool
success campaign-flow-job_v002 check_cluster_status 2023-03-15T05:00:00+00:00 EmrJobFlowSensor 2023-03-15T06:01:51.521348+00:00 2023-03-15T06:11:53.259677+00:00 0:10:01.738329 353840 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2023-03-15T06:01:49.130979+00:00 2 default_pool
success campaign-flow-job_v002 create_cluster_and_add_emr_steps 2023-03-15T05:00:00+00:00 EmrCreateJobFlowOperator 2023-03-15T06:01:29.372667+00:00 2023-03-15T06:01:30.263834+00:00 0:00:00.891167 353838 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 4 default 2023-03-15T06:01:27.110824+00:00 2 default_pool
success campaign-flow-job_v002 create_emr_steps 2023-03-15T05:00:00+00:00 PythonOperator 2023-03-15T06:01:09.875755+00:00 2023-03-15T06:01:14.094213+00:00 0:00:04.218458 353836 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 5 default 2023-03-15T06:01:07.094023+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_booking-processing-job_v002 2023-03-15T04:00:00+00:00 TriggerDagRunOperator 2023-03-15T05:18:35.342676+00:00 2023-03-15T05:18:35.823793+00:00 0:00:00.481117 353828 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2023-03-15T05:18:32.387501+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_campaign-history-job_v002 2023-03-15T04:00:00+00:00 TriggerDagRunOperator 2023-03-15T05:18:35.151263+00:00 2023-03-15T05:18:35.594313+00:00 0:00:00.443050 353827 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2023-03-15T05:18:32.387531+00:00 2 default_pool
success campaign-flow-job_v002 check_cluster_status 2023-03-15T04:00:00+00:00 EmrJobFlowSensor 2023-03-15T05:06:15.912881+00:00 2023-03-15T05:16:17.667674+00:00 0:10:01.754793 353824 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2023-03-15T05:06:13.352282+00:00 2 default_pool
success campaign-flow-job_v002 create_cluster_and_add_emr_steps 2023-03-15T04:00:00+00:00 EmrCreateJobFlowOperator 2023-03-15T05:05:53.981638+00:00 2023-03-15T05:05:55.069678+00:00 0:00:01.088040 353821 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 4 default 2023-03-15T05:05:51.348570+00:00 2 default_pool
success campaign-flow-job_v002 create_emr_steps 2023-03-15T04:00:00+00:00 PythonOperator 2023-03-15T05:05:34.095372+00:00 2023-03-15T05:05:37.118304+00:00 0:00:03.022932 353818 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 5 default 2023-03-15T05:05:29.288073+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_campaign-history-job_v002 2023-03-15T03:00:00+00:00 TriggerDagRunOperator 2023-03-15T04:11:15.483478+00:00 2023-03-15T04:11:15.991288+00:00 0:00:00.507810 353808 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2023-03-15T04:11:12.747415+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_booking-processing-job_v002 2023-03-15T03:00:00+00:00 TriggerDagRunOperator 2023-03-15T04:11:15.216501+00:00 2023-03-15T04:11:15.745186+00:00 0:00:00.528685 353807 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2023-03-15T04:11:12.747386+00:00 2 default_pool
success campaign-flow-job_v002 check_cluster_status 2023-03-15T03:00:00+00:00 EmrJobFlowSensor 2023-03-15T04:00:52.338663+00:00 2023-03-15T04:10:54.121819+00:00 0:10:01.783156 353799 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2023-03-15T04:00:50.046598+00:00 2 default_pool
success campaign-flow-job_v002 create_cluster_and_add_emr_steps 2023-03-15T03:00:00+00:00 EmrCreateJobFlowOperator 2023-03-15T04:00:30.386529+00:00 2023-03-15T04:00:31.166431+00:00 0:00:00.779902 353797 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 4 default 2023-03-15T04:00:27.951814+00:00 2 default_pool
success campaign-flow-job_v002 create_emr_steps 2023-03-15T03:00:00+00:00 PythonOperator 2023-03-15T04:00:10.343146+00:00 2023-03-15T04:00:14.408886+00:00 0:00:04.065740 353795 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 5 default 2023-03-15T04:00:07.915338+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_campaign-history-job_v002 2023-03-15T02:00:00+00:00 TriggerDagRunOperator 2023-03-15T03:11:12.289534+00:00 2023-03-15T03:11:12.789356+00:00 0:00:00.499822 353786 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2023-03-15T03:11:09.838785+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_booking-processing-job_v002 2023-03-15T02:00:00+00:00 TriggerDagRunOperator 2023-03-15T03:11:12.226992+00:00 2023-03-15T03:11:12.759406+00:00 0:00:00.532414 353785 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2023-03-15T03:11:09.838757+00:00 2 default_pool
success campaign-flow-job_v002 check_cluster_status 2023-03-15T02:00:00+00:00 EmrJobFlowSensor 2023-03-15T03:00:51.741205+00:00 2023-03-15T03:10:53.540197+00:00 0:10:01.798992 353779 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2023-03-15T03:00:48.570260+00:00 2 default_pool
success campaign-flow-job_v002 create_cluster_and_add_emr_steps 2023-03-15T02:00:00+00:00 EmrCreateJobFlowOperator 2023-03-15T03:00:29.318925+00:00 2023-03-15T03:00:30.156059+00:00 0:00:00.837134 353777 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 4 default 2023-03-15T03:00:26.545576+00:00 2 default_pool
success campaign-flow-job_v002 create_emr_steps 2023-03-15T02:00:00+00:00 PythonOperator 2023-03-15T03:00:08.843995+00:00 2023-03-15T03:00:12.241052+00:00 0:00:03.397057 353775 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 5 default 2023-03-15T03:00:06.523551+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_campaign-history-job_v002 2023-03-15T01:00:00+00:00 TriggerDagRunOperator 2023-03-15T02:11:03.048583+00:00 2023-03-15T02:11:03.574959+00:00 0:00:00.526376 353763 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2023-03-15T02:11:00.370537+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_booking-processing-job_v002 2023-03-15T01:00:00+00:00 TriggerDagRunOperator 2023-03-15T02:11:03.068476+00:00 2023-03-15T02:11:03.591309+00:00 0:00:00.522833 353762 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2023-03-15T02:11:00.370495+00:00 2 default_pool
success campaign-flow-job_v002 check_cluster_status 2023-03-15T01:00:00+00:00 EmrJobFlowSensor 2023-03-15T02:00:53.064586+00:00 2023-03-15T02:10:54.932653+00:00 0:10:01.868067 353755 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2023-03-15T02:00:50.807831+00:00 2 default_pool
success campaign-flow-job_v002 create_cluster_and_add_emr_steps 2023-03-15T01:00:00+00:00 EmrCreateJobFlowOperator 2023-03-15T02:00:33.040020+00:00 2023-03-15T02:00:34.360762+00:00 0:00:01.320742 353753 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 4 default 2023-03-15T02:00:30.672626+00:00 2 default_pool
success campaign-flow-job_v002 create_emr_steps 2023-03-15T01:00:00+00:00 PythonOperator 2023-03-15T02:00:10.986924+00:00 2023-03-15T02:00:14.991974+00:00 0:00:04.005050 353751 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 5 default 2023-03-15T02:00:08.651056+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_campaign-history-job_v002 2023-03-15T00:00:00+00:00 TriggerDagRunOperator 2023-03-15T01:11:04.723440+00:00 2023-03-15T01:11:05.257681+00:00 0:00:00.534241 353734 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2023-03-15T01:11:02.163692+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_booking-processing-job_v002 2023-03-15T00:00:00+00:00 TriggerDagRunOperator 2023-03-15T01:11:04.526184+00:00 2023-03-15T01:11:05.052254+00:00 0:00:00.526070 353733 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2023-03-15T01:11:02.163650+00:00 2 default_pool
success campaign-flow-job_v002 check_cluster_status 2023-03-15T00:00:00+00:00 EmrJobFlowSensor 2023-03-15T01:00:55.832642+00:00 2023-03-15T01:10:58.102140+00:00 0:10:02.269498 353726 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2023-03-15T01:00:53.129015+00:00 2 default_pool
success campaign-flow-job_v002 create_cluster_and_add_emr_steps 2023-03-15T00:00:00+00:00 EmrCreateJobFlowOperator 2023-03-15T01:00:35.400320+00:00 2023-03-15T01:00:36.231498+00:00 0:00:00.831178 353724 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 4 default 2023-03-15T01:00:33.030756+00:00 2 default_pool
success campaign-flow-job_v002 create_emr_steps 2023-03-15T00:00:00+00:00 PythonOperator 2023-03-15T01:00:13.901381+00:00 2023-03-15T01:00:18.967375+00:00 0:00:05.065994 353722 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 5 default 2023-03-15T01:00:10.997281+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_campaign-history-job_v002 2023-03-14T23:00:00+00:00 TriggerDagRunOperator 2023-03-15T00:11:13.244375+00:00 2023-03-15T00:11:13.768183+00:00 0:00:00.523808 353711 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2023-03-15T00:11:10.879282+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_booking-processing-job_v002 2023-03-14T23:00:00+00:00 TriggerDagRunOperator 2023-03-15T00:11:13.225181+00:00 2023-03-15T00:11:13.730291+00:00 0:00:00.505110 353710 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2023-03-15T00:11:10.879248+00:00 2 default_pool
success campaign-flow-job_v002 check_cluster_status 2023-03-14T23:00:00+00:00 EmrJobFlowSensor 2023-03-15T00:00:56.768291+00:00 2023-03-15T00:10:58.561848+00:00 0:10:01.793557 353703 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2023-03-15T00:00:54.449997+00:00 2 default_pool
success campaign-flow-job_v002 create_cluster_and_add_emr_steps 2023-03-14T23:00:00+00:00 EmrCreateJobFlowOperator 2023-03-15T00:00:34.720560+00:00 2023-03-15T00:00:35.659182+00:00 0:00:00.938622 353701 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 4 default 2023-03-15T00:00:32.428838+00:00 2 default_pool
success campaign-flow-job_v002 create_emr_steps 2023-03-14T23:00:00+00:00 PythonOperator 2023-03-15T00:00:12.673453+00:00 2023-03-15T00:00:16.096326+00:00 0:00:03.422873 353699 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 5 default 2023-03-15T00:00:10.339766+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_campaign-history-job_v002 2023-03-14T22:00:00+00:00 TriggerDagRunOperator 2023-03-14T23:11:17.150410+00:00 2023-03-14T23:11:17.630379+00:00 0:00:00.479969 353688 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2023-03-14T23:11:14.799627+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_booking-processing-job_v002 2023-03-14T22:00:00+00:00 TriggerDagRunOperator 2023-03-14T23:11:17.029878+00:00 2023-03-14T23:11:17.493233+00:00 0:00:00.463355 353687 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2023-03-14T23:11:14.799595+00:00 2 default_pool
success campaign-flow-job_v002 check_cluster_status 2023-03-14T22:00:00+00:00 EmrJobFlowSensor 2023-03-14T23:00:59.286988+00:00 2023-03-14T23:11:01.160389+00:00 0:10:01.873401 353680 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2023-03-14T23:00:56.383550+00:00 2 default_pool
success campaign-flow-job_v002 create_cluster_and_add_emr_steps 2023-03-14T22:00:00+00:00 EmrCreateJobFlowOperator 2023-03-14T23:00:41.465128+00:00 2023-03-14T23:00:42.354917+00:00 0:00:00.889789 353677 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 4 default 2023-03-14T23:00:36.390440+00:00 2 default_pool
success campaign-flow-job_v002 create_emr_steps 2023-03-14T22:00:00+00:00 PythonOperator 2023-03-14T23:00:17.686085+00:00 2023-03-14T23:00:21.750316+00:00 0:00:04.064231 353674 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 5 default 2023-03-14T23:00:14.354079+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_campaign-history-job_v002 2023-03-14T21:00:00+00:00 TriggerDagRunOperator 2023-03-14T22:11:13.303154+00:00 2023-03-14T22:11:13.861356+00:00 0:00:00.558202 353662 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2023-03-14T22:11:10.962435+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_booking-processing-job_v002 2023-03-14T21:00:00+00:00 TriggerDagRunOperator 2023-03-14T22:11:13.149254+00:00 2023-03-14T22:11:13.609363+00:00 0:00:00.460109 353661 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2023-03-14T22:11:10.962401+00:00 2 default_pool
success campaign-flow-job_v002 check_cluster_status 2023-03-14T21:00:00+00:00 EmrJobFlowSensor 2023-03-14T22:01:04.543974+00:00 2023-03-14T22:11:06.404362+00:00 0:10:01.860388 353655 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2023-03-14T22:01:02.321004+00:00 2 default_pool
success campaign-flow-job_v002 create_cluster_and_add_emr_steps 2023-03-14T21:00:00+00:00 EmrCreateJobFlowOperator 2023-03-14T22:00:42.556520+00:00 2023-03-14T22:00:43.430987+00:00 0:00:00.874467 353653 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 4 default 2023-03-14T22:00:40.321918+00:00 2 default_pool
success campaign-flow-job_v002 create_emr_steps 2023-03-14T21:00:00+00:00 PythonOperator 2023-03-14T22:00:20.510123+00:00 2023-03-14T22:00:23.843890+00:00 0:00:03.333767 353651 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 5 default 2023-03-14T22:00:18.277742+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_campaign-history-job_v002 2023-03-14T20:00:00+00:00 TriggerDagRunOperator 2023-03-14T21:11:18.512060+00:00 2023-03-14T21:11:19.067602+00:00 0:00:00.555542 353639 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2023-03-14T21:11:16.179137+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_booking-processing-job_v002 2023-03-14T20:00:00+00:00 TriggerDagRunOperator 2023-03-14T21:11:18.491285+00:00 2023-03-14T21:11:18.986613+00:00 0:00:00.495328 353638 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2023-03-14T21:11:16.179108+00:00 2 default_pool
success campaign-flow-job_v002 check_cluster_status 2023-03-14T20:00:00+00:00 EmrJobFlowSensor 2023-03-14T21:01:04.206477+00:00 2023-03-14T21:11:05.977158+00:00 0:10:01.770681 353632 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2023-03-14T21:01:01.731193+00:00 2 default_pool
success campaign-flow-job_v002 create_cluster_and_add_emr_steps 2023-03-14T20:00:00+00:00 EmrCreateJobFlowOperator 2023-03-14T21:00:44.133845+00:00 2023-03-14T21:00:45.482028+00:00 0:00:01.348183 353630 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 4 default 2023-03-14T21:00:39.707368+00:00 2 default_pool
success campaign-flow-job_v002 create_emr_steps 2023-03-14T20:00:00+00:00 PythonOperator 2023-03-14T21:00:21.967969+00:00 2023-03-14T21:00:26.344551+00:00 0:00:04.376582 353628 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 5 default 2023-03-14T21:00:19.688262+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_campaign-history-job_v002 2023-03-14T19:00:00+00:00 TriggerDagRunOperator 2023-03-14T20:11:15.424021+00:00 2023-03-14T20:11:16.011523+00:00 0:00:00.587502 353616 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2023-03-14T20:11:13.032120+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_booking-processing-job_v002 2023-03-14T19:00:00+00:00 TriggerDagRunOperator 2023-03-14T20:11:15.361282+00:00 2023-03-14T20:11:15.870783+00:00 0:00:00.509501 353615 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2023-03-14T20:11:13.032087+00:00 2 default_pool