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 create_emr_steps 2021-04-23T01:00:00+00:00 PythonOperator 2021-04-23T02:00:17.299671+00:00 2021-04-23T02:00:20.660470+00:00 0:00:03.360799 20216 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 5 default 2021-04-23T02:00:14.916457+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_campaign-history-job_v002 2021-04-23T00:00:00+00:00 TriggerDagRunOperator 2021-04-23T01:11:19.826174+00:00 2021-04-23T01:11:20.346210+00:00 0:00:00.520036 20208 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-23T01:11:17.496818+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_booking-processing-job_v002 2021-04-23T00:00:00+00:00 TriggerDagRunOperator 2021-04-23T01:11:19.784576+00:00 2021-04-23T01:11:20.193515+00:00 0:00:00.408939 20207 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-23T01:11:17.496864+00:00 2 default_pool
success campaign-flow-job_v002 check_cluster_status 2021-04-23T00:00:00+00:00 EmrJobFlowSensor 2021-04-23T01:01:00.438999+00:00 2021-04-23T01:11:03.380673+00:00 0:10:02.941674 20203 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-04-23T01:00:57.760329+00:00 2 default_pool
success campaign-flow-job_v002 create_cluster_and_add_emr_steps 2021-04-23T00:00:00+00:00 EmrCreateJobFlowOperator 2021-04-23T01:00:37.914531+00:00 2021-04-23T01:00:39.593073+00:00 0:00:01.678542 20202 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 4 default 2021-04-23T01:00:35.563803+00:00 2 default_pool
success campaign-flow-job_v002 create_emr_steps 2021-04-23T00:00:00+00:00 PythonOperator 2021-04-23T01:00:17.770431+00:00 2021-04-23T01:00:21.005131+00:00 0:00:03.234700 20201 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 5 default 2021-04-23T01:00:15.434514+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_campaign-history-job_v002 2021-04-22T23:00:00+00:00 TriggerDagRunOperator 2021-04-23T00:12:10.924641+00:00 2021-04-23T00:12:11.332111+00:00 0:00:00.407470 20193 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-23T00:12:08.102735+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_booking-processing-job_v002 2021-04-22T23:00:00+00:00 TriggerDagRunOperator 2021-04-23T00:12:10.386710+00:00 2021-04-23T00:12:10.919276+00:00 0:00:00.532566 20192 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-23T00:12:08.102766+00:00 2 default_pool
success campaign-flow-job_v002 check_cluster_status 2021-04-22T23:00:00+00:00 EmrJobFlowSensor 2021-04-23T00:01:01.273023+00:00 2021-04-23T00:12:04.259855+00:00 0:11:02.986832 20188 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-04-23T00:00:58.668100+00:00 2 default_pool
success campaign-flow-job_v002 create_cluster_and_add_emr_steps 2021-04-22T23:00:00+00:00 EmrCreateJobFlowOperator 2021-04-23T00:00:38.935337+00:00 2021-04-23T00:00:40.835595+00:00 0:00:01.900258 20187 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 4 default 2021-04-23T00:00:36.462225+00:00 2 default_pool
success campaign-flow-job_v002 create_emr_steps 2021-04-22T23:00:00+00:00 PythonOperator 2021-04-23T00:00:17.119268+00:00 2021-04-23T00:00:20.588016+00:00 0:00:03.468748 20186 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 5 default 2021-04-23T00:00:14.281639+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_booking-processing-job_v002 2021-04-22T22:00:00+00:00 TriggerDagRunOperator 2021-04-22T23:11:17.227493+00:00 2021-04-22T23:11:17.737495+00:00 0:00:00.510002 20178 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-22T23:11:14.920271+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_campaign-history-job_v002 2021-04-22T22:00:00+00:00 TriggerDagRunOperator 2021-04-22T23:11:17.089082+00:00 2021-04-22T23:11:17.477416+00:00 0:00:00.388334 20177 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-22T23:11:14.920234+00:00 2 default_pool
success campaign-flow-job_v002 check_cluster_status 2021-04-22T22:00:00+00:00 EmrJobFlowSensor 2021-04-22T23:01:06.260401+00:00 2021-04-22T23:11:09.180779+00:00 0:10:02.920378 20173 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-04-22T23:01:03.845425+00:00 2 default_pool
success campaign-flow-job_v002 create_cluster_and_add_emr_steps 2021-04-22T22:00:00+00:00 EmrCreateJobFlowOperator 2021-04-22T23:00:44.683585+00:00 2021-04-22T23:00:46.485839+00:00 0:00:01.802254 20171 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 4 default 2021-04-22T23:00:41.731839+00:00 2 default_pool
success campaign-flow-job_v002 create_emr_steps 2021-04-22T22:00:00+00:00 PythonOperator 2021-04-22T23:00:24.155604+00:00 2021-04-22T23:00:27.114183+00:00 0:00:02.958579 20169 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 5 default 2021-04-22T23:00:21.712577+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_campaign-history-job_v002 2021-04-22T21:00:00+00:00 TriggerDagRunOperator 2021-04-22T22:10:15.920950+00:00 2021-04-22T22:10:16.340185+00:00 0:00:00.419235 20160 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-22T22:10:13.519869+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_booking-processing-job_v002 2021-04-22T21:00:00+00:00 TriggerDagRunOperator 2021-04-22T22:10:15.906869+00:00 2021-04-22T22:10:16.457580+00:00 0:00:00.550711 20159 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-22T22:10:13.519915+00:00 2 default_pool
success campaign-flow-job_v002 check_cluster_status 2021-04-22T21:00:00+00:00 EmrJobFlowSensor 2021-04-22T22:01:00.770497+00:00 2021-04-22T22:10:03.565311+00:00 0:09:02.794814 20155 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-04-22T22:00:58.244331+00:00 2 default_pool
success campaign-flow-job_v002 create_cluster_and_add_emr_steps 2021-04-22T21:00:00+00:00 EmrCreateJobFlowOperator 2021-04-22T22:00:38.340889+00:00 2021-04-22T22:00:40.105780+00:00 0:00:01.764891 20154 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 4 default 2021-04-22T22:00:36.112356+00:00 2 default_pool
success campaign-flow-job_v002 create_emr_steps 2021-04-22T21:00:00+00:00 PythonOperator 2021-04-22T22:00:16.403013+00:00 2021-04-22T22:00:19.545487+00:00 0:00:03.142474 20153 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 5 default 2021-04-22T22:00:14.094138+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_campaign-history-job_v002 2021-04-22T20:00:00+00:00 TriggerDagRunOperator 2021-04-22T21:11:21.034617+00:00 2021-04-22T21:11:21.537026+00:00 0:00:00.502409 20145 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-22T21:11:18.708885+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_booking-processing-job_v002 2021-04-22T20:00:00+00:00 TriggerDagRunOperator 2021-04-22T21:11:20.917719+00:00 2021-04-22T21:11:21.347573+00:00 0:00:00.429854 20144 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-22T21:11:18.708933+00:00 2 default_pool
success campaign-flow-job_v002 check_cluster_status 2021-04-22T20:00:00+00:00 EmrJobFlowSensor 2021-04-22T21:00:55.059205+00:00 2021-04-22T21:10:58.008795+00:00 0:10:02.949590 20140 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-04-22T21:00:52.802763+00:00 2 default_pool
success campaign-flow-job_v002 create_cluster_and_add_emr_steps 2021-04-22T20:00:00+00:00 EmrCreateJobFlowOperator 2021-04-22T21:00:35.248437+00:00 2021-04-22T21:00:37.067190+00:00 0:00:01.818753 20139 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 4 default 2021-04-22T21:00:32.786101+00:00 2 default_pool
success campaign-flow-job_v002 create_emr_steps 2021-04-22T20:00:00+00:00 PythonOperator 2021-04-22T21:00:11.014894+00:00 2021-04-22T21:00:14.042985+00:00 0:00:03.028091 20138 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 5 default 2021-04-22T21:00:08.729845+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_campaign-history-job_v002 2021-04-22T19:00:00+00:00 TriggerDagRunOperator 2021-04-22T20:12:12.625918+00:00 2021-04-22T20:12:13.222940+00:00 0:00:00.597022 20130 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-22T20:12:10.314804+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_booking-processing-job_v002 2021-04-22T19:00:00+00:00 TriggerDagRunOperator 2021-04-22T20:12:12.530873+00:00 2021-04-22T20:12:12.973593+00:00 0:00:00.442720 20129 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-22T20:12:10.314832+00:00 2 default_pool
success campaign-flow-job_v002 check_cluster_status 2021-04-22T19:00:00+00:00 EmrJobFlowSensor 2021-04-22T20:00:51.277880+00:00 2021-04-22T20:11:54.221721+00:00 0:11:02.943841 20125 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-04-22T20:00:49.061711+00:00 2 default_pool
success campaign-flow-job_v002 create_cluster_and_add_emr_steps 2021-04-22T19:00:00+00:00 EmrCreateJobFlowOperator 2021-04-22T20:00:29.370921+00:00 2021-04-22T20:00:31.110894+00:00 0:00:01.739973 20124 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 4 default 2021-04-22T20:00:27.016387+00:00 2 default_pool
success campaign-flow-job_v002 create_emr_steps 2021-04-22T19:00:00+00:00 PythonOperator 2021-04-22T20:00:09.414902+00:00 2021-04-22T20:00:12.399795+00:00 0:00:02.984893 20123 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 5 default 2021-04-22T20:00:07.003700+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_booking-processing-job_v002 2021-04-22T18:00:00+00:00 TriggerDagRunOperator 2021-04-22T19:11:55.863533+00:00 2021-04-22T19:11:56.404850+00:00 0:00:00.541317 20115 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-22T19:11:53.408873+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_campaign-history-job_v002 2021-04-22T18:00:00+00:00 TriggerDagRunOperator 2021-04-22T19:11:55.647929+00:00 2021-04-22T19:11:56.068456+00:00 0:00:00.420527 20114 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-22T19:11:53.408845+00:00 2 default_pool
success campaign-flow-job_v002 check_cluster_status 2021-04-22T18:00:00+00:00 EmrJobFlowSensor 2021-04-22T19:00:48.571993+00:00 2021-04-22T19:11:51.667625+00:00 0:11:03.095632 20110 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-04-22T19:00:46.096199+00:00 2 default_pool
success campaign-flow-job_v002 create_cluster_and_add_emr_steps 2021-04-22T18:00:00+00:00 EmrCreateJobFlowOperator 2021-04-22T19:00:26.283595+00:00 2021-04-22T19:00:28.098577+00:00 0:00:01.814982 20109 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 4 default 2021-04-22T19:00:24.077173+00:00 2 default_pool
success campaign-flow-job_v002 create_emr_steps 2021-04-22T18:00:00+00:00 PythonOperator 2021-04-22T19:00:04.483542+00:00 2021-04-22T19:00:07.762813+00:00 0:00:03.279271 20108 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 5 default 2021-04-22T19:00:02.062966+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_booking-processing-job_v002 2021-04-22T17:00:00+00:00 TriggerDagRunOperator 2021-04-22T18:16:00.820744+00:00 2021-04-22T18:16:01.355312+00:00 0:00:00.534568 20101 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-22T18:15:58.202823+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_campaign-history-job_v002 2021-04-22T17:00:00+00:00 TriggerDagRunOperator 2021-04-22T18:16:00.797373+00:00 2021-04-22T18:16:01.210451+00:00 0:00:00.413078 20100 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-22T18:15:58.202795+00:00 2 default_pool
success campaign-flow-job_v002 check_cluster_status 2021-04-22T17:00:00+00:00 EmrJobFlowSensor 2021-04-22T18:01:05.726831+00:00 2021-04-22T18:12:08.607141+00:00 0:11:02.880310 20095 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-04-22T18:01:03.498440+00:00 2 default_pool
success campaign-flow-job_v002 create_cluster_and_add_emr_steps 2021-04-22T17:00:00+00:00 EmrCreateJobFlowOperator 2021-04-22T18:00:43.607750+00:00 2021-04-22T18:00:45.348669+00:00 0:00:01.740919 20094 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 4 default 2021-04-22T18:00:41.442314+00:00 2 default_pool
success campaign-flow-job_v002 create_emr_steps 2021-04-22T17:00:00+00:00 PythonOperator 2021-04-22T18:00:21.676904+00:00 2021-04-22T18:00:24.860504+00:00 0:00:03.183600 20093 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 5 default 2021-04-22T18:00:19.413905+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_booking-processing-job_v002 2021-04-22T16:00:00+00:00 TriggerDagRunOperator 2021-04-22T17:11:51.242180+00:00 2021-04-22T17:11:51.846293+00:00 0:00:00.604113 20086 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-22T17:11:48.445393+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_campaign-history-job_v002 2021-04-22T16:00:00+00:00 TriggerDagRunOperator 2021-04-22T17:11:51.197111+00:00 2021-04-22T17:11:51.647415+00:00 0:00:00.450304 20085 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-22T17:11:48.445354+00:00 2 default_pool
success campaign-flow-job_v002 check_cluster_status 2021-04-22T16:00:00+00:00 EmrJobFlowSensor 2021-04-22T17:01:01.436475+00:00 2021-04-22T17:10:04.145238+00:00 0:09:02.708763 20080 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-04-22T17:00:58.941438+00:00 2 default_pool
success campaign-flow-job_v002 create_cluster_and_add_emr_steps 2021-04-22T16:00:00+00:00 EmrCreateJobFlowOperator 2021-04-22T17:00:39.181575+00:00 2021-04-22T17:00:40.847343+00:00 0:00:01.665768 20079 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 4 default 2021-04-22T17:00:36.890033+00:00 2 default_pool
success campaign-flow-job_v002 create_emr_steps 2021-04-22T16:00:00+00:00 PythonOperator 2021-04-22T17:00:17.123740+00:00 2021-04-22T17:00:21.078392+00:00 0:00:03.954652 20078 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 5 default 2021-04-22T17:00:14.848515+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_booking-processing-job_v002 2021-04-22T15:00:00+00:00 TriggerDagRunOperator 2021-04-22T16:21:34.461382+00:00 2021-04-22T16:21:35.003869+00:00 0:00:00.542487 20071 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-22T16:21:32.082141+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_campaign-history-job_v002 2021-04-22T15:00:00+00:00 TriggerDagRunOperator 2021-04-22T16:21:34.331076+00:00 2021-04-22T16:21:34.767979+00:00 0:00:00.436903 20070 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-22T16:21:32.082114+00:00 2 default_pool
success campaign-flow-job_v002 check_cluster_status 2021-04-22T15:00:00+00:00 EmrJobFlowSensor 2021-04-22T16:10:06.944402+00:00 2021-04-22T16:21:09.935248+00:00 0:11:02.990846 20069 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-04-22T16:10:04.380394+00:00 2 default_pool
success campaign-flow-job_v002 create_cluster_and_add_emr_steps 2021-04-22T15:00:00+00:00 EmrCreateJobFlowOperator 2021-04-22T16:09:42.592910+00:00 2021-04-22T16:09:44.673586+00:00 0:00:02.080676 20066 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 4 default 2021-04-22T16:09:40.292728+00:00 2 default_pool
success campaign-flow-job_v002 create_emr_steps 2021-04-22T15:00:00+00:00 PythonOperator 2021-04-22T16:09:21.009571+00:00 2021-04-22T16:09:24.062866+00:00 0:00:03.053295 20064 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 5 default 2021-04-22T16:09:18.270273+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_booking-processing-job_v002 2021-04-22T14:00:00+00:00 TriggerDagRunOperator 2021-04-22T15:11:06.223069+00:00 2021-04-22T15:11:06.690015+00:00 0:00:00.466946 20056 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-22T15:11:03.819944+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_campaign-history-job_v002 2021-04-22T14:00:00+00:00 TriggerDagRunOperator 2021-04-22T15:11:06.095504+00:00 2021-04-22T15:11:06.674924+00:00 0:00:00.579420 20055 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-22T15:11:03.819909+00:00 2 default_pool
success campaign-flow-job_v002 check_cluster_status 2021-04-22T14:00:00+00:00 EmrJobFlowSensor 2021-04-22T15:00:48.815748+00:00 2021-04-22T15:10:51.603142+00:00 0:10:02.787394 20051 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-04-22T15:00:46.552200+00:00 2 default_pool
success campaign-flow-job_v002 create_cluster_and_add_emr_steps 2021-04-22T14:00:00+00:00 EmrCreateJobFlowOperator 2021-04-22T15:00:24.743112+00:00 2021-04-22T15:00:26.504122+00:00 0:00:01.761010 20050 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 4 default 2021-04-22T15:00:22.511973+00:00 2 default_pool
success campaign-flow-job_v002 create_emr_steps 2021-04-22T14:00:00+00:00 PythonOperator 2021-04-22T15:00:04.891143+00:00 2021-04-22T15:00:07.982745+00:00 0:00:03.091602 20049 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 5 default 2021-04-22T15:00:02.485669+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_campaign-history-job_v002 2021-04-22T13:00:00+00:00 TriggerDagRunOperator 2021-04-22T14:10:16.776840+00:00 2021-04-22T14:10:17.330459+00:00 0:00:00.553619 20041 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-22T14:10:14.356526+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_booking-processing-job_v002 2021-04-22T13:00:00+00:00 TriggerDagRunOperator 2021-04-22T14:10:16.672489+00:00 2021-04-22T14:10:17.080057+00:00 0:00:00.407568 20040 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-22T14:10:14.356573+00:00 2 default_pool
success campaign-flow-job_v002 check_cluster_status 2021-04-22T13:00:00+00:00 EmrJobFlowSensor 2021-04-22T14:00:59.408537+00:00 2021-04-22T14:10:02.659268+00:00 0:09:03.250731 20036 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-04-22T14:00:57.270955+00:00 2 default_pool
success campaign-flow-job_v002 create_cluster_and_add_emr_steps 2021-04-22T13:00:00+00:00 EmrCreateJobFlowOperator 2021-04-22T14:00:38.038837+00:00 2021-04-22T14:00:39.748861+00:00 0:00:01.710024 20035 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 4 default 2021-04-22T14:00:35.257701+00:00 2 default_pool
success campaign-flow-job_v002 create_emr_steps 2021-04-22T13:00:00+00:00 PythonOperator 2021-04-22T14:00:15.835143+00:00 2021-04-22T14:00:18.824576+00:00 0:00:02.989433 20034 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 5 default 2021-04-22T14:00:13.272162+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_booking-processing-job_v002 2021-04-22T12:00:00+00:00 TriggerDagRunOperator 2021-04-22T13:11:22.801227+00:00 2021-04-22T13:11:23.227884+00:00 0:00:00.426657 20026 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-22T13:11:20.276867+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_campaign-history-job_v002 2021-04-22T12:00:00+00:00 TriggerDagRunOperator 2021-04-22T13:11:22.551166+00:00 2021-04-22T13:11:23.092718+00:00 0:00:00.541552 20025 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-22T13:11:20.276839+00:00 2 default_pool
success campaign-flow-job_v002 check_cluster_status 2021-04-22T12:00:00+00:00 EmrJobFlowSensor 2021-04-22T13:01:11.617751+00:00 2021-04-22T13:11:14.513613+00:00 0:10:02.895862 20021 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-04-22T13:01:09.438490+00:00 2 default_pool
success campaign-flow-job_v002 create_cluster_and_add_emr_steps 2021-04-22T12:00:00+00:00 EmrCreateJobFlowOperator 2021-04-22T13:00:40.103031+00:00 2021-04-22T13:00:41.801610+00:00 0:00:01.698579 20020 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 4 default 2021-04-22T13:00:37.405798+00:00 2 default_pool
success campaign-flow-job_v002 create_emr_steps 2021-04-22T12:00:00+00:00 PythonOperator 2021-04-22T13:00:18.389730+00:00 2021-04-22T13:00:21.421811+00:00 0:00:03.032081 20019 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 5 default 2021-04-22T13:00:15.452646+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_campaign-history-job_v002 2021-04-22T11:00:00+00:00 TriggerDagRunOperator 2021-04-22T12:11:27.593537+00:00 2021-04-22T12:11:28.138308+00:00 0:00:00.544771 20011 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-22T12:11:25.140701+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_booking-processing-job_v002 2021-04-22T11:00:00+00:00 TriggerDagRunOperator 2021-04-22T12:11:27.525886+00:00 2021-04-22T12:11:27.958774+00:00 0:00:00.432888 20010 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-22T12:11:25.140735+00:00 2 default_pool
success campaign-flow-job_v002 check_cluster_status 2021-04-22T11:00:00+00:00 EmrJobFlowSensor 2021-04-22T12:01:12.414285+00:00 2021-04-22T12:11:15.273040+00:00 0:10:02.858755 20006 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-04-22T12:01:10.067572+00:00 2 default_pool
success campaign-flow-job_v002 create_cluster_and_add_emr_steps 2021-04-22T11:00:00+00:00 EmrCreateJobFlowOperator 2021-04-22T12:00:40.330816+00:00 2021-04-22T12:00:42.148688+00:00 0:00:01.817872 20005 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 4 default 2021-04-22T12:00:37.998714+00:00 2 default_pool
success campaign-flow-job_v002 create_emr_steps 2021-04-22T11:00:00+00:00 PythonOperator 2021-04-22T12:00:18.848189+00:00 2021-04-22T12:00:21.823267+00:00 0:00:02.975078 20004 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 5 default 2021-04-22T12:00:15.933524+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_campaign-history-job_v002 2021-04-22T10:00:00+00:00 TriggerDagRunOperator 2021-04-22T11:12:01.716659+00:00 2021-04-22T11:12:02.132669+00:00 0:00:00.416010 19996 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-22T11:11:58.444529+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_booking-processing-job_v002 2021-04-22T10:00:00+00:00 TriggerDagRunOperator 2021-04-22T11:12:01.240780+00:00 2021-04-22T11:12:01.850160+00:00 0:00:00.609380 19995 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-22T11:11:58.444586+00:00 2 default_pool
success campaign-flow-job_v002 check_cluster_status 2021-04-22T10:00:00+00:00 EmrJobFlowSensor 2021-04-22T11:00:49.356057+00:00 2021-04-22T11:11:52.353034+00:00 0:11:02.996977 19991 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-04-22T11:00:47.123116+00:00 2 default_pool
success campaign-flow-job_v002 create_cluster_and_add_emr_steps 2021-04-22T10:00:00+00:00 EmrCreateJobFlowOperator 2021-04-22T11:00:27.658256+00:00 2021-04-22T11:00:29.478789+00:00 0:00:01.820533 19990 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 4 default 2021-04-22T11:00:25.166163+00:00 2 default_pool
success campaign-flow-job_v002 create_emr_steps 2021-04-22T10:00:00+00:00 PythonOperator 2021-04-22T11:00:05.889903+00:00 2021-04-22T11:00:08.973090+00:00 0:00:03.083187 19989 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 5 default 2021-04-22T11:00:03.087960+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_campaign-history-job_v002 2021-04-22T09:00:00+00:00 TriggerDagRunOperator 2021-04-22T10:11:11.950321+00:00 2021-04-22T10:11:12.396611+00:00 0:00:00.446290 19981 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-22T10:11:09.292506+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_booking-processing-job_v002 2021-04-22T09:00:00+00:00 TriggerDagRunOperator 2021-04-22T10:11:11.980700+00:00 2021-04-22T10:11:12.540936+00:00 0:00:00.560236 19980 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-22T10:11:09.292548+00:00 2 default_pool
success campaign-flow-job_v002 check_cluster_status 2021-04-22T09:00:00+00:00 EmrJobFlowSensor 2021-04-22T10:00:48.515246+00:00 2021-04-22T10:10:51.331581+00:00 0:10:02.816335 19976 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-04-22T10:00:46.104889+00:00 2 default_pool
success campaign-flow-job_v002 create_cluster_and_add_emr_steps 2021-04-22T09:00:00+00:00 EmrCreateJobFlowOperator 2021-04-22T10:00:26.225265+00:00 2021-04-22T10:00:27.879747+00:00 0:00:01.654482 19975 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 4 default 2021-04-22T10:00:24.082757+00:00 2 default_pool
success campaign-flow-job_v002 create_emr_steps 2021-04-22T09:00:00+00:00 PythonOperator 2021-04-22T10:00:06.488139+00:00 2021-04-22T10:00:09.680854+00:00 0:00:03.192715 19974 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 5 default 2021-04-22T10:00:04.032322+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_booking-processing-job_v002 2021-04-22T08:00:00+00:00 TriggerDagRunOperator 2021-04-22T09:11:09.905922+00:00 2021-04-22T09:11:10.433011+00:00 0:00:00.527089 19966 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-22T09:11:07.443023+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_campaign-history-job_v002 2021-04-22T08:00:00+00:00 TriggerDagRunOperator 2021-04-22T09:11:09.674095+00:00 2021-04-22T09:11:10.099426+00:00 0:00:00.425331 19965 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-22T09:11:07.442986+00:00 2 default_pool
success campaign-flow-job_v002 check_cluster_status 2021-04-22T08:00:00+00:00 EmrJobFlowSensor 2021-04-22T09:00:54.724707+00:00 2021-04-22T09:10:57.413006+00:00 0:10:02.688299 19953 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-04-22T09:00:52.403212+00:00 2 default_pool
success campaign-flow-job_v002 create_cluster_and_add_emr_steps 2021-04-22T08:00:00+00:00 EmrCreateJobFlowOperator 2021-04-22T09:00:32.797522+00:00 2021-04-22T09:00:34.462911+00:00 0:00:01.665389 19952 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 4 default 2021-04-22T09:00:30.389331+00:00 2 default_pool
success campaign-flow-job_v002 create_emr_steps 2021-04-22T08:00:00+00:00 PythonOperator 2021-04-22T09:00:11.125512+00:00 2021-04-22T09:00:14.140606+00:00 0:00:03.015094 19951 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 5 default 2021-04-22T09:00:08.355575+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_campaign-history-job_v002 2021-04-22T07:00:00+00:00 TriggerDagRunOperator 2021-04-22T08:11:25.400901+00:00 2021-04-22T08:11:25.900674+00:00 0:00:00.499773 19943 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-22T08:11:22.758159+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_booking-processing-job_v002 2021-04-22T07:00:00+00:00 TriggerDagRunOperator 2021-04-22T08:11:25.180922+00:00 2021-04-22T08:11:25.590998+00:00 0:00:00.410076 19942 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-22T08:11:22.758191+00:00 2 default_pool
success campaign-flow-job_v002 check_cluster_status 2021-04-22T07:00:00+00:00 EmrJobFlowSensor 2021-04-22T08:00:56.058544+00:00 2021-04-22T08:10:58.856334+00:00 0:10:02.797790 19938 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-04-22T08:00:53.855025+00:00 2 default_pool
success campaign-flow-job_v002 create_cluster_and_add_emr_steps 2021-04-22T07:00:00+00:00 EmrCreateJobFlowOperator 2021-04-22T08:00:36.117112+00:00 2021-04-22T08:00:38.347074+00:00 0:00:02.229962 19937 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 4 default 2021-04-22T08:00:33.838610+00:00 2 default_pool
success campaign-flow-job_v002 create_emr_steps 2021-04-22T07:00:00+00:00 PythonOperator 2021-04-22T08:00:14.174317+00:00 2021-04-22T08:00:17.150960+00:00 0:00:02.976643 19936 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 5 default 2021-04-22T08:00:11.844118+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_booking-processing-job_v002 2021-04-22T06:00:00+00:00 TriggerDagRunOperator 2021-04-22T07:17:03.672396+00:00 2021-04-22T07:17:04.206536+00:00 0:00:00.534140 19929 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-22T07:17:00.883759+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_campaign-history-job_v002 2021-04-22T06:00:00+00:00 TriggerDagRunOperator 2021-04-22T07:17:03.463053+00:00 2021-04-22T07:17:03.894536+00:00 0:00:00.431483 19928 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-22T07:17:00.883728+00:00 2 default_pool
success campaign-flow-job_v002 check_cluster_status 2021-04-22T06:00:00+00:00 EmrJobFlowSensor 2021-04-22T07:01:05.517472+00:00 2021-04-22T07:12:08.416707+00:00 0:11:02.899235 19920 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-04-22T07:01:03.360176+00:00 2 default_pool
success campaign-flow-job_v002 create_cluster_and_add_emr_steps 2021-04-22T06:00:00+00:00 EmrCreateJobFlowOperator 2021-04-22T07:00:43.656013+00:00 2021-04-22T07:00:45.487759+00:00 0:00:01.831746 19919 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 4 default 2021-04-22T07:00:41.284018+00:00 2 default_pool
success campaign-flow-job_v002 create_emr_steps 2021-04-22T06:00:00+00:00 PythonOperator 2021-04-22T07:00:21.516246+00:00 2021-04-22T07:00:24.621562+00:00 0:00:03.105316 19918 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 5 default 2021-04-22T07:00:19.254495+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_campaign-history-job_v002 2021-04-22T05:00:00+00:00 TriggerDagRunOperator 2021-04-22T06:11:21.079234+00:00 2021-04-22T06:11:21.525567+00:00 0:00:00.446333 19910 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-22T06:11:18.673068+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_booking-processing-job_v002 2021-04-22T05:00:00+00:00 TriggerDagRunOperator 2021-04-22T06:11:20.992353+00:00 2021-04-22T06:11:21.534705+00:00 0:00:00.542352 19909 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-22T06:11:18.673096+00:00 2 default_pool
success campaign-flow-job_v002 check_cluster_status 2021-04-22T05:00:00+00:00 EmrJobFlowSensor 2021-04-22T06:00:53.817212+00:00 2021-04-22T06:10:56.628485+00:00 0:10:02.811273 19905 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-04-22T06:00:51.502452+00:00 2 default_pool
success campaign-flow-job_v002 create_cluster_and_add_emr_steps 2021-04-22T05:00:00+00:00 EmrCreateJobFlowOperator 2021-04-22T06:00:32.736366+00:00 2021-04-22T06:00:34.498781+00:00 0:00:01.762415 19904 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 4 default 2021-04-22T06:00:29.562388+00:00 2 default_pool