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-02T05:00:00+00:00 PythonOperator 2021-04-02T06:00:34.687680+00:00 2021-04-02T06:00:37.541496+00:00 0:00:02.853816 12659 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 5 default 2021-04-02T06:00:32.038430+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_booking-processing-job_v002 2021-04-02T04:00:00+00:00 TriggerDagRunOperator 2021-04-02T05:10:30.359196+00:00 2021-04-02T05:10:30.941490+00:00 0:00:00.582294 12650 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-02T05:10:27.902710+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_campaign-history-job_v002 2021-04-02T04:00:00+00:00 TriggerDagRunOperator 2021-04-02T05:10:30.313626+00:00 2021-04-02T05:10:30.811057+00:00 0:00:00.497431 12649 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-02T05:10:27.902664+00:00 2 default_pool
success campaign-flow-job_v002 check_cluster_status 2021-04-02T04:00:00+00:00 EmrJobFlowSensor 2021-04-02T05:01:09.366093+00:00 2021-04-02T05:10:12.130354+00:00 0:09:02.764261 12645 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-04-02T05:01:07.014658+00:00 2 default_pool
success campaign-flow-job_v002 create_cluster_and_add_emr_steps 2021-04-02T04:00:00+00:00 EmrCreateJobFlowOperator 2021-04-02T05:00:47.299588+00:00 2021-04-02T05:00:49.118529+00:00 0:00:01.818941 12644 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 4 default 2021-04-02T05:00:44.993955+00:00 2 default_pool
success campaign-flow-job_v002 create_emr_steps 2021-04-02T04:00:00+00:00 PythonOperator 2021-04-02T05:00:25.461807+00:00 2021-04-02T05:00:28.311940+00:00 0:00:02.850133 12643 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 5 default 2021-04-02T05:00:22.965443+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_booking-processing-job_v002 2021-04-02T03:00:00+00:00 TriggerDagRunOperator 2021-04-02T04:09:19.634662+00:00 2021-04-02T04:09:20.148137+00:00 0:00:00.513475 12635 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-02T04:09:17.210271+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_campaign-history-job_v002 2021-04-02T03:00:00+00:00 TriggerDagRunOperator 2021-04-02T04:09:19.497511+00:00 2021-04-02T04:09:19.915399+00:00 0:00:00.417888 12634 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-02T04:09:17.210241+00:00 2 default_pool
success campaign-flow-job_v002 check_cluster_status 2021-04-02T03:00:00+00:00 EmrJobFlowSensor 2021-04-02T04:00:58.744833+00:00 2021-04-02T04:09:01.442813+00:00 0:08:02.697980 12630 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-04-02T04:00:56.301082+00:00 2 default_pool
success campaign-flow-job_v002 create_cluster_and_add_emr_steps 2021-04-02T03:00:00+00:00 EmrCreateJobFlowOperator 2021-04-02T04:00:36.645631+00:00 2021-04-02T04:00:38.393665+00:00 0:00:01.748034 12629 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 4 default 2021-04-02T04:00:34.286469+00:00 2 default_pool
success campaign-flow-job_v002 create_emr_steps 2021-04-02T03:00:00+00:00 PythonOperator 2021-04-02T04:00:16.751777+00:00 2021-04-02T04:00:19.511629+00:00 0:00:02.759852 12628 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 5 default 2021-04-02T04:00:14.266881+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_booking-processing-job_v002 2021-04-02T02:00:00+00:00 TriggerDagRunOperator 2021-04-02T03:10:19.314084+00:00 2021-04-02T03:10:19.867365+00:00 0:00:00.553281 12620 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-02T03:10:16.893629+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_campaign-history-job_v002 2021-04-02T02:00:00+00:00 TriggerDagRunOperator 2021-04-02T03:10:19.250443+00:00 2021-04-02T03:10:19.674288+00:00 0:00:00.423845 12619 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-02T03:10:16.893594+00:00 2 default_pool
success campaign-flow-job_v002 check_cluster_status 2021-04-02T02:00:00+00:00 EmrJobFlowSensor 2021-04-02T03:01:08.370112+00:00 2021-04-02T03:10:11.031588+00:00 0:09:02.661476 12615 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-04-02T03:01:06.114631+00:00 2 default_pool
success campaign-flow-job_v002 create_cluster_and_add_emr_steps 2021-04-02T02:00:00+00:00 EmrCreateJobFlowOperator 2021-04-02T03:00:46.429717+00:00 2021-04-02T03:00:48.302669+00:00 0:00:01.872952 12614 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 4 default 2021-04-02T03:00:44.094599+00:00 2 default_pool
success campaign-flow-job_v002 create_emr_steps 2021-04-02T02:00:00+00:00 PythonOperator 2021-04-02T03:00:24.564246+00:00 2021-04-02T03:00:27.257786+00:00 0:00:02.693540 12613 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 5 default 2021-04-02T03:00:22.063916+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_campaign-history-job_v002 2021-04-02T01:00:00+00:00 TriggerDagRunOperator 2021-04-02T02:11:06.990550+00:00 2021-04-02T02:11:07.536930+00:00 0:00:00.546380 12605 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-02T02:11:04.404660+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_booking-processing-job_v002 2021-04-02T01:00:00+00:00 TriggerDagRunOperator 2021-04-02T02:11:06.610651+00:00 2021-04-02T02:11:07.040549+00:00 0:00:00.429898 12604 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-02T02:11:04.404689+00:00 2 default_pool
success campaign-flow-job_v002 check_cluster_status 2021-04-02T01:00:00+00:00 EmrJobFlowSensor 2021-04-02T02:00:51.757779+00:00 2021-04-02T02:10:54.677653+00:00 0:10:02.919874 12600 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-04-02T02:00:49.503651+00:00 2 default_pool
success campaign-flow-job_v002 create_cluster_and_add_emr_steps 2021-04-02T01:00:00+00:00 EmrCreateJobFlowOperator 2021-04-02T02:00:30.041545+00:00 2021-04-02T02:00:31.725404+00:00 0:00:01.683859 12599 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 4 default 2021-04-02T02:00:27.540830+00:00 2 default_pool
success campaign-flow-job_v002 create_emr_steps 2021-04-02T01:00:00+00:00 PythonOperator 2021-04-02T02:00:10.137752+00:00 2021-04-02T02:00:13.031121+00:00 0:00:02.893369 12598 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 5 default 2021-04-02T02:00:07.417775+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_campaign-history-job_v002 2021-04-02T00:00:00+00:00 TriggerDagRunOperator 2021-04-02T01:10:08.083768+00:00 2021-04-02T01:10:08.508176+00:00 0:00:00.424408 12590 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-02T01:10:05.525327+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_booking-processing-job_v002 2021-04-02T00:00:00+00:00 TriggerDagRunOperator 2021-04-02T01:10:08.085985+00:00 2021-04-02T01:10:08.701554+00:00 0:00:00.615569 12589 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-02T01:10:05.525359+00:00 2 default_pool
success campaign-flow-job_v002 check_cluster_status 2021-04-02T00:00:00+00:00 EmrJobFlowSensor 2021-04-02T01:00:52.746840+00:00 2021-04-02T01:09:55.332775+00:00 0:09:02.585935 12585 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-04-02T01:00:50.570730+00:00 2 default_pool
success campaign-flow-job_v002 create_cluster_and_add_emr_steps 2021-04-02T00:00:00+00:00 EmrCreateJobFlowOperator 2021-04-02T01:00:31.139286+00:00 2021-04-02T01:00:32.948713+00:00 0:00:01.809427 12584 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 4 default 2021-04-02T01:00:28.672616+00:00 2 default_pool
success campaign-flow-job_v002 create_emr_steps 2021-04-02T00:00:00+00:00 PythonOperator 2021-04-02T01:00:09.342706+00:00 2021-04-02T01:00:12.193352+00:00 0:00:02.850646 12583 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 5 default 2021-04-02T01:00:06.564940+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_booking-processing-job_v002 2021-04-01T23:00:00+00:00 TriggerDagRunOperator 2021-04-02T00:11:09.535667+00:00 2021-04-02T00:11:10.193411+00:00 0:00:00.657744 12575 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-02T00:11:06.796048+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_campaign-history-job_v002 2021-04-01T23:00:00+00:00 TriggerDagRunOperator 2021-04-02T00:11:09.360993+00:00 2021-04-02T00:11:09.769387+00:00 0:00:00.408394 12574 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-02T00:11:06.796016+00:00 2 default_pool
success campaign-flow-job_v002 check_cluster_status 2021-04-01T23:00:00+00:00 EmrJobFlowSensor 2021-04-02T00:00:56.095907+00:00 2021-04-02T00:10:59.095372+00:00 0:10:02.999465 12570 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-04-02T00:00:53.804387+00:00 2 default_pool
success campaign-flow-job_v002 create_cluster_and_add_emr_steps 2021-04-01T23:00:00+00:00 EmrCreateJobFlowOperator 2021-04-02T00:00:34.367907+00:00 2021-04-02T00:00:36.181938+00:00 0:00:01.814031 12569 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 4 default 2021-04-02T00:00:31.851216+00:00 2 default_pool
success campaign-flow-job_v002 create_emr_steps 2021-04-01T23:00:00+00:00 PythonOperator 2021-04-02T00:00:12.395948+00:00 2021-04-02T00:00:15.112676+00:00 0:00:02.716728 12568 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 5 default 2021-04-02T00:00:09.766765+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_booking-processing-job_v002 2021-04-01T22:00:00+00:00 TriggerDagRunOperator 2021-04-01T23:11:09.745192+00:00 2021-04-01T23:11:10.168810+00:00 0:00:00.423618 12560 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-01T23:11:07.124408+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_campaign-history-job_v002 2021-04-01T22:00:00+00:00 TriggerDagRunOperator 2021-04-01T23:11:09.597860+00:00 2021-04-01T23:11:10.150757+00:00 0:00:00.552897 12559 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-01T23:11:07.124380+00:00 2 default_pool
success campaign-flow-job_v002 check_cluster_status 2021-04-01T22:00:00+00:00 EmrJobFlowSensor 2021-04-01T23:00:56.104182+00:00 2021-04-01T23:10:58.904699+00:00 0:10:02.800517 12555 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-04-01T23:00:53.976251+00:00 2 default_pool
success campaign-flow-job_v002 create_cluster_and_add_emr_steps 2021-04-01T22:00:00+00:00 EmrCreateJobFlowOperator 2021-04-01T23:00:36.115034+00:00 2021-04-01T23:00:37.840330+00:00 0:00:01.725296 12554 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 4 default 2021-04-01T23:00:33.950386+00:00 2 default_pool
success campaign-flow-job_v002 create_emr_steps 2021-04-01T22:00:00+00:00 PythonOperator 2021-04-01T23:00:12.314302+00:00 2021-04-01T23:00:15.066986+00:00 0:00:02.752684 12553 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 5 default 2021-04-01T23:00:09.887844+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_booking-processing-job_v002 2021-04-01T21:00:00+00:00 TriggerDagRunOperator 2021-04-01T22:10:21.562441+00:00 2021-04-01T22:10:22.093544+00:00 0:00:00.531103 12545 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-01T22:10:19.206279+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_campaign-history-job_v002 2021-04-01T21:00:00+00:00 TriggerDagRunOperator 2021-04-01T22:10:21.395726+00:00 2021-04-01T22:10:21.833680+00:00 0:00:00.437954 12544 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-01T22:10:19.206247+00:00 2 default_pool
success campaign-flow-job_v002 check_cluster_status 2021-04-01T21:00:00+00:00 EmrJobFlowSensor 2021-04-01T22:01:06.450178+00:00 2021-04-01T22:10:09.302108+00:00 0:09:02.851930 12540 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-04-01T22:01:04.285240+00:00 2 default_pool
success campaign-flow-job_v002 create_cluster_and_add_emr_steps 2021-04-01T21:00:00+00:00 EmrCreateJobFlowOperator 2021-04-01T22:00:44.648337+00:00 2021-04-01T22:00:46.541508+00:00 0:00:01.893171 12539 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 4 default 2021-04-01T22:00:42.204622+00:00 2 default_pool
success campaign-flow-job_v002 create_emr_steps 2021-04-01T21:00:00+00:00 PythonOperator 2021-04-01T22:00:22.905132+00:00 2021-04-01T22:00:25.644472+00:00 0:00:02.739340 12538 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 5 default 2021-04-01T22:00:20.243962+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_campaign-history-job_v002 2021-04-01T20:00:00+00:00 TriggerDagRunOperator 2021-04-01T21:11:43.167708+00:00 2021-04-01T21:11:43.709998+00:00 0:00:00.542290 12530 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-01T21:11:40.724855+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_booking-processing-job_v002 2021-04-01T20:00:00+00:00 TriggerDagRunOperator 2021-04-01T21:11:43.001335+00:00 2021-04-01T21:11:43.413336+00:00 0:00:00.412001 12529 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-01T21:11:40.724900+00:00 2 default_pool
success campaign-flow-job_v002 check_cluster_status 2021-04-01T20:00:00+00:00 EmrJobFlowSensor 2021-04-01T21:01:06.234057+00:00 2021-04-01T21:11:09.142288+00:00 0:10:02.908231 12525 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-04-01T21:01:03.867349+00:00 2 default_pool
success campaign-flow-job_v002 create_cluster_and_add_emr_steps 2021-04-01T20:00:00+00:00 EmrCreateJobFlowOperator 2021-04-01T21:00:45.997707+00:00 2021-04-01T21:00:47.692572+00:00 0:00:01.694865 12524 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 4 default 2021-04-01T21:00:43.795821+00:00 2 default_pool
success campaign-flow-job_v002 create_emr_steps 2021-04-01T20:00:00+00:00 PythonOperator 2021-04-01T21:00:24.285050+00:00 2021-04-01T21:00:27.055720+00:00 0:00:02.770670 12523 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 5 default 2021-04-01T21:00:21.740604+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_campaign-history-job_v002 2021-04-01T19:00:00+00:00 TriggerDagRunOperator 2021-04-01T20:11:08.066553+00:00 2021-04-01T20:11:08.712758+00:00 0:00:00.646205 12515 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-01T20:11:05.483693+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_booking-processing-job_v002 2021-04-01T19:00:00+00:00 TriggerDagRunOperator 2021-04-01T20:11:07.628398+00:00 2021-04-01T20:11:08.063001+00:00 0:00:00.434603 12514 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-01T20:11:05.483722+00:00 2 default_pool
success campaign-flow-job_v002 check_cluster_status 2021-04-01T19:00:00+00:00 EmrJobFlowSensor 2021-04-01T20:00:52.583263+00:00 2021-04-01T20:10:55.503177+00:00 0:10:02.919914 12510 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-04-01T20:00:50.242929+00:00 2 default_pool
success campaign-flow-job_v002 create_cluster_and_add_emr_steps 2021-04-01T19:00:00+00:00 EmrCreateJobFlowOperator 2021-04-01T20:00:30.739327+00:00 2021-04-01T20:00:32.440818+00:00 0:00:01.701491 12509 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 4 default 2021-04-01T20:00:28.353612+00:00 2 default_pool
success campaign-flow-job_v002 create_emr_steps 2021-04-01T19:00:00+00:00 PythonOperator 2021-04-01T20:00:06.621476+00:00 2021-04-01T20:00:09.414309+00:00 0:00:02.792833 12508 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 5 default 2021-04-01T20:00:04.220894+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_booking-processing-job_v002 2021-04-01T18:00:00+00:00 TriggerDagRunOperator 2021-04-01T19:10:36.220004+00:00 2021-04-01T19:10:36.763646+00:00 0:00:00.543642 12500 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-01T19:10:33.895425+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_campaign-history-job_v002 2021-04-01T18:00:00+00:00 TriggerDagRunOperator 2021-04-01T19:10:36.098678+00:00 2021-04-01T19:10:36.508638+00:00 0:00:00.409960 12499 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-01T19:10:33.895391+00:00 2 default_pool
success campaign-flow-job_v002 check_cluster_status 2021-04-01T18:00:00+00:00 EmrJobFlowSensor 2021-04-01T19:01:07.107809+00:00 2021-04-01T19:10:09.764630+00:00 0:09:02.656821 12495 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-04-01T19:01:04.908687+00:00 2 default_pool
success campaign-flow-job_v002 create_cluster_and_add_emr_steps 2021-04-01T18:00:00+00:00 EmrCreateJobFlowOperator 2021-04-01T19:00:45.281939+00:00 2021-04-01T19:00:46.988306+00:00 0:00:01.706367 12494 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 4 default 2021-04-01T19:00:42.901150+00:00 2 default_pool
success campaign-flow-job_v002 create_emr_steps 2021-04-01T18:00:00+00:00 PythonOperator 2021-04-01T19:00:25.104855+00:00 2021-04-01T19:00:27.874495+00:00 0:00:02.769640 12493 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 5 default 2021-04-01T19:00:22.845482+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_booking-processing-job_v002 2021-04-01T17:00:00+00:00 TriggerDagRunOperator 2021-04-01T18:10:40.542926+00:00 2021-04-01T18:10:41.044391+00:00 0:00:00.501465 12485 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-01T18:10:37.891882+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_campaign-history-job_v002 2021-04-01T17:00:00+00:00 TriggerDagRunOperator 2021-04-01T18:10:40.193413+00:00 2021-04-01T18:10:40.617768+00:00 0:00:00.424355 12484 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-01T18:10:37.891851+00:00 2 default_pool
success campaign-flow-job_v002 check_cluster_status 2021-04-01T17:00:00+00:00 EmrJobFlowSensor 2021-04-01T18:01:15.151390+00:00 2021-04-01T18:10:18.005557+00:00 0:09:02.854167 12480 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-04-01T18:01:12.801517+00:00 2 default_pool
success campaign-flow-job_v002 create_cluster_and_add_emr_steps 2021-04-01T17:00:00+00:00 EmrCreateJobFlowOperator 2021-04-01T18:00:52.994750+00:00 2021-04-01T18:00:54.673818+00:00 0:00:01.679068 12479 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 4 default 2021-04-01T18:00:50.786472+00:00 2 default_pool
success campaign-flow-job_v002 create_emr_steps 2021-04-01T17:00:00+00:00 PythonOperator 2021-04-01T18:00:21.151002+00:00 2021-04-01T18:00:24.018348+00:00 0:00:02.867346 12478 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 5 default 2021-04-01T18:00:18.758794+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_booking-processing-job_v002 2021-04-01T16:00:00+00:00 TriggerDagRunOperator 2021-04-01T17:09:20.327845+00:00 2021-04-01T17:09:20.847089+00:00 0:00:00.519244 12470 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-01T17:09:17.958607+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_campaign-history-job_v002 2021-04-01T16:00:00+00:00 TriggerDagRunOperator 2021-04-01T17:09:20.217956+00:00 2021-04-01T17:09:20.648227+00:00 0:00:00.430271 12469 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-01T17:09:17.958561+00:00 2 default_pool
success campaign-flow-job_v002 check_cluster_status 2021-04-01T16:00:00+00:00 EmrJobFlowSensor 2021-04-01T17:01:05.380202+00:00 2021-04-01T17:09:07.933639+00:00 0:08:02.553437 12465 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-04-01T17:01:02.982073+00:00 2 default_pool
success campaign-flow-job_v002 create_cluster_and_add_emr_steps 2021-04-01T16:00:00+00:00 EmrCreateJobFlowOperator 2021-04-01T17:00:31.256483+00:00 2021-04-01T17:00:32.931915+00:00 0:00:01.675432 12464 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 4 default 2021-04-01T17:00:28.970215+00:00 2 default_pool
success campaign-flow-job_v002 create_emr_steps 2021-04-01T16:00:00+00:00 PythonOperator 2021-04-01T17:00:11.193451+00:00 2021-04-01T17:00:13.968223+00:00 0:00:02.774772 12463 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 5 default 2021-04-01T17:00:08.919901+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_booking-processing-job_v002 2021-04-01T15:00:00+00:00 TriggerDagRunOperator 2021-04-01T16:11:27.557851+00:00 2021-04-01T16:11:28.064071+00:00 0:00:00.506220 12455 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-01T16:11:25.189808+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_campaign-history-job_v002 2021-04-01T15:00:00+00:00 TriggerDagRunOperator 2021-04-01T16:11:27.401747+00:00 2021-04-01T16:11:27.830050+00:00 0:00:00.428303 12454 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-01T16:11:25.189780+00:00 2 default_pool
success campaign-flow-job_v002 check_cluster_status 2021-04-01T15:00:00+00:00 EmrJobFlowSensor 2021-04-01T16:01:04.366110+00:00 2021-04-01T16:11:07.230000+00:00 0:10:02.863890 12450 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-04-01T16:01:02.031050+00:00 2 default_pool
success campaign-flow-job_v002 create_cluster_and_add_emr_steps 2021-04-01T15:00:00+00:00 EmrCreateJobFlowOperator 2021-04-01T16:00:42.177087+00:00 2021-04-01T16:00:44.005050+00:00 0:00:01.827963 12449 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 4 default 2021-04-01T16:00:40.011944+00:00 2 default_pool
success campaign-flow-job_v002 create_emr_steps 2021-04-01T15:00:00+00:00 PythonOperator 2021-04-01T16:00:20.297333+00:00 2021-04-01T16:00:23.012639+00:00 0:00:02.715306 12448 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 5 default 2021-04-01T16:00:17.994733+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_campaign-history-job_v002 2021-04-01T14:00:00+00:00 TriggerDagRunOperator 2021-04-01T15:11:18.824887+00:00 2021-04-01T15:11:19.354302+00:00 0:00:00.529415 12440 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-01T15:11:16.234401+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_booking-processing-job_v002 2021-04-01T14:00:00+00:00 TriggerDagRunOperator 2021-04-01T15:11:18.696824+00:00 2021-04-01T15:11:19.119119+00:00 0:00:00.422295 12439 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-01T15:11:16.234432+00:00 2 default_pool
success campaign-flow-job_v002 check_cluster_status 2021-04-01T14:00:00+00:00 EmrJobFlowSensor 2021-04-01T15:00:59.503258+00:00 2021-04-01T15:11:02.394667+00:00 0:10:02.891409 12435 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-04-01T15:00:57.111371+00:00 2 default_pool
success campaign-flow-job_v002 create_cluster_and_add_emr_steps 2021-04-01T14:00:00+00:00 EmrCreateJobFlowOperator 2021-04-01T15:00:37.321488+00:00 2021-04-01T15:00:39.110182+00:00 0:00:01.788694 12434 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 4 default 2021-04-01T15:00:35.085979+00:00 2 default_pool
success campaign-flow-job_v002 create_emr_steps 2021-04-01T14:00:00+00:00 PythonOperator 2021-04-01T15:00:17.449253+00:00 2021-04-01T15:00:20.302947+00:00 0:00:02.853694 12433 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 5 default 2021-04-01T15:00:15.011662+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_booking-processing-job_v002 2021-04-01T13:00:00+00:00 TriggerDagRunOperator 2021-04-01T14:11:20.231327+00:00 2021-04-01T14:11:20.762993+00:00 0:00:00.531666 12425 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-01T14:11:17.822796+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_campaign-history-job_v002 2021-04-01T13:00:00+00:00 TriggerDagRunOperator 2021-04-01T14:11:20.034925+00:00 2021-04-01T14:11:20.459459+00:00 0:00:00.424534 12424 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-01T14:11:17.822762+00:00 2 default_pool
success campaign-flow-job_v002 check_cluster_status 2021-04-01T13:00:00+00:00 EmrJobFlowSensor 2021-04-01T14:00:53.587444+00:00 2021-04-01T14:10:56.540986+00:00 0:10:02.953542 12420 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-04-01T14:00:50.808850+00:00 2 default_pool
success campaign-flow-job_v002 create_cluster_and_add_emr_steps 2021-04-01T13:00:00+00:00 EmrCreateJobFlowOperator 2021-04-01T14:00:31.355619+00:00 2021-04-01T14:00:33.090568+00:00 0:00:01.734949 12419 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 4 default 2021-04-01T14:00:28.867647+00:00 2 default_pool
success campaign-flow-job_v002 create_emr_steps 2021-04-01T13:00:00+00:00 PythonOperator 2021-04-01T14:00:09.189853+00:00 2021-04-01T14:00:11.931412+00:00 0:00:02.741559 12418 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 5 default 2021-04-01T14:00:06.743017+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_campaign-history-job_v002 2021-04-01T12:00:00+00:00 TriggerDagRunOperator 2021-04-01T13:10:07.762268+00:00 2021-04-01T13:10:08.181959+00:00 0:00:00.419691 12410 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-01T13:10:05.271701+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_booking-processing-job_v002 2021-04-01T12:00:00+00:00 TriggerDagRunOperator 2021-04-01T13:10:07.774630+00:00 2021-04-01T13:10:08.334627+00:00 0:00:00.559997 12409 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-01T13:10:05.271744+00:00 2 default_pool
success campaign-flow-job_v002 check_cluster_status 2021-04-01T12:00:00+00:00 EmrJobFlowSensor 2021-04-01T13:00:46.661684+00:00 2021-04-01T13:09:49.506042+00:00 0:09:02.844358 12405 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-04-01T13:00:44.286616+00:00 2 default_pool
success campaign-flow-job_v002 create_cluster_and_add_emr_steps 2021-04-01T12:00:00+00:00 EmrCreateJobFlowOperator 2021-04-01T13:00:26.419977+00:00 2021-04-01T13:00:28.147306+00:00 0:00:01.727329 12404 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 4 default 2021-04-01T13:00:24.260821+00:00 2 default_pool
success campaign-flow-job_v002 create_emr_steps 2021-04-01T12:00:00+00:00 PythonOperator 2021-04-01T13:00:04.704856+00:00 2021-04-01T13:00:07.478682+00:00 0:00:02.773826 12403 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 5 default 2021-04-01T13:00:02.203530+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_booking-processing-job_v002 2021-04-01T11:00:00+00:00 TriggerDagRunOperator 2021-04-01T12:11:37.330750+00:00 2021-04-01T12:11:37.859843+00:00 0:00:00.529093 12395 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-01T12:11:34.930157+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_campaign-history-job_v002 2021-04-01T11:00:00+00:00 TriggerDagRunOperator 2021-04-01T12:11:37.246206+00:00 2021-04-01T12:11:37.660640+00:00 0:00:00.414434 12394 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-01T12:11:34.930123+00:00 2 default_pool
success campaign-flow-job_v002 check_cluster_status 2021-04-01T11:00:00+00:00 EmrJobFlowSensor 2021-04-01T12:01:10.150317+00:00 2021-04-01T12:11:13.160671+00:00 0:10:03.010354 12390 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-04-01T12:01:07.826493+00:00 2 default_pool
success campaign-flow-job_v002 create_cluster_and_add_emr_steps 2021-04-01T11:00:00+00:00 EmrCreateJobFlowOperator 2021-04-01T12:00:42.134775+00:00 2021-04-01T12:00:43.828609+00:00 0:00:01.693834 12389 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 4 default 2021-04-01T12:00:39.865787+00:00 2 default_pool
success campaign-flow-job_v002 create_emr_steps 2021-04-01T11:00:00+00:00 PythonOperator 2021-04-01T12:00:22.099391+00:00 2021-04-01T12:00:24.889601+00:00 0:00:02.790210 12388 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 5 default 2021-04-01T12:00:19.783951+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_booking-processing-job_v002 2021-04-01T10:00:00+00:00 TriggerDagRunOperator 2021-04-01T11:11:34.624196+00:00 2021-04-01T11:11:35.195141+00:00 0:00:00.570945 12380 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-01T11:11:32.113304+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_campaign-history-job_v002 2021-04-01T10:00:00+00:00 TriggerDagRunOperator 2021-04-01T11:11:34.423483+00:00 2021-04-01T11:11:34.870202+00:00 0:00:00.446719 12379 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-01T11:11:32.113273+00:00 2 default_pool
success campaign-flow-job_v002 check_cluster_status 2021-04-01T10:00:00+00:00 EmrJobFlowSensor 2021-04-01T11:01:09.888907+00:00 2021-04-01T11:11:12.758761+00:00 0:10:02.869854 12375 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-04-01T11:01:07.279039+00:00 2 default_pool
success campaign-flow-job_v002 create_cluster_and_add_emr_steps 2021-04-01T10:00:00+00:00 EmrCreateJobFlowOperator 2021-04-01T11:00:47.414007+00:00 2021-04-01T11:00:49.127735+00:00 0:00:01.713728 12374 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 4 default 2021-04-01T11:00:45.189350+00:00 2 default_pool
success campaign-flow-job_v002 create_emr_steps 2021-04-01T10:00:00+00:00 PythonOperator 2021-04-01T11:00:21.548792+00:00 2021-04-01T11:00:24.257195+00:00 0:00:02.708403 12373 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 5 default 2021-04-01T11:00:19.126588+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_campaign-history-job_v002 2021-04-01T09:00:00+00:00 TriggerDagRunOperator 2021-04-01T10:10:23.011850+00:00 2021-04-01T10:10:23.689301+00:00 0:00:00.677451 12365 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-01T10:10:20.664280+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_booking-processing-job_v002 2021-04-01T09:00:00+00:00 TriggerDagRunOperator 2021-04-01T10:10:22.931966+00:00 2021-04-01T10:10:23.379518+00:00 0:00:00.447552 12364 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-01T10:10:20.664307+00:00 2 default_pool
success campaign-flow-job_v002 check_cluster_status 2021-04-01T09:00:00+00:00 EmrJobFlowSensor 2021-04-01T10:01:00.458125+00:00 2021-04-01T10:10:03.259011+00:00 0:09:02.800886 12360 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-04-01T10:00:57.963177+00:00 2 default_pool
success campaign-flow-job_v002 create_cluster_and_add_emr_steps 2021-04-01T09:00:00+00:00 EmrCreateJobFlowOperator 2021-04-01T10:00:40.081698+00:00 2021-04-01T10:00:41.781964+00:00 0:00:01.700266 12359 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 4 default 2021-04-01T10:00:37.846007+00:00 2 default_pool