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_cluster_and_add_emr_steps 2021-04-04T16:00:00+00:00 EmrCreateJobFlowOperator 2021-04-04T17:10:46.738101+00:00 2021-04-04T17:10:48.427857+00:00 0:00:01.689756 13554 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 2 default 2021-04-04T17:10:44.058098+00:00 2 default_pool
success campaign-history-job_v002 create_emr_steps 2021-04-04T16:00:00+00:00 PythonOperator 2021-04-04T17:10:28.304908+00:00 2021-04-04T17:10:31.001617+00:00 0:00:02.696709 13553 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-04-04T17:10:26.042112+00:00 2 default_pool
success booking-processing-job_v002 create_emr_steps 2021-04-04T16:00:00+00:00 PythonOperator 2021-04-04T17:10:26.480809+00:00 2021-04-04T17:10:29.556781+00:00 0:00:03.075972 13552 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-04-04T17:10:24.054833+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_campaign-history-job_v002 2021-04-04T16:00:00+00:00 TriggerDagRunOperator 2021-04-04T17:10:08.384634+00:00 2021-04-04T17:10:08.910488+00:00 0:00:00.525854 13551 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-04T17:10:05.951725+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_booking-processing-job_v002 2021-04-04T16:00:00+00:00 TriggerDagRunOperator 2021-04-04T17:10:08.245661+00:00 2021-04-04T17:10:08.739880+00:00 0:00:00.494219 13550 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-04T17:10:05.951755+00:00 2 default_pool
success vc-asset-import_v002 check_cluster_status 2021-04-04T16:05:00+00:00 EmrJobFlowSensor 2021-04-04T17:05:47.780934+00:00 2021-04-04T17:14:50.349294+00:00 0:09:02.568360 13549 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-04T17:05:45.584288+00:00 2 default_pool
success vc-asset-import_v002 create_cluster_and_add_emr_steps 2021-04-04T16:05:00+00:00 EmrCreateJobFlowOperator 2021-04-04T17:05:27.769047+00:00 2021-04-04T17:05:29.537507+00:00 0:00:01.768460 13548 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 2 default 2021-04-04T17:05:25.520935+00:00 2 default_pool
success vc-asset-import_v002 create_emr_steps 2021-04-04T16:05:00+00:00 PythonOperator 2021-04-04T17:05:05.782046+00:00 2021-04-04T17:05:08.536451+00:00 0:00:02.754405 13547 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-04-04T17:05:03.502340+00:00 2 default_pool
success campaign-flow-job_v002 check_cluster_status 2021-04-04T16:00:00+00:00 EmrJobFlowSensor 2021-04-04T17:00:51.326457+00:00 2021-04-04T17:09:53.938187+00:00 0:09:02.611730 13546 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-04-04T17:00:49.064067+00:00 2 default_pool
success campaign-flow-job_v002 create_cluster_and_add_emr_steps 2021-04-04T16:00:00+00:00 EmrCreateJobFlowOperator 2021-04-04T17:00:29.342375+00:00 2021-04-04T17:00:31.140148+00:00 0:00:01.797773 13545 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 4 default 2021-04-04T17:00:27.036674+00:00 2 default_pool
success campaign-flow-job_v002 create_emr_steps 2021-04-04T16:00:00+00:00 PythonOperator 2021-04-04T17:00:09.409456+00:00 2021-04-04T17:00:12.305468+00:00 0:00:02.896012 13544 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 5 default 2021-04-04T17:00:07.018664+00:00 2 default_pool
success campaign-history-job_v002 check_cluster_status 2021-04-04T15:00:00+00:00 EmrJobFlowSensor 2021-04-04T16:12:40.004054+00:00 2021-04-04T16:21:42.783530+00:00 0:09:02.779476 13542 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-04T16:12:37.688381+00:00 2 default_pool
success booking-processing-job_v002 check_cluster_status 2021-04-04T15:00:00+00:00 EmrJobFlowSensor 2021-04-04T16:12:37.991873+00:00 2021-04-04T16:22:40.793987+00:00 0:10:02.802114 13541 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-04T16:12:35.703282+00:00 2 default_pool
success campaign-history-job_v002 create_cluster_and_add_emr_steps 2021-04-04T15:00:00+00:00 EmrCreateJobFlowOperator 2021-04-04T16:12:20.011853+00:00 2021-04-04T16:12:21.672542+00:00 0:00:01.660689 13540 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 2 default 2021-04-04T16:12:17.631348+00:00 2 default_pool
success booking-processing-job_v002 create_cluster_and_add_emr_steps 2021-04-04T15:00:00+00:00 EmrCreateJobFlowOperator 2021-04-04T16:12:15.908370+00:00 2021-04-04T16:12:17.683478+00:00 0:00:01.775108 13539 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 2 default 2021-04-04T16:12:13.626177+00:00 2 default_pool
success campaign-history-job_v002 create_emr_steps 2021-04-04T15:00:00+00:00 PythonOperator 2021-04-04T16:11:57.888461+00:00 2021-04-04T16:12:00.751098+00:00 0:00:02.862637 13538 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-04-04T16:11:55.612468+00:00 2 default_pool
success booking-processing-job_v002 create_emr_steps 2021-04-04T15:00:00+00:00 PythonOperator 2021-04-04T16:11:55.887618+00:00 2021-04-04T16:11:58.855376+00:00 0:00:02.967758 13537 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-04-04T16:11:53.610798+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_booking-processing-job_v002 2021-04-04T15:00:00+00:00 TriggerDagRunOperator 2021-04-04T16:11:41.809106+00:00 2021-04-04T16:11:42.219795+00:00 0:00:00.410689 13536 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-04T16:11:39.598597+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_campaign-history-job_v002 2021-04-04T15:00:00+00:00 TriggerDagRunOperator 2021-04-04T16:11:41.824954+00:00 2021-04-04T16:11:42.349894+00:00 0:00:00.524940 13535 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-04T16:11:39.598560+00:00 2 default_pool
success vc-asset-import_v002 check_cluster_status 2021-04-04T15:05:00+00:00 EmrJobFlowSensor 2021-04-04T16:06:01.275083+00:00 2021-04-04T16:15:03.929047+00:00 0:09:02.653964 13534 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-04T16:05:59.085444+00:00 2 default_pool
success vc-asset-import_v002 create_cluster_and_add_emr_steps 2021-04-04T15:05:00+00:00 EmrCreateJobFlowOperator 2021-04-04T16:05:35.289595+00:00 2021-04-04T16:05:37.013787+00:00 0:00:01.724192 13533 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 2 default 2021-04-04T16:05:33.013467+00:00 2 default_pool
success vc-asset-import_v002 create_emr_steps 2021-04-04T15:05:00+00:00 PythonOperator 2021-04-04T16:05:13.188917+00:00 2021-04-04T16:05:15.874969+00:00 0:00:02.686052 13532 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-04-04T16:05:10.995302+00:00 2 default_pool
success campaign-flow-job_v002 check_cluster_status 2021-04-04T15:00:00+00:00 EmrJobFlowSensor 2021-04-04T16:01:02.971558+00:00 2021-04-04T16:11:05.726672+00:00 0:10:02.755114 13531 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-04-04T16:01:00.583351+00:00 2 default_pool
success campaign-flow-job_v002 create_cluster_and_add_emr_steps 2021-04-04T15:00:00+00:00 EmrCreateJobFlowOperator 2021-04-04T16:00:40.728682+00:00 2021-04-04T16:00:42.422535+00:00 0:00:01.693853 13530 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 4 default 2021-04-04T16:00:38.535035+00:00 2 default_pool
success campaign-flow-job_v002 create_emr_steps 2021-04-04T15:00:00+00:00 PythonOperator 2021-04-04T16:00:20.749339+00:00 2021-04-04T16:00:23.658962+00:00 0:00:02.909623 13529 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 5 default 2021-04-04T16:00:18.508228+00:00 2 default_pool
success campaign-history-job_v002 check_cluster_status 2021-04-04T14:00:00+00:00 EmrJobFlowSensor 2021-04-04T15:22:55.554759+00:00 2021-04-04T15:31:58.307065+00:00 0:09:02.752306 13528 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-04T15:22:53.058722+00:00 2 default_pool
success booking-processing-job_v002 check_cluster_status 2021-04-04T14:00:00+00:00 EmrJobFlowSensor 2021-04-04T15:22:51.353762+00:00 2021-04-04T15:33:54.304590+00:00 0:11:02.950828 13527 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-04T15:22:49.048340+00:00 2 default_pool
success campaign-history-job_v002 create_cluster_and_add_emr_steps 2021-04-04T14:00:00+00:00 EmrCreateJobFlowOperator 2021-04-04T15:22:33.291105+00:00 2021-04-04T15:22:34.952382+00:00 0:00:01.661277 13526 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 2 default 2021-04-04T15:22:31.046781+00:00 2 default_pool
success booking-processing-job_v002 create_cluster_and_add_emr_steps 2021-04-04T14:00:00+00:00 EmrCreateJobFlowOperator 2021-04-04T15:22:29.208041+00:00 2021-04-04T15:22:30.957768+00:00 0:00:01.749727 13525 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 2 default 2021-04-04T15:22:26.940409+00:00 2 default_pool
success campaign-history-job_v002 create_emr_steps 2021-04-04T14:00:00+00:00 PythonOperator 2021-04-04T15:22:13.509725+00:00 2021-04-04T15:22:16.364035+00:00 0:00:02.854310 13524 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-04-04T15:22:10.919375+00:00 2 default_pool
success booking-processing-job_v002 create_emr_steps 2021-04-04T14:00:00+00:00 PythonOperator 2021-04-04T15:22:09.383606+00:00 2021-04-04T15:22:12.858334+00:00 0:00:03.474728 13523 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-04-04T15:22:06.914557+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_booking-processing-job_v002 2021-04-04T14:00:00+00:00 TriggerDagRunOperator 2021-04-04T15:21:53.513788+00:00 2021-04-04T15:21:54.180229+00:00 0:00:00.666441 13522 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-04T15:21:50.900933+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_campaign-history-job_v002 2021-04-04T14:00:00+00:00 TriggerDagRunOperator 2021-04-04T15:21:53.430119+00:00 2021-04-04T15:21:54.140734+00:00 0:00:00.710615 13521 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-04T15:21:50.900905+00:00 2 default_pool
success vc-asset-import_v002 check_cluster_status 2021-04-04T14:05:00+00:00 EmrJobFlowSensor 2021-04-04T15:05:58.898886+00:00 2021-04-04T15:15:01.614108+00:00 0:09:02.715222 13519 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-04T15:05:56.658698+00:00 2 default_pool
success vc-asset-import_v002 create_cluster_and_add_emr_steps 2021-04-04T14:05:00+00:00 EmrCreateJobFlowOperator 2021-04-04T15:05:37.083502+00:00 2021-04-04T15:05:38.721054+00:00 0:00:01.637552 13518 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 2 default 2021-04-04T15:05:34.614772+00:00 2 default_pool
success vc-asset-import_v002 create_emr_steps 2021-04-04T14:05:00+00:00 PythonOperator 2021-04-04T15:05:16.832772+00:00 2021-04-04T15:05:19.606868+00:00 0:00:02.774096 13517 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-04-04T15:05:14.596516+00:00 2 default_pool
success campaign-flow-job_v002 check_cluster_status 2021-04-04T14:00:00+00:00 EmrJobFlowSensor 2021-04-04T15:01:04.541569+00:00 2021-04-04T15:11:07.490955+00:00 0:10:02.949386 13516 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-04-04T15:01:02.208560+00:00 2 default_pool
success campaign-flow-job_v002 create_cluster_and_add_emr_steps 2021-04-04T14:00:00+00:00 EmrCreateJobFlowOperator 2021-04-04T15:00:42.478029+00:00 2021-04-04T15:00:44.181195+00:00 0:00:01.703166 13515 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 4 default 2021-04-04T15:00:40.189909+00:00 2 default_pool
success campaign-flow-job_v002 create_emr_steps 2021-04-04T14:00:00+00:00 PythonOperator 2021-04-04T15:00:22.329881+00:00 2021-04-04T15:00:25.096195+00:00 0:00:02.766314 13514 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 5 default 2021-04-04T15:00:20.160782+00:00 2 default_pool
success campaign-history-job_v002 check_cluster_status 2021-04-04T13:00:00+00:00 EmrJobFlowSensor 2021-04-04T14:10:11.730057+00:00 2021-04-04T14:19:14.364585+00:00 0:09:02.634528 13513 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-04T14:10:09.366193+00:00 2 default_pool
success booking-processing-job_v002 check_cluster_status 2021-04-04T13:00:00+00:00 EmrJobFlowSensor 2021-04-04T14:10:09.909594+00:00 2021-04-04T14:20:12.891905+00:00 0:10:02.982311 13512 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-04T14:10:07.378384+00:00 2 default_pool
success campaign-history-job_v002 create_cluster_and_add_emr_steps 2021-04-04T13:00:00+00:00 EmrCreateJobFlowOperator 2021-04-04T14:09:52.118137+00:00 2021-04-04T14:09:53.786950+00:00 0:00:01.668813 13511 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 2 default 2021-04-04T14:09:49.366498+00:00 2 default_pool
success booking-processing-job_v002 create_cluster_and_add_emr_steps 2021-04-04T13:00:00+00:00 EmrCreateJobFlowOperator 2021-04-04T14:09:49.754990+00:00 2021-04-04T14:09:51.832547+00:00 0:00:02.077557 13510 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 2 default 2021-04-04T14:09:47.356750+00:00 2 default_pool
success campaign-history-job_v002 create_emr_steps 2021-04-04T13:00:00+00:00 PythonOperator 2021-04-04T14:09:29.631245+00:00 2021-04-04T14:09:32.495450+00:00 0:00:02.864205 13509 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-04-04T14:09:27.269317+00:00 2 default_pool
success booking-processing-job_v002 create_emr_steps 2021-04-04T13:00:00+00:00 PythonOperator 2021-04-04T14:09:27.479323+00:00 2021-04-04T14:09:30.429289+00:00 0:00:02.949966 13508 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-04-04T14:09:25.253142+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_booking-processing-job_v002 2021-04-04T13:00:00+00:00 TriggerDagRunOperator 2021-04-04T14:09:03.950092+00:00 2021-04-04T14:09:04.374602+00:00 0:00:00.424510 13507 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-04T14:09:01.246538+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_campaign-history-job_v002 2021-04-04T13:00:00+00:00 TriggerDagRunOperator 2021-04-04T14:09:03.594856+00:00 2021-04-04T14:09:04.173886+00:00 0:00:00.579030 13506 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-04T14:09:01.246510+00:00 2 default_pool
success vc-asset-import_v002 check_cluster_status 2021-04-04T13:05:00+00:00 EmrJobFlowSensor 2021-04-04T14:06:33.311413+00:00 2021-04-04T14:14:35.740139+00:00 0:08:02.428726 13505 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-04T14:06:31.074040+00:00 2 default_pool
success vc-asset-import_v002 create_cluster_and_add_emr_steps 2021-04-04T13:05:00+00:00 EmrCreateJobFlowOperator 2021-04-04T14:05:39.536729+00:00 2021-04-04T14:05:41.252872+00:00 0:00:01.716143 13503 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 2 default 2021-04-04T14:05:36.987762+00:00 2 default_pool
success vc-asset-import_v002 create_emr_steps 2021-04-04T13:05:00+00:00 PythonOperator 2021-04-04T14:05:17.088854+00:00 2021-04-04T14:05:19.866581+00:00 0:00:02.777727 13502 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-04-04T14:05:14.908003+00:00 2 default_pool
success campaign-flow-job_v002 check_cluster_status 2021-04-04T13:00:00+00:00 EmrJobFlowSensor 2021-04-04T14:00:48.685463+00:00 2021-04-04T14:08:51.177681+00:00 0:08:02.492218 13501 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-04-04T14:00:46.426055+00:00 2 default_pool
success campaign-flow-job_v002 create_cluster_and_add_emr_steps 2021-04-04T13:00:00+00:00 EmrCreateJobFlowOperator 2021-04-04T14:00:28.620007+00:00 2021-04-04T14:00:30.322511+00:00 0:00:01.702504 13500 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 4 default 2021-04-04T14:00:26.408728+00:00 2 default_pool
success campaign-flow-job_v002 create_emr_steps 2021-04-04T13:00:00+00:00 PythonOperator 2021-04-04T14:00:06.746468+00:00 2021-04-04T14:00:09.562983+00:00 0:00:02.816515 13499 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 5 default 2021-04-04T14:00:04.388665+00:00 2 default_pool
success booking-processing-job_v002 check_cluster_status 2021-04-04T12:00:00+00:00 EmrJobFlowSensor 2021-04-04T13:12:16.179782+00:00 2021-04-04T13:21:18.922900+00:00 0:09:02.743118 13498 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-04T13:12:13.793509+00:00 2 default_pool
success campaign-history-job_v002 check_cluster_status 2021-04-04T12:00:00+00:00 EmrJobFlowSensor 2021-04-04T13:12:04.068449+00:00 2021-04-04T13:22:06.889662+00:00 0:10:02.821213 13497 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-04T13:12:01.700014+00:00 2 default_pool
success booking-processing-job_v002 create_cluster_and_add_emr_steps 2021-04-04T12:00:00+00:00 EmrCreateJobFlowOperator 2021-04-04T13:11:56.051206+00:00 2021-04-04T13:11:57.697828+00:00 0:00:01.646622 13496 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 2 default 2021-04-04T13:11:53.753144+00:00 2 default_pool
success campaign-history-job_v002 create_cluster_and_add_emr_steps 2021-04-04T12:00:00+00:00 EmrCreateJobFlowOperator 2021-04-04T13:11:41.948204+00:00 2021-04-04T13:11:43.743093+00:00 0:00:01.794889 13495 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 2 default 2021-04-04T13:11:39.676799+00:00 2 default_pool
success booking-processing-job_v002 create_emr_steps 2021-04-04T12:00:00+00:00 PythonOperator 2021-04-04T13:11:33.917928+00:00 2021-04-04T13:11:36.935375+00:00 0:00:03.017447 13494 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-04-04T13:11:31.672764+00:00 2 default_pool
success campaign-history-job_v002 create_emr_steps 2021-04-04T12:00:00+00:00 PythonOperator 2021-04-04T13:11:21.936398+00:00 2021-04-04T13:11:24.766932+00:00 0:00:02.830534 13493 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-04-04T13:11:19.612404+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_campaign-history-job_v002 2021-04-04T12:00:00+00:00 TriggerDagRunOperator 2021-04-04T13:11:14.233283+00:00 2021-04-04T13:11:14.682388+00:00 0:00:00.449105 13492 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-04T13:11:11.607877+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_booking-processing-job_v002 2021-04-04T12:00:00+00:00 TriggerDagRunOperator 2021-04-04T13:11:14.085451+00:00 2021-04-04T13:11:14.667636+00:00 0:00:00.582185 13491 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-04T13:11:11.607913+00:00 2 default_pool
success vc-asset-import_v002 check_cluster_status 2021-04-04T12:05:00+00:00 EmrJobFlowSensor 2021-04-04T13:06:43.619241+00:00 2021-04-04T13:15:46.281566+00:00 0:09:02.662325 13490 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-04T13:06:41.233613+00:00 2 default_pool
success vc-asset-import_v002 create_cluster_and_add_emr_steps 2021-04-04T12:05:00+00:00 EmrCreateJobFlowOperator 2021-04-04T13:06:17.467868+00:00 2021-04-04T13:06:19.198898+00:00 0:00:01.731030 13489 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 2 default 2021-04-04T13:06:15.217157+00:00 2 default_pool
success vc-asset-import_v002 create_emr_steps 2021-04-04T12:05:00+00:00 PythonOperator 2021-04-04T13:05:57.756022+00:00 2021-04-04T13:06:00.473722+00:00 0:00:02.717700 13488 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-04-04T13:05:55.249489+00:00 2 default_pool
success campaign-flow-job_v002 check_cluster_status 2021-04-04T12:00:00+00:00 EmrJobFlowSensor 2021-04-04T13:01:04.038764+00:00 2021-04-04T13:11:06.764465+00:00 0:10:02.725701 13486 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-04-04T13:01:01.745364+00:00 2 default_pool
success campaign-flow-job_v002 create_cluster_and_add_emr_steps 2021-04-04T12:00:00+00:00 EmrCreateJobFlowOperator 2021-04-04T13:00:41.911778+00:00 2021-04-04T13:00:43.598166+00:00 0:00:01.686388 13485 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 4 default 2021-04-04T13:00:39.693465+00:00 2 default_pool
success campaign-flow-job_v002 create_emr_steps 2021-04-04T12:00:00+00:00 PythonOperator 2021-04-04T13:00:05.964176+00:00 2021-04-04T13:00:08.682362+00:00 0:00:02.718186 13484 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 5 default 2021-04-04T13:00:03.626304+00:00 2 default_pool
success booking-processing-job_v002 check_cluster_status 2021-04-04T11:00:00+00:00 EmrJobFlowSensor 2021-04-04T12:11:08.985588+00:00 2021-04-04T12:20:11.672550+00:00 0:09:02.686962 13483 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-04T12:11:06.745722+00:00 2 default_pool
success campaign-history-job_v002 check_cluster_status 2021-04-04T11:00:00+00:00 EmrJobFlowSensor 2021-04-04T12:11:05.161429+00:00 2021-04-04T12:20:07.920843+00:00 0:09:02.759414 13482 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-04T12:11:02.747219+00:00 2 default_pool
success booking-processing-job_v002 create_cluster_and_add_emr_steps 2021-04-04T11:00:00+00:00 EmrCreateJobFlowOperator 2021-04-04T12:10:46.855425+00:00 2021-04-04T12:10:48.636784+00:00 0:00:01.781359 13481 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 2 default 2021-04-04T12:10:44.618262+00:00 2 default_pool
success campaign-history-job_v002 create_cluster_and_add_emr_steps 2021-04-04T11:00:00+00:00 EmrCreateJobFlowOperator 2021-04-04T12:10:42.801689+00:00 2021-04-04T12:10:44.475281+00:00 0:00:01.673592 13480 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 2 default 2021-04-04T12:10:40.617030+00:00 2 default_pool
success booking-processing-job_v002 create_emr_steps 2021-04-04T11:00:00+00:00 PythonOperator 2021-04-04T12:10:25.106811+00:00 2021-04-04T12:10:28.243294+00:00 0:00:03.136483 13479 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-04-04T12:10:22.666098+00:00 2 default_pool
success campaign-history-job_v002 create_emr_steps 2021-04-04T11:00:00+00:00 PythonOperator 2021-04-04T12:10:20.897106+00:00 2021-04-04T12:10:23.691980+00:00 0:00:02.794874 13478 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-04-04T12:10:18.597093+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_booking-processing-job_v002 2021-04-04T11:00:00+00:00 TriggerDagRunOperator 2021-04-04T12:10:06.977972+00:00 2021-04-04T12:10:07.493044+00:00 0:00:00.515072 13477 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-04T12:10:04.586258+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_campaign-history-job_v002 2021-04-04T11:00:00+00:00 TriggerDagRunOperator 2021-04-04T12:10:06.789475+00:00 2021-04-04T12:10:07.196340+00:00 0:00:00.406865 13476 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-04T12:10:04.586225+00:00 2 default_pool
success vc-asset-import_v002 check_cluster_status 2021-04-04T11:05:00+00:00 EmrJobFlowSensor 2021-04-04T12:06:04.697617+00:00 2021-04-04T12:15:07.312070+00:00 0:09:02.614453 13475 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-04T12:06:02.247621+00:00 2 default_pool
success vc-asset-import_v002 create_cluster_and_add_emr_steps 2021-04-04T11:05:00+00:00 EmrCreateJobFlowOperator 2021-04-04T12:05:44.583965+00:00 2021-04-04T12:05:46.317780+00:00 0:00:01.733815 13474 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 2 default 2021-04-04T12:05:42.173790+00:00 2 default_pool
success vc-asset-import_v002 create_emr_steps 2021-04-04T11:05:00+00:00 PythonOperator 2021-04-04T12:05:22.488505+00:00 2021-04-04T12:05:25.161595+00:00 0:00:02.673090 13473 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-04-04T12:05:20.099972+00:00 2 default_pool
success campaign-flow-job_v002 check_cluster_status 2021-04-04T11:00:00+00:00 EmrJobFlowSensor 2021-04-04T12:00:49.909403+00:00 2021-04-04T12:09:52.635361+00:00 0:09:02.725958 13471 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-04-04T12:00:47.622693+00:00 2 default_pool
success campaign-flow-job_v002 create_cluster_and_add_emr_steps 2021-04-04T11:00:00+00:00 EmrCreateJobFlowOperator 2021-04-04T12:00:26.307259+00:00 2021-04-04T12:00:27.979414+00:00 0:00:01.672155 13470 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 4 default 2021-04-04T12:00:23.680826+00:00 2 default_pool
success campaign-flow-job_v002 create_emr_steps 2021-04-04T11:00:00+00:00 PythonOperator 2021-04-04T12:00:06.108440+00:00 2021-04-04T12:00:08.849909+00:00 0:00:02.741469 13469 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 5 default 2021-04-04T12:00:03.662635+00:00 2 default_pool
success booking-processing-job_v002 check_cluster_status 2021-04-04T10:00:00+00:00 EmrJobFlowSensor 2021-04-04T11:12:37.539582+00:00 2021-04-04T11:22:40.319906+00:00 0:10:02.780324 13468 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-04T11:12:34.967010+00:00 2 default_pool
success campaign-history-job_v002 check_cluster_status 2021-04-04T10:00:00+00:00 EmrJobFlowSensor 2021-04-04T11:12:31.136226+00:00 2021-04-04T11:21:33.692633+00:00 0:09:02.556407 13467 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-04T11:12:28.898314+00:00 2 default_pool
success booking-processing-job_v002 create_cluster_and_add_emr_steps 2021-04-04T10:00:00+00:00 EmrCreateJobFlowOperator 2021-04-04T11:12:15.521385+00:00 2021-04-04T11:12:17.408561+00:00 0:00:01.887176 13466 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 2 default 2021-04-04T11:12:12.957795+00:00 2 default_pool
success campaign-history-job_v002 create_cluster_and_add_emr_steps 2021-04-04T10:00:00+00:00 EmrCreateJobFlowOperator 2021-04-04T11:12:09.312471+00:00 2021-04-04T11:12:11.143145+00:00 0:00:01.830674 13465 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 2 default 2021-04-04T11:12:06.879091+00:00 2 default_pool
success booking-processing-job_v002 create_emr_steps 2021-04-04T10:00:00+00:00 PythonOperator 2021-04-04T11:11:53.315585+00:00 2021-04-04T11:11:56.208813+00:00 0:00:02.893228 13464 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-04-04T11:11:50.864754+00:00 2 default_pool
success campaign-history-job_v002 create_emr_steps 2021-04-04T10:00:00+00:00 PythonOperator 2021-04-04T11:11:49.067778+00:00 2021-04-04T11:11:52.002103+00:00 0:00:02.934325 13463 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-04-04T11:11:46.863230+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_campaign-history-job_v002 2021-04-04T10:00:00+00:00 TriggerDagRunOperator 2021-04-04T11:11:27.215319+00:00 2021-04-04T11:11:27.658391+00:00 0:00:00.443072 13462 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-04T11:11:24.816825+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_booking-processing-job_v002 2021-04-04T10:00:00+00:00 TriggerDagRunOperator 2021-04-04T11:11:27.125637+00:00 2021-04-04T11:11:27.683226+00:00 0:00:00.557589 13461 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-04T11:11:24.816853+00:00 2 default_pool
success vc-asset-import_v002 check_cluster_status 2021-04-04T10:05:00+00:00 EmrJobFlowSensor 2021-04-04T11:06:08.606634+00:00 2021-04-04T11:15:11.266567+00:00 0:09:02.659933 13460 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-04T11:06:06.317311+00:00 2 default_pool
success vc-asset-import_v002 create_cluster_and_add_emr_steps 2021-04-04T10:05:00+00:00 EmrCreateJobFlowOperator 2021-04-04T11:05:46.766121+00:00 2021-04-04T11:05:48.531415+00:00 0:00:01.765294 13459 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 2 default 2021-04-04T11:05:44.363114+00:00 2 default_pool
success vc-asset-import_v002 create_emr_steps 2021-04-04T10:05:00+00:00 PythonOperator 2021-04-04T11:05:22.436429+00:00 2021-04-04T11:05:25.137008+00:00 0:00:02.700579 13458 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-04-04T11:05:20.252234+00:00 2 default_pool
success campaign-flow-job_v002 check_cluster_status 2021-04-04T10:00:00+00:00 EmrJobFlowSensor 2021-04-04T11:02:06.327398+00:00 2021-04-04T11:11:09.164528+00:00 0:09:02.837130 13457 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-04-04T11:02:03.957082+00:00 2 default_pool
success campaign-flow-job_v002 create_cluster_and_add_emr_steps 2021-04-04T10:00:00+00:00 EmrCreateJobFlowOperator 2021-04-04T11:01:44.026062+00:00 2021-04-04T11:01:45.739923+00:00 0:00:01.713861 13456 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 4 default 2021-04-04T11:01:41.857902+00:00 2 default_pool
success campaign-flow-job_v002 create_emr_steps 2021-04-04T10:00:00+00:00 PythonOperator 2021-04-04T11:01:12.615693+00:00 2021-04-04T11:01:15.457791+00:00 0:00:02.842098 13455 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 5 default 2021-04-04T11:01:09.874778+00:00 2 default_pool
success campaign-history-job_v002 check_cluster_status 2021-04-04T09:00:00+00:00 EmrJobFlowSensor 2021-04-04T10:11:24.109582+00:00 2021-04-04T10:21:27.023721+00:00 0:10:02.914139 13453 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-04T10:11:21.634613+00:00 2 default_pool
success booking-processing-job_v002 check_cluster_status 2021-04-04T09:00:00+00:00 EmrJobFlowSensor 2021-04-04T10:11:21.893042+00:00 2021-04-04T10:21:24.718195+00:00 0:10:02.825153 13452 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-04T10:11:19.632381+00:00 2 default_pool
success campaign-history-job_v002 create_cluster_and_add_emr_steps 2021-04-04T09:00:00+00:00 EmrCreateJobFlowOperator 2021-04-04T10:11:03.821994+00:00 2021-04-04T10:11:05.558398+00:00 0:00:01.736404 13451 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 2 default 2021-04-04T10:11:01.617979+00:00 2 default_pool
success booking-processing-job_v002 create_cluster_and_add_emr_steps 2021-04-04T09:00:00+00:00 EmrCreateJobFlowOperator 2021-04-04T10:11:02.026956+00:00 2021-04-04T10:11:03.939901+00:00 0:00:01.912945 13450 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 2 default 2021-04-04T10:10:59.663445+00:00 2 default_pool
success campaign-history-job_v002 create_emr_steps 2021-04-04T09:00:00+00:00 PythonOperator 2021-04-04T10:10:41.875010+00:00 2021-04-04T10:10:44.571687+00:00 0:00:02.696677 13449 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-04-04T10:10:39.602841+00:00 2 default_pool