Task Instances

  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-09T06:00:00+00:00 PythonOperator 2021-04-09T07:00:08.902419+00:00 2021-04-09T07:00:11.754427+00:00 0:00:02.852008 15196 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 5 default 2021-04-09T07:00:06.243605+00:00 2 default_pool
success booking-processing-job_v002 check_cluster_status 2021-04-09T05:00:00+00:00 EmrJobFlowSensor 2021-04-09T06:12:08.773246+00:00 2021-04-09T06:23:11.778481+00:00 0:11:03.005235 15194 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-09T06:12:06.299781+00:00 2 default_pool
success campaign-history-job_v002 check_cluster_status 2021-04-09T05:00:00+00:00 EmrJobFlowSensor 2021-04-09T06:12:08.552330+00:00 2021-04-09T06:21:11.270075+00:00 0:09:02.717745 15193 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-09T06:12:06.299814+00:00 2 default_pool
success booking-processing-job_v002 create_cluster_and_add_emr_steps 2021-04-09T05:00:00+00:00 EmrCreateJobFlowOperator 2021-04-09T06:11:49.020762+00:00 2021-04-09T06:11:50.714678+00:00 0:00:01.693916 15192 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 2 default 2021-04-09T06:11:46.279940+00:00 2 default_pool
success campaign-history-job_v002 create_cluster_and_add_emr_steps 2021-04-09T05:00:00+00:00 EmrCreateJobFlowOperator 2021-04-09T06:11:46.400981+00:00 2021-04-09T06:11:48.570270+00:00 0:00:02.169289 15191 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 2 default 2021-04-09T06:11:44.278993+00:00 2 default_pool
success booking-processing-job_v002 create_emr_steps 2021-04-09T05:00:00+00:00 PythonOperator 2021-04-09T06:11:26.718971+00:00 2021-04-09T06:11:29.823334+00:00 0:00:03.104363 15190 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-04-09T06:11:24.279026+00:00 2 default_pool
success campaign-history-job_v002 create_emr_steps 2021-04-09T05:00:00+00:00 PythonOperator 2021-04-09T06:11:24.748664+00:00 2021-04-09T06:11:27.442333+00:00 0:00:02.693669 15189 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-04-09T06:11:22.273996+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_booking-processing-job_v002 2021-04-09T05:00:00+00:00 TriggerDagRunOperator 2021-04-09T06:11:06.999501+00:00 2021-04-09T06:11:07.553007+00:00 0:00:00.553506 15188 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-09T06:11:04.256142+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_campaign-history-job_v002 2021-04-09T05:00:00+00:00 TriggerDagRunOperator 2021-04-09T06:11:06.669046+00:00 2021-04-09T06:11:07.161902+00:00 0:00:00.492856 15187 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-09T06:11:04.256110+00:00 2 default_pool
success vc-asset-import_v002 check_cluster_status 2021-04-09T05:05:00+00:00 EmrJobFlowSensor 2021-04-09T06:06:00.172287+00:00 2021-04-09T06:15:02.959841+00:00 0:09:02.787554 15186 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-09T06:05:57.847518+00:00 2 default_pool
success vc-asset-import_v002 create_cluster_and_add_emr_steps 2021-04-09T05:05:00+00:00 EmrCreateJobFlowOperator 2021-04-09T06:05:39.957419+00:00 2021-04-09T06:05:41.718976+00:00 0:00:01.761557 15185 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 2 default 2021-04-09T06:05:37.717422+00:00 2 default_pool
success vc-asset-import_v002 create_emr_steps 2021-04-09T05:05:00+00:00 PythonOperator 2021-04-09T06:05:18.178780+00:00 2021-04-09T06:05:21.001207+00:00 0:00:02.822427 15184 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-04-09T06:05:15.751279+00:00 2 default_pool
success campaign-flow-job_v002 check_cluster_status 2021-04-09T05:00:00+00:00 EmrJobFlowSensor 2021-04-09T06:00:55.671521+00:00 2021-04-09T06:10:58.531515+00:00 0:10:02.859994 15183 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-04-09T06:00:53.224595+00:00 2 default_pool
success campaign-flow-job_v002 create_cluster_and_add_emr_steps 2021-04-09T05:00:00+00:00 EmrCreateJobFlowOperator 2021-04-09T06:00:35.538917+00:00 2021-04-09T06:00:37.245314+00:00 0:00:01.706397 15182 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 4 default 2021-04-09T06:00:33.213814+00:00 2 default_pool
success campaign-flow-job_v002 create_emr_steps 2021-04-09T05:00:00+00:00 PythonOperator 2021-04-09T06:00:13.514450+00:00 2021-04-09T06:00:16.300855+00:00 0:00:02.786405 15181 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 5 default 2021-04-09T06:00:11.190325+00:00 2 default_pool
success campaign-history-job_v002 check_cluster_status 2021-04-09T04:00:00+00:00 EmrJobFlowSensor 2021-04-09T05:11:11.424589+00:00 2021-04-09T05:20:14.156720+00:00 0:09:02.732131 15179 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-09T05:11:09.192601+00:00 2 default_pool
success booking-processing-job_v002 check_cluster_status 2021-04-09T04:00:00+00:00 EmrJobFlowSensor 2021-04-09T05:11:07.405103+00:00 2021-04-09T05:21:10.157612+00:00 0:10:02.752509 15178 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-09T05:11:05.188242+00:00 2 default_pool
success campaign-history-job_v002 create_cluster_and_add_emr_steps 2021-04-09T04:00:00+00:00 EmrCreateJobFlowOperator 2021-04-09T05:10:51.260218+00:00 2021-04-09T05:10:52.933859+00:00 0:00:01.673641 15177 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 2 default 2021-04-09T05:10:49.129954+00:00 2 default_pool
success booking-processing-job_v002 create_cluster_and_add_emr_steps 2021-04-09T04:00:00+00:00 EmrCreateJobFlowOperator 2021-04-09T05:10:45.722957+00:00 2021-04-09T05:10:47.524114+00:00 0:00:01.801157 15176 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 2 default 2021-04-09T05:10:43.181199+00:00 2 default_pool
success campaign-history-job_v002 create_emr_steps 2021-04-09T04:00:00+00:00 PythonOperator 2021-04-09T05:10:29.738874+00:00 2021-04-09T05:10:32.508174+00:00 0:00:02.769300 15175 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-04-09T05:10:27.117039+00:00 2 default_pool
success booking-processing-job_v002 create_emr_steps 2021-04-09T04:00:00+00:00 PythonOperator 2021-04-09T05:10:23.925650+00:00 2021-04-09T05:10:27.091442+00:00 0:00:03.165792 15174 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-04-09T05:10:21.163222+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_campaign-history-job_v002 2021-04-09T04:00:00+00:00 TriggerDagRunOperator 2021-04-09T05:10:17.600422+00:00 2021-04-09T05:10:18.122293+00:00 0:00:00.521871 15173 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-09T05:10:15.111916+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_booking-processing-job_v002 2021-04-09T04:00:00+00:00 TriggerDagRunOperator 2021-04-09T05:10:17.279832+00:00 2021-04-09T05:10:17.717649+00:00 0:00:00.437817 15172 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-09T05:10:15.111951+00:00 2 default_pool
success vc-asset-import_v002 check_cluster_status 2021-04-09T04:05:00+00:00 EmrJobFlowSensor 2021-04-09T05:05:52.887352+00:00 2021-04-09T05:13:55.273383+00:00 0:08:02.386031 15171 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-09T05:05:50.701582+00:00 2 default_pool
success vc-asset-import_v002 create_cluster_and_add_emr_steps 2021-04-09T04:05:00+00:00 EmrCreateJobFlowOperator 2021-04-09T05:05:32.885700+00:00 2021-04-09T05:05:34.639990+00:00 0:00:01.754290 15170 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 2 default 2021-04-09T05:05:30.683971+00:00 2 default_pool
success vc-asset-import_v002 create_emr_steps 2021-04-09T04:05:00+00:00 PythonOperator 2021-04-09T05:05:10.804807+00:00 2021-04-09T05:05:13.529829+00:00 0:00:02.725022 15169 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-04-09T05:05:08.660988+00:00 2 default_pool
success campaign-flow-job_v002 check_cluster_status 2021-04-09T04:00:00+00:00 EmrJobFlowSensor 2021-04-09T05:00:52.230187+00:00 2021-04-09T05:09:54.951544+00:00 0:09:02.721357 15168 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-04-09T05:00:49.983399+00:00 2 default_pool
success campaign-flow-job_v002 create_cluster_and_add_emr_steps 2021-04-09T04:00:00+00:00 EmrCreateJobFlowOperator 2021-04-09T05:00:32.119843+00:00 2021-04-09T05:00:33.867925+00:00 0:00:01.748082 15167 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 4 default 2021-04-09T05:00:29.930392+00:00 2 default_pool
success campaign-flow-job_v002 create_emr_steps 2021-04-09T04:00:00+00:00 PythonOperator 2021-04-09T05:00:10.547747+00:00 2021-04-09T05:00:13.401389+00:00 0:00:02.853642 15166 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 5 default 2021-04-09T05:00:07.909833+00:00 2 default_pool
success campaign-history-job_v002 check_cluster_status 2021-04-09T03:00:00+00:00 EmrJobFlowSensor 2021-04-09T04:12:21.535194+00:00 2021-04-09T04:21:24.172004+00:00 0:09:02.636810 15164 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-09T04:12:19.394438+00:00 2 default_pool
success booking-processing-job_v002 check_cluster_status 2021-04-09T03:00:00+00:00 EmrJobFlowSensor 2021-04-09T04:12:17.679490+00:00 2021-04-09T04:23:20.645407+00:00 0:11:02.965917 15163 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-09T04:12:15.389438+00:00 2 default_pool
success campaign-history-job_v002 create_cluster_and_add_emr_steps 2021-04-09T03:00:00+00:00 EmrCreateJobFlowOperator 2021-04-09T04:11:59.733018+00:00 2021-04-09T04:12:01.448153+00:00 0:00:01.715135 15162 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 2 default 2021-04-09T04:11:57.363068+00:00 2 default_pool
success booking-processing-job_v002 create_cluster_and_add_emr_steps 2021-04-09T03:00:00+00:00 EmrCreateJobFlowOperator 2021-04-09T04:11:55.572597+00:00 2021-04-09T04:11:57.300436+00:00 0:00:01.727839 15161 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 2 default 2021-04-09T04:11:53.296071+00:00 2 default_pool
success campaign-history-job_v002 create_emr_steps 2021-04-09T03:00:00+00:00 PythonOperator 2021-04-09T04:11:39.813388+00:00 2021-04-09T04:11:42.673261+00:00 0:00:02.859873 15160 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-04-09T04:11:37.293652+00:00 2 default_pool
success booking-processing-job_v002 create_emr_steps 2021-04-09T03:00:00+00:00 PythonOperator 2021-04-09T04:11:35.419585+00:00 2021-04-09T04:11:38.426899+00:00 0:00:03.007314 15159 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-04-09T04:11:33.262007+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_campaign-history-job_v002 2021-04-09T03:00:00+00:00 TriggerDagRunOperator 2021-04-09T04:11:19.698583+00:00 2021-04-09T04:11:20.125730+00:00 0:00:00.427147 15158 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-09T04:11:17.250341+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_booking-processing-job_v002 2021-04-09T03:00:00+00:00 TriggerDagRunOperator 2021-04-09T04:11:19.681283+00:00 2021-04-09T04:11:20.250171+00:00 0:00:00.568888 15157 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-09T04:11:17.250372+00:00 2 default_pool
success vc-asset-import_v002 check_cluster_status 2021-04-09T03:05:00+00:00 EmrJobFlowSensor 2021-04-09T04:05:46.910819+00:00 2021-04-09T04:14:49.593693+00:00 0:09:02.682874 15156 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-09T04:05:44.695981+00:00 2 default_pool
success vc-asset-import_v002 create_cluster_and_add_emr_steps 2021-04-09T03:05:00+00:00 EmrCreateJobFlowOperator 2021-04-09T04:05:26.863251+00:00 2021-04-09T04:05:28.620165+00:00 0:00:01.756914 15155 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 2 default 2021-04-09T04:05:24.632511+00:00 2 default_pool
success vc-asset-import_v002 create_emr_steps 2021-04-09T03:05:00+00:00 PythonOperator 2021-04-09T04:05:04.991728+00:00 2021-04-09T04:05:07.654227+00:00 0:00:02.662499 15154 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-04-09T04:05:02.670965+00:00 2 default_pool
success campaign-flow-job_v002 check_cluster_status 2021-04-09T03:00:00+00:00 EmrJobFlowSensor 2021-04-09T04:01:06.451758+00:00 2021-04-09T04:11:09.548992+00:00 0:10:03.097234 15153 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-04-09T04:01:04.173961+00:00 2 default_pool
success campaign-flow-job_v002 create_cluster_and_add_emr_steps 2021-04-09T03:00:00+00:00 EmrCreateJobFlowOperator 2021-04-09T04:00:44.415167+00:00 2021-04-09T04:00:46.234023+00:00 0:00:01.818856 15152 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 4 default 2021-04-09T04:00:42.091940+00:00 2 default_pool
success campaign-flow-job_v002 create_emr_steps 2021-04-09T03:00:00+00:00 PythonOperator 2021-04-09T04:00:24.622604+00:00 2021-04-09T04:00:27.503346+00:00 0:00:02.880742 15151 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 5 default 2021-04-09T04:00:22.026690+00:00 2 default_pool
success booking-processing-job_v002 check_cluster_status 2021-04-09T02:00:00+00:00 EmrJobFlowSensor 2021-04-09T03:11:28.967800+00:00 2021-04-09T03:23:31.976213+00:00 0:12:03.008413 15149 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-09T03:11:26.732535+00:00 2 default_pool
success campaign-history-job_v002 check_cluster_status 2021-04-09T02:00:00+00:00 EmrJobFlowSensor 2021-04-09T03:11:13.065081+00:00 2021-04-09T03:20:15.872970+00:00 0:09:02.807889 15148 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-09T03:11:10.726244+00:00 2 default_pool
success booking-processing-job_v002 create_cluster_and_add_emr_steps 2021-04-09T02:00:00+00:00 EmrCreateJobFlowOperator 2021-04-09T03:11:07.101151+00:00 2021-04-09T03:11:08.955325+00:00 0:00:01.854174 15147 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 2 default 2021-04-09T03:11:04.729776+00:00 2 default_pool
success campaign-history-job_v002 create_cluster_and_add_emr_steps 2021-04-09T02:00:00+00:00 EmrCreateJobFlowOperator 2021-04-09T03:10:51.114966+00:00 2021-04-09T03:10:52.845133+00:00 0:00:01.730167 15146 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 2 default 2021-04-09T03:10:48.772137+00:00 2 default_pool
success booking-processing-job_v002 create_emr_steps 2021-04-09T02:00:00+00:00 PythonOperator 2021-04-09T03:10:45.182684+00:00 2021-04-09T03:10:48.144845+00:00 0:00:02.962161 15145 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-04-09T03:10:42.754555+00:00 2 default_pool
success campaign-history-job_v002 create_emr_steps 2021-04-09T02:00:00+00:00 PythonOperator 2021-04-09T03:10:31.337335+00:00 2021-04-09T03:10:34.085319+00:00 0:00:02.747984 15144 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-04-09T03:10:28.848937+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_booking-processing-job_v002 2021-04-09T02:00:00+00:00 TriggerDagRunOperator 2021-04-09T03:10:25.055829+00:00 2021-04-09T03:10:25.530826+00:00 0:00:00.474997 15143 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-09T03:10:22.655076+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_campaign-history-job_v002 2021-04-09T02:00:00+00:00 TriggerDagRunOperator 2021-04-09T03:10:25.021872+00:00 2021-04-09T03:10:25.604240+00:00 0:00:00.582368 15142 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-09T03:10:22.655039+00:00 2 default_pool
success vc-asset-import_v002 check_cluster_status 2021-04-09T02:05:00+00:00 EmrJobFlowSensor 2021-04-09T03:05:58.270507+00:00 2021-04-09T03:16:00.969153+00:00 0:10:02.698646 15141 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-09T03:05:56.166905+00:00 2 default_pool
success vc-asset-import_v002 create_cluster_and_add_emr_steps 2021-04-09T02:05:00+00:00 EmrCreateJobFlowOperator 2021-04-09T03:05:38.396852+00:00 2021-04-09T03:05:40.151964+00:00 0:00:01.755112 15140 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 2 default 2021-04-09T03:05:36.142513+00:00 2 default_pool
success vc-asset-import_v002 create_emr_steps 2021-04-09T02:05:00+00:00 PythonOperator 2021-04-09T03:05:16.296945+00:00 2021-04-09T03:05:18.970319+00:00 0:00:02.673374 15139 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-04-09T03:05:14.124028+00:00 2 default_pool
success campaign-flow-job_v002 check_cluster_status 2021-04-09T02:00:00+00:00 EmrJobFlowSensor 2021-04-09T03:01:07.985293+00:00 2021-04-09T03:10:10.597446+00:00 0:09:02.612153 15138 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-04-09T03:01:05.725717+00:00 2 default_pool
success campaign-flow-job_v002 create_cluster_and_add_emr_steps 2021-04-09T02:00:00+00:00 EmrCreateJobFlowOperator 2021-04-09T03:00:46.209521+00:00 2021-04-09T03:00:48.052264+00:00 0:00:01.842743 15137 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 4 default 2021-04-09T03:00:43.750094+00:00 2 default_pool
success campaign-flow-job_v002 create_emr_steps 2021-04-09T02:00:00+00:00 PythonOperator 2021-04-09T03:00:24.266614+00:00 2021-04-09T03:00:26.947937+00:00 0:00:02.681323 15136 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 5 default 2021-04-09T03:00:21.743750+00:00 2 default_pool
success booking-processing-job_v002 check_cluster_status 2021-04-09T01:00:00+00:00 EmrJobFlowSensor 2021-04-09T02:10:09.518938+00:00 2021-04-09T02:20:12.230708+00:00 0:10:02.711770 15134 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-09T02:10:07.337874+00:00 2 default_pool
success campaign-history-job_v002 check_cluster_status 2021-04-09T01:00:00+00:00 EmrJobFlowSensor 2021-04-09T02:09:59.734515+00:00 2021-04-09T02:19:02.565715+00:00 0:09:02.831200 15133 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-09T02:09:57.326222+00:00 2 default_pool
success booking-processing-job_v002 create_cluster_and_add_emr_steps 2021-04-09T01:00:00+00:00 EmrCreateJobFlowOperator 2021-04-09T02:09:47.837818+00:00 2021-04-09T02:09:49.610441+00:00 0:00:01.772623 15132 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 2 default 2021-04-09T02:09:45.364268+00:00 2 default_pool
success campaign-history-job_v002 create_cluster_and_add_emr_steps 2021-04-09T01:00:00+00:00 EmrCreateJobFlowOperator 2021-04-09T02:09:37.501933+00:00 2021-04-09T02:09:39.152086+00:00 0:00:01.650153 15131 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 2 default 2021-04-09T02:09:35.313920+00:00 2 default_pool
success booking-processing-job_v002 create_emr_steps 2021-04-09T01:00:00+00:00 PythonOperator 2021-04-09T02:09:27.743824+00:00 2021-04-09T02:09:30.783671+00:00 0:00:03.039847 15130 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-04-09T02:09:25.371037+00:00 2 default_pool
success campaign-history-job_v002 create_emr_steps 2021-04-09T01:00:00+00:00 PythonOperator 2021-04-09T02:09:17.558789+00:00 2021-04-09T02:09:20.304949+00:00 0:00:02.746160 15129 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-04-09T02:09:15.292254+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_campaign-history-job_v002 2021-04-09T01:00:00+00:00 TriggerDagRunOperator 2021-04-09T02:09:03.890452+00:00 2021-04-09T02:09:04.414033+00:00 0:00:00.523581 15128 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-09T02:09:01.274230+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_booking-processing-job_v002 2021-04-09T01:00:00+00:00 TriggerDagRunOperator 2021-04-09T02:09:03.500958+00:00 2021-04-09T02:09:03.911948+00:00 0:00:00.410990 15127 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-09T02:09:01.274265+00:00 2 default_pool
success vc-asset-import_v002 check_cluster_status 2021-04-09T01:05:00+00:00 EmrJobFlowSensor 2021-04-09T02:06:01.233532+00:00 2021-04-09T02:15:03.891589+00:00 0:09:02.658057 15126 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-09T02:05:58.986929+00:00 2 default_pool
success vc-asset-import_v002 create_cluster_and_add_emr_steps 2021-04-09T01:05:00+00:00 EmrCreateJobFlowOperator 2021-04-09T02:05:39.041692+00:00 2021-04-09T02:05:40.717574+00:00 0:00:01.675882 15125 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 2 default 2021-04-09T02:05:36.888672+00:00 2 default_pool
success vc-asset-import_v002 create_emr_steps 2021-04-09T01:05:00+00:00 PythonOperator 2021-04-09T02:05:19.139051+00:00 2021-04-09T02:05:21.946627+00:00 0:00:02.807576 15124 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-04-09T02:05:16.855316+00:00 2 default_pool
success campaign-flow-job_v002 check_cluster_status 2021-04-09T01:00:00+00:00 EmrJobFlowSensor 2021-04-09T02:00:55.022812+00:00 2021-04-09T02:08:57.621203+00:00 0:08:02.598391 15123 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-04-09T02:00:52.458160+00:00 2 default_pool
success campaign-flow-job_v002 create_cluster_and_add_emr_steps 2021-04-09T01:00:00+00:00 EmrCreateJobFlowOperator 2021-04-09T02:00:34.858194+00:00 2021-04-09T02:00:36.552874+00:00 0:00:01.694680 15122 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 4 default 2021-04-09T02:00:32.442721+00:00 2 default_pool
success campaign-flow-job_v002 create_emr_steps 2021-04-09T01:00:00+00:00 PythonOperator 2021-04-09T02:00:13.033930+00:00 2021-04-09T02:00:15.872045+00:00 0:00:02.838115 15121 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 5 default 2021-04-09T02:00:10.263626+00:00 2 default_pool
success campaign-history-job_v002 check_cluster_status 2021-04-09T00:00:00+00:00 EmrJobFlowSensor 2021-04-09T01:12:09.887669+00:00 2021-04-09T01:22:12.828811+00:00 0:10:02.941142 15119 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-09T01:12:07.281531+00:00 2 default_pool
success booking-processing-job_v002 check_cluster_status 2021-04-09T00:00:00+00:00 EmrJobFlowSensor 2021-04-09T01:12:01.624461+00:00 2021-04-09T01:21:04.277466+00:00 0:09:02.653005 15118 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-09T01:11:59.246460+00:00 2 default_pool
success campaign-history-job_v002 create_cluster_and_add_emr_steps 2021-04-09T00:00:00+00:00 EmrCreateJobFlowOperator 2021-04-09T01:11:47.645882+00:00 2021-04-09T01:11:49.522081+00:00 0:00:01.876199 15117 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 2 default 2021-04-09T01:11:45.186817+00:00 2 default_pool
success booking-processing-job_v002 create_cluster_and_add_emr_steps 2021-04-09T00:00:00+00:00 EmrCreateJobFlowOperator 2021-04-09T01:11:39.412067+00:00 2021-04-09T01:11:41.121881+00:00 0:00:01.709814 15116 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 2 default 2021-04-09T01:11:37.128037+00:00 2 default_pool
success campaign-history-job_v002 create_emr_steps 2021-04-09T00:00:00+00:00 PythonOperator 2021-04-09T01:11:27.406992+00:00 2021-04-09T01:11:30.284201+00:00 0:00:02.877209 15115 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-04-09T01:11:25.081889+00:00 2 default_pool
success booking-processing-job_v002 create_emr_steps 2021-04-09T00:00:00+00:00 PythonOperator 2021-04-09T01:11:19.275767+00:00 2021-04-09T01:11:22.159585+00:00 0:00:02.883818 15114 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-04-09T01:11:17.049702+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_booking-processing-job_v002 2021-04-09T00:00:00+00:00 TriggerDagRunOperator 2021-04-09T01:11:13.589050+00:00 2021-04-09T01:11:14.049202+00:00 0:00:00.460152 15113 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-09T01:11:11.050618+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_campaign-history-job_v002 2021-04-09T00:00:00+00:00 TriggerDagRunOperator 2021-04-09T01:11:13.514524+00:00 2021-04-09T01:11:14.162968+00:00 0:00:00.648444 15112 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-09T01:11:11.050591+00:00 2 default_pool
success vc-asset-import_v002 check_cluster_status 2021-04-09T00:05:00+00:00 EmrJobFlowSensor 2021-04-09T01:05:56.712019+00:00 2021-04-09T01:14:59.415316+00:00 0:09:02.703297 15111 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-09T01:05:54.506745+00:00 2 default_pool
success vc-asset-import_v002 create_cluster_and_add_emr_steps 2021-04-09T00:05:00+00:00 EmrCreateJobFlowOperator 2021-04-09T01:05:34.807505+00:00 2021-04-09T01:05:36.450691+00:00 0:00:01.643186 15110 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 2 default 2021-04-09T01:05:32.547123+00:00 2 default_pool
success vc-asset-import_v002 create_emr_steps 2021-04-09T00:05:00+00:00 PythonOperator 2021-04-09T01:05:14.581991+00:00 2021-04-09T01:05:17.273954+00:00 0:00:02.691963 15109 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-04-09T01:05:12.334772+00:00 2 default_pool
success campaign-flow-job_v002 check_cluster_status 2021-04-09T00:00:00+00:00 EmrJobFlowSensor 2021-04-09T01:00:58.166523+00:00 2021-04-09T01:11:01.032259+00:00 0:10:02.865736 15108 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-04-09T01:00:55.910840+00:00 2 default_pool
success campaign-flow-job_v002 create_cluster_and_add_emr_steps 2021-04-09T00:00:00+00:00 EmrCreateJobFlowOperator 2021-04-09T01:00:36.144249+00:00 2021-04-09T01:00:37.928153+00:00 0:00:01.783904 15107 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 4 default 2021-04-09T01:00:33.888765+00:00 2 default_pool
success campaign-flow-job_v002 create_emr_steps 2021-04-09T00:00:00+00:00 PythonOperator 2021-04-09T01:00:16.820113+00:00 2021-04-09T01:00:19.522336+00:00 0:00:02.702223 15106 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 5 default 2021-04-09T01:00:13.762819+00:00 2 default_pool
success booking-processing-job_v002 check_cluster_status 2021-04-08T23:00:00+00:00 EmrJobFlowSensor 2021-04-09T00:10:10.008098+00:00 2021-04-09T00:20:12.794282+00:00 0:10:02.786184 15104 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-09T00:10:07.736436+00:00 2 default_pool
success campaign-history-job_v002 check_cluster_status 2021-04-08T23:00:00+00:00 EmrJobFlowSensor 2021-04-09T00:09:56.134760+00:00 2021-04-09T00:17:58.604496+00:00 0:08:02.469736 15103 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-09T00:09:53.855075+00:00 2 default_pool
success booking-processing-job_v002 create_cluster_and_add_emr_steps 2021-04-08T23:00:00+00:00 EmrCreateJobFlowOperator 2021-04-09T00:09:48.132329+00:00 2021-04-09T00:09:49.853986+00:00 0:00:01.721657 15102 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 2 default 2021-04-09T00:09:45.779234+00:00 2 default_pool
success campaign-history-job_v002 create_cluster_and_add_emr_steps 2021-04-08T23:00:00+00:00 EmrCreateJobFlowOperator 2021-04-09T00:09:33.953129+00:00 2021-04-09T00:09:35.631614+00:00 0:00:01.678485 15101 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 2 default 2021-04-09T00:09:31.704883+00:00 2 default_pool
success booking-processing-job_v002 create_emr_steps 2021-04-08T23:00:00+00:00 PythonOperator 2021-04-09T00:09:28.121628+00:00 2021-04-09T00:09:31.036077+00:00 0:00:02.914449 15100 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-04-09T00:09:25.713161+00:00 2 default_pool
success campaign-history-job_v002 create_emr_steps 2021-04-08T23:00:00+00:00 PythonOperator 2021-04-09T00:09:11.923246+00:00 2021-04-09T00:09:14.687707+00:00 0:00:02.764461 15099 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-04-09T00:09:09.687631+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_campaign-history-job_v002 2021-04-08T23:00:00+00:00 TriggerDagRunOperator 2021-04-09T00:09:06.106899+00:00 2021-04-09T00:09:06.545387+00:00 0:00:00.438488 15098 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-09T00:09:03.678749+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_booking-processing-job_v002 2021-04-08T23:00:00+00:00 TriggerDagRunOperator 2021-04-09T00:09:05.976528+00:00 2021-04-09T00:09:06.614499+00:00 0:00:00.637971 15097 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-09T00:09:03.678782+00:00 2 default_pool
success vc-asset-import_v002 check_cluster_status 2021-04-08T23:05:00+00:00 EmrJobFlowSensor 2021-04-09T00:05:49.897909+00:00 2021-04-09T00:14:52.472016+00:00 0:09:02.574107 15096 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-09T00:05:47.366368+00:00 2 default_pool
success vc-asset-import_v002 create_cluster_and_add_emr_steps 2021-04-08T23:05:00+00:00 EmrCreateJobFlowOperator 2021-04-09T00:05:29.857806+00:00 2021-04-09T00:05:31.521946+00:00 0:00:01.664140 15095 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 2 default 2021-04-09T00:05:27.369361+00:00 2 default_pool
success vc-asset-import_v002 create_emr_steps 2021-04-08T23:05:00+00:00 PythonOperator 2021-04-09T00:05:05.665826+00:00 2021-04-09T00:05:08.344013+00:00 0:00:02.678187 15094 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-04-09T00:05:03.284559+00:00 2 default_pool
success campaign-flow-job_v002 check_cluster_status 2021-04-08T23:00:00+00:00 EmrJobFlowSensor 2021-04-09T00:00:47.081544+00:00 2021-04-09T00:08:49.701051+00:00 0:08:02.619507 15093 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-04-09T00:00:44.799181+00:00 2 default_pool
success campaign-flow-job_v002 create_cluster_and_add_emr_steps 2021-04-08T23:00:00+00:00 EmrCreateJobFlowOperator 2021-04-09T00:00:24.879056+00:00 2021-04-09T00:00:26.561157+00:00 0:00:01.682101 15092 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 4 default 2021-04-09T00:00:22.708498+00:00 2 default_pool
success campaign-flow-job_v002 create_emr_steps 2021-04-08T23:00:00+00:00 PythonOperator 2021-04-09T00:00:05.328628+00:00 2021-04-09T00:00:08.207131+00:00 0:00:02.878503 15091 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 5 default 2021-04-09T00:00:02.698983+00:00 2 default_pool
success booking-processing-job_v002 check_cluster_status 2021-04-08T22:00:00+00:00 EmrJobFlowSensor 2021-04-08T23:11:11.604549+00:00 2021-04-08T23:21:14.460458+00:00 0:10:02.855909 15089 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-08T23:11:09.043623+00:00 2 default_pool