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-28T01:00:00+00:00 PythonOperator 2021-04-28T02:00:22.783321+00:00 2021-04-28T02:00:25.780983+00:00 0:00:02.997662 22033 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 5 default 2021-04-28T02:00:19.829406+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_campaign-history-job_v002 2021-04-28T00:00:00+00:00 TriggerDagRunOperator 2021-04-28T01:09:15.233942+00:00 2021-04-28T01:09:15.798007+00:00 0:00:00.564065 22025 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-28T01:09:12.757910+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_booking-processing-job_v002 2021-04-28T00:00:00+00:00 TriggerDagRunOperator 2021-04-28T01:09:15.194931+00:00 2021-04-28T01:09:15.614308+00:00 0:00:00.419377 22024 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-28T01:09:12.757956+00:00 2 default_pool
success campaign-flow-job_v002 check_cluster_status 2021-04-28T00:00:00+00:00 EmrJobFlowSensor 2021-04-28T01:00:48.300655+00:00 2021-04-28T01:08:50.933736+00:00 0:08:02.633081 22020 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-04-28T01:00:45.955490+00:00 2 default_pool
success campaign-flow-job_v002 create_cluster_and_add_emr_steps 2021-04-28T00:00:00+00:00 EmrCreateJobFlowOperator 2021-04-28T01:00:26.008451+00:00 2021-04-28T01:00:27.695511+00:00 0:00:01.687060 22019 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 4 default 2021-04-28T01:00:23.865049+00:00 2 default_pool
success campaign-flow-job_v002 create_emr_steps 2021-04-28T00:00:00+00:00 PythonOperator 2021-04-28T01:00:06.152762+00:00 2021-04-28T01:00:09.449598+00:00 0:00:03.296836 22018 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 5 default 2021-04-28T01:00:03.844984+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_booking-processing-job_v002 2021-04-27T23:00:00+00:00 TriggerDagRunOperator 2021-04-28T00:09:31.139552+00:00 2021-04-28T00:09:31.559655+00:00 0:00:00.420103 22010 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-28T00:09:28.587459+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_campaign-history-job_v002 2021-04-27T23:00:00+00:00 TriggerDagRunOperator 2021-04-28T00:09:31.167619+00:00 2021-04-28T00:09:31.697060+00:00 0:00:00.529441 22009 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-28T00:09:28.587413+00:00 2 default_pool
success campaign-flow-job_v002 check_cluster_status 2021-04-27T23:00:00+00:00 EmrJobFlowSensor 2021-04-28T00:01:11.939100+00:00 2021-04-28T00:09:14.510193+00:00 0:08:02.571093 22005 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-04-28T00:01:09.719189+00:00 2 default_pool
success campaign-flow-job_v002 create_cluster_and_add_emr_steps 2021-04-27T23:00:00+00:00 EmrCreateJobFlowOperator 2021-04-28T00:00:37.909185+00:00 2021-04-28T00:00:39.768451+00:00 0:00:01.859266 22004 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 4 default 2021-04-28T00:00:35.691396+00:00 2 default_pool
success campaign-flow-job_v002 create_emr_steps 2021-04-27T23:00:00+00:00 PythonOperator 2021-04-28T00:00:16.026816+00:00 2021-04-28T00:00:19.071397+00:00 0:00:03.044581 22003 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 5 default 2021-04-28T00:00:13.626261+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_campaign-history-job_v002 2021-04-27T22:00:00+00:00 TriggerDagRunOperator 2021-04-27T23:10:14.129060+00:00 2021-04-27T23:10:14.524697+00:00 0:00:00.395637 21995 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-27T23:10:11.650094+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_booking-processing-job_v002 2021-04-27T22:00:00+00:00 TriggerDagRunOperator 2021-04-27T23:10:13.970796+00:00 2021-04-27T23:10:14.510460+00:00 0:00:00.539664 21994 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-27T23:10:11.650128+00:00 2 default_pool
success campaign-flow-job_v002 check_cluster_status 2021-04-27T22:00:00+00:00 EmrJobFlowSensor 2021-04-27T23:01:05.309800+00:00 2021-04-27T23:10:07.988516+00:00 0:09:02.678716 21990 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-04-27T23:01:02.693302+00:00 2 default_pool
success campaign-flow-job_v002 create_cluster_and_add_emr_steps 2021-04-27T22:00:00+00:00 EmrCreateJobFlowOperator 2021-04-27T23:00:42.897626+00:00 2021-04-27T23:00:44.703880+00:00 0:00:01.806254 21988 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 4 default 2021-04-27T23:00:40.611220+00:00 2 default_pool
success campaign-flow-job_v002 create_emr_steps 2021-04-27T22:00:00+00:00 PythonOperator 2021-04-27T23:00:22.799362+00:00 2021-04-27T23:00:26.201084+00:00 0:00:03.401722 21986 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 5 default 2021-04-27T23:00:20.596640+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_campaign-history-job_v002 2021-04-27T21:00:00+00:00 TriggerDagRunOperator 2021-04-27T22:11:07.080184+00:00 2021-04-27T22:11:07.486795+00:00 0:00:00.406611 21977 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-27T22:11:04.558601+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_booking-processing-job_v002 2021-04-27T21:00:00+00:00 TriggerDagRunOperator 2021-04-27T22:11:06.830995+00:00 2021-04-27T22:11:07.355783+00:00 0:00:00.524788 21976 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-27T22:11:04.558646+00:00 2 default_pool
success campaign-flow-job_v002 check_cluster_status 2021-04-27T21:00:00+00:00 EmrJobFlowSensor 2021-04-27T22:00:55.819199+00:00 2021-04-27T22:10:58.566456+00:00 0:10:02.747257 21972 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-04-27T22:00:53.593599+00:00 2 default_pool
success campaign-flow-job_v002 create_cluster_and_add_emr_steps 2021-04-27T21:00:00+00:00 EmrCreateJobFlowOperator 2021-04-27T22:00:35.910376+00:00 2021-04-27T22:00:37.754883+00:00 0:00:01.844507 21971 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 4 default 2021-04-27T22:00:33.546103+00:00 2 default_pool
success campaign-flow-job_v002 create_emr_steps 2021-04-27T21:00:00+00:00 PythonOperator 2021-04-27T22:00:12.445694+00:00 2021-04-27T22:00:15.634023+00:00 0:00:03.188329 21970 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 5 default 2021-04-27T22:00:09.464137+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_booking-processing-job_v002 2021-04-27T20:00:00+00:00 TriggerDagRunOperator 2021-04-27T21:11:20.785799+00:00 2021-04-27T21:11:21.202241+00:00 0:00:00.416442 21962 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-27T21:11:18.367163+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_campaign-history-job_v002 2021-04-27T20:00:00+00:00 TriggerDagRunOperator 2021-04-27T21:11:20.730901+00:00 2021-04-27T21:11:21.251671+00:00 0:00:00.520770 21961 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-27T21:11:18.367127+00:00 2 default_pool
success campaign-flow-job_v002 check_cluster_status 2021-04-27T20:00:00+00:00 EmrJobFlowSensor 2021-04-27T21:00:57.699604+00:00 2021-04-27T21:11:00.448849+00:00 0:10:02.749245 21957 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-04-27T21:00:55.360886+00:00 2 default_pool
success campaign-flow-job_v002 create_cluster_and_add_emr_steps 2021-04-27T20:00:00+00:00 EmrCreateJobFlowOperator 2021-04-27T21:00:37.582340+00:00 2021-04-27T21:00:39.393565+00:00 0:00:01.811225 21956 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 4 default 2021-04-27T21:00:35.260816+00:00 2 default_pool
success campaign-flow-job_v002 create_emr_steps 2021-04-27T20:00:00+00:00 PythonOperator 2021-04-27T21:00:05.968007+00:00 2021-04-27T21:00:09.050492+00:00 0:00:03.082485 21955 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 5 default 2021-04-27T21:00:03.221615+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_campaign-history-job_v002 2021-04-27T19:00:00+00:00 TriggerDagRunOperator 2021-04-27T20:11:31.421393+00:00 2021-04-27T20:11:31.976374+00:00 0:00:00.554981 21946 airflow-worker-2.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-27T20:11:28.476778+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_booking-processing-job_v002 2021-04-27T19:00:00+00:00 TriggerDagRunOperator 2021-04-27T20:11:31.122523+00:00 2021-04-27T20:11:31.634920+00:00 0:00:00.512397 21945 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-27T20:11:28.476810+00:00 2 default_pool
success campaign-flow-job_v002 check_cluster_status 2021-04-27T19:00:00+00:00 EmrJobFlowSensor 2021-04-27T20:01:03.835691+00:00 2021-04-27T20:11:06.644598+00:00 0:10:02.808907 21941 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-04-27T20:01:01.460382+00:00 2 default_pool
success campaign-flow-job_v002 create_cluster_and_add_emr_steps 2021-04-27T19:00:00+00:00 EmrCreateJobFlowOperator 2021-04-27T20:00:41.603854+00:00 2021-04-27T20:00:43.381060+00:00 0:00:01.777206 21940 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 4 default 2021-04-27T20:00:39.390400+00:00 2 default_pool
success campaign-flow-job_v002 create_emr_steps 2021-04-27T19:00:00+00:00 PythonOperator 2021-04-27T20:00:21.721407+00:00 2021-04-27T20:00:24.751615+00:00 0:00:03.030208 21939 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 5 default 2021-04-27T20:00:19.288807+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_campaign-history-job_v002 2021-04-27T18:00:00+00:00 TriggerDagRunOperator 2021-04-27T19:11:26.694000+00:00 2021-04-27T19:11:27.181868+00:00 0:00:00.487868 21929 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-27T19:11:24.246803+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_booking-processing-job_v002 2021-04-27T18:00:00+00:00 TriggerDagRunOperator 2021-04-27T19:11:26.712297+00:00 2021-04-27T19:11:27.290337+00:00 0:00:00.578040 21928 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-27T19:11:24.246856+00:00 2 default_pool
success campaign-flow-job_v002 check_cluster_status 2021-04-27T18:00:00+00:00 EmrJobFlowSensor 2021-04-27T19:00:59.607126+00:00 2021-04-27T19:11:02.566544+00:00 0:10:02.959418 21924 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-04-27T19:00:57.114220+00:00 2 default_pool
success campaign-flow-job_v002 create_cluster_and_add_emr_steps 2021-04-27T18:00:00+00:00 EmrCreateJobFlowOperator 2021-04-27T19:00:37.489892+00:00 2021-04-27T19:00:39.189203+00:00 0:00:01.699311 21923 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 4 default 2021-04-27T19:00:35.102041+00:00 2 default_pool
success campaign-flow-job_v002 create_emr_steps 2021-04-27T18:00:00+00:00 PythonOperator 2021-04-27T19:00:17.651418+00:00 2021-04-27T19:00:20.706470+00:00 0:00:03.055052 21922 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 5 default 2021-04-27T19:00:15.075772+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_campaign-history-job_v002 2021-04-27T17:00:00+00:00 TriggerDagRunOperator 2021-04-27T18:09:10.200086+00:00 2021-04-27T18:09:10.740039+00:00 0:00:00.539953 21914 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-27T18:09:07.845792+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_booking-processing-job_v002 2021-04-27T17:00:00+00:00 TriggerDagRunOperator 2021-04-27T18:09:10.096142+00:00 2021-04-27T18:09:10.494761+00:00 0:00:00.398619 21913 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-27T18:09:07.845828+00:00 2 default_pool
success campaign-flow-job_v002 check_cluster_status 2021-04-27T17:00:00+00:00 EmrJobFlowSensor 2021-04-27T18:00:49.211741+00:00 2021-04-27T18:08:51.698994+00:00 0:08:02.487253 21909 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-04-27T18:00:47.018583+00:00 2 default_pool
success campaign-flow-job_v002 create_cluster_and_add_emr_steps 2021-04-27T17:00:00+00:00 EmrCreateJobFlowOperator 2021-04-27T18:00:29.218174+00:00 2021-04-27T18:00:30.894099+00:00 0:00:01.675925 21908 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 4 default 2021-04-27T18:00:27.003092+00:00 2 default_pool
success campaign-flow-job_v002 create_emr_steps 2021-04-27T17:00:00+00:00 PythonOperator 2021-04-27T18:00:07.772718+00:00 2021-04-27T18:00:10.762204+00:00 0:00:02.989486 21907 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 5 default 2021-04-27T18:00:05.044984+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_booking-processing-job_v002 2021-04-27T16:00:00+00:00 TriggerDagRunOperator 2021-04-27T17:10:06.337694+00:00 2021-04-27T17:10:06.775142+00:00 0:00:00.437448 21899 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-27T17:10:03.790278+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_campaign-history-job_v002 2021-04-27T16:00:00+00:00 TriggerDagRunOperator 2021-04-27T17:10:06.345572+00:00 2021-04-27T17:10:06.888766+00:00 0:00:00.543194 21898 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-27T17:10:03.790245+00:00 2 default_pool
success campaign-flow-job_v002 check_cluster_status 2021-04-27T16:00:00+00:00 EmrJobFlowSensor 2021-04-27T17:00:57.110055+00:00 2021-04-27T17:09:59.728539+00:00 0:09:02.618484 21894 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-04-27T17:00:54.930278+00:00 2 default_pool
success campaign-flow-job_v002 create_cluster_and_add_emr_steps 2021-04-27T16:00:00+00:00 EmrCreateJobFlowOperator 2021-04-27T17:00:35.298950+00:00 2021-04-27T17:00:37.000532+00:00 0:00:01.701582 21893 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 4 default 2021-04-27T17:00:32.908994+00:00 2 default_pool
success campaign-flow-job_v002 create_emr_steps 2021-04-27T16:00:00+00:00 PythonOperator 2021-04-27T17:00:13.198314+00:00 2021-04-27T17:00:16.217685+00:00 0:00:03.019371 21892 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 5 default 2021-04-27T17:00:10.895324+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_booking-processing-job_v002 2021-04-27T15:00:00+00:00 TriggerDagRunOperator 2021-04-27T16:11:01.121538+00:00 2021-04-27T16:11:01.703205+00:00 0:00:00.581667 21884 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-27T16:10:58.675479+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_campaign-history-job_v002 2021-04-27T15:00:00+00:00 TriggerDagRunOperator 2021-04-27T16:11:00.885470+00:00 2021-04-27T16:11:01.320934+00:00 0:00:00.435464 21883 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-27T16:10:58.675441+00:00 2 default_pool
success campaign-flow-job_v002 check_cluster_status 2021-04-27T15:00:00+00:00 EmrJobFlowSensor 2021-04-27T16:00:47.883039+00:00 2021-04-27T16:10:50.783579+00:00 0:10:02.900540 21879 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-04-27T16:00:45.631859+00:00 2 default_pool
success campaign-flow-job_v002 create_cluster_and_add_emr_steps 2021-04-27T15:00:00+00:00 EmrCreateJobFlowOperator 2021-04-27T16:00:25.962387+00:00 2021-04-27T16:00:27.799479+00:00 0:00:01.837092 21878 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 4 default 2021-04-27T16:00:23.604870+00:00 2 default_pool
success campaign-flow-job_v002 create_emr_steps 2021-04-27T15:00:00+00:00 PythonOperator 2021-04-27T16:00:06.157184+00:00 2021-04-27T16:00:09.157395+00:00 0:00:03.000211 21877 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 5 default 2021-04-27T16:00:03.658001+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_campaign-history-job_v002 2021-04-27T14:00:00+00:00 TriggerDagRunOperator 2021-04-27T15:10:33.171842+00:00 2021-04-27T15:10:33.700376+00:00 0:00:00.528534 21869 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-27T15:10:30.888485+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_booking-processing-job_v002 2021-04-27T14:00:00+00:00 TriggerDagRunOperator 2021-04-27T15:10:33.073104+00:00 2021-04-27T15:10:33.480461+00:00 0:00:00.407357 21868 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-27T15:10:30.888520+00:00 2 default_pool
success campaign-flow-job_v002 check_cluster_status 2021-04-27T14:00:00+00:00 EmrJobFlowSensor 2021-04-27T15:00:56.338370+00:00 2021-04-27T15:09:59.009660+00:00 0:09:02.671290 21864 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-04-27T15:00:54.073473+00:00 2 default_pool
success campaign-flow-job_v002 create_cluster_and_add_emr_steps 2021-04-27T14:00:00+00:00 EmrCreateJobFlowOperator 2021-04-27T15:00:34.520645+00:00 2021-04-27T15:00:36.336230+00:00 0:00:01.815585 21863 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 4 default 2021-04-27T15:00:31.990558+00:00 2 default_pool
success campaign-flow-job_v002 create_emr_steps 2021-04-27T14:00:00+00:00 PythonOperator 2021-04-27T15:00:12.331933+00:00 2021-04-27T15:00:15.418010+00:00 0:00:03.086077 21862 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 5 default 2021-04-27T15:00:09.970629+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_campaign-history-job_v002 2021-04-27T13:00:00+00:00 TriggerDagRunOperator 2021-04-27T14:11:19.736683+00:00 2021-04-27T14:11:20.277085+00:00 0:00:00.540402 21854 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-27T14:11:17.375144+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_booking-processing-job_v002 2021-04-27T13:00:00+00:00 TriggerDagRunOperator 2021-04-27T14:11:19.589127+00:00 2021-04-27T14:11:20.001739+00:00 0:00:00.412612 21853 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-27T14:11:17.375187+00:00 2 default_pool
success campaign-flow-job_v002 check_cluster_status 2021-04-27T13:00:00+00:00 EmrJobFlowSensor 2021-04-27T14:00:58.342636+00:00 2021-04-27T14:11:01.172765+00:00 0:10:02.830129 21849 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-04-27T14:00:56.204404+00:00 2 default_pool
success campaign-flow-job_v002 create_cluster_and_add_emr_steps 2021-04-27T13:00:00+00:00 EmrCreateJobFlowOperator 2021-04-27T14:00:38.337374+00:00 2021-04-27T14:00:40.039174+00:00 0:00:01.701800 21848 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 4 default 2021-04-27T14:00:36.186573+00:00 2 default_pool
success campaign-flow-job_v002 create_emr_steps 2021-04-27T13:00:00+00:00 PythonOperator 2021-04-27T14:00:14.384195+00:00 2021-04-27T14:00:17.719803+00:00 0:00:03.335608 21847 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 5 default 2021-04-27T14:00:12.119647+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_campaign-history-job_v002 2021-04-27T12:00:00+00:00 TriggerDagRunOperator 2021-04-27T13:12:58.177100+00:00 2021-04-27T13:12:58.690700+00:00 0:00:00.513600 21840 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-27T13:12:55.502653+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_booking-processing-job_v002 2021-04-27T12:00:00+00:00 TriggerDagRunOperator 2021-04-27T13:12:58.189286+00:00 2021-04-27T13:12:58.760327+00:00 0:00:00.571041 21839 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-27T13:12:55.502681+00:00 2 default_pool
success campaign-flow-job_v002 check_cluster_status 2021-04-27T12:00:00+00:00 EmrJobFlowSensor 2021-04-27T13:01:04.436188+00:00 2021-04-27T13:10:07.224119+00:00 0:09:02.787931 21834 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-04-27T13:01:02.084483+00:00 2 default_pool
success campaign-flow-job_v002 create_cluster_and_add_emr_steps 2021-04-27T12:00:00+00:00 EmrCreateJobFlowOperator 2021-04-27T13:00:42.294050+00:00 2021-04-27T13:00:44.007592+00:00 0:00:01.713542 21833 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 4 default 2021-04-27T13:00:40.039597+00:00 2 default_pool
success campaign-flow-job_v002 create_emr_steps 2021-04-27T12:00:00+00:00 PythonOperator 2021-04-27T13:00:22.273353+00:00 2021-04-27T13:00:25.292732+00:00 0:00:03.019379 21832 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 5 default 2021-04-27T13:00:20.024113+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_booking-processing-job_v002 2021-04-27T11:00:00+00:00 TriggerDagRunOperator 2021-04-27T12:11:21.718210+00:00 2021-04-27T12:11:22.264929+00:00 0:00:00.546719 21825 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-27T12:11:19.326590+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_campaign-history-job_v002 2021-04-27T11:00:00+00:00 TriggerDagRunOperator 2021-04-27T12:11:21.628058+00:00 2021-04-27T12:11:22.058512+00:00 0:00:00.430454 21824 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-27T12:11:19.326557+00:00 2 default_pool
success campaign-flow-job_v002 check_cluster_status 2021-04-27T11:00:00+00:00 EmrJobFlowSensor 2021-04-27T12:01:07.531833+00:00 2021-04-27T12:11:10.358965+00:00 0:10:02.827132 21819 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-04-27T12:01:05.059465+00:00 2 default_pool
success campaign-flow-job_v002 create_cluster_and_add_emr_steps 2021-04-27T11:00:00+00:00 EmrCreateJobFlowOperator 2021-04-27T12:00:45.256086+00:00 2021-04-27T12:00:46.989716+00:00 0:00:01.733630 21818 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 4 default 2021-04-27T12:00:42.962253+00:00 2 default_pool
success campaign-flow-job_v002 create_emr_steps 2021-04-27T11:00:00+00:00 PythonOperator 2021-04-27T12:00:23.143924+00:00 2021-04-27T12:00:26.105993+00:00 0:00:02.962069 21817 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 5 default 2021-04-27T12:00:20.943154+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_booking-processing-job_v002 2021-04-27T10:00:00+00:00 TriggerDagRunOperator 2021-04-27T11:10:04.329252+00:00 2021-04-27T11:10:05.082778+00:00 0:00:00.753526 21810 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-27T11:10:01.840852+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_campaign-history-job_v002 2021-04-27T10:00:00+00:00 TriggerDagRunOperator 2021-04-27T11:10:04.216219+00:00 2021-04-27T11:10:04.820872+00:00 0:00:00.604653 21809 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-27T11:10:01.840818+00:00 2 default_pool
success campaign-flow-job_v002 check_cluster_status 2021-04-27T10:00:00+00:00 EmrJobFlowSensor 2021-04-27T11:00:48.176969+00:00 2021-04-27T11:09:50.813082+00:00 0:09:02.636113 21804 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-04-27T11:00:45.901110+00:00 2 default_pool
success campaign-flow-job_v002 create_cluster_and_add_emr_steps 2021-04-27T10:00:00+00:00 EmrCreateJobFlowOperator 2021-04-27T11:00:26.107792+00:00 2021-04-27T11:00:27.842248+00:00 0:00:01.734456 21803 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 4 default 2021-04-27T11:00:23.877976+00:00 2 default_pool
success campaign-flow-job_v002 create_emr_steps 2021-04-27T10:00:00+00:00 PythonOperator 2021-04-27T11:00:06.158793+00:00 2021-04-27T11:00:09.200921+00:00 0:00:03.042128 21802 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 5 default 2021-04-27T11:00:03.859085+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_campaign-history-job_v002 2021-04-27T09:00:00+00:00 TriggerDagRunOperator 2021-04-27T10:09:12.143317+00:00 2021-04-27T10:09:12.670618+00:00 0:00:00.527301 21795 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-27T10:09:09.678496+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_booking-processing-job_v002 2021-04-27T09:00:00+00:00 TriggerDagRunOperator 2021-04-27T10:09:12.045796+00:00 2021-04-27T10:09:12.502484+00:00 0:00:00.456688 21794 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-27T10:09:09.678543+00:00 2 default_pool
success campaign-flow-job_v002 check_cluster_status 2021-04-27T09:00:00+00:00 EmrJobFlowSensor 2021-04-27T10:00:57.280495+00:00 2021-04-27T10:08:59.845182+00:00 0:08:02.564687 21789 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-04-27T10:00:55.138698+00:00 2 default_pool
success campaign-flow-job_v002 create_cluster_and_add_emr_steps 2021-04-27T09:00:00+00:00 EmrCreateJobFlowOperator 2021-04-27T10:00:35.384722+00:00 2021-04-27T10:00:37.183235+00:00 0:00:01.798513 21788 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 4 default 2021-04-27T10:00:33.115163+00:00 2 default_pool
success campaign-flow-job_v002 create_emr_steps 2021-04-27T09:00:00+00:00 PythonOperator 2021-04-27T10:00:13.629574+00:00 2021-04-27T10:00:16.625974+00:00 0:00:02.996400 21787 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 5 default 2021-04-27T10:00:11.163757+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_campaign-history-job_v002 2021-04-27T08:00:00+00:00 TriggerDagRunOperator 2021-04-27T09:12:08.685991+00:00 2021-04-27T09:12:09.208112+00:00 0:00:00.522121 21780 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-27T09:12:06.195665+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_booking-processing-job_v002 2021-04-27T08:00:00+00:00 TriggerDagRunOperator 2021-04-27T09:12:08.501311+00:00 2021-04-27T09:12:08.920639+00:00 0:00:00.419328 21779 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-27T09:12:06.195706+00:00 2 default_pool
success campaign-flow-job_v002 check_cluster_status 2021-04-27T08:00:00+00:00 EmrJobFlowSensor 2021-04-27T09:02:59.462077+00:00 2021-04-27T09:12:02.235150+00:00 0:09:02.773073 21775 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-04-27T09:02:57.196725+00:00 2 default_pool
success campaign-flow-job_v002 create_cluster_and_add_emr_steps 2021-04-27T08:00:00+00:00 EmrCreateJobFlowOperator 2021-04-27T09:02:37.437859+00:00 2021-04-27T09:02:39.216311+00:00 0:00:01.778452 21774 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 4 default 2021-04-27T09:02:35.162676+00:00 2 default_pool
success campaign-flow-job_v002 create_emr_steps 2021-04-27T08:00:00+00:00 PythonOperator 2021-04-27T09:02:17.736152+00:00 2021-04-27T09:02:20.717815+00:00 0:00:02.981663 21773 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 5 default 2021-04-27T09:02:15.017282+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_booking-processing-job_v002 2021-04-27T07:00:00+00:00 TriggerDagRunOperator 2021-04-27T08:11:14.808911+00:00 2021-04-27T08:11:15.232730+00:00 0:00:00.423819 21765 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-27T08:11:12.125786+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_campaign-history-job_v002 2021-04-27T07:00:00+00:00 TriggerDagRunOperator 2021-04-27T08:11:14.425014+00:00 2021-04-27T08:11:14.958574+00:00 0:00:00.533560 21764 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-27T08:11:12.125754+00:00 2 default_pool
success campaign-flow-job_v002 check_cluster_status 2021-04-27T07:00:00+00:00 EmrJobFlowSensor 2021-04-27T08:01:03.316409+00:00 2021-04-27T08:11:06.110521+00:00 0:10:02.794112 21760 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-04-27T08:01:00.860062+00:00 2 default_pool
success campaign-flow-job_v002 create_cluster_and_add_emr_steps 2021-04-27T07:00:00+00:00 EmrCreateJobFlowOperator 2021-04-27T08:00:41.261609+00:00 2021-04-27T08:00:43.093268+00:00 0:00:01.831659 21759 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 4 default 2021-04-27T08:00:38.879777+00:00 2 default_pool
success campaign-flow-job_v002 create_emr_steps 2021-04-27T07:00:00+00:00 PythonOperator 2021-04-27T08:00:19.318799+00:00 2021-04-27T08:00:22.279410+00:00 0:00:02.960611 21758 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 5 default 2021-04-27T08:00:16.862742+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_campaign-history-job_v002 2021-04-27T06:00:00+00:00 TriggerDagRunOperator 2021-04-27T07:11:10.862224+00:00 2021-04-27T07:11:11.376311+00:00 0:00:00.514087 21750 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-27T07:11:08.425690+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_booking-processing-job_v002 2021-04-27T06:00:00+00:00 TriggerDagRunOperator 2021-04-27T07:11:10.812823+00:00 2021-04-27T07:11:11.239955+00:00 0:00:00.427132 21749 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-27T07:11:08.425734+00:00 2 default_pool
success campaign-flow-job_v002 check_cluster_status 2021-04-27T06:00:00+00:00 EmrJobFlowSensor 2021-04-27T07:00:47.330699+00:00 2021-04-27T07:10:50.191882+00:00 0:10:02.861183 21745 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-04-27T07:00:44.995763+00:00 2 default_pool
success campaign-flow-job_v002 create_cluster_and_add_emr_steps 2021-04-27T06:00:00+00:00 EmrCreateJobFlowOperator 2021-04-27T07:00:25.240501+00:00 2021-04-27T07:00:26.907061+00:00 0:00:01.666560 21744 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 4 default 2021-04-27T07:00:22.956328+00:00 2 default_pool
success campaign-flow-job_v002 create_emr_steps 2021-04-27T06:00:00+00:00 PythonOperator 2021-04-27T07:00:05.570828+00:00 2021-04-27T07:00:08.569159+00:00 0:00:02.998331 21743 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 5 default 2021-04-27T07:00:02.956833+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_campaign-history-job_v002 2021-04-27T05:00:00+00:00 TriggerDagRunOperator 2021-04-27T06:09:12.109388+00:00 2021-04-27T06:09:12.670600+00:00 0:00:00.561212 21734 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-27T06:09:09.836460+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_booking-processing-job_v002 2021-04-27T05:00:00+00:00 TriggerDagRunOperator 2021-04-27T06:09:12.060938+00:00 2021-04-27T06:09:12.481296+00:00 0:00:00.420358 21733 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-27T06:09:09.836496+00:00 2 default_pool
success campaign-flow-job_v002 check_cluster_status 2021-04-27T05:00:00+00:00 EmrJobFlowSensor 2021-04-27T06:00:57.198949+00:00 2021-04-27T06:08:59.790126+00:00 0:08:02.591177 21729 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-04-27T06:00:54.703168+00:00 2 default_pool
success campaign-flow-job_v002 create_cluster_and_add_emr_steps 2021-04-27T05:00:00+00:00 EmrCreateJobFlowOperator 2021-04-27T06:00:35.233752+00:00 2021-04-27T06:00:36.938031+00:00 0:00:01.704279 21728 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 4 default 2021-04-27T06:00:32.763970+00:00 2 default_pool