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 trigger_dagrun_campaign-history-job_v002 2021-05-15T12:00:00+00:00 TriggerDagRunOperator 2021-05-15T13:10:32.163984+00:00 2021-05-15T13:10:32.636295+00:00 0:00:00.472311 28369 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-05-15T13:10:29.864094+00:00 2 default_pool
success vc-asset-import_v002 check_cluster_status 2021-05-15T12:05:00+00:00 EmrJobFlowSensor 2021-05-15T13:06:03.727287+00:00 2021-05-15T13:15:06.433223+00:00 0:09:02.705936 28368 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-05-15T13:06:01.358987+00:00 2 default_pool
success vc-asset-import_v002 create_cluster_and_add_emr_steps 2021-05-15T12:05:00+00:00 EmrCreateJobFlowOperator 2021-05-15T13:05:41.393152+00:00 2021-05-15T13:05:43.041474+00:00 0:00:01.648322 28367 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 2 default 2021-05-15T13:05:39.291231+00:00 2 default_pool
success vc-asset-import_v002 create_emr_steps 2021-05-15T12:05:00+00:00 PythonOperator 2021-05-15T13:05:19.483782+00:00 2021-05-15T13:05:22.549183+00:00 0:00:03.065401 28366 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-05-15T13:05:17.211271+00:00 2 default_pool
success campaign-flow-job_v002 check_cluster_status 2021-05-15T12:00:00+00:00 EmrJobFlowSensor 2021-05-15T13:01:06.830439+00:00 2021-05-15T13:10:09.553631+00:00 0:09:02.723192 28365 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-05-15T13:01:04.744456+00:00 2 default_pool
success campaign-flow-job_v002 create_cluster_and_add_emr_steps 2021-05-15T12:00:00+00:00 EmrCreateJobFlowOperator 2021-05-15T13:00:30.994131+00:00 2021-05-15T13:00:32.718235+00:00 0:00:01.724104 28364 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 4 default 2021-05-15T13:00:28.722725+00:00 2 default_pool
success campaign-flow-job_v002 create_emr_steps 2021-05-15T12:00:00+00:00 PythonOperator 2021-05-15T13:00:09.195458+00:00 2021-05-15T13:00:12.309882+00:00 0:00:03.114424 28363 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 5 default 2021-05-15T13:00:06.743647+00:00 2 default_pool
success booking-processing-job_v002 check_cluster_status 2021-05-15T11:00:00+00:00 EmrJobFlowSensor 2021-05-15T12:11:09.151861+00:00 2021-05-15T12:20:12.005580+00:00 0:09:02.853719 28361 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-05-15T12:11:06.788706+00:00 2 default_pool
success campaign-history-job_v002 check_cluster_status 2021-05-15T11:00:00+00:00 EmrJobFlowSensor 2021-05-15T12:10:58.796138+00:00 2021-05-15T12:20:01.494733+00:00 0:09:02.698595 28360 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-05-15T12:10:56.729311+00:00 2 default_pool
success booking-processing-job_v002 create_cluster_and_add_emr_steps 2021-05-15T11:00:00+00:00 EmrCreateJobFlowOperator 2021-05-15T12:10:48.901055+00:00 2021-05-15T12:10:50.639280+00:00 0:00:01.738225 28359 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 2 default 2021-05-15T12:10:46.722091+00:00 2 default_pool
success campaign-history-job_v002 create_cluster_and_add_emr_steps 2021-05-15T11:00:00+00:00 EmrCreateJobFlowOperator 2021-05-15T12:10:39.000417+00:00 2021-05-15T12:10:40.680757+00:00 0:00:01.680340 28358 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 2 default 2021-05-15T12:10:36.711446+00:00 2 default_pool
success booking-processing-job_v002 create_emr_steps 2021-05-15T11:00:00+00:00 PythonOperator 2021-05-15T12:10:26.897038+00:00 2021-05-15T12:10:30.254209+00:00 0:00:03.357171 28357 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-05-15T12:10:24.704745+00:00 2 default_pool
success campaign-history-job_v002 create_emr_steps 2021-05-15T11:00:00+00:00 PythonOperator 2021-05-15T12:10:16.774292+00:00 2021-05-15T12:10:19.937983+00:00 0:00:03.163691 28356 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-05-15T12:10:14.696346+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_campaign-history-job_v002 2021-05-15T11:00:00+00:00 TriggerDagRunOperator 2021-05-15T12:10:05.296135+00:00 2021-05-15T12:10:05.720034+00:00 0:00:00.423899 28355 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-05-15T12:10:02.699594+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_booking-processing-job_v002 2021-05-15T11:00:00+00:00 TriggerDagRunOperator 2021-05-15T12:10:05.280065+00:00 2021-05-15T12:10:05.819900+00:00 0:00:00.539835 28354 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-05-15T12:10:02.699642+00:00 2 default_pool
success vc-asset-import_v002 check_cluster_status 2021-05-15T11:05:00+00:00 EmrJobFlowSensor 2021-05-15T12:06:18.399482+00:00 2021-05-15T12:14:20.864642+00:00 0:08:02.465160 28353 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-05-15T12:06:16.287313+00:00 2 default_pool
success vc-asset-import_v002 create_cluster_and_add_emr_steps 2021-05-15T11:05:00+00:00 EmrCreateJobFlowOperator 2021-05-15T12:05:48.530457+00:00 2021-05-15T12:05:50.295701+00:00 0:00:01.765244 28352 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 2 default 2021-05-15T12:05:46.214150+00:00 2 default_pool
success vc-asset-import_v002 create_emr_steps 2021-05-15T11:05:00+00:00 PythonOperator 2021-05-15T12:05:24.508303+00:00 2021-05-15T12:05:27.596168+00:00 0:00:03.087865 28351 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-05-15T12:05:22.257389+00:00 2 default_pool
success campaign-flow-job_v002 check_cluster_status 2021-05-15T11:00:00+00:00 EmrJobFlowSensor 2021-05-15T12:00:53.790398+00:00 2021-05-15T12:09:56.560458+00:00 0:09:02.770060 28350 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-05-15T12:00:51.661525+00:00 2 default_pool
success campaign-flow-job_v002 create_cluster_and_add_emr_steps 2021-05-15T11:00:00+00:00 EmrCreateJobFlowOperator 2021-05-15T12:00:25.787361+00:00 2021-05-15T12:00:27.490370+00:00 0:00:01.703009 28349 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 4 default 2021-05-15T12:00:23.636302+00:00 2 default_pool
success campaign-flow-job_v002 create_emr_steps 2021-05-15T11:00:00+00:00 PythonOperator 2021-05-15T12:00:04.345701+00:00 2021-05-15T12:00:07.515763+00:00 0:00:03.170062 28348 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 5 default 2021-05-15T12:00:01.748584+00:00 2 default_pool
success booking-processing-job_v002 check_cluster_status 2021-05-15T10:00:00+00:00 EmrJobFlowSensor 2021-05-15T11:10:20.086298+00:00 2021-05-15T11:19:22.864854+00:00 0:09:02.778556 28346 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-05-15T11:10:17.920129+00:00 2 default_pool
success campaign-history-job_v002 check_cluster_status 2021-05-15T10:00:00+00:00 EmrJobFlowSensor 2021-05-15T11:10:08.068789+00:00 2021-05-15T11:20:10.923180+00:00 0:10:02.854391 28345 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-05-15T11:10:05.908761+00:00 2 default_pool
success booking-processing-job_v002 create_cluster_and_add_emr_steps 2021-05-15T10:00:00+00:00 EmrCreateJobFlowOperator 2021-05-15T11:09:58.095131+00:00 2021-05-15T11:09:59.763809+00:00 0:00:01.668678 28344 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 2 default 2021-05-15T11:09:55.925819+00:00 2 default_pool
success campaign-history-job_v002 create_cluster_and_add_emr_steps 2021-05-15T10:00:00+00:00 EmrCreateJobFlowOperator 2021-05-15T11:09:42.109930+00:00 2021-05-15T11:09:43.980107+00:00 0:00:01.870177 28343 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 2 default 2021-05-15T11:09:39.889494+00:00 2 default_pool
success booking-processing-job_v002 create_emr_steps 2021-05-15T10:00:00+00:00 PythonOperator 2021-05-15T11:09:36.298134+00:00 2021-05-15T11:09:39.610114+00:00 0:00:03.311980 28342 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-05-15T11:09:33.960405+00:00 2 default_pool
success campaign-history-job_v002 create_emr_steps 2021-05-15T10:00:00+00:00 PythonOperator 2021-05-15T11:09:22.267281+00:00 2021-05-15T11:09:25.415222+00:00 0:00:03.147941 28341 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-05-15T11:09:19.846443+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_campaign-history-job_v002 2021-05-15T10:00:00+00:00 TriggerDagRunOperator 2021-05-15T11:09:12.059534+00:00 2021-05-15T11:09:12.630171+00:00 0:00:00.570637 28340 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-05-15T11:09:09.784446+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_booking-processing-job_v002 2021-05-15T10:00:00+00:00 TriggerDagRunOperator 2021-05-15T11:09:11.916411+00:00 2021-05-15T11:09:12.345578+00:00 0:00:00.429167 28339 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-05-15T11:09:09.784480+00:00 2 default_pool
success vc-asset-import_v002 check_cluster_status 2021-05-15T10:05:00+00:00 EmrJobFlowSensor 2021-05-15T11:05:51.493679+00:00 2021-05-15T11:14:54.113230+00:00 0:09:02.619551 28338 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-05-15T11:05:49.367074+00:00 2 default_pool
success vc-asset-import_v002 create_cluster_and_add_emr_steps 2021-05-15T10:05:00+00:00 EmrCreateJobFlowOperator 2021-05-15T11:05:29.763824+00:00 2021-05-15T11:05:31.400107+00:00 0:00:01.636283 28337 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 2 default 2021-05-15T11:05:27.371712+00:00 2 default_pool
success vc-asset-import_v002 create_emr_steps 2021-05-15T10:05:00+00:00 PythonOperator 2021-05-15T11:05:09.810377+00:00 2021-05-15T11:05:12.898484+00:00 0:00:03.088107 28336 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-05-15T11:05:07.295502+00:00 2 default_pool
success campaign-flow-job_v002 check_cluster_status 2021-05-15T10:00:00+00:00 EmrJobFlowSensor 2021-05-15T11:00:49.232894+00:00 2021-05-15T11:08:51.739985+00:00 0:08:02.507091 28335 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-05-15T11:00:46.956735+00:00 2 default_pool
success campaign-flow-job_v002 create_cluster_and_add_emr_steps 2021-05-15T10:00:00+00:00 EmrCreateJobFlowOperator 2021-05-15T11:00:27.012460+00:00 2021-05-15T11:00:28.926505+00:00 0:00:01.914045 28334 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 4 default 2021-05-15T11:00:24.789377+00:00 2 default_pool
success campaign-flow-job_v002 create_emr_steps 2021-05-15T10:00:00+00:00 PythonOperator 2021-05-15T11:00:07.142463+00:00 2021-05-15T11:00:10.285900+00:00 0:00:03.143437 28333 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 5 default 2021-05-15T11:00:04.744565+00:00 2 default_pool
success campaign-history-job_v002 check_cluster_status 2021-05-15T09:00:00+00:00 EmrJobFlowSensor 2021-05-15T10:12:21.474070+00:00 2021-05-15T10:22:24.414876+00:00 0:10:02.940806 28331 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-05-15T10:12:19.158382+00:00 2 default_pool
success booking-processing-job_v002 check_cluster_status 2021-05-15T09:00:00+00:00 EmrJobFlowSensor 2021-05-15T10:12:15.400108+00:00 2021-05-15T10:22:18.251383+00:00 0:10:02.851275 28330 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-05-15T10:12:13.154654+00:00 2 default_pool
success campaign-history-job_v002 create_cluster_and_add_emr_steps 2021-05-15T09:00:00+00:00 EmrCreateJobFlowOperator 2021-05-15T10:12:01.322405+00:00 2021-05-15T10:12:03.041657+00:00 0:00:01.719252 28329 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 2 default 2021-05-15T10:11:59.141586+00:00 2 default_pool
success booking-processing-job_v002 create_cluster_and_add_emr_steps 2021-05-15T09:00:00+00:00 EmrCreateJobFlowOperator 2021-05-15T10:11:55.307263+00:00 2021-05-15T10:11:57.011486+00:00 0:00:01.704223 28328 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 2 default 2021-05-15T10:11:53.137493+00:00 2 default_pool
success campaign-history-job_v002 create_emr_steps 2021-05-15T09:00:00+00:00 PythonOperator 2021-05-15T10:11:39.367928+00:00 2021-05-15T10:11:42.462400+00:00 0:00:03.094472 28327 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-05-15T10:11:37.121164+00:00 2 default_pool
success booking-processing-job_v002 create_emr_steps 2021-05-15T09:00:00+00:00 PythonOperator 2021-05-15T10:11:29.227265+00:00 2021-05-15T10:11:32.654727+00:00 0:00:03.427462 28326 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-05-15T10:11:27.108143+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_campaign-history-job_v002 2021-05-15T09:00:00+00:00 TriggerDagRunOperator 2021-05-15T10:11:09.745200+00:00 2021-05-15T10:11:10.302038+00:00 0:00:00.556838 28325 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-05-15T10:11:07.154941+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_booking-processing-job_v002 2021-05-15T09:00:00+00:00 TriggerDagRunOperator 2021-05-15T10:11:09.572847+00:00 2021-05-15T10:11:09.975185+00:00 0:00:00.402338 28324 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-05-15T10:11:07.154972+00:00 2 default_pool
success vc-asset-import_v002 check_cluster_status 2021-05-15T09:05:00+00:00 EmrJobFlowSensor 2021-05-15T10:05:56.694893+00:00 2021-05-15T10:14:59.285423+00:00 0:09:02.590530 28323 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-05-15T10:05:54.615992+00:00 2 default_pool
success vc-asset-import_v002 create_cluster_and_add_emr_steps 2021-05-15T09:05:00+00:00 EmrCreateJobFlowOperator 2021-05-15T10:05:34.860324+00:00 2021-05-15T10:05:36.512357+00:00 0:00:01.652033 28322 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 2 default 2021-05-15T10:05:32.646143+00:00 2 default_pool
success vc-asset-import_v002 create_emr_steps 2021-05-15T09:05:00+00:00 PythonOperator 2021-05-15T10:05:12.687571+00:00 2021-05-15T10:05:15.756796+00:00 0:00:03.069225 28321 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-05-15T10:05:10.520555+00:00 2 default_pool
success campaign-flow-job_v002 check_cluster_status 2021-05-15T09:00:00+00:00 EmrJobFlowSensor 2021-05-15T10:00:56.606695+00:00 2021-05-15T10:10:59.660589+00:00 0:10:03.053894 28320 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-05-15T10:00:54.165688+00:00 2 default_pool
success campaign-flow-job_v002 create_cluster_and_add_emr_steps 2021-05-15T09:00:00+00:00 EmrCreateJobFlowOperator 2021-05-15T10:00:36.441355+00:00 2021-05-15T10:00:38.262070+00:00 0:00:01.820715 28319 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 4 default 2021-05-15T10:00:34.093033+00:00 2 default_pool
success campaign-flow-job_v002 create_emr_steps 2021-05-15T09:00:00+00:00 PythonOperator 2021-05-15T10:00:12.550518+00:00 2021-05-15T10:00:15.667961+00:00 0:00:03.117443 28318 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 5 default 2021-05-15T10:00:10.029214+00:00 2 default_pool
success booking-processing-job_v002 check_cluster_status 2021-05-15T08:00:00+00:00 EmrJobFlowSensor 2021-05-15T09:11:15.802999+00:00 2021-05-15T09:21:18.748278+00:00 0:10:02.945279 28316 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-05-15T09:11:13.539682+00:00 2 default_pool
success campaign-history-job_v002 check_cluster_status 2021-05-15T08:00:00+00:00 EmrJobFlowSensor 2021-05-15T09:10:57.869524+00:00 2021-05-15T09:21:00.714525+00:00 0:10:02.845001 28315 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-05-15T09:10:55.553049+00:00 2 default_pool
success booking-processing-job_v002 create_cluster_and_add_emr_steps 2021-05-15T08:00:00+00:00 EmrCreateJobFlowOperator 2021-05-15T09:10:53.814693+00:00 2021-05-15T09:10:55.521268+00:00 0:00:01.706575 28314 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 2 default 2021-05-15T09:10:51.567309+00:00 2 default_pool
success campaign-history-job_v002 create_cluster_and_add_emr_steps 2021-05-15T08:00:00+00:00 EmrCreateJobFlowOperator 2021-05-15T09:10:36.966576+00:00 2021-05-15T09:10:38.685463+00:00 0:00:01.718887 28313 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 2 default 2021-05-15T09:10:33.552483+00:00 2 default_pool
success booking-processing-job_v002 create_emr_steps 2021-05-15T08:00:00+00:00 PythonOperator 2021-05-15T09:10:31.981569+00:00 2021-05-15T09:10:36.264851+00:00 0:00:04.283282 28312 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-05-15T09:10:29.561529+00:00 2 default_pool
success campaign-history-job_v002 create_emr_steps 2021-05-15T08:00:00+00:00 PythonOperator 2021-05-15T09:10:09.609051+00:00 2021-05-15T09:10:12.839177+00:00 0:00:03.230126 28311 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-05-15T09:10:07.428822+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_campaign-history-job_v002 2021-05-15T08:00:00+00:00 TriggerDagRunOperator 2021-05-15T09:10:03.933693+00:00 2021-05-15T09:10:04.449840+00:00 0:00:00.516147 28310 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-05-15T09:10:01.424702+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_booking-processing-job_v002 2021-05-15T08:00:00+00:00 TriggerDagRunOperator 2021-05-15T09:10:03.678530+00:00 2021-05-15T09:10:04.139598+00:00 0:00:00.461068 28309 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-05-15T09:10:01.424734+00:00 2 default_pool
success vc-asset-import_v002 check_cluster_status 2021-05-15T08:05:00+00:00 EmrJobFlowSensor 2021-05-15T09:05:49.598888+00:00 2021-05-15T09:14:52.370867+00:00 0:09:02.771979 28308 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-05-15T09:05:47.060867+00:00 2 default_pool
success vc-asset-import_v002 create_cluster_and_add_emr_steps 2021-05-15T08:05:00+00:00 EmrCreateJobFlowOperator 2021-05-15T09:05:29.544518+00:00 2021-05-15T09:05:31.289839+00:00 0:00:01.745321 28307 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 2 default 2021-05-15T09:05:26.962834+00:00 2 default_pool
success vc-asset-import_v002 create_emr_steps 2021-05-15T08:05:00+00:00 PythonOperator 2021-05-15T09:05:06.949294+00:00 2021-05-15T09:05:10.100393+00:00 0:00:03.151099 28306 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-05-15T09:05:04.847658+00:00 2 default_pool
success campaign-flow-job_v002 check_cluster_status 2021-05-15T08:00:00+00:00 EmrJobFlowSensor 2021-05-15T09:00:48.493541+00:00 2021-05-15T09:09:51.197116+00:00 0:09:02.703575 28305 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-05-15T09:00:46.398342+00:00 2 default_pool
success campaign-flow-job_v002 create_cluster_and_add_emr_steps 2021-05-15T08:00:00+00:00 EmrCreateJobFlowOperator 2021-05-15T09:00:28.487035+00:00 2021-05-15T09:00:30.256567+00:00 0:00:01.769532 28304 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 4 default 2021-05-15T09:00:26.367903+00:00 2 default_pool
success campaign-flow-job_v002 create_emr_steps 2021-05-15T08:00:00+00:00 PythonOperator 2021-05-15T09:00:06.580854+00:00 2021-05-15T09:00:09.738217+00:00 0:00:03.157363 28303 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 5 default 2021-05-15T09:00:04.335467+00:00 2 default_pool
success campaign-history-job_v002 check_cluster_status 2021-05-15T07:00:00+00:00 EmrJobFlowSensor 2021-05-15T08:12:28.511541+00:00 2021-05-15T08:21:31.354436+00:00 0:09:02.842895 28301 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-05-15T08:12:25.878541+00:00 2 default_pool
success booking-processing-job_v002 check_cluster_status 2021-05-15T07:00:00+00:00 EmrJobFlowSensor 2021-05-15T08:12:20.170129+00:00 2021-05-15T08:21:22.821094+00:00 0:09:02.650965 28300 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-05-15T08:12:17.862409+00:00 2 default_pool
success campaign-history-job_v002 create_cluster_and_add_emr_steps 2021-05-15T07:00:00+00:00 EmrCreateJobFlowOperator 2021-05-15T08:12:06.359060+00:00 2021-05-15T08:12:08.259614+00:00 0:00:01.900554 28299 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 2 default 2021-05-15T08:12:03.868668+00:00 2 default_pool
success booking-processing-job_v002 create_cluster_and_add_emr_steps 2021-05-15T07:00:00+00:00 EmrCreateJobFlowOperator 2021-05-15T08:11:58.026990+00:00 2021-05-15T08:11:59.757310+00:00 0:00:01.730320 28298 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 2 default 2021-05-15T08:11:55.804421+00:00 2 default_pool
success campaign-history-job_v002 create_emr_steps 2021-05-15T07:00:00+00:00 PythonOperator 2021-05-15T08:11:46.033107+00:00 2021-05-15T08:11:49.173299+00:00 0:00:03.140192 28297 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-05-15T08:11:43.734176+00:00 2 default_pool
success booking-processing-job_v002 create_emr_steps 2021-05-15T07:00:00+00:00 PythonOperator 2021-05-15T08:11:37.888685+00:00 2021-05-15T08:11:41.259036+00:00 0:00:03.370351 28296 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-05-15T08:11:35.726098+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_booking-processing-job_v002 2021-05-15T07:00:00+00:00 TriggerDagRunOperator 2021-05-15T08:11:28.275202+00:00 2021-05-15T08:11:28.729622+00:00 0:00:00.454420 28295 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-05-15T08:11:25.719415+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_campaign-history-job_v002 2021-05-15T07:00:00+00:00 TriggerDagRunOperator 2021-05-15T08:11:28.054340+00:00 2021-05-15T08:11:28.621692+00:00 0:00:00.567352 28294 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-05-15T08:11:25.719380+00:00 2 default_pool
success vc-asset-import_v002 check_cluster_status 2021-05-15T07:05:00+00:00 EmrJobFlowSensor 2021-05-15T08:06:03.435933+00:00 2021-05-15T08:14:06.050208+00:00 0:08:02.614275 28293 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-05-15T08:06:01.160941+00:00 2 default_pool
success vc-asset-import_v002 create_cluster_and_add_emr_steps 2021-05-15T07:05:00+00:00 EmrCreateJobFlowOperator 2021-05-15T08:05:39.420025+00:00 2021-05-15T08:05:41.036130+00:00 0:00:01.616105 28292 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 2 default 2021-05-15T08:05:37.162576+00:00 2 default_pool
success vc-asset-import_v002 create_emr_steps 2021-05-15T07:05:00+00:00 PythonOperator 2021-05-15T08:05:19.475583+00:00 2021-05-15T08:05:22.591423+00:00 0:00:03.115840 28291 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-05-15T08:05:17.149940+00:00 2 default_pool
success campaign-flow-job_v002 check_cluster_status 2021-05-15T07:00:00+00:00 EmrJobFlowSensor 2021-05-15T08:01:06.610458+00:00 2021-05-15T08:11:09.428882+00:00 0:10:02.818424 28290 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-05-15T08:01:04.513869+00:00 2 default_pool
success campaign-flow-job_v002 create_cluster_and_add_emr_steps 2021-05-15T07:00:00+00:00 EmrCreateJobFlowOperator 2021-05-15T08:00:46.778819+00:00 2021-05-15T08:00:48.644685+00:00 0:00:01.865866 28289 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 4 default 2021-05-15T08:00:44.496941+00:00 2 default_pool
success campaign-flow-job_v002 create_emr_steps 2021-05-15T07:00:00+00:00 PythonOperator 2021-05-15T08:00:24.872455+00:00 2021-05-15T08:00:27.998110+00:00 0:00:03.125655 28288 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 5 default 2021-05-15T08:00:22.459394+00:00 2 default_pool
success campaign-history-job_v002 check_cluster_status 2021-05-15T06:00:00+00:00 EmrJobFlowSensor 2021-05-15T07:11:35.178189+00:00 2021-05-15T07:20:37.974097+00:00 0:09:02.795908 28286 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-05-15T07:11:32.744362+00:00 2 default_pool
success booking-processing-job_v002 check_cluster_status 2021-05-15T06:00:00+00:00 EmrJobFlowSensor 2021-05-15T07:11:29.074691+00:00 2021-05-15T07:20:31.824065+00:00 0:09:02.749374 28285 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-05-15T07:11:26.682807+00:00 2 default_pool
success campaign-history-job_v002 create_cluster_and_add_emr_steps 2021-05-15T06:00:00+00:00 EmrCreateJobFlowOperator 2021-05-15T07:11:04.771911+00:00 2021-05-15T07:11:06.473758+00:00 0:00:01.701847 28284 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 2 default 2021-05-15T07:11:02.625094+00:00 2 default_pool
success booking-processing-job_v002 create_cluster_and_add_emr_steps 2021-05-15T06:00:00+00:00 EmrCreateJobFlowOperator 2021-05-15T07:10:54.689741+00:00 2021-05-15T07:10:56.405598+00:00 0:00:01.715857 28283 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 2 default 2021-05-15T07:10:52.603121+00:00 2 default_pool
success campaign-history-job_v002 create_emr_steps 2021-05-15T06:00:00+00:00 PythonOperator 2021-05-15T07:10:41.148054+00:00 2021-05-15T07:10:44.327418+00:00 0:00:03.179364 28282 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-05-15T07:10:38.593518+00:00 2 default_pool
success booking-processing-job_v002 create_emr_steps 2021-05-15T06:00:00+00:00 PythonOperator 2021-05-15T07:10:32.755172+00:00 2021-05-15T07:10:36.077368+00:00 0:00:03.322196 28281 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-05-15T07:10:30.582048+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_booking-processing-job_v002 2021-05-15T06:00:00+00:00 TriggerDagRunOperator 2021-05-15T07:10:18.949117+00:00 2021-05-15T07:10:19.487318+00:00 0:00:00.538201 28280 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-05-15T07:10:16.524087+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_campaign-history-job_v002 2021-05-15T06:00:00+00:00 TriggerDagRunOperator 2021-05-15T07:10:18.760117+00:00 2021-05-15T07:10:19.171574+00:00 0:00:00.411457 28279 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-05-15T07:10:16.524053+00:00 2 default_pool
success vc-asset-import_v002 check_cluster_status 2021-05-15T06:05:00+00:00 EmrJobFlowSensor 2021-05-15T07:05:48.760604+00:00 2021-05-15T07:13:51.359751+00:00 0:08:02.599147 28278 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-05-15T07:05:46.244790+00:00 2 default_pool
success vc-asset-import_v002 create_cluster_and_add_emr_steps 2021-05-15T06:05:00+00:00 EmrCreateJobFlowOperator 2021-05-15T07:05:26.417119+00:00 2021-05-15T07:05:28.082818+00:00 0:00:01.665699 28277 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 2 default 2021-05-15T07:05:24.167730+00:00 2 default_pool
success vc-asset-import_v002 create_emr_steps 2021-05-15T06:05:00+00:00 PythonOperator 2021-05-15T07:05:06.150311+00:00 2021-05-15T07:05:09.328252+00:00 0:00:03.177941 28276 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-05-15T07:05:04.087850+00:00 2 default_pool
success campaign-flow-job_v002 check_cluster_status 2021-05-15T06:00:00+00:00 EmrJobFlowSensor 2021-05-15T07:01:01.964097+00:00 2021-05-15T07:10:04.861724+00:00 0:09:02.897627 28275 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-05-15T07:00:59.742108+00:00 2 default_pool
success campaign-flow-job_v002 create_cluster_and_add_emr_steps 2021-05-15T06:00:00+00:00 EmrCreateJobFlowOperator 2021-05-15T07:00:39.777082+00:00 2021-05-15T07:00:41.533169+00:00 0:00:01.756087 28274 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 4 default 2021-05-15T07:00:37.662142+00:00 2 default_pool
success campaign-flow-job_v002 create_emr_steps 2021-05-15T06:00:00+00:00 PythonOperator 2021-05-15T07:00:20.444068+00:00 2021-05-15T07:00:23.540583+00:00 0:00:03.096515 28273 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 5 default 2021-05-15T07:00:17.620762+00:00 2 default_pool
success booking-processing-job_v002 check_cluster_status 2021-05-15T05:00:00+00:00 EmrJobFlowSensor 2021-05-15T06:12:12.425730+00:00 2021-05-15T06:22:15.245325+00:00 0:10:02.819595 28271 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-05-15T06:12:10.101225+00:00 2 default_pool
success campaign-history-job_v002 check_cluster_status 2021-05-15T05:00:00+00:00 EmrJobFlowSensor 2021-05-15T06:12:08.339505+00:00 2021-05-15T06:20:10.944128+00:00 0:08:02.604623 28270 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-05-15T06:12:06.099560+00:00 2 default_pool
success booking-processing-job_v002 create_cluster_and_add_emr_steps 2021-05-15T05:00:00+00:00 EmrCreateJobFlowOperator 2021-05-15T06:11:46.388709+00:00 2021-05-15T06:11:48.054156+00:00 0:00:01.665447 28269 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 2 default 2021-05-15T06:11:44.159524+00:00 2 default_pool
success campaign-history-job_v002 create_cluster_and_add_emr_steps 2021-05-15T05:00:00+00:00 EmrCreateJobFlowOperator 2021-05-15T06:11:42.390034+00:00 2021-05-15T06:11:44.295676+00:00 0:00:01.905642 28268 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 2 default 2021-05-15T06:11:40.054725+00:00 2 default_pool
success booking-processing-job_v002 create_emr_steps 2021-05-15T05:00:00+00:00 PythonOperator 2021-05-15T06:11:26.140116+00:00 2021-05-15T06:11:29.581677+00:00 0:00:03.441561 28267 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-05-15T06:11:24.041180+00:00 2 default_pool
success campaign-history-job_v002 create_emr_steps 2021-05-15T05:00:00+00:00 PythonOperator 2021-05-15T06:11:22.245942+00:00 2021-05-15T06:11:25.359300+00:00 0:00:03.113358 28266 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-05-15T06:11:20.042859+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_booking-processing-job_v002 2021-05-15T05:00:00+00:00 TriggerDagRunOperator 2021-05-15T06:11:08.411759+00:00 2021-05-15T06:11:09.005170+00:00 0:00:00.593411 28265 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-05-15T06:11:06.028855+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_campaign-history-job_v002 2021-05-15T05:00:00+00:00 TriggerDagRunOperator 2021-05-15T06:11:08.338986+00:00 2021-05-15T06:11:08.797656+00:00 0:00:00.458670 28264 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-05-15T06:11:06.028821+00:00 2 default_pool
success vc-asset-import_v002 check_cluster_status 2021-05-15T05:05:00+00:00 EmrJobFlowSensor 2021-05-15T06:05:58.021686+00:00 2021-05-15T06:15:00.655999+00:00 0:09:02.634313 28263 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-05-15T06:05:55.651772+00:00 2 default_pool