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-05-09T23:00:00+00:00 PythonOperator 2021-05-10T00:00:11.814823+00:00 2021-05-10T00:00:14.927705+00:00 0:00:03.112882 26355 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 5 default 2021-05-10T00:00:09.603642+00:00 2 default_pool
success booking-processing-job_v002 check_cluster_status 2021-05-09T22:00:00+00:00 EmrJobFlowSensor 2021-05-09T23:11:20.678111+00:00 2021-05-09T23:21:23.519297+00:00 0:10:02.841186 26353 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-05-09T23:11:18.599934+00:00 2 default_pool
success campaign-history-job_v002 check_cluster_status 2021-05-09T22:00:00+00:00 EmrJobFlowSensor 2021-05-09T23:11:19.134426+00:00 2021-05-09T23:19:21.646479+00:00 0:08:02.512053 26352 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-05-09T23:11:16.658464+00:00 2 default_pool
success booking-processing-job_v002 create_cluster_and_add_emr_steps 2021-05-09T22:00:00+00:00 EmrCreateJobFlowOperator 2021-05-09T23:10:59.199452+00:00 2021-05-09T23:11:00.871156+00:00 0:00:01.671704 26351 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 2 default 2021-05-09T23:10:56.583970+00:00 2 default_pool
success campaign-history-job_v002 create_cluster_and_add_emr_steps 2021-05-09T22:00:00+00:00 EmrCreateJobFlowOperator 2021-05-09T23:10:56.677984+00:00 2021-05-09T23:10:58.739459+00:00 0:00:02.061475 26350 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 2 default 2021-05-09T23:10:54.525322+00:00 2 default_pool
success booking-processing-job_v002 create_emr_steps 2021-05-09T22:00:00+00:00 PythonOperator 2021-05-09T23:10:38.798915+00:00 2021-05-09T23:10:42.120462+00:00 0:00:03.321547 26349 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-05-09T23:10:36.510118+00:00 2 default_pool
success campaign-history-job_v002 create_emr_steps 2021-05-09T22:00:00+00:00 PythonOperator 2021-05-09T23:10:36.740768+00:00 2021-05-09T23:10:39.888551+00:00 0:00:03.147783 26348 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-05-09T23:10:34.508658+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_campaign-history-job_v002 2021-05-09T22:00:00+00:00 TriggerDagRunOperator 2021-05-09T23:10:20.877051+00:00 2021-05-09T23:10:21.401410+00:00 0:00:00.524359 26347 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-05-09T23:10:18.493692+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_booking-processing-job_v002 2021-05-09T22:00:00+00:00 TriggerDagRunOperator 2021-05-09T23:10:20.553421+00:00 2021-05-09T23:10:20.958767+00:00 0:00:00.405346 26346 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-05-09T23:10:18.493719+00:00 2 default_pool
success vc-asset-import_v002 check_cluster_status 2021-05-09T22:05:00+00:00 EmrJobFlowSensor 2021-05-09T23:06:16.485325+00:00 2021-05-09T23:15:19.309140+00:00 0:09:02.823815 26345 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-05-09T23:06:14.152670+00:00 2 default_pool
success vc-asset-import_v002 create_cluster_and_add_emr_steps 2021-05-09T22:05:00+00:00 EmrCreateJobFlowOperator 2021-05-09T23:05:50.379729+00:00 2021-05-09T23:05:52.137744+00:00 0:00:01.758015 26344 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 2 default 2021-05-09T23:05:48.053402+00:00 2 default_pool
success vc-asset-import_v002 create_emr_steps 2021-05-09T22:05:00+00:00 PythonOperator 2021-05-09T23:05:20.255534+00:00 2021-05-09T23:05:23.295041+00:00 0:00:03.039507 26343 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-05-09T23:05:18.025095+00:00 2 default_pool
success campaign-delta-past-delete-job_v002 check_cluster_status 2021-05-08T23:00:00+00:00 EmrJobFlowSensor 2021-05-09T23:01:16.056477+00:00 2021-05-09T23:10:18.745102+00:00 0:09:02.688625 26342 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-05-09T23:01:13.700902+00:00 2 default_pool
success campaign-flow-job_v002 check_cluster_status 2021-05-09T22:00:00+00:00 EmrJobFlowSensor 2021-05-09T23:01:05.888050+00:00 2021-05-09T23:10:08.613923+00:00 0:09:02.725873 26341 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-05-09T23:01:03.690898+00:00 2 default_pool
success campaign-delta-past-delete-job_v002 create_cluster_and_add_emr_steps 2021-05-08T23:00:00+00:00 EmrCreateJobFlowOperator 2021-05-09T23:00:53.761540+00:00 2021-05-09T23:00:55.494509+00:00 0:00:01.732969 26340 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 2 default 2021-05-09T23:00:51.628559+00:00 2 default_pool
success campaign-flow-job_v002 create_cluster_and_add_emr_steps 2021-05-09T22:00:00+00:00 EmrCreateJobFlowOperator 2021-05-09T23:00:43.943793+00:00 2021-05-09T23:00:45.812265+00:00 0:00:01.868472 26339 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 4 default 2021-05-09T23:00:41.617720+00:00 2 default_pool
success campaign-delta-past-delete-job_v002 create_emr_steps 2021-05-08T23:00:00+00:00 PythonOperator 2021-05-09T23:00:22.278061+00:00 2021-05-09T23:00:25.744229+00:00 0:00:03.466168 26338 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-05-09T23:00:19.599951+00:00 2 default_pool
success campaign-flow-job_v002 create_emr_steps 2021-05-09T22:00:00+00:00 PythonOperator 2021-05-09T23:00:17.885427+00:00 2021-05-09T23:00:21.640312+00:00 0:00:03.754885 26337 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 5 default 2021-05-09T23:00:15.595877+00:00 2 default_pool
success booking-processing-job_v002 check_cluster_status 2021-05-09T21:00:00+00:00 EmrJobFlowSensor 2021-05-09T22:11:34.988362+00:00 2021-05-09T22:20:37.650538+00:00 0:09:02.662176 26335 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-05-09T22:11:32.560892+00:00 2 default_pool
success campaign-history-job_v002 check_cluster_status 2021-05-09T21:00:00+00:00 EmrJobFlowSensor 2021-05-09T22:11:29.021484+00:00 2021-05-09T22:31:33.419910+00:00 0:20:04.398426 26334 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-05-09T22:11:26.546907+00:00 2 default_pool
success booking-processing-job_v002 create_cluster_and_add_emr_steps 2021-05-09T21:00:00+00:00 EmrCreateJobFlowOperator 2021-05-09T22:11:12.600448+00:00 2021-05-09T22:11:14.291698+00:00 0:00:01.691250 26333 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 2 default 2021-05-09T22:11:10.464429+00:00 2 default_pool
success campaign-history-job_v002 create_cluster_and_add_emr_steps 2021-05-09T21:00:00+00:00 EmrCreateJobFlowOperator 2021-05-09T22:11:08.795567+00:00 2021-05-09T22:11:10.625460+00:00 0:00:01.829893 26332 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 2 default 2021-05-09T22:11:06.459792+00:00 2 default_pool
success booking-processing-job_v002 create_emr_steps 2021-05-09T21:00:00+00:00 PythonOperator 2021-05-09T22:10:48.575488+00:00 2021-05-09T22:10:51.882571+00:00 0:00:03.307083 26331 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-05-09T22:10:46.443948+00:00 2 default_pool
success campaign-history-job_v002 create_emr_steps 2021-05-09T21:00:00+00:00 PythonOperator 2021-05-09T22:10:34.647116+00:00 2021-05-09T22:10:37.711570+00:00 0:00:03.064454 26330 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-05-09T22:10:32.433117+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_booking-processing-job_v002 2021-05-09T21:00:00+00:00 TriggerDagRunOperator 2021-05-09T22:10:24.838309+00:00 2021-05-09T22:10:25.268151+00:00 0:00:00.429842 26329 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-05-09T22:10:22.482575+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_campaign-history-job_v002 2021-05-09T21:00:00+00:00 TriggerDagRunOperator 2021-05-09T22:10:24.828893+00:00 2021-05-09T22:10:25.392057+00:00 0:00:00.563164 26328 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-05-09T22:10:22.482507+00:00 2 default_pool
success vc-asset-import_v002 check_cluster_status 2021-05-09T21:05:00+00:00 EmrJobFlowSensor 2021-05-09T22:06:04.177585+00:00 2021-05-09T22:15:06.835417+00:00 0:09:02.657832 26327 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-05-09T22:06:02.084355+00:00 2 default_pool
success vc-asset-import_v002 create_cluster_and_add_emr_steps 2021-05-09T21:05:00+00:00 EmrCreateJobFlowOperator 2021-05-09T22:05:42.142544+00:00 2021-05-09T22:05:43.773090+00:00 0:00:01.630546 26326 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 2 default 2021-05-09T22:05:40.042509+00:00 2 default_pool
success vc-asset-import_v002 create_emr_steps 2021-05-09T21:05:00+00:00 PythonOperator 2021-05-09T22:05:20.467539+00:00 2021-05-09T22:05:23.478258+00:00 0:00:03.010719 26325 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-05-09T22:05:18.071703+00:00 2 default_pool
success campaign-flow-job_v002 check_cluster_status 2021-05-09T21:00:00+00:00 EmrJobFlowSensor 2021-05-09T22:01:03.963516+00:00 2021-05-09T22:10:06.798094+00:00 0:09:02.834578 26324 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-05-09T22:01:01.610107+00:00 2 default_pool
success campaign-flow-job_v002 create_cluster_and_add_emr_steps 2021-05-09T21:00:00+00:00 EmrCreateJobFlowOperator 2021-05-09T22:00:37.990246+00:00 2021-05-09T22:00:39.697643+00:00 0:00:01.707397 26323 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 4 default 2021-05-09T22:00:35.646351+00:00 2 default_pool
success campaign-flow-job_v002 create_emr_steps 2021-05-09T21:00:00+00:00 PythonOperator 2021-05-09T22:00:17.902699+00:00 2021-05-09T22:00:21.009521+00:00 0:00:03.106822 26322 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 5 default 2021-05-09T22:00:15.544251+00:00 2 default_pool
success campaign-history-job_v002 check_cluster_status 2021-05-09T20:00:00+00:00 EmrJobFlowSensor 2021-05-09T21:10:26.841751+00:00 2021-05-09T21:19:29.627164+00:00 0:09:02.785413 26320 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-05-09T21:10:24.465387+00:00 2 default_pool
success booking-processing-job_v002 check_cluster_status 2021-05-09T20:00:00+00:00 EmrJobFlowSensor 2021-05-09T21:10:20.715886+00:00 2021-05-09T21:20:23.558799+00:00 0:10:02.842913 26319 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-05-09T21:10:18.402764+00:00 2 default_pool
success campaign-history-job_v002 create_cluster_and_add_emr_steps 2021-05-09T20:00:00+00:00 EmrCreateJobFlowOperator 2021-05-09T21:10:04.808841+00:00 2021-05-09T21:10:06.582448+00:00 0:00:01.773607 26318 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 2 default 2021-05-09T21:10:02.387297+00:00 2 default_pool
success booking-processing-job_v002 create_cluster_and_add_emr_steps 2021-05-09T20:00:00+00:00 EmrCreateJobFlowOperator 2021-05-09T21:09:58.713526+00:00 2021-05-09T21:10:00.500236+00:00 0:00:01.786710 26317 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 2 default 2021-05-09T21:09:56.330639+00:00 2 default_pool
success campaign-history-job_v002 create_emr_steps 2021-05-09T20:00:00+00:00 PythonOperator 2021-05-09T21:09:43.081011+00:00 2021-05-09T21:09:46.512795+00:00 0:00:03.431784 26316 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-05-09T21:09:40.304655+00:00 2 default_pool
success booking-processing-job_v002 create_emr_steps 2021-05-09T20:00:00+00:00 PythonOperator 2021-05-09T21:09:38.582139+00:00 2021-05-09T21:09:42.543799+00:00 0:00:03.961660 26315 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-05-09T21:09:36.304083+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_campaign-history-job_v002 2021-05-09T20:00:00+00:00 TriggerDagRunOperator 2021-05-09T21:09:23.002735+00:00 2021-05-09T21:09:23.434126+00:00 0:00:00.431391 26314 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-05-09T21:09:20.352669+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_booking-processing-job_v002 2021-05-09T20:00:00+00:00 TriggerDagRunOperator 2021-05-09T21:09:22.871848+00:00 2021-05-09T21:09:23.410780+00:00 0:00:00.538932 26313 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-05-09T21:09:20.352721+00:00 2 default_pool
success vc-asset-import_v002 check_cluster_status 2021-05-09T20:05:00+00:00 EmrJobFlowSensor 2021-05-09T21:05:56.177767+00:00 2021-05-09T21:16:59.358723+00:00 0:11:03.180956 26312 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-05-09T21:05:53.931645+00:00 2 default_pool
success vc-asset-import_v002 create_cluster_and_add_emr_steps 2021-05-09T20:05:00+00:00 EmrCreateJobFlowOperator 2021-05-09T21:05:33.996570+00:00 2021-05-09T21:05:35.707051+00:00 0:00:01.710481 26311 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 2 default 2021-05-09T21:05:31.910995+00:00 2 default_pool
success vc-asset-import_v002 create_emr_steps 2021-05-09T20:05:00+00:00 PythonOperator 2021-05-09T21:05:12.017080+00:00 2021-05-09T21:05:15.099735+00:00 0:00:03.082655 26310 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-05-09T21:05:09.894385+00:00 2 default_pool
success campaign-flow-job_v002 check_cluster_status 2021-05-09T20:00:00+00:00 EmrJobFlowSensor 2021-05-09T21:01:11.732196+00:00 2021-05-09T21:09:14.376657+00:00 0:08:02.644461 26309 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-05-09T21:01:09.517453+00:00 2 default_pool
success campaign-flow-job_v002 create_cluster_and_add_emr_steps 2021-05-09T20:00:00+00:00 EmrCreateJobFlowOperator 2021-05-09T21:00:45.815430+00:00 2021-05-09T21:00:47.687236+00:00 0:00:01.871806 26308 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 4 default 2021-05-09T21:00:43.495213+00:00 2 default_pool
success campaign-flow-job_v002 create_emr_steps 2021-05-09T20:00:00+00:00 PythonOperator 2021-05-09T21:00:23.733134+00:00 2021-05-09T21:00:26.954689+00:00 0:00:03.221555 26307 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 5 default 2021-05-09T21:00:21.454192+00:00 2 default_pool
success campaign-history-job_v002 check_cluster_status 2021-05-09T19:00:00+00:00 EmrJobFlowSensor 2021-05-09T20:11:19.992787+00:00 2021-05-09T20:21:22.957996+00:00 0:10:02.965209 26305 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-05-09T20:11:17.714048+00:00 2 default_pool
success booking-processing-job_v002 check_cluster_status 2021-05-09T19:00:00+00:00 EmrJobFlowSensor 2021-05-09T20:11:09.960481+00:00 2021-05-09T20:21:12.793854+00:00 0:10:02.833373 26304 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-05-09T20:11:07.701559+00:00 2 default_pool
success campaign-history-job_v002 create_cluster_and_add_emr_steps 2021-05-09T19:00:00+00:00 EmrCreateJobFlowOperator 2021-05-09T20:10:54.271403+00:00 2021-05-09T20:10:56.099634+00:00 0:00:01.828231 26303 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 2 default 2021-05-09T20:10:51.743811+00:00 2 default_pool
success booking-processing-job_v002 create_cluster_and_add_emr_steps 2021-05-09T19:00:00+00:00 EmrCreateJobFlowOperator 2021-05-09T20:10:49.974097+00:00 2021-05-09T20:10:51.689339+00:00 0:00:01.715242 26302 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 2 default 2021-05-09T20:10:47.707590+00:00 2 default_pool
success campaign-history-job_v002 create_emr_steps 2021-05-09T19:00:00+00:00 PythonOperator 2021-05-09T20:10:33.925532+00:00 2021-05-09T20:10:37.022065+00:00 0:00:03.096533 26301 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-05-09T20:10:31.638028+00:00 2 default_pool
success booking-processing-job_v002 create_emr_steps 2021-05-09T19:00:00+00:00 PythonOperator 2021-05-09T20:10:28.124772+00:00 2021-05-09T20:10:31.436326+00:00 0:00:03.311554 26300 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-05-09T20:10:25.637098+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_campaign-history-job_v002 2021-05-09T19:00:00+00:00 TriggerDagRunOperator 2021-05-09T20:10:21.911031+00:00 2021-05-09T20:10:22.459098+00:00 0:00:00.548067 26299 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-05-09T20:10:19.630366+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_booking-processing-job_v002 2021-05-09T19:00:00+00:00 TriggerDagRunOperator 2021-05-09T20:10:21.801295+00:00 2021-05-09T20:10:22.266418+00:00 0:00:00.465123 26298 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-05-09T20:10:19.630397+00:00 2 default_pool
success vc-asset-import_v002 check_cluster_status 2021-05-09T19:05:00+00:00 EmrJobFlowSensor 2021-05-09T20:05:57.214211+00:00 2021-05-09T20:13:59.672090+00:00 0:08:02.457879 26297 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-05-09T20:05:55.094728+00:00 2 default_pool
success vc-asset-import_v002 create_cluster_and_add_emr_steps 2021-05-09T19:05:00+00:00 EmrCreateJobFlowOperator 2021-05-09T20:05:35.635140+00:00 2021-05-09T20:05:37.337229+00:00 0:00:01.702089 26296 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 2 default 2021-05-09T20:05:33.144636+00:00 2 default_pool
success vc-asset-import_v002 create_emr_steps 2021-05-09T19:05:00+00:00 PythonOperator 2021-05-09T20:05:13.172117+00:00 2021-05-09T20:05:16.260182+00:00 0:00:03.088065 26295 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-05-09T20:05:10.988810+00:00 2 default_pool
success campaign-flow-job_v002 check_cluster_status 2021-05-09T19:00:00+00:00 EmrJobFlowSensor 2021-05-09T20:01:04.719597+00:00 2021-05-09T20:10:07.462787+00:00 0:09:02.743190 26294 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-05-09T20:01:02.507963+00:00 2 default_pool
success campaign-flow-job_v002 create_cluster_and_add_emr_steps 2021-05-09T19:00:00+00:00 EmrCreateJobFlowOperator 2021-05-09T20:00:42.809202+00:00 2021-05-09T20:00:44.626642+00:00 0:00:01.817440 26293 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 4 default 2021-05-09T20:00:40.490357+00:00 2 default_pool
success campaign-flow-job_v002 create_emr_steps 2021-05-09T19:00:00+00:00 PythonOperator 2021-05-09T20:00:22.538372+00:00 2021-05-09T20:00:25.665845+00:00 0:00:03.127473 26292 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 5 default 2021-05-09T20:00:20.433462+00:00 2 default_pool
success campaign-history-job_v002 check_cluster_status 2021-05-09T18:00:00+00:00 EmrJobFlowSensor 2021-05-09T19:13:05.989347+00:00 2021-05-09T19:21:08.428800+00:00 0:08:02.439453 26291 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-05-09T19:13:03.823543+00:00 2 default_pool
success booking-processing-job_v002 check_cluster_status 2021-05-09T18:00:00+00:00 EmrJobFlowSensor 2021-05-09T19:12:58.146799+00:00 2021-05-09T19:23:01.105386+00:00 0:10:02.958587 26290 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-05-09T19:12:55.811221+00:00 2 default_pool
success booking-processing-job_v002 create_cluster_and_add_emr_steps 2021-05-09T18:00:00+00:00 EmrCreateJobFlowOperator 2021-05-09T19:12:34.145882+00:00 2021-05-09T19:12:35.959261+00:00 0:00:01.813379 26289 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 2 default 2021-05-09T19:12:31.786584+00:00 2 default_pool
success campaign-history-job_v002 create_cluster_and_add_emr_steps 2021-05-09T18:00:00+00:00 EmrCreateJobFlowOperator 2021-05-09T19:12:34.045944+00:00 2021-05-09T19:12:35.727933+00:00 0:00:01.681989 26288 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 2 default 2021-05-09T19:12:31.786614+00:00 2 default_pool
success campaign-history-job_v002 create_emr_steps 2021-05-09T18:00:00+00:00 PythonOperator 2021-05-09T19:12:10.463772+00:00 2021-05-09T19:12:13.512032+00:00 0:00:03.048260 26287 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-05-09T19:12:07.770257+00:00 2 default_pool
success booking-processing-job_v002 create_emr_steps 2021-05-09T18:00:00+00:00 PythonOperator 2021-05-09T19:12:10.320615+00:00 2021-05-09T19:12:13.648429+00:00 0:00:03.327814 26286 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-05-09T19:12:07.770286+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_campaign-history-job_v002 2021-05-09T18:00:00+00:00 TriggerDagRunOperator 2021-05-09T19:11:16.808752+00:00 2021-05-09T19:11:17.355128+00:00 0:00:00.546376 26284 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-05-09T19:11:14.551432+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_booking-processing-job_v002 2021-05-09T18:00:00+00:00 TriggerDagRunOperator 2021-05-09T19:11:16.734750+00:00 2021-05-09T19:11:17.142794+00:00 0:00:00.408044 26283 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-05-09T19:11:14.551465+00:00 2 default_pool
success vc-asset-import_v002 check_cluster_status 2021-05-09T18:05:00+00:00 EmrJobFlowSensor 2021-05-09T19:05:50.282981+00:00 2021-05-09T19:14:52.814987+00:00 0:09:02.532006 26282 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-05-09T19:05:48.102078+00:00 2 default_pool
success vc-asset-import_v002 create_cluster_and_add_emr_steps 2021-05-09T18:05:00+00:00 EmrCreateJobFlowOperator 2021-05-09T19:05:28.128675+00:00 2021-05-09T19:05:30.391703+00:00 0:00:02.263028 26281 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 2 default 2021-05-09T19:05:26.020052+00:00 2 default_pool
success vc-asset-import_v002 create_emr_steps 2021-05-09T18:05:00+00:00 PythonOperator 2021-05-09T19:05:06.250822+00:00 2021-05-09T19:05:09.307673+00:00 0:00:03.056851 26280 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-05-09T19:05:04.069322+00:00 2 default_pool
success campaign-flow-job_v002 check_cluster_status 2021-05-09T18:00:00+00:00 EmrJobFlowSensor 2021-05-09T19:01:04.114877+00:00 2021-05-09T19:11:06.994541+00:00 0:10:02.879664 26279 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-05-09T19:01:01.675557+00:00 2 default_pool
success campaign-flow-job_v002 create_cluster_and_add_emr_steps 2021-05-09T18:00:00+00:00 EmrCreateJobFlowOperator 2021-05-09T19:00:41.793319+00:00 2021-05-09T19:00:43.637066+00:00 0:00:01.843747 26278 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 4 default 2021-05-09T19:00:39.598568+00:00 2 default_pool
success campaign-flow-job_v002 create_emr_steps 2021-05-09T18:00:00+00:00 PythonOperator 2021-05-09T19:00:20.016605+00:00 2021-05-09T19:00:23.138072+00:00 0:00:03.121467 26277 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 5 default 2021-05-09T19:00:17.574560+00:00 2 default_pool
success booking-processing-job_v002 check_cluster_status 2021-05-09T17:00:00+00:00 EmrJobFlowSensor 2021-05-09T18:12:45.179021+00:00 2021-05-09T18:21:47.845396+00:00 0:09:02.666375 26276 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-05-09T18:12:42.841251+00:00 2 default_pool
success campaign-history-job_v002 check_cluster_status 2021-05-09T17:00:00+00:00 EmrJobFlowSensor 2021-05-09T18:12:35.044316+00:00 2021-05-09T18:22:37.940149+00:00 0:10:02.895833 26275 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-05-09T18:12:32.728075+00:00 2 default_pool
success booking-processing-job_v002 create_cluster_and_add_emr_steps 2021-05-09T17:00:00+00:00 EmrCreateJobFlowOperator 2021-05-09T18:12:25.084558+00:00 2021-05-09T18:12:26.911666+00:00 0:00:01.827108 26274 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 2 default 2021-05-09T18:12:22.727642+00:00 2 default_pool
success campaign-history-job_v002 create_cluster_and_add_emr_steps 2021-05-09T17:00:00+00:00 EmrCreateJobFlowOperator 2021-05-09T18:12:15.073851+00:00 2021-05-09T18:12:16.868057+00:00 0:00:01.794206 26273 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 2 default 2021-05-09T18:12:12.708010+00:00 2 default_pool
success booking-processing-job_v002 create_emr_steps 2021-05-09T17:00:00+00:00 PythonOperator 2021-05-09T18:12:02.874343+00:00 2021-05-09T18:12:06.152588+00:00 0:00:03.278245 26272 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-05-09T18:12:00.700398+00:00 2 default_pool
success campaign-history-job_v002 create_emr_steps 2021-05-09T17:00:00+00:00 PythonOperator 2021-05-09T18:11:53.149742+00:00 2021-05-09T18:11:56.504710+00:00 0:00:03.354968 26271 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-05-09T18:11:50.692752+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_campaign-history-job_v002 2021-05-09T17:00:00+00:00 TriggerDagRunOperator 2021-05-09T18:11:43.380252+00:00 2021-05-09T18:11:43.797216+00:00 0:00:00.416964 26270 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-05-09T18:11:40.563546+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_booking-processing-job_v002 2021-05-09T17:00:00+00:00 TriggerDagRunOperator 2021-05-09T18:11:43.400923+00:00 2021-05-09T18:11:43.949390+00:00 0:00:00.548467 26269 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-05-09T18:11:40.563578+00:00 2 default_pool
success vc-asset-import_v002 check_cluster_status 2021-05-09T17:05:00+00:00 EmrJobFlowSensor 2021-05-09T18:05:59.186846+00:00 2021-05-09T18:14:01.702809+00:00 0:08:02.515963 26267 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-05-09T18:05:57.106088+00:00 2 default_pool
success vc-asset-import_v002 create_cluster_and_add_emr_steps 2021-05-09T17:05:00+00:00 EmrCreateJobFlowOperator 2021-05-09T18:05:37.371614+00:00 2021-05-09T18:05:39.016838+00:00 0:00:01.645224 26266 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 2 default 2021-05-09T18:05:35.154919+00:00 2 default_pool
success vc-asset-import_v002 create_emr_steps 2021-05-09T17:05:00+00:00 PythonOperator 2021-05-09T18:05:15.162063+00:00 2021-05-09T18:05:18.247188+00:00 0:00:03.085125 26265 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-05-09T18:05:13.003347+00:00 2 default_pool
success campaign-flow-job_v002 check_cluster_status 2021-05-09T17:00:00+00:00 EmrJobFlowSensor 2021-05-09T18:00:50.812854+00:00 2021-05-09T18:10:53.706903+00:00 0:10:02.894049 26264 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-05-09T18:00:48.630998+00:00 2 default_pool
success campaign-flow-job_v002 create_cluster_and_add_emr_steps 2021-05-09T17:00:00+00:00 EmrCreateJobFlowOperator 2021-05-09T18:00:29.040003+00:00 2021-05-09T18:00:30.871923+00:00 0:00:01.831920 26263 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 4 default 2021-05-09T18:00:26.612496+00:00 2 default_pool
success campaign-flow-job_v002 create_emr_steps 2021-05-09T17:00:00+00:00 PythonOperator 2021-05-09T18:00:07.022973+00:00 2021-05-09T18:00:10.110882+00:00 0:00:03.087909 26262 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 5 default 2021-05-09T18:00:04.598203+00:00 2 default_pool
success booking-processing-job_v002 check_cluster_status 2021-05-09T16:00:00+00:00 EmrJobFlowSensor 2021-05-09T17:12:40.081154+00:00 2021-05-09T17:22:42.879296+00:00 0:10:02.798142 26261 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-05-09T17:12:37.891557+00:00 2 default_pool
success campaign-history-job_v002 check_cluster_status 2021-05-09T16:00:00+00:00 EmrJobFlowSensor 2021-05-09T17:12:28.178549+00:00 2021-05-09T17:21:30.770401+00:00 0:09:02.591852 26260 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-05-09T17:12:25.946234+00:00 2 default_pool
success booking-processing-job_v002 create_cluster_and_add_emr_steps 2021-05-09T16:00:00+00:00 EmrCreateJobFlowOperator 2021-05-09T17:12:18.415490+00:00 2021-05-09T17:12:20.254820+00:00 0:00:01.839330 26259 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 2 default 2021-05-09T17:12:15.854323+00:00 2 default_pool
success campaign-history-job_v002 create_cluster_and_add_emr_steps 2021-05-09T16:00:00+00:00 EmrCreateJobFlowOperator 2021-05-09T17:12:08.001555+00:00 2021-05-09T17:12:09.806472+00:00 0:00:01.804917 26258 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 2 default 2021-05-09T17:12:05.799539+00:00 2 default_pool
success booking-processing-job_v002 create_emr_steps 2021-05-09T16:00:00+00:00 PythonOperator 2021-05-09T17:11:58.182118+00:00 2021-05-09T17:12:01.488096+00:00 0:00:03.305978 26257 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-05-09T17:11:55.944583+00:00 2 default_pool
success campaign-history-job_v002 create_emr_steps 2021-05-09T16:00:00+00:00 PythonOperator 2021-05-09T17:11:45.870407+00:00 2021-05-09T17:11:48.931629+00:00 0:00:03.061222 26256 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-05-09T17:11:43.703378+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_booking-processing-job_v002 2021-05-09T16:00:00+00:00 TriggerDagRunOperator 2021-05-09T17:11:30.207028+00:00 2021-05-09T17:11:30.787307+00:00 0:00:00.580279 26255 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-05-09T17:11:27.691111+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_campaign-history-job_v002 2021-05-09T16:00:00+00:00 TriggerDagRunOperator 2021-05-09T17:11:30.083031+00:00 2021-05-09T17:11:30.542121+00:00 0:00:00.459090 26254 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-05-09T17:11:27.691084+00:00 2 default_pool
success vc-asset-import_v002 check_cluster_status 2021-05-09T16:05:00+00:00 EmrJobFlowSensor 2021-05-09T17:05:58.824385+00:00 2021-05-09T17:14:01.190078+00:00 0:08:02.365693 26252 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-05-09T17:05:56.632167+00:00 2 default_pool
success vc-asset-import_v002 create_cluster_and_add_emr_steps 2021-05-09T16:05:00+00:00 EmrCreateJobFlowOperator 2021-05-09T17:05:36.655682+00:00 2021-05-09T17:05:38.291485+00:00 0:00:01.635803 26251 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 2 default 2021-05-09T17:05:34.613266+00:00 2 default_pool
success vc-asset-import_v002 create_emr_steps 2021-05-09T16:05:00+00:00 PythonOperator 2021-05-09T17:05:14.795189+00:00 2021-05-09T17:05:17.869142+00:00 0:00:03.073953 26250 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-05-09T17:05:12.594823+00:00 2 default_pool
success campaign-flow-job_v002 check_cluster_status 2021-05-09T16:00:00+00:00 EmrJobFlowSensor 2021-05-09T17:00:58.487607+00:00 2021-05-09T17:11:01.282573+00:00 0:10:02.794966 26249 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-05-09T17:00:56.256488+00:00 2 default_pool