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 booking-processing-job_v002 create_emr_steps 2021-05-06T22:00:00+00:00 PythonOperator 2021-05-06T23:10:51.921682+00:00 2021-05-06T23:10:55.195996+00:00 0:00:03.274314 25259 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-05-06T23:10:49.741935+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_booking-processing-job_v002 2021-05-06T22:00:00+00:00 TriggerDagRunOperator 2021-05-06T23:10:28.175139+00:00 2021-05-06T23:10:28.786368+00:00 0:00:00.611229 25258 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-05-06T23:10:25.725928+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_campaign-history-job_v002 2021-05-06T22:00:00+00:00 TriggerDagRunOperator 2021-05-06T23:10:27.956640+00:00 2021-05-06T23:10:28.412291+00:00 0:00:00.455651 25257 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-05-06T23:10:25.725882+00:00 2 default_pool
success vc-asset-import_v002 create_cluster_and_add_emr_steps 2021-05-06T22:05:00+00:00 EmrCreateJobFlowOperator 2021-05-06T23:05:31.507453+00:00 2021-05-06T23:05:33.307266+00:00 0:00:01.799813 25255 airflow-worker-2.airflow-worker.bigdata.svc.cluster.local airflow 2 default 2021-05-06T23:05:29.151801+00:00 2 default_pool
success vc-asset-import_v002 create_emr_steps 2021-05-06T22:05:00+00:00 PythonOperator 2021-05-06T23:05:09.469845+00:00 2021-05-06T23:05:12.319736+00:00 0:00:02.849891 25254 airflow-worker-2.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-05-06T23:05:07.094918+00:00 2 default_pool
success campaign-delta-past-delete-job_v002 check_cluster_status 2021-05-05T23:00:00+00:00 EmrJobFlowSensor 2021-05-06T23:01:04.798076+00:00 2021-05-06T23:09:07.204481+00:00 0:08:02.406405 25253 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-05-06T23:01:02.587508+00:00 2 default_pool
success campaign-flow-job_v002 check_cluster_status 2021-05-06T22:00:00+00:00 EmrJobFlowSensor 2021-05-06T23:01:01.186199+00:00 2021-05-06T23:10:04.092791+00:00 0:09:02.906592 25252 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-05-06T23:00:58.667620+00:00 2 default_pool
success campaign-delta-past-delete-job_v002 create_cluster_and_add_emr_steps 2021-05-05T23:00:00+00:00 EmrCreateJobFlowOperator 2021-05-06T23:00:42.616850+00:00 2021-05-06T23:00:44.275559+00:00 0:00:01.658709 25251 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 2 default 2021-05-06T23:00:40.519219+00:00 2 default_pool
success campaign-flow-job_v002 create_cluster_and_add_emr_steps 2021-05-06T22:00:00+00:00 EmrCreateJobFlowOperator 2021-05-06T23:00:38.775880+00:00 2021-05-06T23:00:40.474148+00:00 0:00:01.698268 25250 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 4 default 2021-05-06T23:00:36.571342+00:00 2 default_pool
success campaign-delta-past-delete-job_v002 create_emr_steps 2021-05-05T23:00:00+00:00 PythonOperator 2021-05-06T23:00:20.961081+00:00 2021-05-06T23:00:24.097209+00:00 0:00:03.136128 25249 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-05-06T23:00:18.563405+00:00 2 default_pool
success campaign-flow-job_v002 create_emr_steps 2021-05-06T22:00:00+00:00 PythonOperator 2021-05-06T23:00:17.082039+00:00 2021-05-06T23:00:20.163242+00:00 0:00:03.081203 25248 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 5 default 2021-05-06T23:00:14.544110+00:00 2 default_pool
success booking-processing-job_v002 check_cluster_status 2021-05-06T21:00:00+00:00 EmrJobFlowSensor 2021-05-06T22:11:08.795185+00:00 2021-05-06T22:21:11.670639+00:00 0:10:02.875454 25246 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-05-06T22:11:06.470139+00:00 2 default_pool
success campaign-history-job_v002 check_cluster_status 2021-05-06T21:00:00+00:00 EmrJobFlowSensor 2021-05-06T22:11:08.681827+00:00 2021-05-06T22:19:11.379471+00:00 0:08:02.697644 25245 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-05-06T22:11:06.470100+00:00 2 default_pool
success booking-processing-job_v002 create_cluster_and_add_emr_steps 2021-05-06T21:00:00+00:00 EmrCreateJobFlowOperator 2021-05-06T22:10:46.746148+00:00 2021-05-06T22:10:48.568783+00:00 0:00:01.822635 25244 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 2 default 2021-05-06T22:10:44.445706+00:00 2 default_pool
success campaign-history-job_v002 create_cluster_and_add_emr_steps 2021-05-06T21:00:00+00:00 EmrCreateJobFlowOperator 2021-05-06T22:10:46.593335+00:00 2021-05-06T22:10:48.312944+00:00 0:00:01.719609 25243 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 2 default 2021-05-06T22:10:44.445680+00:00 2 default_pool
success campaign-history-job_v002 create_emr_steps 2021-05-06T21:00:00+00:00 PythonOperator 2021-05-06T22:10:24.954674+00:00 2021-05-06T22:10:28.072969+00:00 0:00:03.118295 25242 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-05-06T22:10:22.558822+00:00 2 default_pool
success booking-processing-job_v002 create_emr_steps 2021-05-06T21:00:00+00:00 PythonOperator 2021-05-06T22:10:24.985392+00:00 2021-05-06T22:10:28.310390+00:00 0:00:03.324998 25241 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-05-06T22:10:22.558851+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_booking-processing-job_v002 2021-05-06T21:00:00+00:00 TriggerDagRunOperator 2021-05-06T22:10:15.016027+00:00 2021-05-06T22:10:15.543373+00:00 0:00:00.527346 25240 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-05-06T22:10:12.481798+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_campaign-history-job_v002 2021-05-06T21:00:00+00:00 TriggerDagRunOperator 2021-05-06T22:10:14.674020+00:00 2021-05-06T22:10:15.095508+00:00 0:00:00.421488 25239 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-05-06T22:10:12.481733+00:00 2 default_pool
success vc-asset-import_v002 check_cluster_status 2021-05-06T21:05:00+00:00 EmrJobFlowSensor 2021-05-06T22:06:04.451138+00:00 2021-05-06T22:14:07.021510+00:00 0:08:02.570372 25238 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-05-06T22:06:02.016208+00:00 2 default_pool
success vc-asset-import_v002 create_cluster_and_add_emr_steps 2021-05-06T21:05:00+00:00 EmrCreateJobFlowOperator 2021-05-06T22:05:42.050663+00:00 2021-05-06T22:05:43.706245+00:00 0:00:01.655582 25237 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 2 default 2021-05-06T22:05:39.993772+00:00 2 default_pool
success vc-asset-import_v002 create_emr_steps 2021-05-06T21:05:00+00:00 PythonOperator 2021-05-06T22:05:20.301102+00:00 2021-05-06T22:05:23.354880+00:00 0:00:03.053778 25236 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-05-06T22:05:17.932087+00:00 2 default_pool
success campaign-flow-job_v002 check_cluster_status 2021-05-06T21:00:00+00:00 EmrJobFlowSensor 2021-05-06T22:00:49.599440+00:00 2021-05-06T22:09:52.402222+00:00 0:09:02.802782 25235 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-05-06T22:00:47.416561+00:00 2 default_pool
success campaign-flow-job_v002 create_cluster_and_add_emr_steps 2021-05-06T21:00:00+00:00 EmrCreateJobFlowOperator 2021-05-06T22:00:27.582379+00:00 2021-05-06T22:00:29.299702+00:00 0:00:01.717323 25234 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 4 default 2021-05-06T22:00:25.400494+00:00 2 default_pool
success campaign-flow-job_v002 create_emr_steps 2021-05-06T21:00:00+00:00 PythonOperator 2021-05-06T22:00:05.895374+00:00 2021-05-06T22:00:08.985402+00:00 0:00:03.090028 25233 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 5 default 2021-05-06T22:00:03.444481+00:00 2 default_pool
success campaign-history-job_v002 check_cluster_status 2021-05-06T20:00:00+00:00 EmrJobFlowSensor 2021-05-06T21:11:07.639999+00:00 2021-05-06T21:24:10.878194+00:00 0:13:03.238195 25231 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-05-06T21:11:05.142663+00:00 2 default_pool
success booking-processing-job_v002 check_cluster_status 2021-05-06T20:00:00+00:00 EmrJobFlowSensor 2021-05-06T21:11:07.485504+00:00 2021-05-06T21:21:10.300350+00:00 0:10:02.814846 25230 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-05-06T21:11:05.142615+00:00 2 default_pool
success booking-processing-job_v002 create_cluster_and_add_emr_steps 2021-05-06T20:00:00+00:00 EmrCreateJobFlowOperator 2021-05-06T21:10:47.288362+00:00 2021-05-06T21:10:49.093140+00:00 0:00:01.804778 25229 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 2 default 2021-05-06T21:10:44.997614+00:00 2 default_pool
success campaign-history-job_v002 create_cluster_and_add_emr_steps 2021-05-06T20:00:00+00:00 EmrCreateJobFlowOperator 2021-05-06T21:10:47.239869+00:00 2021-05-06T21:10:48.986119+00:00 0:00:01.746250 25228 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 2 default 2021-05-06T21:10:44.997661+00:00 2 default_pool
success campaign-history-job_v002 create_emr_steps 2021-05-06T20:00:00+00:00 PythonOperator 2021-05-06T21:10:25.671230+00:00 2021-05-06T21:10:28.822678+00:00 0:00:03.151448 25227 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-05-06T21:10:22.929044+00:00 2 default_pool
success booking-processing-job_v002 create_emr_steps 2021-05-06T20:00:00+00:00 PythonOperator 2021-05-06T21:10:25.680088+00:00 2021-05-06T21:10:28.957264+00:00 0:00:03.277176 25226 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-05-06T21:10:22.929076+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_booking-processing-job_v002 2021-05-06T20:00:00+00:00 TriggerDagRunOperator 2021-05-06T21:10:17.314726+00:00 2021-05-06T21:10:17.742583+00:00 0:00:00.427857 25225 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-05-06T21:10:14.923952+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_campaign-history-job_v002 2021-05-06T20:00:00+00:00 TriggerDagRunOperator 2021-05-06T21:10:17.176407+00:00 2021-05-06T21:10:17.734310+00:00 0:00:00.557903 25224 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-05-06T21:10:14.923914+00:00 2 default_pool
success vc-asset-import_v002 check_cluster_status 2021-05-06T20:05:00+00:00 EmrJobFlowSensor 2021-05-06T21:05:58.767418+00:00 2021-05-06T21:15:01.417028+00:00 0:09:02.649610 25223 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-05-06T21:05:56.520741+00:00 2 default_pool
success vc-asset-import_v002 create_cluster_and_add_emr_steps 2021-05-06T20:05:00+00:00 EmrCreateJobFlowOperator 2021-05-06T21:05:36.781214+00:00 2021-05-06T21:05:38.505093+00:00 0:00:01.723879 25222 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 2 default 2021-05-06T21:05:34.501798+00:00 2 default_pool
success vc-asset-import_v002 create_emr_steps 2021-05-06T20:05:00+00:00 PythonOperator 2021-05-06T21:05:16.527443+00:00 2021-05-06T21:05:19.558639+00:00 0:00:03.031196 25221 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-05-06T21:05:14.423138+00:00 2 default_pool
success campaign-flow-job_v002 check_cluster_status 2021-05-06T20:00:00+00:00 EmrJobFlowSensor 2021-05-06T21:00:58.111182+00:00 2021-05-06T21:10:00.770880+00:00 0:09:02.659698 25220 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-05-06T21:00:56.008452+00:00 2 default_pool
success campaign-flow-job_v002 create_cluster_and_add_emr_steps 2021-05-06T20:00:00+00:00 EmrCreateJobFlowOperator 2021-05-06T21:00:36.276560+00:00 2021-05-06T21:00:38.060265+00:00 0:00:01.783705 25219 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 4 default 2021-05-06T21:00:33.991884+00:00 2 default_pool
success campaign-flow-job_v002 create_emr_steps 2021-05-06T20:00:00+00:00 PythonOperator 2021-05-06T21:00:16.212137+00:00 2021-05-06T21:00:19.279012+00:00 0:00:03.066875 25218 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 5 default 2021-05-06T21:00:13.982074+00:00 2 default_pool
success booking-processing-job_v002 check_cluster_status 2021-05-06T19:00:00+00:00 EmrJobFlowSensor 2021-05-06T20:24:31.175839+00:00 2021-05-06T20:24:32.666374+00:00 0:00:01.490535 25217 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-05-06T20:24:28.244323+00:00 3 default_pool
success campaign-history-job_v002 check_cluster_status 2021-05-06T19:00:00+00:00 EmrJobFlowSensor 2021-05-06T20:12:25.073016+00:00 2021-05-06T20:22:27.751361+00:00 0:10:02.678345 25214 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-05-06T20:12:22.885389+00:00 2 default_pool
success booking-processing-job_v002 create_cluster_and_add_emr_steps 2021-05-06T19:00:00+00:00 EmrCreateJobFlowOperator 2021-05-06T20:12:21.137077+00:00 2021-05-06T20:12:22.949378+00:00 0:00:01.812301 25213 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 2 default 2021-05-06T20:12:18.901162+00:00 2 default_pool
success campaign-history-job_v002 create_cluster_and_add_emr_steps 2021-05-06T19:00:00+00:00 EmrCreateJobFlowOperator 2021-05-06T20:12:02.990223+00:00 2021-05-06T20:12:04.705911+00:00 0:00:01.715688 25212 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 2 default 2021-05-06T20:12:00.825642+00:00 2 default_pool
success booking-processing-job_v002 create_emr_steps 2021-05-06T19:00:00+00:00 PythonOperator 2021-05-06T20:11:48.982384+00:00 2021-05-06T20:11:52.265073+00:00 0:00:03.282689 25211 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-05-06T20:11:46.811262+00:00 2 default_pool
success campaign-history-job_v002 create_emr_steps 2021-05-06T19:00:00+00:00 PythonOperator 2021-05-06T20:11:39.109804+00:00 2021-05-06T20:11:42.135638+00:00 0:00:03.025834 25210 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-05-06T20:11:36.817129+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_campaign-history-job_v002 2021-05-06T19:00:00+00:00 TriggerDagRunOperator 2021-05-06T20:11:27.047207+00:00 2021-05-06T20:11:27.547322+00:00 0:00:00.500115 25209 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-05-06T20:11:24.792211+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_booking-processing-job_v002 2021-05-06T19:00:00+00:00 TriggerDagRunOperator 2021-05-06T20:11:26.883260+00:00 2021-05-06T20:11:27.349489+00:00 0:00:00.466229 25208 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-05-06T20:11:24.792247+00:00 2 default_pool
success vc-asset-import_v002 check_cluster_status 2021-05-06T19:05:00+00:00 EmrJobFlowSensor 2021-05-06T20:06:02.419078+00:00 2021-05-06T20:14:05.089845+00:00 0:08:02.670767 25207 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-05-06T20:06:00.216940+00:00 2 default_pool
success vc-asset-import_v002 create_cluster_and_add_emr_steps 2021-05-06T19:05:00+00:00 EmrCreateJobFlowOperator 2021-05-06T20:05:40.281453+00:00 2021-05-06T20:05:41.919263+00:00 0:00:01.637810 25206 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 2 default 2021-05-06T20:05:38.193852+00:00 2 default_pool
success vc-asset-import_v002 create_emr_steps 2021-05-06T19:05:00+00:00 PythonOperator 2021-05-06T20:05:14.420712+00:00 2021-05-06T20:05:17.403288+00:00 0:00:02.982576 25205 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-05-06T20:05:12.143294+00:00 2 default_pool
success campaign-flow-job_v002 check_cluster_status 2021-05-06T19:00:00+00:00 EmrJobFlowSensor 2021-05-06T20:01:03.903347+00:00 2021-05-06T20:11:06.742154+00:00 0:10:02.838807 25204 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-05-06T20:01:01.802294+00:00 2 default_pool
success campaign-flow-job_v002 create_cluster_and_add_emr_steps 2021-05-06T19:00:00+00:00 EmrCreateJobFlowOperator 2021-05-06T20:00:42.020320+00:00 2021-05-06T20:00:43.827350+00:00 0:00:01.807030 25203 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 4 default 2021-05-06T20:00:39.792834+00:00 2 default_pool
success campaign-flow-job_v002 create_emr_steps 2021-05-06T19:00:00+00:00 PythonOperator 2021-05-06T20:00:22.029947+00:00 2021-05-06T20:00:25.272958+00:00 0:00:03.243011 25202 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 5 default 2021-05-06T20:00:19.686500+00:00 2 default_pool
success campaign-history-job_v002 check_cluster_status 2021-05-06T18:00:00+00:00 EmrJobFlowSensor 2021-05-06T19:11:16.080400+00:00 2021-05-06T19:20:18.737456+00:00 0:09:02.657056 25200 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-05-06T19:11:13.891141+00:00 2 default_pool
success booking-processing-job_v002 check_cluster_status 2021-05-06T18:00:00+00:00 EmrJobFlowSensor 2021-05-06T19:11:08.007222+00:00 2021-05-06T19:21:11.145444+00:00 0:10:03.138222 25199 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-05-06T19:11:05.826167+00:00 2 default_pool
success campaign-history-job_v002 create_cluster_and_add_emr_steps 2021-05-06T18:00:00+00:00 EmrCreateJobFlowOperator 2021-05-06T19:10:56.182043+00:00 2021-05-06T19:10:58.111882+00:00 0:00:01.929839 25198 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 2 default 2021-05-06T19:10:53.818249+00:00 2 default_pool
success booking-processing-job_v002 create_cluster_and_add_emr_steps 2021-05-06T18:00:00+00:00 EmrCreateJobFlowOperator 2021-05-06T19:10:45.879754+00:00 2021-05-06T19:10:47.597008+00:00 0:00:01.717254 25197 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 2 default 2021-05-06T19:10:43.810031+00:00 2 default_pool
success campaign-history-job_v002 create_emr_steps 2021-05-06T18:00:00+00:00 PythonOperator 2021-05-06T19:10:34.791569+00:00 2021-05-06T19:10:37.848441+00:00 0:00:03.056872 25196 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-05-06T19:10:31.862931+00:00 2 default_pool
success booking-processing-job_v002 create_emr_steps 2021-05-06T18:00:00+00:00 PythonOperator 2021-05-06T19:10:26.535155+00:00 2021-05-06T19:10:29.970784+00:00 0:00:03.435629 25195 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-05-06T19:10:23.875675+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_campaign-history-job_v002 2021-05-06T18:00:00+00:00 TriggerDagRunOperator 2021-05-06T19:10:12.151464+00:00 2021-05-06T19:10:12.741262+00:00 0:00:00.589798 25194 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-05-06T19:10:09.790198+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_booking-processing-job_v002 2021-05-06T18:00:00+00:00 TriggerDagRunOperator 2021-05-06T19:10:11.979684+00:00 2021-05-06T19:10:12.406034+00:00 0:00:00.426350 25193 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-05-06T19:10:09.790232+00:00 2 default_pool
success vc-asset-import_v002 check_cluster_status 2021-05-06T18:05:00+00:00 EmrJobFlowSensor 2021-05-06T19:06:03.585820+00:00 2021-05-06T19:14:06.211628+00:00 0:08:02.625808 25192 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-05-06T19:06:01.389867+00:00 2 default_pool
success vc-asset-import_v002 create_cluster_and_add_emr_steps 2021-05-06T18:05:00+00:00 EmrCreateJobFlowOperator 2021-05-06T19:05:41.388752+00:00 2021-05-06T19:05:43.012311+00:00 0:00:01.623559 25191 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 2 default 2021-05-06T19:05:39.330306+00:00 2 default_pool
success vc-asset-import_v002 create_emr_steps 2021-05-06T18:05:00+00:00 PythonOperator 2021-05-06T19:05:21.365674+00:00 2021-05-06T19:05:24.394973+00:00 0:00:03.029299 25190 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-05-06T19:05:19.313329+00:00 2 default_pool
success campaign-flow-job_v002 check_cluster_status 2021-05-06T18:00:00+00:00 EmrJobFlowSensor 2021-05-06T19:01:03.194832+00:00 2021-05-06T19:10:06.040755+00:00 0:09:02.845923 25189 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-05-06T19:01:00.908244+00:00 2 default_pool
success campaign-flow-job_v002 create_cluster_and_add_emr_steps 2021-05-06T18:00:00+00:00 EmrCreateJobFlowOperator 2021-05-06T19:00:40.998654+00:00 2021-05-06T19:00:42.737940+00:00 0:00:01.739286 25188 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 4 default 2021-05-06T19:00:38.890073+00:00 2 default_pool
success campaign-flow-job_v002 create_emr_steps 2021-05-06T18:00:00+00:00 PythonOperator 2021-05-06T19:00:19.856992+00:00 2021-05-06T19:00:22.960090+00:00 0:00:03.103098 25187 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 5 default 2021-05-06T19:00:16.859582+00:00 2 default_pool
success campaign-history-job_v002 check_cluster_status 2021-05-06T17:00:00+00:00 EmrJobFlowSensor 2021-05-06T18:11:24.715282+00:00 2021-05-06T18:19:27.245343+00:00 0:08:02.530061 25185 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-05-06T18:11:22.508912+00:00 2 default_pool
success booking-processing-job_v002 check_cluster_status 2021-05-06T17:00:00+00:00 EmrJobFlowSensor 2021-05-06T18:11:20.662497+00:00 2021-05-06T18:20:23.458715+00:00 0:09:02.796218 25184 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-05-06T18:11:18.504817+00:00 2 default_pool
success campaign-history-job_v002 create_cluster_and_add_emr_steps 2021-05-06T17:00:00+00:00 EmrCreateJobFlowOperator 2021-05-06T18:11:02.693620+00:00 2021-05-06T18:11:04.394159+00:00 0:00:01.700539 25183 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 2 default 2021-05-06T18:11:00.487830+00:00 2 default_pool
success booking-processing-job_v002 create_cluster_and_add_emr_steps 2021-05-06T17:00:00+00:00 EmrCreateJobFlowOperator 2021-05-06T18:11:00.931180+00:00 2021-05-06T18:11:02.819799+00:00 0:00:01.888619 25182 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 2 default 2021-05-06T18:10:58.548187+00:00 2 default_pool
success campaign-history-job_v002 create_emr_steps 2021-05-06T17:00:00+00:00 PythonOperator 2021-05-06T18:10:41.454538+00:00 2021-05-06T18:10:44.592839+00:00 0:00:03.138301 25181 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-05-06T18:10:38.442170+00:00 2 default_pool
success booking-processing-job_v002 create_emr_steps 2021-05-06T17:00:00+00:00 PythonOperator 2021-05-06T18:10:39.493503+00:00 2021-05-06T18:10:43.112251+00:00 0:00:03.618748 25180 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-05-06T18:10:36.436216+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_campaign-history-job_v002 2021-05-06T17:00:00+00:00 TriggerDagRunOperator 2021-05-06T18:10:31.000777+00:00 2021-05-06T18:10:31.554734+00:00 0:00:00.553957 25179 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-05-06T18:10:28.558675+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_booking-processing-job_v002 2021-05-06T17:00:00+00:00 TriggerDagRunOperator 2021-05-06T18:10:30.861128+00:00 2021-05-06T18:10:31.308978+00:00 0:00:00.447850 25178 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-05-06T18:10:28.558725+00:00 2 default_pool
success vc-asset-import_v002 check_cluster_status 2021-05-06T17:05:00+00:00 EmrJobFlowSensor 2021-05-06T18:06:20.358929+00:00 2021-05-06T18:15:22.930408+00:00 0:09:02.571479 25177 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-05-06T18:06:18.106386+00:00 2 default_pool
success vc-asset-import_v002 create_cluster_and_add_emr_steps 2021-05-06T17:05:00+00:00 EmrCreateJobFlowOperator 2021-05-06T18:05:58.511765+00:00 2021-05-06T18:06:00.225966+00:00 0:00:01.714201 25176 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 2 default 2021-05-06T18:05:56.146850+00:00 2 default_pool
success vc-asset-import_v002 create_emr_steps 2021-05-06T17:05:00+00:00 PythonOperator 2021-05-06T18:05:30.241940+00:00 2021-05-06T18:05:33.253870+00:00 0:00:03.011930 25175 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-05-06T18:05:28.068035+00:00 2 default_pool
success campaign-flow-job_v002 check_cluster_status 2021-05-06T17:00:00+00:00 EmrJobFlowSensor 2021-05-06T18:01:03.782285+00:00 2021-05-06T18:10:06.526139+00:00 0:09:02.743854 25174 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-05-06T18:01:01.684509+00:00 2 default_pool
success campaign-flow-job_v002 create_cluster_and_add_emr_steps 2021-05-06T17:00:00+00:00 EmrCreateJobFlowOperator 2021-05-06T18:00:41.794519+00:00 2021-05-06T18:00:43.471589+00:00 0:00:01.677070 25173 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 4 default 2021-05-06T18:00:39.644286+00:00 2 default_pool
success campaign-flow-job_v002 create_emr_steps 2021-05-06T17:00:00+00:00 PythonOperator 2021-05-06T18:00:19.969897+00:00 2021-05-06T18:00:23.130190+00:00 0:00:03.160293 25172 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 5 default 2021-05-06T18:00:17.596857+00:00 2 default_pool
success booking-processing-job_v002 check_cluster_status 2021-05-06T16:00:00+00:00 EmrJobFlowSensor 2021-05-06T17:11:12.200263+00:00 2021-05-06T17:21:15.046544+00:00 0:10:02.846281 25170 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-05-06T17:11:10.045283+00:00 2 default_pool
success campaign-history-job_v002 check_cluster_status 2021-05-06T16:00:00+00:00 EmrJobFlowSensor 2021-05-06T17:10:56.503887+00:00 2021-05-06T17:18:59.080790+00:00 0:08:02.576903 25169 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-05-06T17:10:54.036813+00:00 2 default_pool
success booking-processing-job_v002 create_cluster_and_add_emr_steps 2021-05-06T16:00:00+00:00 EmrCreateJobFlowOperator 2021-05-06T17:10:50.181636+00:00 2021-05-06T17:10:51.919401+00:00 0:00:01.737765 25168 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 2 default 2021-05-06T17:10:48.023092+00:00 2 default_pool
success campaign-history-job_v002 create_cluster_and_add_emr_steps 2021-05-06T16:00:00+00:00 EmrCreateJobFlowOperator 2021-05-06T17:10:34.485400+00:00 2021-05-06T17:10:36.222972+00:00 0:00:01.737572 25167 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 2 default 2021-05-06T17:10:32.076456+00:00 2 default_pool
success booking-processing-job_v002 create_emr_steps 2021-05-06T16:00:00+00:00 PythonOperator 2021-05-06T17:10:28.376131+00:00 2021-05-06T17:10:31.600257+00:00 0:00:03.224126 25166 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-05-06T17:10:26.061351+00:00 2 default_pool
success campaign-history-job_v002 create_emr_steps 2021-05-06T16:00:00+00:00 PythonOperator 2021-05-06T17:10:12.298070+00:00 2021-05-06T17:10:15.364889+00:00 0:00:03.066819 25165 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-05-06T17:10:10.000893+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_booking-processing-job_v002 2021-05-06T16:00:00+00:00 TriggerDagRunOperator 2021-05-06T17:10:06.364151+00:00 2021-05-06T17:10:06.872777+00:00 0:00:00.508626 25164 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-05-06T17:10:03.993611+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_campaign-history-job_v002 2021-05-06T16:00:00+00:00 TriggerDagRunOperator 2021-05-06T17:10:06.174611+00:00 2021-05-06T17:10:06.591734+00:00 0:00:00.417123 25163 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-05-06T17:10:03.993577+00:00 2 default_pool
success vc-asset-import_v002 check_cluster_status 2021-05-06T16:05:00+00:00 EmrJobFlowSensor 2021-05-06T17:06:05.989322+00:00 2021-05-06T17:15:08.703819+00:00 0:09:02.714497 25162 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-05-06T17:06:03.597052+00:00 2 default_pool
success vc-asset-import_v002 create_cluster_and_add_emr_steps 2021-05-06T16:05:00+00:00 EmrCreateJobFlowOperator 2021-05-06T17:05:45.790032+00:00 2021-05-06T17:05:47.563548+00:00 0:00:01.773516 25161 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 2 default 2021-05-06T17:05:43.543224+00:00 2 default_pool
success vc-asset-import_v002 create_emr_steps 2021-05-06T16:05:00+00:00 PythonOperator 2021-05-06T17:05:23.645947+00:00 2021-05-06T17:05:26.736242+00:00 0:00:03.090295 25160 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-05-06T17:05:21.518411+00:00 2 default_pool
success campaign-flow-job_v002 check_cluster_status 2021-05-06T16:00:00+00:00 EmrJobFlowSensor 2021-05-06T17:00:49.406597+00:00 2021-05-06T17:09:52.084166+00:00 0:09:02.677569 25159 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-05-06T17:00:47.152576+00:00 2 default_pool
success campaign-flow-job_v002 create_cluster_and_add_emr_steps 2021-05-06T16:00:00+00:00 EmrCreateJobFlowOperator 2021-05-06T17:00:27.421635+00:00 2021-05-06T17:00:29.247688+00:00 0:00:01.826053 25158 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 4 default 2021-05-06T17:00:25.076347+00:00 2 default_pool
success campaign-flow-job_v002 create_emr_steps 2021-05-06T16:00:00+00:00 PythonOperator 2021-05-06T17:00:07.204501+00:00 2021-05-06T17:00:10.347496+00:00 0:00:03.142995 25157 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 5 default 2021-05-06T17:00:05.024184+00:00 2 default_pool
success booking-processing-job_v002 check_cluster_status 2021-05-06T15:00:00+00:00 EmrJobFlowSensor 2021-05-06T16:14:26.611583+00:00 2021-05-06T16:23:29.235886+00:00 0:09:02.624303 25156 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-05-06T16:14:24.400116+00:00 2 default_pool
success campaign-history-job_v002 check_cluster_status 2021-05-06T15:00:00+00:00 EmrJobFlowSensor 2021-05-06T16:14:18.821604+00:00 2021-05-06T16:22:21.329214+00:00 0:08:02.507610 25155 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-05-06T16:14:16.459461+00:00 2 default_pool
success booking-processing-job_v002 create_cluster_and_add_emr_steps 2021-05-06T15:00:00+00:00 EmrCreateJobFlowOperator 2021-05-06T16:14:04.889194+00:00 2021-05-06T16:14:06.620985+00:00 0:00:01.731791 25154 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 2 default 2021-05-06T16:14:02.385212+00:00 2 default_pool
success vc-asset-import_v002 check_cluster_status 2021-05-06T15:05:00+00:00 EmrJobFlowSensor 2021-05-06T16:13:56.712152+00:00 2021-05-06T16:21:59.315054+00:00 0:08:02.602902 25153 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-05-06T16:13:54.333984+00:00 2 default_pool
success campaign-history-job_v002 create_cluster_and_add_emr_steps 2021-05-06T15:00:00+00:00 EmrCreateJobFlowOperator 2021-05-06T16:13:56.679381+00:00 2021-05-06T16:13:58.399604+00:00 0:00:01.720223 25152 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 2 default 2021-05-06T16:13:54.333955+00:00 2 default_pool