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 vc-asset-import_v002 create_cluster_and_add_emr_steps 2021-05-11T05:05:00+00:00 EmrCreateJobFlowOperator 2021-05-11T06:06:16.375287+00:00 2021-05-11T06:06:18.170964+00:00 0:00:01.795677 26811 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 2 default 2021-05-11T06:06:14.102859+00:00 2 default_pool
success vc-asset-import_v002 create_emr_steps 2021-05-11T05:05:00+00:00 PythonOperator 2021-05-11T06:05:56.375337+00:00 2021-05-11T06:05:59.433428+00:00 0:00:03.058091 26810 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-05-11T06:05:54.054311+00:00 2 default_pool
success campaign-flow-job_v002 check_cluster_status 2021-05-11T05:00:00+00:00 EmrJobFlowSensor 2021-05-11T06:00:53.777609+00:00 2021-05-11T06:23:58.500511+00:00 0:23:04.722902 26809 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-05-11T06:00:51.672394+00:00 2 default_pool
success campaign-flow-job_v002 create_cluster_and_add_emr_steps 2021-05-11T05:00:00+00:00 EmrCreateJobFlowOperator 2021-05-11T06:00:30.341746+00:00 2021-05-11T06:00:32.143988+00:00 0:00:01.802242 26808 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 4 default 2021-05-11T06:00:27.748467+00:00 2 default_pool
success campaign-flow-job_v002 create_emr_steps 2021-05-11T05:00:00+00:00 PythonOperator 2021-05-11T06:00:07.864363+00:00 2021-05-11T06:00:11.106209+00:00 0:00:03.241846 26807 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 5 default 2021-05-11T06:00:05.575298+00:00 2 default_pool
success campaign-history-job_v002 check_cluster_status 2021-05-11T04:00:00+00:00 EmrJobFlowSensor 2021-05-11T05:12:16.463971+00:00 2021-05-11T05:20:19.139667+00:00 0:08:02.675696 26805 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-05-11T05:12:14.145878+00:00 2 default_pool
success booking-processing-job_v002 check_cluster_status 2021-05-11T04:00:00+00:00 EmrJobFlowSensor 2021-05-11T05:12:10.346949+00:00 2021-05-11T05:22:13.153671+00:00 0:10:02.806722 26804 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-05-11T05:12:08.068309+00:00 2 default_pool
success campaign-history-job_v002 create_cluster_and_add_emr_steps 2021-05-11T04:00:00+00:00 EmrCreateJobFlowOperator 2021-05-11T05:11:54.256844+00:00 2021-05-11T05:11:55.938578+00:00 0:00:01.681734 26803 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 2 default 2021-05-11T05:11:52.059281+00:00 2 default_pool
success booking-processing-job_v002 create_cluster_and_add_emr_steps 2021-05-11T04:00:00+00:00 EmrCreateJobFlowOperator 2021-05-11T05:11:50.088240+00:00 2021-05-11T05:11:51.758866+00:00 0:00:01.670626 26802 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 2 default 2021-05-11T05:11:48.000932+00:00 2 default_pool
success campaign-history-job_v002 create_emr_steps 2021-05-11T04:00:00+00:00 PythonOperator 2021-05-11T05:11:34.437981+00:00 2021-05-11T05:11:37.554189+00:00 0:00:03.116208 26801 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-05-11T05:11:31.984817+00:00 2 default_pool
success booking-processing-job_v002 create_emr_steps 2021-05-11T04:00:00+00:00 PythonOperator 2021-05-11T05:11:28.371740+00:00 2021-05-11T05:11:31.743569+00:00 0:00:03.371829 26800 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-05-11T05:11:25.929834+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_booking-processing-job_v002 2021-05-11T04:00:00+00:00 TriggerDagRunOperator 2021-05-11T05:11:10.528426+00:00 2021-05-11T05:11:11.087285+00:00 0:00:00.558859 26799 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-05-11T05:11:07.973802+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_campaign-history-job_v002 2021-05-11T04:00:00+00:00 TriggerDagRunOperator 2021-05-11T05:11:10.402483+00:00 2021-05-11T05:11:10.798983+00:00 0:00:00.396500 26798 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-05-11T05:11:07.973767+00:00 2 default_pool
success vc-asset-import_v002 check_cluster_status 2021-05-11T04:05:00+00:00 EmrJobFlowSensor 2021-05-11T05:06:05.367024+00:00 2021-05-11T05:15:08.053722+00:00 0:09:02.686698 26797 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-05-11T05:06:03.255466+00:00 2 default_pool
success vc-asset-import_v002 create_cluster_and_add_emr_steps 2021-05-11T04:05:00+00:00 EmrCreateJobFlowOperator 2021-05-11T05:05:43.389196+00:00 2021-05-11T05:05:45.087136+00:00 0:00:01.697940 26796 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 2 default 2021-05-11T05:05:41.221698+00:00 2 default_pool
success vc-asset-import_v002 create_emr_steps 2021-05-11T04:05:00+00:00 PythonOperator 2021-05-11T05:05:21.265990+00:00 2021-05-11T05:05:24.307528+00:00 0:00:03.041538 26795 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-05-11T05:05:19.195793+00:00 2 default_pool
success campaign-flow-job_v002 check_cluster_status 2021-05-11T04:00:00+00:00 EmrJobFlowSensor 2021-05-11T05:00:49.143474+00:00 2021-05-11T05:10:52.037822+00:00 0:10:02.894348 26794 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-05-11T05:00:46.607363+00:00 2 default_pool
success campaign-flow-job_v002 create_cluster_and_add_emr_steps 2021-05-11T04:00:00+00:00 EmrCreateJobFlowOperator 2021-05-11T05:00:29.089489+00:00 2021-05-11T05:00:30.914590+00:00 0:00:01.825101 26793 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 4 default 2021-05-11T05:00:26.593570+00:00 2 default_pool
success campaign-flow-job_v002 create_emr_steps 2021-05-11T04:00:00+00:00 PythonOperator 2021-05-11T05:00:06.778936+00:00 2021-05-11T05:00:09.933427+00:00 0:00:03.154491 26792 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 5 default 2021-05-11T05:00:04.544773+00:00 2 default_pool
success booking-processing-job_v002 check_cluster_status 2021-05-11T03:00:00+00:00 EmrJobFlowSensor 2021-05-11T04:12:12.764913+00:00 2021-05-11T04:24:15.919070+00:00 0:12:03.154157 26790 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-05-11T04:12:10.489843+00:00 2 default_pool
success campaign-history-job_v002 check_cluster_status 2021-05-11T03:00:00+00:00 EmrJobFlowSensor 2021-05-11T04:12:01.413797+00:00 2021-05-11T04:21:04.121735+00:00 0:09:02.707938 26789 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-05-11T04:11:58.566110+00:00 2 default_pool
success booking-processing-job_v002 create_cluster_and_add_emr_steps 2021-05-11T03:00:00+00:00 EmrCreateJobFlowOperator 2021-05-11T04:11:52.540754+00:00 2021-05-11T04:11:54.276029+00:00 0:00:01.735275 26788 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 2 default 2021-05-11T04:11:50.380384+00:00 2 default_pool
success campaign-history-job_v002 create_cluster_and_add_emr_steps 2021-05-11T03:00:00+00:00 EmrCreateJobFlowOperator 2021-05-11T04:11:40.629191+00:00 2021-05-11T04:11:42.464932+00:00 0:00:01.835741 26787 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 2 default 2021-05-11T04:11:38.344019+00:00 2 default_pool
success booking-processing-job_v002 create_emr_steps 2021-05-11T03:00:00+00:00 PythonOperator 2021-05-11T04:11:30.719212+00:00 2021-05-11T04:11:34.046901+00:00 0:00:03.327689 26786 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-05-11T04:11:28.462704+00:00 2 default_pool
success campaign-history-job_v002 create_emr_steps 2021-05-11T03:00:00+00:00 PythonOperator 2021-05-11T04:11:18.482996+00:00 2021-05-11T04:11:21.660484+00:00 0:00:03.177488 26785 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-05-11T04:11:16.325105+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_booking-processing-job_v002 2021-05-11T03:00:00+00:00 TriggerDagRunOperator 2021-05-11T04:11:12.610273+00:00 2021-05-11T04:11:13.120573+00:00 0:00:00.510300 26784 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-05-11T04:11:10.317892+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_campaign-history-job_v002 2021-05-11T03:00:00+00:00 TriggerDagRunOperator 2021-05-11T04:11:12.479129+00:00 2021-05-11T04:11:12.883102+00:00 0:00:00.403973 26783 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-05-11T04:11:10.317851+00:00 2 default_pool
success vc-asset-import_v002 check_cluster_status 2021-05-11T03:05:00+00:00 EmrJobFlowSensor 2021-05-11T04:06:14.191426+00:00 2021-05-11T04:14:16.788342+00:00 0:08:02.596916 26782 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-05-11T04:06:11.896427+00:00 2 default_pool
success vc-asset-import_v002 create_cluster_and_add_emr_steps 2021-05-11T03:05:00+00:00 EmrCreateJobFlowOperator 2021-05-11T04:05:43.978120+00:00 2021-05-11T04:05:45.633427+00:00 0:00:01.655307 26781 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 2 default 2021-05-11T04:05:41.847085+00:00 2 default_pool
success vc-asset-import_v002 create_emr_steps 2021-05-11T03:05:00+00:00 PythonOperator 2021-05-11T04:05:20.082345+00:00 2021-05-11T04:05:23.092349+00:00 0:00:03.010004 26780 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-05-11T04:05:17.825263+00:00 2 default_pool
success campaign-flow-job_v002 check_cluster_status 2021-05-11T03:00:00+00:00 EmrJobFlowSensor 2021-05-11T04:00:57.524549+00:00 2021-05-11T04:11:00.365445+00:00 0:10:02.840896 26779 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-05-11T04:00:55.402813+00:00 2 default_pool
success campaign-flow-job_v002 create_cluster_and_add_emr_steps 2021-05-11T03:00:00+00:00 EmrCreateJobFlowOperator 2021-05-11T04:00:35.510867+00:00 2021-05-11T04:00:37.232014+00:00 0:00:01.721147 26778 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 4 default 2021-05-11T04:00:33.390747+00:00 2 default_pool
success campaign-flow-job_v002 create_emr_steps 2021-05-11T03:00:00+00:00 PythonOperator 2021-05-11T04:00:16.040345+00:00 2021-05-11T04:00:19.145663+00:00 0:00:03.105318 26777 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 5 default 2021-05-11T04:00:13.119946+00:00 2 default_pool
success booking-processing-job_v002 check_cluster_status 2021-05-11T02:00:00+00:00 EmrJobFlowSensor 2021-05-11T03:11:19.899098+00:00 2021-05-11T03:20:22.555918+00:00 0:09:02.656820 26775 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-05-11T03:11:17.690455+00:00 2 default_pool
success campaign-history-job_v002 check_cluster_status 2021-05-11T02:00:00+00:00 EmrJobFlowSensor 2021-05-11T03:11:13.911994+00:00 2021-05-11T03:20:16.673308+00:00 0:09:02.761314 26774 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-05-11T03:11:11.650153+00:00 2 default_pool
success booking-processing-job_v002 create_cluster_and_add_emr_steps 2021-05-11T02:00:00+00:00 EmrCreateJobFlowOperator 2021-05-11T03:10:57.854673+00:00 2021-05-11T03:10:59.497109+00:00 0:00:01.642436 26773 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 2 default 2021-05-11T03:10:55.667554+00:00 2 default_pool
success campaign-history-job_v002 create_cluster_and_add_emr_steps 2021-05-11T02:00:00+00:00 EmrCreateJobFlowOperator 2021-05-11T03:10:52.046428+00:00 2021-05-11T03:10:53.947738+00:00 0:00:01.901310 26772 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 2 default 2021-05-11T03:10:49.680891+00:00 2 default_pool
success booking-processing-job_v002 create_emr_steps 2021-05-11T02:00:00+00:00 PythonOperator 2021-05-11T03:10:36.210326+00:00 2021-05-11T03:10:39.611409+00:00 0:00:03.401083 26771 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-05-11T03:10:33.672565+00:00 2 default_pool
success campaign-history-job_v002 create_emr_steps 2021-05-11T02:00:00+00:00 PythonOperator 2021-05-11T03:10:29.968969+00:00 2021-05-11T03:10:33.133745+00:00 0:00:03.164776 26770 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-05-11T03:10:27.744242+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_campaign-history-job_v002 2021-05-11T02:00:00+00:00 TriggerDagRunOperator 2021-05-11T03:10:11.824139+00:00 2021-05-11T03:10:12.344092+00:00 0:00:00.519953 26769 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-05-11T03:10:09.584483+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_booking-processing-job_v002 2021-05-11T02:00:00+00:00 TriggerDagRunOperator 2021-05-11T03:10:11.684333+00:00 2021-05-11T03:10:12.092801+00:00 0:00:00.408468 26768 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-05-11T03:10:09.584515+00:00 2 default_pool
success vc-asset-import_v002 check_cluster_status 2021-05-11T02:05:00+00:00 EmrJobFlowSensor 2021-05-11T03:05:49.245079+00:00 2021-05-11T03:14:51.785921+00:00 0:09:02.540842 26767 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-05-11T03:05:47.139611+00:00 2 default_pool
success vc-asset-import_v002 create_cluster_and_add_emr_steps 2021-05-11T02:05:00+00:00 EmrCreateJobFlowOperator 2021-05-11T03:05:27.488152+00:00 2021-05-11T03:05:29.143876+00:00 0:00:01.655724 26766 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 2 default 2021-05-11T03:05:25.240873+00:00 2 default_pool
success vc-asset-import_v002 create_emr_steps 2021-05-11T02:05:00+00:00 PythonOperator 2021-05-11T03:05:05.727386+00:00 2021-05-11T03:05:09.020912+00:00 0:00:03.293526 26765 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-05-11T03:05:03.152619+00:00 2 default_pool
success campaign-flow-job_v002 check_cluster_status 2021-05-11T02:00:00+00:00 EmrJobFlowSensor 2021-05-11T03:00:48.798048+00:00 2021-05-11T03:09:51.457360+00:00 0:09:02.659312 26764 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-05-11T03:00:46.643916+00:00 2 default_pool
success campaign-flow-job_v002 create_cluster_and_add_emr_steps 2021-05-11T02:00:00+00:00 EmrCreateJobFlowOperator 2021-05-11T03:00:29.055075+00:00 2021-05-11T03:00:30.870110+00:00 0:00:01.815035 26763 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 4 default 2021-05-11T03:00:26.549163+00:00 2 default_pool
success campaign-flow-job_v002 create_emr_steps 2021-05-11T02:00:00+00:00 PythonOperator 2021-05-11T03:00:06.800546+00:00 2021-05-11T03:00:09.947753+00:00 0:00:03.147207 26762 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 5 default 2021-05-11T03:00:04.433644+00:00 2 default_pool
success campaign-history-job_v002 check_cluster_status 2021-05-11T01:00:00+00:00 EmrJobFlowSensor 2021-05-11T02:10:20.111671+00:00 2021-05-11T02:19:22.924389+00:00 0:09:02.812718 26760 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-05-11T02:10:17.665694+00:00 2 default_pool
success booking-processing-job_v002 check_cluster_status 2021-05-11T01:00:00+00:00 EmrJobFlowSensor 2021-05-11T02:10:08.228980+00:00 2021-05-11T02:21:11.420086+00:00 0:11:03.191106 26759 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-05-11T02:10:05.600343+00:00 2 default_pool
success campaign-history-job_v002 create_cluster_and_add_emr_steps 2021-05-11T01:00:00+00:00 EmrCreateJobFlowOperator 2021-05-11T02:10:00.287734+00:00 2021-05-11T02:10:02.114267+00:00 0:00:01.826533 26758 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 2 default 2021-05-11T02:09:57.749441+00:00 2 default_pool
success booking-processing-job_v002 create_cluster_and_add_emr_steps 2021-05-11T01:00:00+00:00 EmrCreateJobFlowOperator 2021-05-11T02:09:46.254830+00:00 2021-05-11T02:09:47.928652+00:00 0:00:01.673822 26757 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 2 default 2021-05-11T02:09:43.568592+00:00 2 default_pool
success campaign-history-job_v002 create_emr_steps 2021-05-11T01:00:00+00:00 PythonOperator 2021-05-11T02:09:37.672055+00:00 2021-05-11T02:09:40.807032+00:00 0:00:03.134977 26756 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-05-11T02:09:35.556874+00:00 2 default_pool
success booking-processing-job_v002 create_emr_steps 2021-05-11T01:00:00+00:00 PythonOperator 2021-05-11T02:09:24.066341+00:00 2021-05-11T02:09:27.436832+00:00 0:00:03.370491 26755 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-05-11T02:09:21.567134+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_campaign-history-job_v002 2021-05-11T01:00:00+00:00 TriggerDagRunOperator 2021-05-11T02:09:14.108562+00:00 2021-05-11T02:09:14.655140+00:00 0:00:00.546578 26754 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-05-11T02:09:11.555598+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_booking-processing-job_v002 2021-05-11T01:00:00+00:00 TriggerDagRunOperator 2021-05-11T02:09:13.938915+00:00 2021-05-11T02:09:14.441630+00:00 0:00:00.502715 26753 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-05-11T02:09:11.555629+00:00 2 default_pool
success vc-asset-import_v002 check_cluster_status 2021-05-11T01:05:00+00:00 EmrJobFlowSensor 2021-05-11T02:05:55.542136+00:00 2021-05-11T02:13:58.114364+00:00 0:08:02.572228 26752 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-05-11T02:05:53.169115+00:00 2 default_pool
success vc-asset-import_v002 create_cluster_and_add_emr_steps 2021-05-11T01:05:00+00:00 EmrCreateJobFlowOperator 2021-05-11T02:05:33.389882+00:00 2021-05-11T02:05:35.047382+00:00 0:00:01.657500 26751 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 2 default 2021-05-11T02:05:31.150847+00:00 2 default_pool
success vc-asset-import_v002 create_emr_steps 2021-05-11T01:05:00+00:00 PythonOperator 2021-05-11T02:05:11.167867+00:00 2021-05-11T02:05:14.314896+00:00 0:00:03.147029 26750 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-05-11T02:05:09.037851+00:00 2 default_pool
success campaign-flow-job_v002 check_cluster_status 2021-05-11T01:00:00+00:00 EmrJobFlowSensor 2021-05-11T02:00:54.662864+00:00 2021-05-11T02:08:57.237411+00:00 0:08:02.574547 26749 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-05-11T02:00:52.462608+00:00 2 default_pool
success campaign-flow-job_v002 create_cluster_and_add_emr_steps 2021-05-11T01:00:00+00:00 EmrCreateJobFlowOperator 2021-05-11T02:00:30.692537+00:00 2021-05-11T02:00:32.397442+00:00 0:00:01.704905 26748 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 4 default 2021-05-11T02:00:28.463133+00:00 2 default_pool
success campaign-flow-job_v002 create_emr_steps 2021-05-11T01:00:00+00:00 PythonOperator 2021-05-11T02:00:05.301265+00:00 2021-05-11T02:00:08.513170+00:00 0:00:03.211905 26747 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 5 default 2021-05-11T02:00:02.469390+00:00 2 default_pool
success booking-processing-job_v002 check_cluster_status 2021-05-11T00:00:00+00:00 EmrJobFlowSensor 2021-05-11T01:10:47.904167+00:00 2021-05-11T01:20:50.631849+00:00 0:10:02.727682 26745 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-05-11T01:10:45.747689+00:00 2 default_pool
success campaign-history-job_v002 check_cluster_status 2021-05-11T00:00:00+00:00 EmrJobFlowSensor 2021-05-11T01:10:45.997135+00:00 2021-05-11T01:19:48.734768+00:00 0:09:02.737633 26744 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-05-11T01:10:43.752888+00:00 2 default_pool
success booking-processing-job_v002 create_cluster_and_add_emr_steps 2021-05-11T00:00:00+00:00 EmrCreateJobFlowOperator 2021-05-11T01:10:27.913545+00:00 2021-05-11T01:10:29.653665+00:00 0:00:01.740120 26743 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 2 default 2021-05-11T01:10:25.738693+00:00 2 default_pool
success campaign-history-job_v002 create_cluster_and_add_emr_steps 2021-05-11T00:00:00+00:00 EmrCreateJobFlowOperator 2021-05-11T01:10:24.118676+00:00 2021-05-11T01:10:25.815130+00:00 0:00:01.696454 26742 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 2 default 2021-05-11T01:10:21.728527+00:00 2 default_pool
success booking-processing-job_v002 create_emr_steps 2021-05-11T00:00:00+00:00 PythonOperator 2021-05-11T01:10:06.660478+00:00 2021-05-11T01:10:09.998447+00:00 0:00:03.337969 26741 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-05-11T01:10:03.712174+00:00 2 default_pool
success campaign-history-job_v002 create_emr_steps 2021-05-11T00:00:00+00:00 PythonOperator 2021-05-11T01:10:03.976979+00:00 2021-05-11T01:10:07.025455+00:00 0:00:03.048476 26740 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-05-11T01:10:01.707927+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_booking-processing-job_v002 2021-05-11T00:00:00+00:00 TriggerDagRunOperator 2021-05-11T01:09:58.802600+00:00 2021-05-11T01:09:59.313034+00:00 0:00:00.510434 26739 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-05-11T01:09:55.707638+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_campaign-history-job_v002 2021-05-11T00:00:00+00:00 TriggerDagRunOperator 2021-05-11T01:09:58.071919+00:00 2021-05-11T01:09:58.463924+00:00 0:00:00.392005 26738 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-05-11T01:09:55.707588+00:00 2 default_pool
success vc-asset-import_v002 check_cluster_status 2021-05-11T00:05:00+00:00 EmrJobFlowSensor 2021-05-11T01:05:53.768368+00:00 2021-05-11T01:14:56.497215+00:00 0:09:02.728847 26737 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-05-11T01:05:51.326645+00:00 2 default_pool
success vc-asset-import_v002 create_cluster_and_add_emr_steps 2021-05-11T00:05:00+00:00 EmrCreateJobFlowOperator 2021-05-11T01:05:31.660269+00:00 2021-05-11T01:05:33.479761+00:00 0:00:01.819492 26736 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 2 default 2021-05-11T01:05:29.377722+00:00 2 default_pool
success vc-asset-import_v002 create_emr_steps 2021-05-11T00:05:00+00:00 PythonOperator 2021-05-11T01:05:09.429929+00:00 2021-05-11T01:05:12.551664+00:00 0:00:03.121735 26735 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-05-11T01:05:07.293030+00:00 2 default_pool
success campaign-flow-job_v002 check_cluster_status 2021-05-11T00:00:00+00:00 EmrJobFlowSensor 2021-05-11T01:00:47.275756+00:00 2021-05-11T01:09:50.120591+00:00 0:09:02.844835 26734 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-05-11T01:00:44.971222+00:00 2 default_pool
success campaign-flow-job_v002 create_cluster_and_add_emr_steps 2021-05-11T00:00:00+00:00 EmrCreateJobFlowOperator 2021-05-11T01:00:25.435055+00:00 2021-05-11T01:00:27.286610+00:00 0:00:01.851555 26733 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 4 default 2021-05-11T01:00:22.955821+00:00 2 default_pool
success campaign-flow-job_v002 create_emr_steps 2021-05-11T00:00:00+00:00 PythonOperator 2021-05-11T01:00:03.646013+00:00 2021-05-11T01:00:06.829958+00:00 0:00:03.183945 26732 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 5 default 2021-05-11T01:00:00.963017+00:00 2 default_pool
success campaign-history-job_v002 check_cluster_status 2021-05-10T23:00:00+00:00 EmrJobFlowSensor 2021-05-11T00:11:41.017408+00:00 2021-05-11T00:21:43.848036+00:00 0:10:02.830628 26730 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-05-11T00:11:38.891968+00:00 2 default_pool
success booking-processing-job_v002 check_cluster_status 2021-05-10T23:00:00+00:00 EmrJobFlowSensor 2021-05-11T00:11:33.293506+00:00 2021-05-11T00:21:36.403084+00:00 0:10:03.109578 26729 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-05-11T00:11:30.883641+00:00 2 default_pool
success campaign-history-job_v002 create_cluster_and_add_emr_steps 2021-05-10T23:00:00+00:00 EmrCreateJobFlowOperator 2021-05-11T00:11:19.625637+00:00 2021-05-11T00:11:21.306237+00:00 0:00:01.680600 26728 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 2 default 2021-05-11T00:11:17.059865+00:00 2 default_pool
success booking-processing-job_v002 create_cluster_and_add_emr_steps 2021-05-10T23:00:00+00:00 EmrCreateJobFlowOperator 2021-05-11T00:11:11.131289+00:00 2021-05-11T00:11:12.913966+00:00 0:00:01.782677 26727 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 2 default 2021-05-11T00:11:08.793479+00:00 2 default_pool
success campaign-history-job_v002 create_emr_steps 2021-05-10T23:00:00+00:00 PythonOperator 2021-05-11T00:10:57.081043+00:00 2021-05-11T00:11:00.178727+00:00 0:00:03.097684 26726 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-05-11T00:10:54.854979+00:00 2 default_pool
success booking-processing-job_v002 create_emr_steps 2021-05-10T23:00:00+00:00 PythonOperator 2021-05-11T00:10:49.294643+00:00 2021-05-11T00:10:52.675492+00:00 0:00:03.380849 26725 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-05-11T00:10:46.861879+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_booking-processing-job_v002 2021-05-10T23:00:00+00:00 TriggerDagRunOperator 2021-05-11T00:10:33.409576+00:00 2021-05-11T00:10:33.952601+00:00 0:00:00.543025 26724 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-05-11T00:10:30.764111+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_campaign-history-job_v002 2021-05-10T23:00:00+00:00 TriggerDagRunOperator 2021-05-11T00:10:33.300601+00:00 2021-05-11T00:10:33.696299+00:00 0:00:00.395698 26723 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-05-11T00:10:30.764061+00:00 2 default_pool
success vc-asset-import_v002 check_cluster_status 2021-05-10T23:05:00+00:00 EmrJobFlowSensor 2021-05-11T00:05:58.497840+00:00 2021-05-11T00:14:01.087707+00:00 0:08:02.589867 26722 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-05-11T00:05:56.010701+00:00 2 default_pool
success vc-asset-import_v002 create_cluster_and_add_emr_steps 2021-05-10T23:05:00+00:00 EmrCreateJobFlowOperator 2021-05-11T00:05:38.166397+00:00 2021-05-11T00:05:39.915604+00:00 0:00:01.749207 26721 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 2 default 2021-05-11T00:05:35.992539+00:00 2 default_pool
success vc-asset-import_v002 create_emr_steps 2021-05-10T23:05:00+00:00 PythonOperator 2021-05-11T00:05:16.076042+00:00 2021-05-11T00:05:19.120818+00:00 0:00:03.044776 26720 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-05-11T00:05:13.968945+00:00 2 default_pool
success campaign-flow-job_v002 check_cluster_status 2021-05-10T23:00:00+00:00 EmrJobFlowSensor 2021-05-11T00:01:09.581386+00:00 2021-05-11T00:10:12.340172+00:00 0:09:02.758786 26719 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-05-11T00:01:07.470134+00:00 2 default_pool
success campaign-flow-job_v002 create_cluster_and_add_emr_steps 2021-05-10T23:00:00+00:00 EmrCreateJobFlowOperator 2021-05-11T00:00:39.654440+00:00 2021-05-11T00:00:41.374295+00:00 0:00:01.719855 26718 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 4 default 2021-05-11T00:00:37.409701+00:00 2 default_pool
success campaign-flow-job_v002 create_emr_steps 2021-05-10T23:00:00+00:00 PythonOperator 2021-05-11T00:00:17.603087+00:00 2021-05-11T00:00:20.711950+00:00 0:00:03.108863 26717 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 5 default 2021-05-11T00:00:15.389457+00:00 2 default_pool
success booking-processing-job_v002 check_cluster_status 2021-05-10T22:00:00+00:00 EmrJobFlowSensor 2021-05-10T23:12:59.007345+00:00 2021-05-10T23:29:02.700235+00:00 0:16:03.692890 26716 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-05-10T23:12:56.362356+00:00 2 default_pool
success campaign-history-job_v002 check_cluster_status 2021-05-10T22:00:00+00:00 EmrJobFlowSensor 2021-05-10T23:12:58.668493+00:00 2021-05-10T23:21:01.190344+00:00 0:08:02.521851 26715 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-05-10T23:12:56.362325+00:00 2 default_pool
success campaign-history-job_v002 create_cluster_and_add_emr_steps 2021-05-10T22:00:00+00:00 EmrCreateJobFlowOperator 2021-05-10T23:12:36.885163+00:00 2021-05-10T23:12:38.690751+00:00 0:00:01.805588 26714 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 2 default 2021-05-10T23:12:34.353814+00:00 2 default_pool
success booking-processing-job_v002 create_cluster_and_add_emr_steps 2021-05-10T22:00:00+00:00 EmrCreateJobFlowOperator 2021-05-10T23:12:36.710214+00:00 2021-05-10T23:12:38.408300+00:00 0:00:01.698086 26713 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 2 default 2021-05-10T23:12:34.353859+00:00 2 default_pool
success campaign-history-job_v002 create_emr_steps 2021-05-10T22:00:00+00:00 PythonOperator 2021-05-10T23:12:16.547690+00:00 2021-05-10T23:12:19.636698+00:00 0:00:03.089008 26712 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-05-10T23:12:14.265918+00:00 2 default_pool
success booking-processing-job_v002 create_emr_steps 2021-05-10T22:00:00+00:00 PythonOperator 2021-05-10T23:12:16.422842+00:00 2021-05-10T23:12:19.687115+00:00 0:00:03.264273 26711 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-05-10T23:12:14.265888+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_campaign-history-job_v002 2021-05-10T22:00:00+00:00 TriggerDagRunOperator 2021-05-10T23:11:56.935152+00:00 2021-05-10T23:11:57.472450+00:00 0:00:00.537298 26710 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-05-10T23:11:54.251242+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_booking-processing-job_v002 2021-05-10T22:00:00+00:00 TriggerDagRunOperator 2021-05-10T23:11:56.799982+00:00 2021-05-10T23:11:57.257740+00:00 0:00:00.457758 26709 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-05-10T23:11:54.251283+00:00 2 default_pool
success vc-asset-import_v002 check_cluster_status 2021-05-10T22:05:00+00:00 EmrJobFlowSensor 2021-05-10T23:05:47.186815+00:00 2021-05-10T23:14:49.760467+00:00 0:09:02.573652 26707 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-05-10T23:05:44.945589+00:00 2 default_pool
success vc-asset-import_v002 create_cluster_and_add_emr_steps 2021-05-10T22:05:00+00:00 EmrCreateJobFlowOperator 2021-05-10T23:05:25.076018+00:00 2021-05-10T23:05:26.724495+00:00 0:00:01.648477 26706 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 2 default 2021-05-10T23:05:22.860260+00:00 2 default_pool
success vc-asset-import_v002 create_emr_steps 2021-05-10T22:05:00+00:00 PythonOperator 2021-05-10T23:05:04.952976+00:00 2021-05-10T23:05:08.007052+00:00 0:00:03.054076 26705 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-05-10T23:05:02.797489+00:00 2 default_pool