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-07-06T21:00:00+00:00 TriggerDagRunOperator 2021-07-06T22:10:48.316797+00:00 2021-07-06T22:10:48.821572+00:00 0:00:00.504775 50749 airflow-worker-2.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-07-06T22:10:45.652880+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_booking-processing-job_v002 2021-07-06T21:00:00+00:00 TriggerDagRunOperator 2021-07-06T22:10:47.995456+00:00 2021-07-06T22:10:48.369899+00:00 0:00:00.374443 50748 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-07-06T22:10:45.652927+00:00 2 default_pool
success vc-asset-import_v002 check_cluster_status 2021-07-06T21:05:00+00:00 EmrJobFlowSensor 2021-07-06T22:05:59.728866+00:00 2021-07-06T22:15:02.528396+00:00 0:09:02.799530 50747 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-07-06T22:05:57.179213+00:00 2 default_pool
success vc-asset-import_v002 create_cluster_and_add_emr_steps 2021-07-06T21:05:00+00:00 EmrCreateJobFlowOperator 2021-07-06T22:05:39.370526+00:00 2021-07-06T22:05:40.985244+00:00 0:00:01.614718 50746 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 2 default 2021-07-06T22:05:37.057966+00:00 2 default_pool
success vc-asset-import_v002 create_emr_steps 2021-07-06T21:05:00+00:00 PythonOperator 2021-07-06T22:05:17.258768+00:00 2021-07-06T22:05:20.641297+00:00 0:00:03.382529 50745 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-07-06T22:05:14.884239+00:00 2 default_pool
success campaign-flow-job_v002 check_cluster_status 2021-07-06T21:00:00+00:00 EmrJobFlowSensor 2021-07-06T22:01:32.817218+00:00 2021-07-06T22:10:35.728038+00:00 0:09:02.910820 50744 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-07-06T22:01:30.485541+00:00 2 default_pool
success livepop-shuffle-job_v002 check_cluster_status 2021-07-06T21:00:00+00:00 EmrJobFlowSensor 2021-07-06T22:01:12.695271+00:00 2021-07-06T22:12:15.737259+00:00 0:11:03.041988 50743 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-07-06T22:01:10.456720+00:00 2 default_pool
success campaign-flow-job_v002 create_cluster_and_add_emr_steps 2021-07-06T21:00:00+00:00 EmrCreateJobFlowOperator 2021-07-06T22:00:50.630608+00:00 2021-07-06T22:00:52.423924+00:00 0:00:01.793316 50742 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 4 default 2021-07-06T22:00:48.437756+00:00 2 default_pool
success livepop-shuffle-job_v002 create_cluster_and_add_emr_steps 2021-07-06T21:00:00+00:00 EmrCreateJobFlowOperator 2021-07-06T22:00:40.643814+00:00 2021-07-06T22:00:42.344679+00:00 0:00:01.700865 50741 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 2 default 2021-07-06T22:00:38.434990+00:00 2 default_pool
success campaign-flow-job_v002 create_emr_steps 2021-07-06T21:00:00+00:00 PythonOperator 2021-07-06T22:00:17.443836+00:00 2021-07-06T22:00:21.486649+00:00 0:00:04.042813 50740 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 5 default 2021-07-06T22:00:14.416753+00:00 2 default_pool
success livepop-shuffle-job_v002 create_emr_steps 2021-07-06T21:00:00+00:00 PythonOperator 2021-07-06T22:00:13.366527+00:00 2021-07-06T22:00:18.379514+00:00 0:00:05.012987 50739 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-07-06T22:00:10.559988+00:00 2 default_pool
success campaign-history-job_v002 check_cluster_status 2021-07-06T20:00:00+00:00 EmrJobFlowSensor 2021-07-06T21:10:28.130449+00:00 2021-07-06T21:19:30.800056+00:00 0:09:02.669607 50737 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-07-06T21:10:25.832557+00:00 2 default_pool
success booking-processing-job_v002 check_cluster_status 2021-07-06T20:00:00+00:00 EmrJobFlowSensor 2021-07-06T21:10:20.017162+00:00 2021-07-06T21:20:23.030753+00:00 0:10:03.013591 50736 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-07-06T21:10:17.844410+00:00 2 default_pool
success campaign-history-job_v002 create_cluster_and_add_emr_steps 2021-07-06T20:00:00+00:00 EmrCreateJobFlowOperator 2021-07-06T21:10:06.011167+00:00 2021-07-06T21:10:07.681279+00:00 0:00:01.670112 50735 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 2 default 2021-07-06T21:10:03.813588+00:00 2 default_pool
success booking-processing-job_v002 create_cluster_and_add_emr_steps 2021-07-06T20:00:00+00:00 EmrCreateJobFlowOperator 2021-07-06T21:10:00.194739+00:00 2021-07-06T21:10:02.037447+00:00 0:00:01.842708 50734 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 2 default 2021-07-06T21:09:57.810551+00:00 2 default_pool
success campaign-history-job_v002 create_emr_steps 2021-07-06T20:00:00+00:00 PythonOperator 2021-07-06T21:09:45.238263+00:00 2021-07-06T21:09:49.244516+00:00 0:00:04.006253 50733 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-07-06T21:09:41.796346+00:00 2 default_pool
success booking-processing-job_v002 create_emr_steps 2021-07-06T20:00:00+00:00 PythonOperator 2021-07-06T21:09:38.630744+00:00 2021-07-06T21:09:43.793121+00:00 0:00:05.162377 50732 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-07-06T21:09:35.864597+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_booking-processing-job_v002 2021-07-06T20:00:00+00:00 TriggerDagRunOperator 2021-07-06T21:09:30.402181+00:00 2021-07-06T21:09:30.898897+00:00 0:00:00.496716 50731 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-07-06T21:09:27.664046+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_campaign-history-job_v002 2021-07-06T20:00:00+00:00 TriggerDagRunOperator 2021-07-06T21:09:30.263901+00:00 2021-07-06T21:09:30.649661+00:00 0:00:00.385760 50730 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-07-06T21:09:27.663996+00:00 2 default_pool
success vc-asset-import_v002 check_cluster_status 2021-07-06T20:05:00+00:00 EmrJobFlowSensor 2021-07-06T21:06:17.252367+00:00 2021-07-06T21:15:20.076130+00:00 0:09:02.823763 50729 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-07-06T21:06:15.130814+00:00 2 default_pool
success vc-asset-import_v002 create_cluster_and_add_emr_steps 2021-07-06T20:05:00+00:00 EmrCreateJobFlowOperator 2021-07-06T21:05:55.342712+00:00 2021-07-06T21:05:57.139833+00:00 0:00:01.797121 50728 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 2 default 2021-07-06T21:05:53.108673+00:00 2 default_pool
success vc-asset-import_v002 create_emr_steps 2021-07-06T20:05:00+00:00 PythonOperator 2021-07-06T21:05:27.173405+00:00 2021-07-06T21:05:30.786429+00:00 0:00:03.613024 50727 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-07-06T21:05:25.077533+00:00 2 default_pool
success campaign-flow-job_v002 check_cluster_status 2021-07-06T20:00:00+00:00 EmrJobFlowSensor 2021-07-06T21:01:07.126368+00:00 2021-07-06T21:09:09.891614+00:00 0:08:02.765246 50726 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-07-06T21:01:04.609721+00:00 2 default_pool
success livepop-shuffle-job_v002 check_cluster_status 2021-07-06T20:00:00+00:00 EmrJobFlowSensor 2021-07-06T21:01:04.806295+00:00 2021-07-06T21:11:08.035446+00:00 0:10:03.229151 50725 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-07-06T21:01:02.610327+00:00 2 default_pool
success campaign-flow-job_v002 create_cluster_and_add_emr_steps 2021-07-06T20:00:00+00:00 EmrCreateJobFlowOperator 2021-07-06T21:00:45.138621+00:00 2021-07-06T21:00:46.914406+00:00 0:00:01.775785 50724 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 4 default 2021-07-06T21:00:42.597989+00:00 2 default_pool
success livepop-shuffle-job_v002 create_cluster_and_add_emr_steps 2021-07-06T20:00:00+00:00 EmrCreateJobFlowOperator 2021-07-06T21:00:42.987237+00:00 2021-07-06T21:00:44.697759+00:00 0:00:01.710522 50723 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 2 default 2021-07-06T21:00:40.652365+00:00 2 default_pool
success campaign-flow-job_v002 create_emr_steps 2021-07-06T20:00:00+00:00 PythonOperator 2021-07-06T21:00:20.968092+00:00 2021-07-06T21:00:24.670194+00:00 0:00:03.702102 50722 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 5 default 2021-07-06T21:00:18.585010+00:00 2 default_pool
success livepop-shuffle-job_v002 create_emr_steps 2021-07-06T20:00:00+00:00 PythonOperator 2021-07-06T21:00:19.035466+00:00 2021-07-06T21:00:22.429016+00:00 0:00:03.393550 50721 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-07-06T21:00:16.580427+00:00 2 default_pool
success campaign-history-job_v002 check_cluster_status 2021-07-06T19:00:00+00:00 EmrJobFlowSensor 2021-07-06T20:12:45.659238+00:00 2021-07-06T20:22:48.512721+00:00 0:10:02.853483 50719 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-07-06T20:12:43.495236+00:00 2 default_pool
success campaign-history-job_v002 create_cluster_and_add_emr_steps 2021-07-06T19:00:00+00:00 EmrCreateJobFlowOperator 2021-07-06T20:12:23.961744+00:00 2021-07-06T20:12:25.817613+00:00 0:00:01.855869 50718 airflow-worker-2.airflow-worker.bigdata.svc.cluster.local airflow 2 default 2021-07-06T20:12:21.467292+00:00 2 default_pool
success booking-processing-job_v002 check_cluster_status 2021-07-06T19:00:00+00:00 EmrJobFlowSensor 2021-07-06T20:12:23.792516+00:00 2021-07-06T20:22:26.867497+00:00 0:10:03.074981 50717 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-07-06T20:12:21.467257+00:00 2 default_pool
success campaign-history-job_v002 create_emr_steps 2021-07-06T19:00:00+00:00 PythonOperator 2021-07-06T20:12:02.018688+00:00 2021-07-06T20:12:05.699293+00:00 0:00:03.680605 50716 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-07-06T20:11:59.553669+00:00 2 default_pool
success booking-processing-job_v002 create_cluster_and_add_emr_steps 2021-07-06T19:00:00+00:00 EmrCreateJobFlowOperator 2021-07-06T20:12:02.039081+00:00 2021-07-06T20:12:03.952463+00:00 0:00:01.913382 50715 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 2 default 2021-07-06T20:11:59.553610+00:00 2 default_pool
success booking-processing-job_v002 create_emr_steps 2021-07-06T19:00:00+00:00 PythonOperator 2021-07-06T20:11:39.670776+00:00 2021-07-06T20:11:43.732347+00:00 0:00:04.061571 50714 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-07-06T20:11:37.395797+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_booking-processing-job_v002 2021-07-06T19:00:00+00:00 TriggerDagRunOperator 2021-07-06T20:11:35.615427+00:00 2021-07-06T20:11:36.127616+00:00 0:00:00.512189 50713 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-07-06T20:11:33.385092+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_campaign-history-job_v002 2021-07-06T19:00:00+00:00 TriggerDagRunOperator 2021-07-06T20:11:35.552054+00:00 2021-07-06T20:11:35.974563+00:00 0:00:00.422509 50712 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-07-06T20:11:33.385057+00:00 2 default_pool
success vc-asset-import_v002 check_cluster_status 2021-07-06T19:05:00+00:00 EmrJobFlowSensor 2021-07-06T20:06:05.056872+00:00 2021-07-06T20:14:07.529917+00:00 0:08:02.473045 50711 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-07-06T20:06:02.836930+00:00 2 default_pool
success vc-asset-import_v002 create_cluster_and_add_emr_steps 2021-07-06T19:05:00+00:00 EmrCreateJobFlowOperator 2021-07-06T20:05:39.130036+00:00 2021-07-06T20:05:40.892456+00:00 0:00:01.762420 50710 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 2 default 2021-07-06T20:05:36.812567+00:00 2 default_pool
success vc-asset-import_v002 create_emr_steps 2021-07-06T19:05:00+00:00 PythonOperator 2021-07-06T20:05:13.521622+00:00 2021-07-06T20:05:16.556261+00:00 0:00:03.034639 50709 airflow-worker-2.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-07-06T20:05:10.861618+00:00 2 default_pool
success campaign-flow-job_v002 check_cluster_status 2021-07-06T19:00:00+00:00 EmrJobFlowSensor 2021-07-06T20:01:06.749210+00:00 2021-07-06T20:11:09.894980+00:00 0:10:03.145770 50708 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-07-06T20:01:04.358458+00:00 2 default_pool
success livepop-shuffle-job_v002 check_cluster_status 2021-07-06T19:00:00+00:00 EmrJobFlowSensor 2021-07-06T20:00:54.743690+00:00 2021-07-06T20:10:57.613304+00:00 0:10:02.869614 50707 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-07-06T20:00:52.257911+00:00 2 default_pool
success campaign-flow-job_v002 create_cluster_and_add_emr_steps 2021-07-06T19:00:00+00:00 EmrCreateJobFlowOperator 2021-07-06T20:00:44.612755+00:00 2021-07-06T20:00:46.422870+00:00 0:00:01.810115 50706 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 4 default 2021-07-06T20:00:42.259520+00:00 2 default_pool
success livepop-shuffle-job_v002 create_cluster_and_add_emr_steps 2021-07-06T19:00:00+00:00 EmrCreateJobFlowOperator 2021-07-06T20:00:34.644707+00:00 2021-07-06T20:00:36.422501+00:00 0:00:01.777794 50705 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 2 default 2021-07-06T20:00:32.239765+00:00 2 default_pool
success campaign-flow-job_v002 create_emr_steps 2021-07-06T19:00:00+00:00 PythonOperator 2021-07-06T20:00:22.426815+00:00 2021-07-06T20:00:26.052104+00:00 0:00:03.625289 50704 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 5 default 2021-07-06T20:00:20.228723+00:00 2 default_pool
success livepop-shuffle-job_v002 create_emr_steps 2021-07-06T19:00:00+00:00 PythonOperator 2021-07-06T20:00:13.034954+00:00 2021-07-06T20:00:16.509356+00:00 0:00:03.474402 50703 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-07-06T20:00:10.229777+00:00 2 default_pool
success booking-processing-job_v002 check_cluster_status 2021-07-06T18:00:00+00:00 EmrJobFlowSensor 2021-07-06T19:12:12.447771+00:00 2021-07-06T19:22:15.503933+00:00 0:10:03.056162 50701 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-07-06T19:12:09.853449+00:00 2 default_pool
success campaign-history-job_v002 check_cluster_status 2021-07-06T18:00:00+00:00 EmrJobFlowSensor 2021-07-06T19:12:12.386262+00:00 2021-07-06T19:22:15.507467+00:00 0:10:03.121205 50700 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-07-06T19:12:09.853501+00:00 2 default_pool
success booking-processing-job_v002 create_cluster_and_add_emr_steps 2021-07-06T18:00:00+00:00 EmrCreateJobFlowOperator 2021-07-06T19:11:51.971134+00:00 2021-07-06T19:11:53.674692+00:00 0:00:01.703558 50699 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 2 default 2021-07-06T19:11:49.782496+00:00 2 default_pool
success campaign-history-job_v002 create_cluster_and_add_emr_steps 2021-07-06T18:00:00+00:00 EmrCreateJobFlowOperator 2021-07-06T19:11:50.407237+00:00 2021-07-06T19:11:52.240312+00:00 0:00:01.833075 50698 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 2 default 2021-07-06T19:11:47.856998+00:00 2 default_pool
success campaign-history-job_v002 create_emr_steps 2021-07-06T18:00:00+00:00 PythonOperator 2021-07-06T19:11:30.367224+00:00 2021-07-06T19:11:33.755923+00:00 0:00:03.388699 50697 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-07-06T19:11:27.757557+00:00 2 default_pool
success booking-processing-job_v002 create_emr_steps 2021-07-06T18:00:00+00:00 PythonOperator 2021-07-06T19:11:30.191708+00:00 2021-07-06T19:11:34.189967+00:00 0:00:03.998259 50696 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-07-06T19:11:27.757522+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_booking-processing-job_v002 2021-07-06T18:00:00+00:00 TriggerDagRunOperator 2021-07-06T19:11:10.301965+00:00 2021-07-06T19:11:10.796867+00:00 0:00:00.494902 50695 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-07-06T19:11:07.747009+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_campaign-history-job_v002 2021-07-06T18:00:00+00:00 TriggerDagRunOperator 2021-07-06T19:11:10.245242+00:00 2021-07-06T19:11:10.642694+00:00 0:00:00.397452 50694 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-07-06T19:11:07.746969+00:00 2 default_pool
success vc-asset-import_v002 check_cluster_status 2021-07-06T18:05:00+00:00 EmrJobFlowSensor 2021-07-06T19:05:55.255592+00:00 2021-07-06T19:14:57.752613+00:00 0:09:02.497021 50693 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-07-06T19:05:53.150304+00:00 2 default_pool
success vc-asset-import_v002 create_cluster_and_add_emr_steps 2021-07-06T18:05:00+00:00 EmrCreateJobFlowOperator 2021-07-06T19:05:35.602081+00:00 2021-07-06T19:05:37.268529+00:00 0:00:01.666448 50692 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 2 default 2021-07-06T19:05:33.119296+00:00 2 default_pool
success vc-asset-import_v002 create_emr_steps 2021-07-06T18:05:00+00:00 PythonOperator 2021-07-06T19:05:13.443984+00:00 2021-07-06T19:05:17.086320+00:00 0:00:03.642336 50691 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-07-06T19:05:11.101327+00:00 2 default_pool
success livepop-shuffle-job_v002 check_cluster_status 2021-07-06T18:00:00+00:00 EmrJobFlowSensor 2021-07-06T19:00:53.140700+00:00 2021-07-06T19:11:56.124031+00:00 0:11:02.983331 50690 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-07-06T19:00:50.749041+00:00 2 default_pool
success campaign-flow-job_v002 check_cluster_status 2021-07-06T18:00:00+00:00 EmrJobFlowSensor 2021-07-06T19:00:47.003709+00:00 2021-07-06T19:10:50.028418+00:00 0:10:03.024709 50689 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-07-06T19:00:44.676688+00:00 2 default_pool
success livepop-shuffle-job_v002 create_cluster_and_add_emr_steps 2021-07-06T18:00:00+00:00 EmrCreateJobFlowOperator 2021-07-06T19:00:31.173072+00:00 2021-07-06T19:00:32.923206+00:00 0:00:01.750134 50688 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 2 default 2021-07-06T19:00:28.764538+00:00 2 default_pool
success campaign-flow-job_v002 create_cluster_and_add_emr_steps 2021-07-06T18:00:00+00:00 EmrCreateJobFlowOperator 2021-07-06T19:00:26.828873+00:00 2021-07-06T19:00:28.680210+00:00 0:00:01.851337 50687 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 4 default 2021-07-06T19:00:24.601306+00:00 2 default_pool
success livepop-shuffle-job_v002 create_emr_steps 2021-07-06T18:00:00+00:00 PythonOperator 2021-07-06T19:00:10.945860+00:00 2021-07-06T19:00:14.630837+00:00 0:00:03.684977 50686 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-07-06T19:00:08.591144+00:00 2 default_pool
success campaign-flow-job_v002 create_emr_steps 2021-07-06T18:00:00+00:00 PythonOperator 2021-07-06T19:00:05.053885+00:00 2021-07-06T19:00:08.659001+00:00 0:00:03.605116 50685 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 5 default 2021-07-06T19:00:02.585002+00:00 2 default_pool
success booking-processing-job_v002 check_cluster_status 2021-07-06T17:00:00+00:00 EmrJobFlowSensor 2021-07-06T18:12:09.100594+00:00 2021-07-06T18:22:12.084717+00:00 0:10:02.984123 50683 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-07-06T18:12:06.900151+00:00 2 default_pool
success campaign-history-job_v002 check_cluster_status 2021-07-06T17:00:00+00:00 EmrJobFlowSensor 2021-07-06T18:12:03.209671+00:00 2021-07-06T18:22:05.962555+00:00 0:10:02.752884 50682 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-07-06T18:12:00.885798+00:00 2 default_pool
success booking-processing-job_v002 create_cluster_and_add_emr_steps 2021-07-06T17:00:00+00:00 EmrCreateJobFlowOperator 2021-07-06T18:11:46.966868+00:00 2021-07-06T18:11:48.678975+00:00 0:00:01.712107 50681 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 2 default 2021-07-06T18:11:44.819304+00:00 2 default_pool
success campaign-history-job_v002 create_cluster_and_add_emr_steps 2021-07-06T17:00:00+00:00 EmrCreateJobFlowOperator 2021-07-06T18:11:41.090658+00:00 2021-07-06T18:11:42.936534+00:00 0:00:01.845876 50680 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 2 default 2021-07-06T18:11:38.814629+00:00 2 default_pool
success booking-processing-job_v002 create_emr_steps 2021-07-06T17:00:00+00:00 PythonOperator 2021-07-06T18:11:26.311505+00:00 2021-07-06T18:11:30.182941+00:00 0:00:03.871436 50679 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-07-06T18:11:22.798955+00:00 2 default_pool
success campaign-history-job_v002 create_emr_steps 2021-07-06T17:00:00+00:00 PythonOperator 2021-07-06T18:11:20.963713+00:00 2021-07-06T18:11:26.013411+00:00 0:00:05.049698 50678 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-07-06T18:11:18.795326+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_booking-processing-job_v002 2021-07-06T17:00:00+00:00 TriggerDagRunOperator 2021-07-06T18:11:15.444778+00:00 2021-07-06T18:11:15.817288+00:00 0:00:00.372510 50677 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-07-06T18:11:12.797625+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_campaign-history-job_v002 2021-07-06T17:00:00+00:00 TriggerDagRunOperator 2021-07-06T18:11:15.214678+00:00 2021-07-06T18:11:15.702340+00:00 0:00:00.487662 50676 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-07-06T18:11:12.797590+00:00 2 default_pool
success vc-asset-import_v002 check_cluster_status 2021-07-06T17:05:00+00:00 EmrJobFlowSensor 2021-07-06T18:05:54.659234+00:00 2021-07-06T18:14:57.330726+00:00 0:09:02.671492 50675 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-07-06T18:05:52.358794+00:00 2 default_pool
success vc-asset-import_v002 create_cluster_and_add_emr_steps 2021-07-06T17:05:00+00:00 EmrCreateJobFlowOperator 2021-07-06T18:05:34.964519+00:00 2021-07-06T18:05:36.636569+00:00 0:00:01.672050 50674 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 2 default 2021-07-06T18:05:32.367907+00:00 2 default_pool
success vc-asset-import_v002 create_emr_steps 2021-07-06T17:05:00+00:00 PythonOperator 2021-07-06T18:05:12.537034+00:00 2021-07-06T18:05:16.173887+00:00 0:00:03.636853 50673 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-07-06T18:05:10.263143+00:00 2 default_pool
success campaign-flow-job_v002 check_cluster_status 2021-07-06T17:00:00+00:00 EmrJobFlowSensor 2021-07-06T18:01:04.040774+00:00 2021-07-06T18:11:07.038114+00:00 0:10:02.997340 50672 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-07-06T18:01:01.828458+00:00 2 default_pool
success livepop-shuffle-job_v002 check_cluster_status 2021-07-06T17:00:00+00:00 EmrJobFlowSensor 2021-07-06T18:01:00.264237+00:00 2021-07-06T18:13:03.338967+00:00 0:12:03.074730 50671 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-07-06T18:00:57.852903+00:00 2 default_pool
success campaign-flow-job_v002 create_cluster_and_add_emr_steps 2021-07-06T17:00:00+00:00 EmrCreateJobFlowOperator 2021-07-06T18:00:42.394281+00:00 2021-07-06T18:00:44.105525+00:00 0:00:01.711244 50670 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 4 default 2021-07-06T18:00:39.864397+00:00 2 default_pool
success livepop-shuffle-job_v002 create_cluster_and_add_emr_steps 2021-07-06T17:00:00+00:00 EmrCreateJobFlowOperator 2021-07-06T18:00:36.173524+00:00 2021-07-06T18:00:37.910398+00:00 0:00:01.736874 50669 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 2 default 2021-07-06T18:00:33.877838+00:00 2 default_pool
success campaign-flow-job_v002 create_emr_steps 2021-07-06T17:00:00+00:00 PythonOperator 2021-07-06T18:00:20.335216+00:00 2021-07-06T18:00:24.006744+00:00 0:00:03.671528 50668 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 5 default 2021-07-06T18:00:17.789734+00:00 2 default_pool
success livepop-shuffle-job_v002 create_emr_steps 2021-07-06T17:00:00+00:00 PythonOperator 2021-07-06T18:00:14.510298+00:00 2021-07-06T18:00:18.453814+00:00 0:00:03.943516 50667 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-07-06T18:00:11.786270+00:00 2 default_pool
success booking-processing-job_v002 check_cluster_status 2021-07-06T16:00:00+00:00 EmrJobFlowSensor 2021-07-06T17:12:21.116116+00:00 2021-07-06T17:22:24.258692+00:00 0:10:03.142576 50665 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-07-06T17:12:18.850317+00:00 2 default_pool
success campaign-history-job_v002 check_cluster_status 2021-07-06T16:00:00+00:00 EmrJobFlowSensor 2021-07-06T17:12:09.229733+00:00 2021-07-06T17:20:11.900881+00:00 0:08:02.671148 50664 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-07-06T17:12:06.790860+00:00 2 default_pool
success booking-processing-job_v002 create_cluster_and_add_emr_steps 2021-07-06T16:00:00+00:00 EmrCreateJobFlowOperator 2021-07-06T17:12:01.379234+00:00 2021-07-06T17:12:03.229735+00:00 0:00:01.850501 50663 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 2 default 2021-07-06T17:11:58.951085+00:00 2 default_pool
success campaign-history-job_v002 create_cluster_and_add_emr_steps 2021-07-06T16:00:00+00:00 EmrCreateJobFlowOperator 2021-07-06T17:11:49.124793+00:00 2021-07-06T17:11:50.795604+00:00 0:00:01.670811 50662 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 2 default 2021-07-06T17:11:46.722387+00:00 2 default_pool
success booking-processing-job_v002 create_emr_steps 2021-07-06T16:00:00+00:00 PythonOperator 2021-07-06T17:11:38.984304+00:00 2021-07-06T17:11:42.756097+00:00 0:00:03.771793 50661 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-07-06T17:11:36.710130+00:00 2 default_pool
success campaign-history-job_v002 create_emr_steps 2021-07-06T16:00:00+00:00 PythonOperator 2021-07-06T17:11:26.950318+00:00 2021-07-06T17:11:30.354956+00:00 0:00:03.404638 50660 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-07-06T17:11:24.700341+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_campaign-history-job_v002 2021-07-06T16:00:00+00:00 TriggerDagRunOperator 2021-07-06T17:11:21.197083+00:00 2021-07-06T17:11:21.595197+00:00 0:00:00.398114 50659 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-07-06T17:11:18.746371+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_booking-processing-job_v002 2021-07-06T16:00:00+00:00 TriggerDagRunOperator 2021-07-06T17:11:21.201848+00:00 2021-07-06T17:11:21.710344+00:00 0:00:00.508496 50658 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-07-06T17:11:18.746418+00:00 2 default_pool
success vc-asset-import_v002 check_cluster_status 2021-07-06T16:05:00+00:00 EmrJobFlowSensor 2021-07-06T17:05:48.616722+00:00 2021-07-06T17:13:51.320864+00:00 0:08:02.704142 50657 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-07-06T17:05:46.153191+00:00 2 default_pool
success vc-asset-import_v002 create_cluster_and_add_emr_steps 2021-07-06T16:05:00+00:00 EmrCreateJobFlowOperator 2021-07-06T17:05:26.495016+00:00 2021-07-06T17:05:28.249554+00:00 0:00:01.754538 50656 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 2 default 2021-07-06T17:05:24.163298+00:00 2 default_pool
success vc-asset-import_v002 create_emr_steps 2021-07-06T16:05:00+00:00 PythonOperator 2021-07-06T17:05:06.171180+00:00 2021-07-06T17:05:09.520656+00:00 0:00:03.349476 50655 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-07-06T17:05:03.997433+00:00 2 default_pool
success campaign-flow-job_v002 check_cluster_status 2021-07-06T16:00:00+00:00 EmrJobFlowSensor 2021-07-06T17:01:05.777425+00:00 2021-07-06T17:11:08.837694+00:00 0:10:03.060269 50654 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-07-06T17:01:03.514085+00:00 2 default_pool
success livepop-shuffle-job_v002 check_cluster_status 2021-07-06T16:00:00+00:00 EmrJobFlowSensor 2021-07-06T17:00:50.133046+00:00 2021-07-06T17:11:53.129068+00:00 0:11:02.996022 50653 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-07-06T17:00:47.506494+00:00 2 default_pool
success campaign-flow-job_v002 create_cluster_and_add_emr_steps 2021-07-06T16:00:00+00:00 EmrCreateJobFlowOperator 2021-07-06T17:00:43.998383+00:00 2021-07-06T17:00:45.745164+00:00 0:00:01.746781 50652 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 4 default 2021-07-06T17:00:41.552553+00:00 2 default_pool
success livepop-shuffle-job_v002 create_cluster_and_add_emr_steps 2021-07-06T16:00:00+00:00 EmrCreateJobFlowOperator 2021-07-06T17:00:27.837716+00:00 2021-07-06T17:00:29.543340+00:00 0:00:01.705624 50651 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 2 default 2021-07-06T17:00:25.427238+00:00 2 default_pool
success campaign-flow-job_v002 create_emr_steps 2021-07-06T16:00:00+00:00 PythonOperator 2021-07-06T17:00:21.604544+00:00 2021-07-06T17:00:25.068307+00:00 0:00:03.463763 50650 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 5 default 2021-07-06T17:00:19.390764+00:00 2 default_pool
success livepop-shuffle-job_v002 create_emr_steps 2021-07-06T16:00:00+00:00 PythonOperator 2021-07-06T17:00:05.789941+00:00 2021-07-06T17:00:09.513901+00:00 0:00:03.723960 50649 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-07-06T17:00:03.380290+00:00 2 default_pool
success booking-processing-job_v002 check_cluster_status 2021-07-06T15:00:00+00:00 EmrJobFlowSensor 2021-07-06T16:11:24.671470+00:00 2021-07-06T16:21:27.601069+00:00 0:10:02.929599 50647 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-07-06T16:11:22.227837+00:00 2 default_pool
success campaign-history-job_v002 check_cluster_status 2021-07-06T15:00:00+00:00 EmrJobFlowSensor 2021-07-06T16:11:12.566227+00:00 2021-07-06T16:19:15.113230+00:00 0:08:02.547003 50646 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-07-06T16:11:10.276017+00:00 2 default_pool
success booking-processing-job_v002 create_cluster_and_add_emr_steps 2021-07-06T15:00:00+00:00 EmrCreateJobFlowOperator 2021-07-06T16:11:02.449594+00:00 2021-07-06T16:11:04.205413+00:00 0:00:01.755819 50645 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 2 default 2021-07-06T16:11:00.212832+00:00 2 default_pool
success campaign-history-job_v002 create_cluster_and_add_emr_steps 2021-07-06T15:00:00+00:00 EmrCreateJobFlowOperator 2021-07-06T16:10:50.421167+00:00 2021-07-06T16:10:52.097290+00:00 0:00:01.676123 50644 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 2 default 2021-07-06T16:10:48.198220+00:00 2 default_pool