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 check_cluster_status 2021-05-19T10:00:00+00:00 EmrJobFlowSensor 2021-05-19T11:12:09.598120+00:00 2021-05-19T11:22:12.355542+00:00 0:10:02.757422 29800 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-05-19T11:12:07.441402+00:00 2 default_pool
success campaign-history-job_v002 check_cluster_status 2021-05-19T10:00:00+00:00 EmrJobFlowSensor 2021-05-19T11:12:07.778351+00:00 2021-05-19T11:21:10.595526+00:00 0:09:02.817175 29799 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-05-19T11:12:05.440142+00:00 2 default_pool
success booking-processing-job_v002 create_cluster_and_add_emr_steps 2021-05-19T10:00:00+00:00 EmrCreateJobFlowOperator 2021-05-19T11:11:49.709844+00:00 2021-05-19T11:11:51.507780+00:00 0:00:01.797936 29798 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 2 default 2021-05-19T11:11:47.366166+00:00 2 default_pool
success campaign-history-job_v002 create_cluster_and_add_emr_steps 2021-05-19T10:00:00+00:00 EmrCreateJobFlowOperator 2021-05-19T11:11:43.582128+00:00 2021-05-19T11:11:45.299644+00:00 0:00:01.717516 29797 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 2 default 2021-05-19T11:11:41.371314+00:00 2 default_pool
success booking-processing-job_v002 create_emr_steps 2021-05-19T10:00:00+00:00 PythonOperator 2021-05-19T11:11:27.728651+00:00 2021-05-19T11:11:31.145072+00:00 0:00:03.416421 29796 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-05-19T11:11:25.344108+00:00 2 default_pool
success campaign-history-job_v002 create_emr_steps 2021-05-19T10:00:00+00:00 PythonOperator 2021-05-19T11:11:21.601394+00:00 2021-05-19T11:11:24.779314+00:00 0:00:03.177920 29795 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-05-19T11:11:19.357388+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_booking-processing-job_v002 2021-05-19T10:00:00+00:00 TriggerDagRunOperator 2021-05-19T11:11:15.952438+00:00 2021-05-19T11:11:16.543479+00:00 0:00:00.591041 29794 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-05-19T11:11:13.367443+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_campaign-history-job_v002 2021-05-19T10:00:00+00:00 TriggerDagRunOperator 2021-05-19T11:11:15.884882+00:00 2021-05-19T11:11:16.308793+00:00 0:00:00.423911 29793 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-05-19T11:11:13.367395+00:00 2 default_pool
success vc-asset-import_v002 check_cluster_status 2021-05-19T10:05:00+00:00 EmrJobFlowSensor 2021-05-19T11:06:01.028126+00:00 2021-05-19T11:14:03.642013+00:00 0:08:02.613887 29792 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-05-19T11:05:58.841332+00:00 2 default_pool
success vc-asset-import_v002 create_cluster_and_add_emr_steps 2021-05-19T10:05:00+00:00 EmrCreateJobFlowOperator 2021-05-19T11:05:40.958509+00:00 2021-05-19T11:05:42.713803+00:00 0:00:01.755294 29791 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 2 default 2021-05-19T11:05:38.790796+00:00 2 default_pool
success vc-asset-import_v002 create_emr_steps 2021-05-19T10:05:00+00:00 PythonOperator 2021-05-19T11:05:18.852160+00:00 2021-05-19T11:05:22.008148+00:00 0:00:03.155988 29790 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-05-19T11:05:16.712516+00:00 2 default_pool
success campaign-flow-job_v002 check_cluster_status 2021-05-19T10:00:00+00:00 EmrJobFlowSensor 2021-05-19T11:00:48.842891+00:00 2021-05-19T11:10:52.038846+00:00 0:10:03.195955 29789 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-05-19T11:00:46.268398+00:00 2 default_pool
success campaign-flow-job_v002 create_cluster_and_add_emr_steps 2021-05-19T10:00:00+00:00 EmrCreateJobFlowOperator 2021-05-19T11:00:26.597857+00:00 2021-05-19T11:00:28.343434+00:00 0:00:01.745577 29788 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 4 default 2021-05-19T11:00:24.247791+00:00 2 default_pool
success campaign-flow-job_v002 create_emr_steps 2021-05-19T10:00:00+00:00 PythonOperator 2021-05-19T11:00:04.846050+00:00 2021-05-19T11:00:08.048327+00:00 0:00:03.202277 29787 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 5 default 2021-05-19T11:00:02.172654+00:00 2 default_pool
success booking-processing-job_v002 check_cluster_status 2021-05-19T09:00:00+00:00 EmrJobFlowSensor 2021-05-19T10:12:03.582958+00:00 2021-05-19T10:22:06.474139+00:00 0:10:02.891181 29785 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-05-19T10:12:01.246362+00:00 2 default_pool
success campaign-history-job_v002 check_cluster_status 2021-05-19T09:00:00+00:00 EmrJobFlowSensor 2021-05-19T10:12:03.615338+00:00 2021-05-19T10:21:06.453636+00:00 0:09:02.838298 29784 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-05-19T10:12:01.246407+00:00 2 default_pool
success campaign-history-job_v002 create_cluster_and_add_emr_steps 2021-05-19T09:00:00+00:00 EmrCreateJobFlowOperator 2021-05-19T10:11:41.502512+00:00 2021-05-19T10:11:43.299438+00:00 0:00:01.796926 29783 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 2 default 2021-05-19T10:11:39.219629+00:00 2 default_pool
success booking-processing-job_v002 create_cluster_and_add_emr_steps 2021-05-19T09:00:00+00:00 EmrCreateJobFlowOperator 2021-05-19T10:11:39.427353+00:00 2021-05-19T10:11:41.184432+00:00 0:00:01.757079 29782 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 2 default 2021-05-19T10:11:37.218990+00:00 2 default_pool
success campaign-history-job_v002 create_emr_steps 2021-05-19T09:00:00+00:00 PythonOperator 2021-05-19T10:11:21.147144+00:00 2021-05-19T10:11:24.362774+00:00 0:00:03.215630 29781 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-05-19T10:11:17.200041+00:00 2 default_pool
success booking-processing-job_v002 create_emr_steps 2021-05-19T09:00:00+00:00 PythonOperator 2021-05-19T10:11:15.450320+00:00 2021-05-19T10:11:19.931092+00:00 0:00:04.480772 29780 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-05-19T10:11:13.199574+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_campaign-history-job_v002 2021-05-19T09:00:00+00:00 TriggerDagRunOperator 2021-05-19T10:11:11.836965+00:00 2021-05-19T10:11:12.305408+00:00 0:00:00.468443 29779 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-05-19T10:11:09.265514+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_booking-processing-job_v002 2021-05-19T09:00:00+00:00 TriggerDagRunOperator 2021-05-19T10:11:11.810442+00:00 2021-05-19T10:11:12.389419+00:00 0:00:00.578977 29778 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-05-19T10:11:09.265548+00:00 2 default_pool
success vc-asset-import_v002 check_cluster_status 2021-05-19T09:05:00+00:00 EmrJobFlowSensor 2021-05-19T10:05:56.716977+00:00 2021-05-19T10:13:59.189658+00:00 0:08:02.472681 29777 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-05-19T10:05:54.505448+00:00 2 default_pool
success vc-asset-import_v002 create_cluster_and_add_emr_steps 2021-05-19T09:05:00+00:00 EmrCreateJobFlowOperator 2021-05-19T10:05:36.646755+00:00 2021-05-19T10:05:38.281088+00:00 0:00:01.634333 29776 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 2 default 2021-05-19T10:05:34.495420+00:00 2 default_pool
success vc-asset-import_v002 create_emr_steps 2021-05-19T09:05:00+00:00 PythonOperator 2021-05-19T10:05:14.607822+00:00 2021-05-19T10:05:17.778551+00:00 0:00:03.170729 29775 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-05-19T10:05:12.414530+00:00 2 default_pool
success campaign-flow-job_v002 check_cluster_status 2021-05-19T09:00:00+00:00 EmrJobFlowSensor 2021-05-19T10:00:58.180644+00:00 2021-05-19T10:11:01.064574+00:00 0:10:02.883930 29774 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-05-19T10:00:55.989322+00:00 2 default_pool
success campaign-flow-job_v002 create_cluster_and_add_emr_steps 2021-05-19T09:00:00+00:00 EmrCreateJobFlowOperator 2021-05-19T10:00:36.216555+00:00 2021-05-19T10:00:38.022379+00:00 0:00:01.805824 29773 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 4 default 2021-05-19T10:00:33.951643+00:00 2 default_pool
success campaign-flow-job_v002 create_emr_steps 2021-05-19T09:00:00+00:00 PythonOperator 2021-05-19T10:00:14.156309+00:00 2021-05-19T10:00:17.333876+00:00 0:00:03.177567 29772 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 5 default 2021-05-19T10:00:11.818295+00:00 2 default_pool
success booking-processing-job_v002 check_cluster_status 2021-05-19T08:00:00+00:00 EmrJobFlowSensor 2021-05-19T09:11:06.534219+00:00 2021-05-19T09:22:09.762884+00:00 0:11:03.228665 29770 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-05-19T09:11:03.758126+00:00 2 default_pool
success campaign-history-job_v002 check_cluster_status 2021-05-19T08:00:00+00:00 EmrJobFlowSensor 2021-05-19T09:11:06.350046+00:00 2021-05-19T09:20:09.197972+00:00 0:09:02.847926 29769 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-05-19T09:11:03.758089+00:00 2 default_pool
success booking-processing-job_v002 create_cluster_and_add_emr_steps 2021-05-19T08:00:00+00:00 EmrCreateJobFlowOperator 2021-05-19T09:10:44.330850+00:00 2021-05-19T09:10:46.165053+00:00 0:00:01.834203 29768 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 2 default 2021-05-19T09:10:41.725294+00:00 2 default_pool
success campaign-history-job_v002 create_cluster_and_add_emr_steps 2021-05-19T08:00:00+00:00 EmrCreateJobFlowOperator 2021-05-19T09:10:43.930419+00:00 2021-05-19T09:10:45.657478+00:00 0:00:01.727059 29767 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 2 default 2021-05-19T09:10:41.725249+00:00 2 default_pool
success campaign-history-job_v002 create_emr_steps 2021-05-19T08:00:00+00:00 PythonOperator 2021-05-19T09:10:22.256710+00:00 2021-05-19T09:10:25.387859+00:00 0:00:03.131149 29766 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-05-19T09:10:19.844422+00:00 2 default_pool
success booking-processing-job_v002 create_emr_steps 2021-05-19T08:00:00+00:00 PythonOperator 2021-05-19T09:10:20.136172+00:00 2021-05-19T09:10:23.604034+00:00 0:00:03.467862 29765 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-05-19T09:10:17.841406+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_campaign-history-job_v002 2021-05-19T08:00:00+00:00 TriggerDagRunOperator 2021-05-19T09:10:16.450799+00:00 2021-05-19T09:10:16.899822+00:00 0:00:00.449023 29764 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-05-19T09:10:13.713084+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_booking-processing-job_v002 2021-05-19T08:00:00+00:00 TriggerDagRunOperator 2021-05-19T09:10:16.152866+00:00 2021-05-19T09:10:16.726438+00:00 0:00:00.573572 29763 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-05-19T09:10:13.713132+00:00 2 default_pool
success vc-asset-import_v002 check_cluster_status 2021-05-19T08:05:00+00:00 EmrJobFlowSensor 2021-05-19T09:06:05.383499+00:00 2021-05-19T09:15:08.159398+00:00 0:09:02.775899 29762 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-05-19T09:06:03.261899+00:00 2 default_pool
success vc-asset-import_v002 create_cluster_and_add_emr_steps 2021-05-19T08:05:00+00:00 EmrCreateJobFlowOperator 2021-05-19T09:05:41.442034+00:00 2021-05-19T09:05:43.176924+00:00 0:00:01.734890 29761 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 2 default 2021-05-19T09:05:39.193205+00:00 2 default_pool
success vc-asset-import_v002 create_emr_steps 2021-05-19T08:05:00+00:00 PythonOperator 2021-05-19T09:05:17.514739+00:00 2021-05-19T09:05:20.687849+00:00 0:00:03.173110 29760 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-05-19T09:05:15.166010+00:00 2 default_pool
success campaign-flow-job_v002 check_cluster_status 2021-05-19T08:00:00+00:00 EmrJobFlowSensor 2021-05-19T09:01:04.731722+00:00 2021-05-19T09:10:07.564656+00:00 0:09:02.832934 29759 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-05-19T09:01:02.620637+00:00 2 default_pool
success campaign-flow-job_v002 create_cluster_and_add_emr_steps 2021-05-19T08:00:00+00:00 EmrCreateJobFlowOperator 2021-05-19T09:00:42.790835+00:00 2021-05-19T09:00:44.505321+00:00 0:00:01.714486 29758 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 4 default 2021-05-19T09:00:40.589668+00:00 2 default_pool
success campaign-flow-job_v002 create_emr_steps 2021-05-19T08:00:00+00:00 PythonOperator 2021-05-19T09:00:20.770881+00:00 2021-05-19T09:00:23.946548+00:00 0:00:03.175667 29757 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 5 default 2021-05-19T09:00:18.540494+00:00 2 default_pool
success campaign-history-job_v002 check_cluster_status 2021-05-19T07:00:00+00:00 EmrJobFlowSensor 2021-05-19T08:12:07.015940+00:00 2021-05-19T08:22:09.918372+00:00 0:10:02.902432 29755 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-05-19T08:12:04.638153+00:00 2 default_pool
success booking-processing-job_v002 check_cluster_status 2021-05-19T07:00:00+00:00 EmrJobFlowSensor 2021-05-19T08:12:06.893779+00:00 2021-05-19T08:23:10.024909+00:00 0:11:03.131130 29754 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-05-19T08:12:04.638185+00:00 2 default_pool
success campaign-history-job_v002 create_cluster_and_add_emr_steps 2021-05-19T07:00:00+00:00 EmrCreateJobFlowOperator 2021-05-19T08:11:45.288638+00:00 2021-05-19T08:11:46.988106+00:00 0:00:01.699468 29753 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 2 default 2021-05-19T08:11:42.753597+00:00 2 default_pool
success booking-processing-job_v002 create_cluster_and_add_emr_steps 2021-05-19T07:00:00+00:00 EmrCreateJobFlowOperator 2021-05-19T08:11:43.103247+00:00 2021-05-19T08:11:44.951531+00:00 0:00:01.848284 29752 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 2 default 2021-05-19T08:11:40.677594+00:00 2 default_pool
success campaign-history-job_v002 create_emr_steps 2021-05-19T07:00:00+00:00 PythonOperator 2021-05-19T08:11:22.856467+00:00 2021-05-19T08:11:25.981305+00:00 0:00:03.124838 29751 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-05-19T08:11:20.613495+00:00 2 default_pool
success booking-processing-job_v002 create_emr_steps 2021-05-19T07:00:00+00:00 PythonOperator 2021-05-19T08:11:20.915789+00:00 2021-05-19T08:11:24.653450+00:00 0:00:03.737661 29750 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-05-19T08:11:18.616122+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_campaign-history-job_v002 2021-05-19T07:00:00+00:00 TriggerDagRunOperator 2021-05-19T08:11:16.827899+00:00 2021-05-19T08:11:17.347752+00:00 0:00:00.519853 29749 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-05-19T08:11:14.600234+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_booking-processing-job_v002 2021-05-19T07:00:00+00:00 TriggerDagRunOperator 2021-05-19T08:11:16.705942+00:00 2021-05-19T08:11:17.098029+00:00 0:00:00.392087 29748 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-05-19T08:11:14.600266+00:00 2 default_pool
success vc-asset-import_v002 check_cluster_status 2021-05-19T07:05:00+00:00 EmrJobFlowSensor 2021-05-19T08:05:56.233317+00:00 2021-05-19T08:14:58.961230+00:00 0:09:02.727913 29747 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-05-19T08:05:54.078606+00:00 2 default_pool
success vc-asset-import_v002 create_cluster_and_add_emr_steps 2021-05-19T07:05:00+00:00 EmrCreateJobFlowOperator 2021-05-19T08:05:34.534886+00:00 2021-05-19T08:05:36.263853+00:00 0:00:01.728967 29746 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 2 default 2021-05-19T08:05:32.061851+00:00 2 default_pool
success vc-asset-import_v002 create_emr_steps 2021-05-19T07:05:00+00:00 PythonOperator 2021-05-19T08:05:10.266126+00:00 2021-05-19T08:05:13.434248+00:00 0:00:03.168122 29745 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-05-19T08:05:08.043482+00:00 2 default_pool
success campaign-flow-job_v002 check_cluster_status 2021-05-19T07:00:00+00:00 EmrJobFlowSensor 2021-05-19T08:01:01.904272+00:00 2021-05-19T08:11:04.943908+00:00 0:10:03.039636 29744 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-05-19T08:00:59.575956+00:00 2 default_pool
success campaign-flow-job_v002 create_cluster_and_add_emr_steps 2021-05-19T07:00:00+00:00 EmrCreateJobFlowOperator 2021-05-19T08:00:41.609369+00:00 2021-05-19T08:00:43.362747+00:00 0:00:01.753378 29743 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 4 default 2021-05-19T08:00:39.510295+00:00 2 default_pool
success campaign-flow-job_v002 create_emr_steps 2021-05-19T07:00:00+00:00 PythonOperator 2021-05-19T08:00:20.470434+00:00 2021-05-19T08:00:23.651921+00:00 0:00:03.181487 29742 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 5 default 2021-05-19T08:00:17.504754+00:00 2 default_pool
success campaign-history-job_v002 check_cluster_status 2021-05-19T06:00:00+00:00 EmrJobFlowSensor 2021-05-19T07:21:41.618847+00:00 2021-05-19T07:30:44.327685+00:00 0:09:02.708838 29740 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-05-19T07:21:39.271725+00:00 2 default_pool
success booking-processing-job_v002 check_cluster_status 2021-05-19T06:00:00+00:00 EmrJobFlowSensor 2021-05-19T07:21:31.719095+00:00 2021-05-19T07:32:34.757498+00:00 0:11:03.038403 29739 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-05-19T07:21:29.289754+00:00 2 default_pool
success campaign-history-job_v002 create_cluster_and_add_emr_steps 2021-05-19T06:00:00+00:00 EmrCreateJobFlowOperator 2021-05-19T07:21:10.033199+00:00 2021-05-19T07:21:11.719038+00:00 0:00:01.685839 29738 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 2 default 2021-05-19T07:21:07.234661+00:00 2 default_pool
success booking-processing-job_v002 create_cluster_and_add_emr_steps 2021-05-19T06:00:00+00:00 EmrCreateJobFlowOperator 2021-05-19T07:21:07.491715+00:00 2021-05-19T07:21:09.615008+00:00 0:00:02.123293 29737 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 2 default 2021-05-19T07:21:05.233534+00:00 2 default_pool
success campaign-history-job_v002 create_emr_steps 2021-05-19T06:00:00+00:00 PythonOperator 2021-05-19T07:20:45.693501+00:00 2021-05-19T07:20:49.115005+00:00 0:00:03.421504 29736 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-05-19T07:20:43.217940+00:00 2 default_pool
success booking-processing-job_v002 create_emr_steps 2021-05-19T06:00:00+00:00 PythonOperator 2021-05-19T07:20:45.726304+00:00 2021-05-19T07:20:49.110602+00:00 0:00:03.384298 29735 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-05-19T07:20:43.217977+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_booking-processing-job_v002 2021-05-19T06:00:00+00:00 TriggerDagRunOperator 2021-05-19T07:20:31.814669+00:00 2021-05-19T07:20:32.348850+00:00 0:00:00.534181 29734 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-05-19T07:20:29.268347+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_campaign-history-job_v002 2021-05-19T06:00:00+00:00 TriggerDagRunOperator 2021-05-19T07:20:31.718667+00:00 2021-05-19T07:20:32.124609+00:00 0:00:00.405942 29733 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-05-19T07:20:29.268301+00:00 2 default_pool
success vc-asset-import_v002 check_cluster_status 2021-05-19T06:05:00+00:00 EmrJobFlowSensor 2021-05-19T07:06:05.758791+00:00 2021-05-19T07:14:08.260731+00:00 0:08:02.501940 29732 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-05-19T07:06:03.570850+00:00 2 default_pool
success vc-asset-import_v002 create_cluster_and_add_emr_steps 2021-05-19T06:05:00+00:00 EmrCreateJobFlowOperator 2021-05-19T07:05:43.827510+00:00 2021-05-19T07:05:45.579204+00:00 0:00:01.751694 29731 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 2 default 2021-05-19T07:05:41.543202+00:00 2 default_pool
success vc-asset-import_v002 create_emr_steps 2021-05-19T06:05:00+00:00 PythonOperator 2021-05-19T07:05:21.997472+00:00 2021-05-19T07:05:25.135349+00:00 0:00:03.137877 29730 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-05-19T07:05:19.582993+00:00 2 default_pool
success campaign-flow-job_v002 check_cluster_status 2021-05-19T06:00:00+00:00 EmrJobFlowSensor 2021-05-19T07:01:03.536202+00:00 2021-05-19T07:20:07.809279+00:00 0:19:04.273077 29729 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-05-19T07:01:01.068804+00:00 2 default_pool
success campaign-flow-job_v002 create_cluster_and_add_emr_steps 2021-05-19T06:00:00+00:00 EmrCreateJobFlowOperator 2021-05-19T07:00:39.307091+00:00 2021-05-19T07:00:41.004640+00:00 0:00:01.697549 29728 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 4 default 2021-05-19T07:00:37.054173+00:00 2 default_pool
success campaign-flow-job_v002 create_emr_steps 2021-05-19T06:00:00+00:00 PythonOperator 2021-05-19T07:00:15.721905+00:00 2021-05-19T07:00:18.943980+00:00 0:00:03.222075 29727 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 5 default 2021-05-19T07:00:12.916365+00:00 2 default_pool
success campaign-history-job_v002 check_cluster_status 2021-05-19T05:00:00+00:00 EmrJobFlowSensor 2021-05-19T06:11:15.009391+00:00 2021-05-19T06:20:17.907078+00:00 0:09:02.897687 29725 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-05-19T06:11:12.228485+00:00 2 default_pool
success booking-processing-job_v002 check_cluster_status 2021-05-19T05:00:00+00:00 EmrJobFlowSensor 2021-05-19T06:11:14.571956+00:00 2021-05-19T06:22:17.571976+00:00 0:11:03.000020 29724 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-05-19T06:11:12.228437+00:00 2 default_pool
success booking-processing-job_v002 create_cluster_and_add_emr_steps 2021-05-19T05:00:00+00:00 EmrCreateJobFlowOperator 2021-05-19T06:10:55.160835+00:00 2021-05-19T06:10:56.994158+00:00 0:00:01.833323 29723 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 2 default 2021-05-19T06:10:52.201653+00:00 2 default_pool
success campaign-history-job_v002 create_cluster_and_add_emr_steps 2021-05-19T05:00:00+00:00 EmrCreateJobFlowOperator 2021-05-19T06:10:52.549075+00:00 2021-05-19T06:10:54.660858+00:00 0:00:02.111783 29722 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 2 default 2021-05-19T06:10:50.205436+00:00 2 default_pool
success booking-processing-job_v002 create_emr_steps 2021-05-19T05:00:00+00:00 PythonOperator 2021-05-19T06:10:32.790756+00:00 2021-05-19T06:10:36.111856+00:00 0:00:03.321100 29721 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-05-19T06:10:30.272565+00:00 2 default_pool
success campaign-history-job_v002 create_emr_steps 2021-05-19T05:00:00+00:00 PythonOperator 2021-05-19T06:10:30.578180+00:00 2021-05-19T06:10:33.742730+00:00 0:00:03.164550 29720 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-05-19T06:10:28.265419+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_campaign-history-job_v002 2021-05-19T05:00:00+00:00 TriggerDagRunOperator 2021-05-19T06:10:14.645469+00:00 2021-05-19T06:10:15.159982+00:00 0:00:00.514513 29719 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-05-19T06:10:12.139027+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_booking-processing-job_v002 2021-05-19T05:00:00+00:00 TriggerDagRunOperator 2021-05-19T06:10:14.404571+00:00 2021-05-19T06:10:14.835466+00:00 0:00:00.430895 29718 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-05-19T06:10:12.139074+00:00 2 default_pool
success vc-asset-import_v002 check_cluster_status 2021-05-19T05:05:00+00:00 EmrJobFlowSensor 2021-05-19T06:05:51.900367+00:00 2021-05-19T06:14:54.426078+00:00 0:09:02.525711 29717 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-05-19T06:05:49.679665+00:00 2 default_pool
success vc-asset-import_v002 create_cluster_and_add_emr_steps 2021-05-19T05:05:00+00:00 EmrCreateJobFlowOperator 2021-05-19T06:05:30.002217+00:00 2021-05-19T06:05:31.656822+00:00 0:00:01.654605 29716 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 2 default 2021-05-19T06:05:27.745559+00:00 2 default_pool
success vc-asset-import_v002 create_emr_steps 2021-05-19T05:05:00+00:00 PythonOperator 2021-05-19T06:05:07.951615+00:00 2021-05-19T06:05:11.219400+00:00 0:00:03.267785 29715 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-05-19T06:05:05.664163+00:00 2 default_pool
success campaign-flow-job_v002 check_cluster_status 2021-05-19T05:00:00+00:00 EmrJobFlowSensor 2021-05-19T06:00:59.253917+00:00 2021-05-19T06:10:02.079048+00:00 0:09:02.825131 29714 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-05-19T06:00:57.006443+00:00 2 default_pool
success campaign-flow-job_v002 create_cluster_and_add_emr_steps 2021-05-19T05:00:00+00:00 EmrCreateJobFlowOperator 2021-05-19T06:00:37.248624+00:00 2021-05-19T06:00:39.085332+00:00 0:00:01.836708 29713 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 4 default 2021-05-19T06:00:34.899378+00:00 2 default_pool
success campaign-flow-job_v002 create_emr_steps 2021-05-19T05:00:00+00:00 PythonOperator 2021-05-19T06:00:17.081487+00:00 2021-05-19T06:00:20.274119+00:00 0:00:03.192632 29712 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 5 default 2021-05-19T06:00:14.840047+00:00 2 default_pool
success booking-processing-job_v002 check_cluster_status 2021-05-19T04:00:00+00:00 EmrJobFlowSensor 2021-05-19T05:11:18.492819+00:00 2021-05-19T05:21:21.352663+00:00 0:10:02.859844 29710 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-05-19T05:11:15.945590+00:00 2 default_pool
success campaign-history-job_v002 check_cluster_status 2021-05-19T04:00:00+00:00 EmrJobFlowSensor 2021-05-19T05:11:18.378211+00:00 2021-05-19T05:21:21.304139+00:00 0:10:02.925928 29709 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-05-19T05:11:15.945642+00:00 2 default_pool
success booking-processing-job_v002 create_cluster_and_add_emr_steps 2021-05-19T04:00:00+00:00 EmrCreateJobFlowOperator 2021-05-19T05:10:58.449461+00:00 2021-05-19T05:11:00.165844+00:00 0:00:01.716383 29708 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 2 default 2021-05-19T05:10:55.920777+00:00 2 default_pool
success campaign-history-job_v002 create_cluster_and_add_emr_steps 2021-05-19T04:00:00+00:00 EmrCreateJobFlowOperator 2021-05-19T05:10:56.137600+00:00 2021-05-19T05:10:58.200859+00:00 0:00:02.063259 29707 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 2 default 2021-05-19T05:10:53.893545+00:00 2 default_pool
success campaign-history-job_v002 create_emr_steps 2021-05-19T04:00:00+00:00 PythonOperator 2021-05-19T05:10:36.153669+00:00 2021-05-19T05:10:39.310111+00:00 0:00:03.156442 29706 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-05-19T05:10:33.831658+00:00 2 default_pool
success booking-processing-job_v002 create_emr_steps 2021-05-19T04:00:00+00:00 PythonOperator 2021-05-19T05:10:36.028595+00:00 2021-05-19T05:10:39.422274+00:00 0:00:03.393679 29705 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-05-19T05:10:33.831621+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_booking-processing-job_v002 2021-05-19T04:00:00+00:00 TriggerDagRunOperator 2021-05-19T05:10:14.231548+00:00 2021-05-19T05:10:14.774671+00:00 0:00:00.543123 29704 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-05-19T05:10:11.749831+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_campaign-history-job_v002 2021-05-19T04:00:00+00:00 TriggerDagRunOperator 2021-05-19T05:10:14.074211+00:00 2021-05-19T05:10:14.476373+00:00 0:00:00.402162 29703 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-05-19T05:10:11.749798+00:00 2 default_pool
success vc-asset-import_v002 check_cluster_status 2021-05-19T04:05:00+00:00 EmrJobFlowSensor 2021-05-19T05:05:57.762792+00:00 2021-05-19T05:14:00.265897+00:00 0:08:02.503105 29702 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-05-19T05:05:55.454177+00:00 2 default_pool
success vc-asset-import_v002 create_cluster_and_add_emr_steps 2021-05-19T04:05:00+00:00 EmrCreateJobFlowOperator 2021-05-19T05:05:37.666885+00:00 2021-05-19T05:05:39.462691+00:00 0:00:01.795806 29701 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 2 default 2021-05-19T05:05:35.417611+00:00 2 default_pool
success vc-asset-import_v002 create_emr_steps 2021-05-19T04:05:00+00:00 PythonOperator 2021-05-19T05:05:15.580457+00:00 2021-05-19T05:05:18.739845+00:00 0:00:03.159388 29700 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-05-19T05:05:13.346201+00:00 2 default_pool
success campaign-flow-job_v002 check_cluster_status 2021-05-19T04:00:00+00:00 EmrJobFlowSensor 2021-05-19T05:00:50.998178+00:00 2021-05-19T05:09:53.686323+00:00 0:09:02.688145 29699 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-05-19T05:00:48.832431+00:00 2 default_pool
success campaign-flow-job_v002 create_cluster_and_add_emr_steps 2021-05-19T04:00:00+00:00 EmrCreateJobFlowOperator 2021-05-19T05:00:29.095704+00:00 2021-05-19T05:00:30.800941+00:00 0:00:01.705237 29698 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 4 default 2021-05-19T05:00:26.808890+00:00 2 default_pool
success campaign-flow-job_v002 create_emr_steps 2021-05-19T04:00:00+00:00 PythonOperator 2021-05-19T05:00:07.121013+00:00 2021-05-19T05:00:10.333404+00:00 0:00:03.212391 29697 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 5 default 2021-05-19T05:00:04.791927+00:00 2 default_pool
success booking-processing-job_v002 check_cluster_status 2021-05-19T03:00:00+00:00 EmrJobFlowSensor 2021-05-19T04:11:00.508219+00:00 2021-05-19T04:21:03.524499+00:00 0:10:03.016280 29695 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-05-19T04:10:58.147624+00:00 2 default_pool
success campaign-history-job_v002 check_cluster_status 2021-05-19T03:00:00+00:00 EmrJobFlowSensor 2021-05-19T04:10:58.209172+00:00 2021-05-19T04:21:01.003224+00:00 0:10:02.794052 29694 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-05-19T04:10:56.029272+00:00 2 default_pool