Task Instances

  State Dag Id Task Id Execution Date Operator Start Date End Date Duration Job Id Hostname Unixname Priority Weight Queue Queued Dttm Try Number Pool Log Url
success booking-processing-job_v002 create_cluster_and_add_emr_steps 2021-04-19T09:00:00+00:00 EmrCreateJobFlowOperator 2021-04-19T10:24:35.886420+00:00 2021-04-19T10:24:37.685686+00:00 0:00:01.799266 18872 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 2 default 2021-04-19T10:24:33.475666+00:00 2 default_pool
success campaign-history-job_v002 create_cluster_and_add_emr_steps 2021-04-19T09:00:00+00:00 EmrCreateJobFlowOperator 2021-04-19T10:24:30.156424+00:00 2021-04-19T10:24:31.928666+00:00 0:00:01.772242 18871 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 2 default 2021-04-19T10:24:27.546251+00:00 2 default_pool
success booking-processing-job_v002 create_emr_steps 2021-04-19T09:00:00+00:00 PythonOperator 2021-04-19T10:24:13.651974+00:00 2021-04-19T10:24:16.783433+00:00 0:00:03.131459 18870 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-04-19T10:24:11.440653+00:00 2 default_pool
success campaign-history-job_v002 create_emr_steps 2021-04-19T09:00:00+00:00 PythonOperator 2021-04-19T10:24:09.799618+00:00 2021-04-19T10:24:12.786138+00:00 0:00:02.986520 18869 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-04-19T10:24:07.396274+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_campaign-history-job_v002 2021-04-19T09:00:00+00:00 TriggerDagRunOperator 2021-04-19T10:23:47.826658+00:00 2021-04-19T10:23:48.240549+00:00 0:00:00.413891 18868 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-19T10:23:45.367014+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_booking-processing-job_v002 2021-04-19T09:00:00+00:00 TriggerDagRunOperator 2021-04-19T10:23:47.829466+00:00 2021-04-19T10:23:48.396461+00:00 0:00:00.566995 18867 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-19T10:23:45.367042+00:00 2 default_pool
success vc-asset-import_v002 check_cluster_status 2021-04-19T09:05:00+00:00 EmrJobFlowSensor 2021-04-19T10:06:03.255421+00:00 2021-04-19T10:15:05.893699+00:00 0:09:02.638278 18865 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-19T10:06:00.931567+00:00 2 default_pool
success vc-asset-import_v002 create_cluster_and_add_emr_steps 2021-04-19T09:05:00+00:00 EmrCreateJobFlowOperator 2021-04-19T10:05:39.452609+00:00 2021-04-19T10:05:41.159864+00:00 0:00:01.707255 18864 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 2 default 2021-04-19T10:05:36.964488+00:00 2 default_pool
success vc-asset-import_v002 create_emr_steps 2021-04-19T09:05:00+00:00 PythonOperator 2021-04-19T10:05:19.653070+00:00 2021-04-19T10:05:22.589459+00:00 0:00:02.936389 18863 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-04-19T10:05:16.852987+00:00 2 default_pool
success campaign-flow-job_v002 check_cluster_status 2021-04-19T09:00:00+00:00 EmrJobFlowSensor 2021-04-19T10:00:56.651264+00:00 2021-04-19T10:20:01.252457+00:00 0:19:04.601193 18862 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-04-19T10:00:54.343931+00:00 2 default_pool
success campaign-flow-job_v002 create_cluster_and_add_emr_steps 2021-04-19T09:00:00+00:00 EmrCreateJobFlowOperator 2021-04-19T10:00:34.817887+00:00 2021-04-19T10:00:36.686036+00:00 0:00:01.868149 18861 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 4 default 2021-04-19T10:00:32.365480+00:00 2 default_pool
success campaign-flow-job_v002 create_emr_steps 2021-04-19T09:00:00+00:00 PythonOperator 2021-04-19T10:00:12.564792+00:00 2021-04-19T10:00:15.740281+00:00 0:00:03.175489 18860 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 5 default 2021-04-19T10:00:10.222910+00:00 2 default_pool
success booking-processing-job_v002 check_cluster_status 2021-04-19T08:00:00+00:00 EmrJobFlowSensor 2021-04-19T09:12:12.791052+00:00 2021-04-19T09:20:15.427241+00:00 0:08:02.636189 18858 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-19T09:12:10.555698+00:00 2 default_pool
success campaign-history-job_v002 check_cluster_status 2021-04-19T08:00:00+00:00 EmrJobFlowSensor 2021-04-19T09:11:32.701332+00:00 2021-04-19T09:21:35.444521+00:00 0:10:02.743189 18857 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-19T09:11:30.435387+00:00 2 default_pool
success campaign-history-job_v002 create_cluster_and_add_emr_steps 2021-04-19T08:00:00+00:00 EmrCreateJobFlowOperator 2021-04-19T09:11:05.035248+00:00 2021-04-19T09:11:06.787821+00:00 0:00:01.752573 18856 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 2 default 2021-04-19T09:11:02.464337+00:00 2 default_pool
success booking-processing-job_v002 create_cluster_and_add_emr_steps 2021-04-19T08:00:00+00:00 EmrCreateJobFlowOperator 2021-04-19T09:10:54.965520+00:00 2021-04-19T09:10:56.849705+00:00 0:00:01.884185 18855 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 2 default 2021-04-19T09:10:52.475426+00:00 2 default_pool
success campaign-history-job_v002 create_emr_steps 2021-04-19T08:00:00+00:00 PythonOperator 2021-04-19T09:10:42.654073+00:00 2021-04-19T09:10:45.535360+00:00 0:00:02.881287 18854 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-04-19T09:10:40.391828+00:00 2 default_pool
success booking-processing-job_v002 create_emr_steps 2021-04-19T08:00:00+00:00 PythonOperator 2021-04-19T09:10:33.013770+00:00 2021-04-19T09:10:36.139749+00:00 0:00:03.125979 18853 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-04-19T09:10:30.446204+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_booking-processing-job_v002 2021-04-19T08:00:00+00:00 TriggerDagRunOperator 2021-04-19T09:10:20.593355+00:00 2021-04-19T09:10:21.050289+00:00 0:00:00.456934 18852 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-19T09:10:18.325846+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_campaign-history-job_v002 2021-04-19T08:00:00+00:00 TriggerDagRunOperator 2021-04-19T09:10:20.614613+00:00 2021-04-19T09:10:21.159833+00:00 0:00:00.545220 18851 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-19T09:10:18.325815+00:00 2 default_pool
success vc-asset-import_v002 check_cluster_status 2021-04-19T08:05:00+00:00 EmrJobFlowSensor 2021-04-19T09:05:57.998250+00:00 2021-04-19T09:15:00.491825+00:00 0:09:02.493575 18850 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-19T09:05:55.807800+00:00 2 default_pool
success vc-asset-import_v002 create_cluster_and_add_emr_steps 2021-04-19T08:05:00+00:00 EmrCreateJobFlowOperator 2021-04-19T09:05:35.955206+00:00 2021-04-19T09:05:37.809720+00:00 0:00:01.854514 18849 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 2 default 2021-04-19T09:05:33.797717+00:00 2 default_pool
success vc-asset-import_v002 create_emr_steps 2021-04-19T08:05:00+00:00 PythonOperator 2021-04-19T09:05:14.679779+00:00 2021-04-19T09:05:17.795990+00:00 0:00:03.116211 18848 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-04-19T09:05:11.757169+00:00 2 default_pool
success campaign-flow-job_v002 check_cluster_status 2021-04-19T08:00:00+00:00 EmrJobFlowSensor 2021-04-19T09:00:55.724145+00:00 2021-04-19T09:09:58.416079+00:00 0:09:02.691934 18847 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-04-19T09:00:53.397617+00:00 2 default_pool
success campaign-flow-job_v002 create_cluster_and_add_emr_steps 2021-04-19T08:00:00+00:00 EmrCreateJobFlowOperator 2021-04-19T09:00:33.875510+00:00 2021-04-19T09:00:35.856862+00:00 0:00:01.981352 18846 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 4 default 2021-04-19T09:00:31.450189+00:00 2 default_pool
success campaign-flow-job_v002 create_emr_steps 2021-04-19T08:00:00+00:00 PythonOperator 2021-04-19T09:00:11.503624+00:00 2021-04-19T09:00:14.477813+00:00 0:00:02.974189 18845 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 5 default 2021-04-19T09:00:09.287129+00:00 2 default_pool
success campaign-history-job_v002 check_cluster_status 2021-04-19T07:00:00+00:00 EmrJobFlowSensor 2021-04-19T08:15:03.056345+00:00 2021-04-19T08:25:05.775383+00:00 0:10:02.719038 18844 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-19T08:15:00.687420+00:00 2 default_pool
success booking-processing-job_v002 check_cluster_status 2021-04-19T07:00:00+00:00 EmrJobFlowSensor 2021-04-19T08:15:01.168160+00:00 2021-04-19T08:25:04.136739+00:00 0:10:02.968579 18843 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-19T08:14:58.764323+00:00 2 default_pool
success campaign-history-job_v002 create_cluster_and_add_emr_steps 2021-04-19T07:00:00+00:00 EmrCreateJobFlowOperator 2021-04-19T08:14:40.845715+00:00 2021-04-19T08:14:42.593695+00:00 0:00:01.747980 18842 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 2 default 2021-04-19T08:14:38.607647+00:00 2 default_pool
success booking-processing-job_v002 create_cluster_and_add_emr_steps 2021-04-19T07:00:00+00:00 EmrCreateJobFlowOperator 2021-04-19T08:14:38.896529+00:00 2021-04-19T08:14:40.627651+00:00 0:00:01.731122 18841 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 2 default 2021-04-19T08:14:36.660006+00:00 2 default_pool
success booking-processing-job_v002 create_emr_steps 2021-04-19T07:00:00+00:00 PythonOperator 2021-04-19T08:14:18.976053+00:00 2021-04-19T08:14:22.127951+00:00 0:00:03.151898 18840 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-04-19T08:14:16.584146+00:00 2 default_pool
success campaign-history-job_v002 create_emr_steps 2021-04-19T07:00:00+00:00 PythonOperator 2021-04-19T08:14:18.917275+00:00 2021-04-19T08:14:21.872755+00:00 0:00:02.955480 18839 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-04-19T08:14:16.584116+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_booking-processing-job_v002 2021-04-19T07:00:00+00:00 TriggerDagRunOperator 2021-04-19T08:13:57.670461+00:00 2021-04-19T08:13:58.236508+00:00 0:00:00.566047 18838 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-19T08:13:54.536357+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_campaign-history-job_v002 2021-04-19T07:00:00+00:00 TriggerDagRunOperator 2021-04-19T08:13:57.625928+00:00 2021-04-19T08:13:58.046535+00:00 0:00:00.420607 18837 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-19T08:13:54.536329+00:00 2 default_pool
success vc-asset-import_v002 check_cluster_status 2021-04-19T07:05:00+00:00 EmrJobFlowSensor 2021-04-19T08:05:53.871155+00:00 2021-04-19T08:14:56.468032+00:00 0:09:02.596877 18835 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-19T08:05:51.659881+00:00 2 default_pool
success vc-asset-import_v002 create_cluster_and_add_emr_steps 2021-04-19T07:05:00+00:00 EmrCreateJobFlowOperator 2021-04-19T08:05:34.583958+00:00 2021-04-19T08:05:36.280640+00:00 0:00:01.696682 18834 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 2 default 2021-04-19T08:05:31.645706+00:00 2 default_pool
success vc-asset-import_v002 create_emr_steps 2021-04-19T07:05:00+00:00 PythonOperator 2021-04-19T08:05:10.231754+00:00 2021-04-19T08:05:13.178967+00:00 0:00:02.947213 18833 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-04-19T08:05:07.674886+00:00 2 default_pool
success campaign-flow-job_v002 check_cluster_status 2021-04-19T07:00:00+00:00 EmrJobFlowSensor 2021-04-19T08:00:55.601818+00:00 2021-04-19T08:09:58.093899+00:00 0:09:02.492081 18832 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-04-19T08:00:53.295228+00:00 2 default_pool
success campaign-flow-job_v002 create_cluster_and_add_emr_steps 2021-04-19T07:00:00+00:00 EmrCreateJobFlowOperator 2021-04-19T08:00:35.406788+00:00 2021-04-19T08:00:37.118842+00:00 0:00:01.712054 18831 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 4 default 2021-04-19T08:00:33.247249+00:00 2 default_pool
success campaign-flow-job_v002 create_emr_steps 2021-04-19T07:00:00+00:00 PythonOperator 2021-04-19T08:00:13.487301+00:00 2021-04-19T08:00:16.506859+00:00 0:00:03.019558 18830 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 5 default 2021-04-19T08:00:11.192202+00:00 2 default_pool
success booking-processing-job_v002 check_cluster_status 2021-04-19T06:00:00+00:00 EmrJobFlowSensor 2021-04-19T07:11:16.397584+00:00 2021-04-19T07:21:19.110029+00:00 0:10:02.712445 18829 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-19T07:11:14.283263+00:00 2 default_pool
success campaign-history-job_v002 check_cluster_status 2021-04-19T06:00:00+00:00 EmrJobFlowSensor 2021-04-19T07:11:08.961425+00:00 2021-04-19T07:28:12.860891+00:00 0:17:03.899466 18828 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-19T07:11:06.255937+00:00 2 default_pool
success booking-processing-job_v002 create_cluster_and_add_emr_steps 2021-04-19T06:00:00+00:00 EmrCreateJobFlowOperator 2021-04-19T07:10:54.511548+00:00 2021-04-19T07:10:56.331500+00:00 0:00:01.819952 18827 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 2 default 2021-04-19T07:10:52.120076+00:00 2 default_pool
success campaign-history-job_v002 create_cluster_and_add_emr_steps 2021-04-19T06:00:00+00:00 EmrCreateJobFlowOperator 2021-04-19T07:10:46.625287+00:00 2021-04-19T07:10:48.612225+00:00 0:00:01.986938 18826 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 2 default 2021-04-19T07:10:44.174166+00:00 2 default_pool
success booking-processing-job_v002 create_emr_steps 2021-04-19T06:00:00+00:00 PythonOperator 2021-04-19T07:10:34.401771+00:00 2021-04-19T07:10:38.054224+00:00 0:00:03.652453 18825 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-04-19T07:10:32.099259+00:00 2 default_pool
success campaign-history-job_v002 create_emr_steps 2021-04-19T06:00:00+00:00 PythonOperator 2021-04-19T07:10:26.375319+00:00 2021-04-19T07:10:29.357374+00:00 0:00:02.982055 18824 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-04-19T07:10:24.159732+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_booking-processing-job_v002 2021-04-19T06:00:00+00:00 TriggerDagRunOperator 2021-04-19T07:10:10.500741+00:00 2021-04-19T07:10:10.930406+00:00 0:00:00.429665 18823 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-19T07:10:08.086592+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_campaign-history-job_v002 2021-04-19T06:00:00+00:00 TriggerDagRunOperator 2021-04-19T07:10:10.537454+00:00 2021-04-19T07:10:11.084321+00:00 0:00:00.546867 18822 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-19T07:10:08.086562+00:00 2 default_pool
success vc-asset-import_v002 check_cluster_status 2021-04-19T06:05:00+00:00 EmrJobFlowSensor 2021-04-19T07:05:49.064551+00:00 2021-04-19T07:13:51.565892+00:00 0:08:02.501341 18820 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-19T07:05:46.884156+00:00 2 default_pool
success vc-asset-import_v002 create_cluster_and_add_emr_steps 2021-04-19T06:05:00+00:00 EmrCreateJobFlowOperator 2021-04-19T07:05:26.985108+00:00 2021-04-19T07:05:28.674317+00:00 0:00:01.689209 18819 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 2 default 2021-04-19T07:05:24.861123+00:00 2 default_pool
success vc-asset-import_v002 create_emr_steps 2021-04-19T06:05:00+00:00 PythonOperator 2021-04-19T07:05:06.991879+00:00 2021-04-19T07:05:10.104139+00:00 0:00:03.112260 18818 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-04-19T07:05:04.838563+00:00 2 default_pool
success campaign-flow-job_v002 check_cluster_status 2021-04-19T06:00:00+00:00 EmrJobFlowSensor 2021-04-19T07:00:48.873492+00:00 2021-04-19T07:09:51.809454+00:00 0:09:02.935962 18817 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-04-19T07:00:46.486728+00:00 2 default_pool
success campaign-flow-job_v002 create_cluster_and_add_emr_steps 2021-04-19T06:00:00+00:00 EmrCreateJobFlowOperator 2021-04-19T07:00:24.998433+00:00 2021-04-19T07:00:26.831001+00:00 0:00:01.832568 18816 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 4 default 2021-04-19T07:00:22.546813+00:00 2 default_pool
success campaign-flow-job_v002 create_emr_steps 2021-04-19T06:00:00+00:00 PythonOperator 2021-04-19T07:00:05.610096+00:00 2021-04-19T07:00:08.774687+00:00 0:00:03.164591 18815 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 5 default 2021-04-19T07:00:02.443849+00:00 2 default_pool
success campaign-history-job_v002 check_cluster_status 2021-04-19T05:00:00+00:00 EmrJobFlowSensor 2021-04-19T06:11:47.833286+00:00 2021-04-19T06:20:50.293479+00:00 0:09:02.460193 18814 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-19T06:11:45.449960+00:00 2 default_pool
success booking-processing-job_v002 check_cluster_status 2021-04-19T05:00:00+00:00 EmrJobFlowSensor 2021-04-19T06:11:29.474708+00:00 2021-04-19T06:21:32.220805+00:00 0:10:02.746097 18813 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-19T06:11:27.329710+00:00 2 default_pool
success campaign-history-job_v002 create_cluster_and_add_emr_steps 2021-04-19T05:00:00+00:00 EmrCreateJobFlowOperator 2021-04-19T06:11:13.732471+00:00 2021-04-19T06:11:15.469170+00:00 0:00:01.736699 18812 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 2 default 2021-04-19T06:11:11.315784+00:00 2 default_pool
success booking-processing-job_v002 create_cluster_and_add_emr_steps 2021-04-19T05:00:00+00:00 EmrCreateJobFlowOperator 2021-04-19T06:11:05.491354+00:00 2021-04-19T06:11:07.164072+00:00 0:00:01.672718 18811 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 2 default 2021-04-19T06:11:03.310860+00:00 2 default_pool
success campaign-history-job_v002 create_emr_steps 2021-04-19T05:00:00+00:00 PythonOperator 2021-04-19T06:10:51.510567+00:00 2021-04-19T06:10:54.427204+00:00 0:00:02.916637 18810 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-04-19T06:10:49.298515+00:00 2 default_pool
success booking-processing-job_v002 create_emr_steps 2021-04-19T05:00:00+00:00 PythonOperator 2021-04-19T06:10:41.900985+00:00 2021-04-19T06:10:45.121859+00:00 0:00:03.220874 18809 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-04-19T06:10:39.355813+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_booking-processing-job_v002 2021-04-19T05:00:00+00:00 TriggerDagRunOperator 2021-04-19T06:10:29.840565+00:00 2021-04-19T06:10:30.358942+00:00 0:00:00.518377 18808 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-19T06:10:27.290901+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_campaign-history-job_v002 2021-04-19T05:00:00+00:00 TriggerDagRunOperator 2021-04-19T06:10:29.758133+00:00 2021-04-19T06:10:30.222852+00:00 0:00:00.464719 18807 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-19T06:10:27.290859+00:00 2 default_pool
success vc-asset-import_v002 check_cluster_status 2021-04-19T05:05:00+00:00 EmrJobFlowSensor 2021-04-19T06:09:57.337725+00:00 2021-04-19T06:17:59.759562+00:00 0:08:02.421837 18806 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-19T06:09:55.202846+00:00 2 default_pool
success vc-asset-import_v002 create_cluster_and_add_emr_steps 2021-04-19T05:05:00+00:00 EmrCreateJobFlowOperator 2021-04-19T06:09:37.454435+00:00 2021-04-19T06:09:39.114907+00:00 0:00:01.660472 18805 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 2 default 2021-04-19T06:09:35.191487+00:00 2 default_pool
success vc-asset-import_v002 create_emr_steps 2021-04-19T05:05:00+00:00 PythonOperator 2021-04-19T06:09:15.758422+00:00 2021-04-19T06:09:19.014303+00:00 0:00:03.255881 18804 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-04-19T06:09:13.169635+00:00 2 default_pool
success campaign-flow-job_v002 check_cluster_status 2021-04-19T05:00:00+00:00 EmrJobFlowSensor 2021-04-19T06:01:08.924701+00:00 2021-04-19T06:10:11.651459+00:00 0:09:02.726758 18802 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-04-19T06:01:06.730208+00:00 2 default_pool
success campaign-flow-job_v002 create_cluster_and_add_emr_steps 2021-04-19T05:00:00+00:00 EmrCreateJobFlowOperator 2021-04-19T06:00:36.878197+00:00 2021-04-19T06:00:38.565338+00:00 0:00:01.687141 18801 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 4 default 2021-04-19T06:00:34.707803+00:00 2 default_pool
success campaign-flow-job_v002 create_emr_steps 2021-04-19T05:00:00+00:00 PythonOperator 2021-04-19T06:00:11.159736+00:00 2021-04-19T06:00:14.182779+00:00 0:00:03.023043 18800 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 5 default 2021-04-19T06:00:08.756338+00:00 2 default_pool
success campaign-history-job_v002 check_cluster_status 2021-04-19T04:00:00+00:00 EmrJobFlowSensor 2021-04-19T05:13:36.281894+00:00 2021-04-19T05:30:40.003025+00:00 0:17:03.721131 18799 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-19T05:13:33.989095+00:00 2 default_pool
success booking-processing-job_v002 check_cluster_status 2021-04-19T04:00:00+00:00 EmrJobFlowSensor 2021-04-19T05:13:32.890073+00:00 2021-04-19T05:23:35.631454+00:00 0:10:02.741381 18798 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-19T05:13:29.972465+00:00 2 default_pool
success campaign-history-job_v002 create_cluster_and_add_emr_steps 2021-04-19T04:00:00+00:00 EmrCreateJobFlowOperator 2021-04-19T05:13:16.285467+00:00 2021-04-19T05:13:18.017870+00:00 0:00:01.732403 18797 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 2 default 2021-04-19T05:13:13.956022+00:00 2 default_pool
success booking-processing-job_v002 create_cluster_and_add_emr_steps 2021-04-19T04:00:00+00:00 EmrCreateJobFlowOperator 2021-04-19T05:13:10.294468+00:00 2021-04-19T05:13:11.979115+00:00 0:00:01.684647 18796 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 2 default 2021-04-19T05:13:07.953592+00:00 2 default_pool
success campaign-history-job_v002 create_emr_steps 2021-04-19T04:00:00+00:00 PythonOperator 2021-04-19T05:12:54.566417+00:00 2021-04-19T05:12:57.496703+00:00 0:00:02.930286 18795 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-04-19T05:12:51.978879+00:00 2 default_pool
success booking-processing-job_v002 create_emr_steps 2021-04-19T04:00:00+00:00 PythonOperator 2021-04-19T05:12:48.291444+00:00 2021-04-19T05:12:51.736775+00:00 0:00:03.445331 18794 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-04-19T05:12:45.977828+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_booking-processing-job_v002 2021-04-19T04:00:00+00:00 TriggerDagRunOperator 2021-04-19T05:12:30.698155+00:00 2021-04-19T05:12:31.230429+00:00 0:00:00.532274 18793 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-19T05:12:28.044866+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_campaign-history-job_v002 2021-04-19T04:00:00+00:00 TriggerDagRunOperator 2021-04-19T05:12:30.595938+00:00 2021-04-19T05:12:31.210905+00:00 0:00:00.614967 18792 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-19T05:12:28.044815+00:00 2 default_pool
success vc-asset-import_v002 check_cluster_status 2021-04-19T04:05:00+00:00 EmrJobFlowSensor 2021-04-19T05:06:01.582796+00:00 2021-04-19T05:15:04.193676+00:00 0:09:02.610880 18791 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-19T05:05:59.264830+00:00 2 default_pool
success vc-asset-import_v002 create_cluster_and_add_emr_steps 2021-04-19T04:05:00+00:00 EmrCreateJobFlowOperator 2021-04-19T05:05:41.276495+00:00 2021-04-19T05:05:42.915108+00:00 0:00:01.638613 18790 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 2 default 2021-04-19T05:05:39.143464+00:00 2 default_pool
success vc-asset-import_v002 create_emr_steps 2021-04-19T04:05:00+00:00 PythonOperator 2021-04-19T05:05:19.671273+00:00 2021-04-19T05:05:22.795354+00:00 0:00:03.124081 18789 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-04-19T05:05:17.144502+00:00 2 default_pool
success campaign-flow-job_v002 check_cluster_status 2021-04-19T04:00:00+00:00 EmrJobFlowSensor 2021-04-19T05:03:23.076662+00:00 2021-04-19T05:12:25.697844+00:00 0:09:02.621182 18788 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-04-19T05:03:20.727796+00:00 2 default_pool
success campaign-flow-job_v002 create_cluster_and_add_emr_steps 2021-04-19T04:00:00+00:00 EmrCreateJobFlowOperator 2021-04-19T05:03:01.211088+00:00 2021-04-19T05:03:03.036150+00:00 0:00:01.825062 18787 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 4 default 2021-04-19T05:02:58.768702+00:00 2 default_pool
success campaign-flow-job_v002 create_emr_steps 2021-04-19T04:00:00+00:00 PythonOperator 2021-04-19T05:02:41.765851+00:00 2021-04-19T05:02:44.763126+00:00 0:00:02.997275 18786 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 5 default 2021-04-19T05:02:38.703508+00:00 2 default_pool
success campaign-history-job_v002 check_cluster_status 2021-04-19T03:00:00+00:00 EmrJobFlowSensor 2021-04-19T04:11:42.980380+00:00 2021-04-19T04:21:45.843220+00:00 0:10:02.862840 18784 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-19T04:11:40.591154+00:00 2 default_pool
success booking-processing-job_v002 check_cluster_status 2021-04-19T03:00:00+00:00 EmrJobFlowSensor 2021-04-19T04:11:42.803913+00:00 2021-04-19T04:21:45.593137+00:00 0:10:02.789224 18783 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-19T04:11:40.591188+00:00 2 default_pool
success campaign-history-job_v002 create_cluster_and_add_emr_steps 2021-04-19T03:00:00+00:00 EmrCreateJobFlowOperator 2021-04-19T04:11:23.285025+00:00 2021-04-19T04:11:24.963938+00:00 0:00:01.678913 18782 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 2 default 2021-04-19T04:11:20.576493+00:00 2 default_pool
success booking-processing-job_v002 create_cluster_and_add_emr_steps 2021-04-19T03:00:00+00:00 EmrCreateJobFlowOperator 2021-04-19T04:11:20.824448+00:00 2021-04-19T04:11:22.907987+00:00 0:00:02.083539 18781 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 2 default 2021-04-19T04:11:18.580128+00:00 2 default_pool
success campaign-history-job_v002 create_emr_steps 2021-04-19T03:00:00+00:00 PythonOperator 2021-04-19T04:11:01.030941+00:00 2021-04-19T04:11:03.964972+00:00 0:00:02.934031 18780 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-04-19T04:10:58.654052+00:00 2 default_pool
success booking-processing-job_v002 create_emr_steps 2021-04-19T03:00:00+00:00 PythonOperator 2021-04-19T04:10:58.923988+00:00 2021-04-19T04:11:02.280045+00:00 0:00:03.356057 18779 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-04-19T04:10:56.575200+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_campaign-history-job_v002 2021-04-19T03:00:00+00:00 TriggerDagRunOperator 2021-04-19T04:10:42.840436+00:00 2021-04-19T04:10:43.384746+00:00 0:00:00.544310 18778 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-19T04:10:40.492324+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_booking-processing-job_v002 2021-04-19T03:00:00+00:00 TriggerDagRunOperator 2021-04-19T04:10:42.683284+00:00 2021-04-19T04:10:43.110648+00:00 0:00:00.427364 18777 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-19T04:10:40.492358+00:00 2 default_pool
success vc-asset-import_v002 check_cluster_status 2021-04-19T03:05:00+00:00 EmrJobFlowSensor 2021-04-19T04:06:52.215700+00:00 2021-04-19T04:14:54.663926+00:00 0:08:02.448226 18776 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-19T04:06:50.056743+00:00 2 default_pool
success vc-asset-import_v002 create_cluster_and_add_emr_steps 2021-04-19T03:05:00+00:00 EmrCreateJobFlowOperator 2021-04-19T04:05:38.376883+00:00 2021-04-19T04:05:40.059425+00:00 0:00:01.682542 18775 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 2 default 2021-04-19T04:05:35.991820+00:00 2 default_pool
success vc-asset-import_v002 create_emr_steps 2021-04-19T03:05:00+00:00 PythonOperator 2021-04-19T04:05:18.135202+00:00 2021-04-19T04:05:21.285307+00:00 0:00:03.150105 18774 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-04-19T04:05:15.924141+00:00 2 default_pool
success campaign-flow-job_v002 check_cluster_status 2021-04-19T03:00:00+00:00 EmrJobFlowSensor 2021-04-19T04:01:17.822488+00:00 2021-04-19T04:10:20.445231+00:00 0:09:02.622743 18773 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-04-19T04:01:15.658600+00:00 2 default_pool
success campaign-flow-job_v002 create_cluster_and_add_emr_steps 2021-04-19T03:00:00+00:00 EmrCreateJobFlowOperator 2021-04-19T04:00:55.809268+00:00 2021-04-19T04:00:58.161168+00:00 0:00:02.351900 18772 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 4 default 2021-04-19T04:00:53.631041+00:00 2 default_pool
success campaign-flow-job_v002 create_emr_steps 2021-04-19T03:00:00+00:00 PythonOperator 2021-04-19T04:00:26.027756+00:00 2021-04-19T04:00:28.959890+00:00 0:00:02.932134 18771 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 5 default 2021-04-19T04:00:23.610719+00:00 2 default_pool
success booking-processing-job_v002 check_cluster_status 2021-04-19T02:00:00+00:00 EmrJobFlowSensor 2021-04-19T03:11:56.483330+00:00 2021-04-19T03:23:59.458279+00:00 0:12:02.974949 18769 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-19T03:11:54.316003+00:00 2 default_pool
success campaign-history-job_v002 check_cluster_status 2021-04-19T02:00:00+00:00 EmrJobFlowSensor 2021-04-19T03:11:54.587337+00:00 2021-04-19T03:20:57.445800+00:00 0:09:02.858463 18768 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-19T03:11:52.316990+00:00 2 default_pool
success booking-processing-job_v002 create_cluster_and_add_emr_steps 2021-04-19T02:00:00+00:00 EmrCreateJobFlowOperator 2021-04-19T03:11:36.489203+00:00 2021-04-19T03:11:38.186244+00:00 0:00:01.697041 18767 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 2 default 2021-04-19T03:11:34.299526+00:00 2 default_pool
success campaign-history-job_v002 create_cluster_and_add_emr_steps 2021-04-19T02:00:00+00:00 EmrCreateJobFlowOperator 2021-04-19T03:11:32.886163+00:00 2021-04-19T03:11:34.545466+00:00 0:00:01.659303 18766 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 2 default 2021-04-19T03:11:30.366061+00:00 2 default_pool