Task Instances

  State Dag Id Task Id Execution Date Operator Start Date End Date Duration Job Id Hostname Unixname Priority Weight Queue Queued Dttm Try Number Pool Log Url
success campaign-flow-job_v002 trigger_dagrun_booking-processing-job_v002 2021-04-17T12:00:00+00:00 TriggerDagRunOperator 2021-04-17T13:10:13.926862+00:00 2021-04-17T13:10:14.315406+00:00 0:00:00.388544 18193 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-17T13:10:11.727386+00:00 2 default_pool
success vc-asset-import_v002 check_cluster_status 2021-04-17T12:05:00+00:00 EmrJobFlowSensor 2021-04-17T13:06:03.555967+00:00 2021-04-17T13:15:06.228328+00:00 0:09:02.672361 18192 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-17T13:06:01.387320+00:00 2 default_pool
success vc-asset-import_v002 create_cluster_and_add_emr_steps 2021-04-17T12:05:00+00:00 EmrCreateJobFlowOperator 2021-04-17T13:05:41.807567+00:00 2021-04-17T13:05:43.433330+00:00 0:00:01.625763 18191 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 2 default 2021-04-17T13:05:39.353069+00:00 2 default_pool
success vc-asset-import_v002 create_emr_steps 2021-04-17T12:05:00+00:00 PythonOperator 2021-04-17T13:05:21.511902+00:00 2021-04-17T13:05:24.402503+00:00 0:00:02.890601 18190 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-04-17T13:05:19.335142+00:00 2 default_pool
success campaign-flow-job_v002 check_cluster_status 2021-04-17T12:00:00+00:00 EmrJobFlowSensor 2021-04-17T13:00:55.250689+00:00 2021-04-17T13:09:57.775659+00:00 0:09:02.524970 18189 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-04-17T13:00:52.884739+00:00 2 default_pool
success campaign-flow-job_v002 create_cluster_and_add_emr_steps 2021-04-17T12:00:00+00:00 EmrCreateJobFlowOperator 2021-04-17T13:00:35.338667+00:00 2021-04-17T13:00:37.169987+00:00 0:00:01.831320 18188 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 4 default 2021-04-17T13:00:32.836287+00:00 2 default_pool
success campaign-flow-job_v002 create_emr_steps 2021-04-17T12:00:00+00:00 PythonOperator 2021-04-17T13:00:13.567078+00:00 2021-04-17T13:00:16.534844+00:00 0:00:02.967766 18187 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 5 default 2021-04-17T13:00:10.792831+00:00 2 default_pool
success booking-processing-job_v002 check_cluster_status 2021-04-17T11:00:00+00:00 EmrJobFlowSensor 2021-04-17T12:12:16.012847+00:00 2021-04-17T12:22:18.973325+00:00 0:10:02.960478 18185 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-17T12:12:13.607245+00:00 2 default_pool
success campaign-history-job_v002 check_cluster_status 2021-04-17T11:00:00+00:00 EmrJobFlowSensor 2021-04-17T12:12:11.975279+00:00 2021-04-17T12:21:14.635118+00:00 0:09:02.659839 18184 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-17T12:12:09.663941+00:00 2 default_pool
success booking-processing-job_v002 create_cluster_and_add_emr_steps 2021-04-17T11:00:00+00:00 EmrCreateJobFlowOperator 2021-04-17T12:11:53.855501+00:00 2021-04-17T12:11:55.600586+00:00 0:00:01.745085 18183 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 2 default 2021-04-17T12:11:51.590152+00:00 2 default_pool
success campaign-history-job_v002 create_cluster_and_add_emr_steps 2021-04-17T11:00:00+00:00 EmrCreateJobFlowOperator 2021-04-17T12:11:50.005035+00:00 2021-04-17T12:11:52.003018+00:00 0:00:01.997983 18182 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 2 default 2021-04-17T12:11:47.590139+00:00 2 default_pool
success booking-processing-job_v002 create_emr_steps 2021-04-17T11:00:00+00:00 PythonOperator 2021-04-17T12:11:33.858047+00:00 2021-04-17T12:11:37.036592+00:00 0:00:03.178545 18181 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-04-17T12:11:31.579289+00:00 2 default_pool
success campaign-history-job_v002 create_emr_steps 2021-04-17T11:00:00+00:00 PythonOperator 2021-04-17T12:11:30.060353+00:00 2021-04-17T12:11:32.991361+00:00 0:00:02.931008 18180 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-04-17T12:11:27.568382+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_booking-processing-job_v002 2021-04-17T11:00:00+00:00 TriggerDagRunOperator 2021-04-17T12:11:14.012696+00:00 2021-04-17T12:11:14.526788+00:00 0:00:00.514092 18179 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-17T12:11:11.513445+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_campaign-history-job_v002 2021-04-17T11:00:00+00:00 TriggerDagRunOperator 2021-04-17T12:11:13.845761+00:00 2021-04-17T12:11:14.280289+00:00 0:00:00.434528 18178 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-17T12:11:11.513409+00:00 2 default_pool
success vc-asset-import_v002 check_cluster_status 2021-04-17T11:05:00+00:00 EmrJobFlowSensor 2021-04-17T12:05:59.228659+00:00 2021-04-17T12:15:01.816650+00:00 0:09:02.587991 18177 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-17T12:05:57.003733+00:00 2 default_pool
success vc-asset-import_v002 create_cluster_and_add_emr_steps 2021-04-17T11:05:00+00:00 EmrCreateJobFlowOperator 2021-04-17T12:05:37.113751+00:00 2021-04-17T12:05:38.740419+00:00 0:00:01.626668 18176 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 2 default 2021-04-17T12:05:34.995863+00:00 2 default_pool
success vc-asset-import_v002 create_emr_steps 2021-04-17T11:05:00+00:00 PythonOperator 2021-04-17T12:05:17.060934+00:00 2021-04-17T12:05:19.910957+00:00 0:00:02.850023 18175 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-04-17T12:05:14.934660+00:00 2 default_pool
success campaign-flow-job_v002 check_cluster_status 2021-04-17T11:00:00+00:00 EmrJobFlowSensor 2021-04-17T12:01:00.714176+00:00 2021-04-17T12:11:03.499334+00:00 0:10:02.785158 18174 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-04-17T12:00:58.463067+00:00 2 default_pool
success campaign-flow-job_v002 create_cluster_and_add_emr_steps 2021-04-17T11:00:00+00:00 EmrCreateJobFlowOperator 2021-04-17T12:00:38.715814+00:00 2021-04-17T12:00:40.578641+00:00 0:00:01.862827 18173 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 4 default 2021-04-17T12:00:36.432238+00:00 2 default_pool
success campaign-flow-job_v002 create_emr_steps 2021-04-17T11:00:00+00:00 PythonOperator 2021-04-17T12:00:16.934700+00:00 2021-04-17T12:00:19.912912+00:00 0:00:02.978212 18172 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 5 default 2021-04-17T12:00:14.411166+00:00 2 default_pool
success booking-processing-job_v002 check_cluster_status 2021-04-17T10:00:00+00:00 EmrJobFlowSensor 2021-04-17T11:11:18.598387+00:00 2021-04-17T11:21:21.408334+00:00 0:10:02.809947 18170 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-17T11:11:15.624224+00:00 2 default_pool
success campaign-history-job_v002 check_cluster_status 2021-04-17T10:00:00+00:00 EmrJobFlowSensor 2021-04-17T11:11:17.962707+00:00 2021-04-17T11:20:20.589222+00:00 0:09:02.626515 18169 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-17T11:11:15.624259+00:00 2 default_pool
success booking-processing-job_v002 create_cluster_and_add_emr_steps 2021-04-17T10:00:00+00:00 EmrCreateJobFlowOperator 2021-04-17T11:10:58.541166+00:00 2021-04-17T11:11:00.372319+00:00 0:00:01.831153 18168 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 2 default 2021-04-17T11:10:55.585513+00:00 2 default_pool
success campaign-history-job_v002 create_cluster_and_add_emr_steps 2021-04-17T10:00:00+00:00 EmrCreateJobFlowOperator 2021-04-17T11:10:56.360720+00:00 2021-04-17T11:10:58.547978+00:00 0:00:02.187258 18167 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 2 default 2021-04-17T11:10:53.657534+00:00 2 default_pool
success booking-processing-job_v002 create_emr_steps 2021-04-17T10:00:00+00:00 PythonOperator 2021-04-17T11:10:35.868097+00:00 2021-04-17T11:10:39.050857+00:00 0:00:03.182760 18166 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-04-17T11:10:33.533917+00:00 2 default_pool
success campaign-history-job_v002 create_emr_steps 2021-04-17T10:00:00+00:00 PythonOperator 2021-04-17T11:10:35.804486+00:00 2021-04-17T11:10:38.964907+00:00 0:00:03.160421 18165 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-04-17T11:10:33.533950+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_campaign-history-job_v002 2021-04-17T10:00:00+00:00 TriggerDagRunOperator 2021-04-17T11:10:17.791927+00:00 2021-04-17T11:10:18.271605+00:00 0:00:00.479678 18164 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-17T11:10:15.515537+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_booking-processing-job_v002 2021-04-17T10:00:00+00:00 TriggerDagRunOperator 2021-04-17T11:10:17.746335+00:00 2021-04-17T11:10:18.304652+00:00 0:00:00.558317 18163 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-17T11:10:15.515570+00:00 2 default_pool
success vc-asset-import_v002 check_cluster_status 2021-04-17T10:05:00+00:00 EmrJobFlowSensor 2021-04-17T11:06:07.361622+00:00 2021-04-17T11:15:10.072214+00:00 0:09:02.710592 18162 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-17T11:06:05.113543+00:00 2 default_pool
success vc-asset-import_v002 create_cluster_and_add_emr_steps 2021-04-17T10:05:00+00:00 EmrCreateJobFlowOperator 2021-04-17T11:05:47.180672+00:00 2021-04-17T11:05:48.796983+00:00 0:00:01.616311 18161 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 2 default 2021-04-17T11:05:45.099874+00:00 2 default_pool
success vc-asset-import_v002 create_emr_steps 2021-04-17T10:05:00+00:00 PythonOperator 2021-04-17T11:05:25.772557+00:00 2021-04-17T11:05:28.828301+00:00 0:00:03.055744 18160 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-04-17T11:05:23.077447+00:00 2 default_pool
success campaign-flow-job_v002 check_cluster_status 2021-04-17T10:00:00+00:00 EmrJobFlowSensor 2021-04-17T11:00:56.545098+00:00 2021-04-17T11:09:59.235808+00:00 0:09:02.690710 18159 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-04-17T11:00:54.408415+00:00 2 default_pool
success campaign-flow-job_v002 create_cluster_and_add_emr_steps 2021-04-17T10:00:00+00:00 EmrCreateJobFlowOperator 2021-04-17T11:00:34.858404+00:00 2021-04-17T11:00:36.664622+00:00 0:00:01.806218 18158 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 4 default 2021-04-17T11:00:32.390459+00:00 2 default_pool
success campaign-flow-job_v002 create_emr_steps 2021-04-17T10:00:00+00:00 PythonOperator 2021-04-17T11:00:15.300008+00:00 2021-04-17T11:00:18.387985+00:00 0:00:03.087977 18157 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 5 default 2021-04-17T11:00:12.332158+00:00 2 default_pool
success campaign-history-job_v002 check_cluster_status 2021-04-17T09:00:00+00:00 EmrJobFlowSensor 2021-04-17T10:11:11.428048+00:00 2021-04-17T10:19:13.924998+00:00 0:08:02.496950 18155 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-17T10:11:08.651151+00:00 2 default_pool
success booking-processing-job_v002 check_cluster_status 2021-04-17T09:00:00+00:00 EmrJobFlowSensor 2021-04-17T10:11:09.046501+00:00 2021-04-17T10:21:12.120539+00:00 0:10:03.074038 18154 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-17T10:11:06.594318+00:00 2 default_pool
success campaign-history-job_v002 create_cluster_and_add_emr_steps 2021-04-17T09:00:00+00:00 EmrCreateJobFlowOperator 2021-04-17T10:10:50.717912+00:00 2021-04-17T10:10:52.417593+00:00 0:00:01.699681 18153 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 2 default 2021-04-17T10:10:48.523910+00:00 2 default_pool
success booking-processing-job_v002 create_cluster_and_add_emr_steps 2021-04-17T09:00:00+00:00 EmrCreateJobFlowOperator 2021-04-17T10:10:46.755907+00:00 2021-04-17T10:10:48.586309+00:00 0:00:01.830402 18152 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 2 default 2021-04-17T10:10:44.524164+00:00 2 default_pool
success campaign-history-job_v002 create_emr_steps 2021-04-17T09:00:00+00:00 PythonOperator 2021-04-17T10:10:28.932307+00:00 2021-04-17T10:10:31.875659+00:00 0:00:02.943352 18151 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-04-17T10:10:26.506314+00:00 2 default_pool
success booking-processing-job_v002 create_emr_steps 2021-04-17T09:00:00+00:00 PythonOperator 2021-04-17T10:10:26.812297+00:00 2021-04-17T10:10:29.914002+00:00 0:00:03.101705 18150 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-04-17T10:10:24.503001+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_booking-processing-job_v002 2021-04-17T09:00:00+00:00 TriggerDagRunOperator 2021-04-17T10:10:21.096720+00:00 2021-04-17T10:10:21.523641+00:00 0:00:00.426921 18149 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-17T10:10:18.500188+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_campaign-history-job_v002 2021-04-17T09:00:00+00:00 TriggerDagRunOperator 2021-04-17T10:10:20.945945+00:00 2021-04-17T10:10:21.483276+00:00 0:00:00.537331 18148 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-17T10:10:18.500161+00:00 2 default_pool
success vc-asset-import_v002 check_cluster_status 2021-04-17T09:05:00+00:00 EmrJobFlowSensor 2021-04-17T10:05:52.189483+00:00 2021-04-17T10:14:54.800106+00:00 0:09:02.610623 18147 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-17T10:05:50.060562+00:00 2 default_pool
success vc-asset-import_v002 create_cluster_and_add_emr_steps 2021-04-17T09:05:00+00:00 EmrCreateJobFlowOperator 2021-04-17T10:05:32.221517+00:00 2021-04-17T10:05:34.045399+00:00 0:00:01.823882 18146 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 2 default 2021-04-17T10:05:30.016631+00:00 2 default_pool
success vc-asset-import_v002 create_emr_steps 2021-04-17T09:05:00+00:00 PythonOperator 2021-04-17T10:05:10.266966+00:00 2021-04-17T10:05:13.105552+00:00 0:00:02.838586 18145 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-04-17T10:05:07.987872+00:00 2 default_pool
success campaign-flow-job_v002 check_cluster_status 2021-04-17T09:00:00+00:00 EmrJobFlowSensor 2021-04-17T10:01:11.801194+00:00 2021-04-17T10:10:14.542143+00:00 0:09:02.740949 18144 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-04-17T10:01:09.566728+00:00 2 default_pool
success campaign-flow-job_v002 create_cluster_and_add_emr_steps 2021-04-17T09:00:00+00:00 EmrCreateJobFlowOperator 2021-04-17T10:00:48.056437+00:00 2021-04-17T10:00:49.939118+00:00 0:00:01.882681 18143 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 4 default 2021-04-17T10:00:45.644243+00:00 2 default_pool
success campaign-flow-job_v002 create_emr_steps 2021-04-17T09:00:00+00:00 PythonOperator 2021-04-17T10:00:25.847281+00:00 2021-04-17T10:00:28.859613+00:00 0:00:03.012332 18142 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 5 default 2021-04-17T10:00:23.502494+00:00 2 default_pool
success booking-processing-job_v002 check_cluster_status 2021-04-17T08:00:00+00:00 EmrJobFlowSensor 2021-04-17T09:11:16.323128+00:00 2021-04-17T09:21:18.991757+00:00 0:10:02.668629 18140 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-17T09:11:14.144734+00:00 2 default_pool
success campaign-history-job_v002 check_cluster_status 2021-04-17T08:00:00+00:00 EmrJobFlowSensor 2021-04-17T09:11:04.452666+00:00 2021-04-17T09:20:07.500945+00:00 0:09:03.048279 18139 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-17T09:11:02.133075+00:00 2 default_pool
success booking-processing-job_v002 create_cluster_and_add_emr_steps 2021-04-17T08:00:00+00:00 EmrCreateJobFlowOperator 2021-04-17T09:10:54.564376+00:00 2021-04-17T09:10:56.263964+00:00 0:00:01.699588 18138 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 2 default 2021-04-17T09:10:52.126188+00:00 2 default_pool
success campaign-history-job_v002 create_cluster_and_add_emr_steps 2021-04-17T08:00:00+00:00 EmrCreateJobFlowOperator 2021-04-17T09:10:42.341494+00:00 2021-04-17T09:10:44.018674+00:00 0:00:01.677180 18137 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 2 default 2021-04-17T09:10:40.117802+00:00 2 default_pool
success booking-processing-job_v002 create_emr_steps 2021-04-17T08:00:00+00:00 PythonOperator 2021-04-17T09:10:32.788923+00:00 2021-04-17T09:10:36.062172+00:00 0:00:03.273249 18136 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-04-17T09:10:30.157716+00:00 2 default_pool
success campaign-history-job_v002 create_emr_steps 2021-04-17T08:00:00+00:00 PythonOperator 2021-04-17T09:10:20.585135+00:00 2021-04-17T09:10:23.513856+00:00 0:00:02.928721 18135 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-04-17T09:10:18.158953+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_booking-processing-job_v002 2021-04-17T08:00:00+00:00 TriggerDagRunOperator 2021-04-17T09:10:14.703033+00:00 2021-04-17T09:10:15.215521+00:00 0:00:00.512488 18134 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-17T09:10:12.102380+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_campaign-history-job_v002 2021-04-17T08:00:00+00:00 TriggerDagRunOperator 2021-04-17T09:10:14.324069+00:00 2021-04-17T09:10:14.749708+00:00 0:00:00.425639 18133 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-17T09:10:12.102344+00:00 2 default_pool
success vc-asset-import_v002 check_cluster_status 2021-04-17T08:05:00+00:00 EmrJobFlowSensor 2021-04-17T09:06:03.905559+00:00 2021-04-17T09:15:06.694835+00:00 0:09:02.789276 18132 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-17T09:06:01.684948+00:00 2 default_pool
success vc-asset-import_v002 create_cluster_and_add_emr_steps 2021-04-17T08:05:00+00:00 EmrCreateJobFlowOperator 2021-04-17T09:05:41.751820+00:00 2021-04-17T09:05:43.461063+00:00 0:00:01.709243 18131 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 2 default 2021-04-17T09:05:39.531436+00:00 2 default_pool
success vc-asset-import_v002 create_emr_steps 2021-04-17T08:05:00+00:00 PythonOperator 2021-04-17T09:05:21.734609+00:00 2021-04-17T09:05:24.605749+00:00 0:00:02.871140 18130 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-04-17T09:05:19.493555+00:00 2 default_pool
success campaign-flow-job_v002 check_cluster_status 2021-04-17T08:00:00+00:00 EmrJobFlowSensor 2021-04-17T09:01:05.549186+00:00 2021-04-17T09:10:08.260477+00:00 0:09:02.711291 18129 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-04-17T09:01:03.147520+00:00 2 default_pool
success campaign-flow-job_v002 create_cluster_and_add_emr_steps 2021-04-17T08:00:00+00:00 EmrCreateJobFlowOperator 2021-04-17T09:00:43.287051+00:00 2021-04-17T09:00:44.975300+00:00 0:00:01.688249 18128 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 4 default 2021-04-17T09:00:41.089403+00:00 2 default_pool
success campaign-flow-job_v002 create_emr_steps 2021-04-17T08:00:00+00:00 PythonOperator 2021-04-17T09:00:15.389503+00:00 2021-04-17T09:00:18.597248+00:00 0:00:03.207745 18127 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 5 default 2021-04-17T09:00:13.062785+00:00 2 default_pool
success booking-processing-job_v002 check_cluster_status 2021-04-17T07:00:00+00:00 EmrJobFlowSensor 2021-04-17T08:12:19.497509+00:00 2021-04-17T08:22:22.147734+00:00 0:10:02.650225 18125 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-17T08:12:17.333472+00:00 2 default_pool
success campaign-history-job_v002 check_cluster_status 2021-04-17T07:00:00+00:00 EmrJobFlowSensor 2021-04-17T08:12:09.889327+00:00 2021-04-17T08:21:12.540517+00:00 0:09:02.651190 18124 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-17T08:12:07.325166+00:00 2 default_pool
success booking-processing-job_v002 create_cluster_and_add_emr_steps 2021-04-17T07:00:00+00:00 EmrCreateJobFlowOperator 2021-04-17T08:11:57.479487+00:00 2021-04-17T08:11:59.547476+00:00 0:00:02.067989 18123 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 2 default 2021-04-17T08:11:55.314111+00:00 2 default_pool
success campaign-history-job_v002 create_cluster_and_add_emr_steps 2021-04-17T07:00:00+00:00 EmrCreateJobFlowOperator 2021-04-17T08:11:43.738380+00:00 2021-04-17T08:11:45.516515+00:00 0:00:01.778135 18122 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 2 default 2021-04-17T08:11:41.297000+00:00 2 default_pool
success booking-processing-job_v002 create_emr_steps 2021-04-17T07:00:00+00:00 PythonOperator 2021-04-17T08:11:35.754573+00:00 2021-04-17T08:11:38.967188+00:00 0:00:03.212615 18121 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-04-17T08:11:33.368576+00:00 2 default_pool
success campaign-history-job_v002 create_emr_steps 2021-04-17T07:00:00+00:00 PythonOperator 2021-04-17T08:11:23.802249+00:00 2021-04-17T08:11:26.980297+00:00 0:00:03.178048 18120 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-04-17T08:11:21.343394+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_campaign-history-job_v002 2021-04-17T07:00:00+00:00 TriggerDagRunOperator 2021-04-17T08:11:15.862521+00:00 2021-04-17T08:11:16.402791+00:00 0:00:00.540270 18119 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-17T08:11:13.354816+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_booking-processing-job_v002 2021-04-17T07:00:00+00:00 TriggerDagRunOperator 2021-04-17T08:11:15.685881+00:00 2021-04-17T08:11:16.078715+00:00 0:00:00.392834 18118 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-17T08:11:13.354862+00:00 2 default_pool
success vc-asset-import_v002 check_cluster_status 2021-04-17T07:05:00+00:00 EmrJobFlowSensor 2021-04-17T08:05:46.723930+00:00 2021-04-17T08:14:49.348967+00:00 0:09:02.625037 18117 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-17T08:05:44.594895+00:00 2 default_pool
success vc-asset-import_v002 create_cluster_and_add_emr_steps 2021-04-17T07:05:00+00:00 EmrCreateJobFlowOperator 2021-04-17T08:05:24.792752+00:00 2021-04-17T08:05:26.507919+00:00 0:00:01.715167 18116 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 2 default 2021-04-17T08:05:22.512909+00:00 2 default_pool
success vc-asset-import_v002 create_emr_steps 2021-04-17T07:05:00+00:00 PythonOperator 2021-04-17T08:05:04.859616+00:00 2021-04-17T08:05:07.789181+00:00 0:00:02.929565 18115 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-04-17T08:05:02.492112+00:00 2 default_pool
success campaign-flow-job_v002 check_cluster_status 2021-04-17T07:00:00+00:00 EmrJobFlowSensor 2021-04-17T08:00:52.436086+00:00 2021-04-17T08:10:55.254015+00:00 0:10:02.817929 18114 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-04-17T08:00:50.064884+00:00 2 default_pool
success campaign-flow-job_v002 create_cluster_and_add_emr_steps 2021-04-17T07:00:00+00:00 EmrCreateJobFlowOperator 2021-04-17T08:00:32.391812+00:00 2021-04-17T08:00:34.208640+00:00 0:00:01.816828 18113 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 4 default 2021-04-17T08:00:29.977900+00:00 2 default_pool
success campaign-flow-job_v002 create_emr_steps 2021-04-17T07:00:00+00:00 PythonOperator 2021-04-17T08:00:10.203855+00:00 2021-04-17T08:00:13.131076+00:00 0:00:02.927221 18112 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 5 default 2021-04-17T08:00:07.914215+00:00 2 default_pool
success booking-processing-job_v002 check_cluster_status 2021-04-17T06:00:00+00:00 EmrJobFlowSensor 2021-04-17T07:11:40.836743+00:00 2021-04-17T07:21:43.691275+00:00 0:10:02.854532 18110 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-17T07:11:38.575762+00:00 2 default_pool
success campaign-history-job_v002 check_cluster_status 2021-04-17T06:00:00+00:00 EmrJobFlowSensor 2021-04-17T07:11:29.006153+00:00 2021-04-17T07:20:31.688337+00:00 0:09:02.682184 18109 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-17T07:11:26.504682+00:00 2 default_pool
success booking-processing-job_v002 create_cluster_and_add_emr_steps 2021-04-17T06:00:00+00:00 EmrCreateJobFlowOperator 2021-04-17T07:11:18.924614+00:00 2021-04-17T07:11:20.745537+00:00 0:00:01.820923 18108 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 2 default 2021-04-17T07:11:16.497262+00:00 2 default_pool
success campaign-history-job_v002 create_cluster_and_add_emr_steps 2021-04-17T06:00:00+00:00 EmrCreateJobFlowOperator 2021-04-17T07:11:05.383010+00:00 2021-04-17T07:11:07.482300+00:00 0:00:02.099290 18107 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 2 default 2021-04-17T07:11:02.555533+00:00 2 default_pool
success booking-processing-job_v002 create_emr_steps 2021-04-17T06:00:00+00:00 PythonOperator 2021-04-17T07:10:56.932466+00:00 2021-04-17T07:11:00.072388+00:00 0:00:03.139922 18106 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-04-17T07:10:54.453493+00:00 2 default_pool
success campaign-history-job_v002 create_emr_steps 2021-04-17T06:00:00+00:00 PythonOperator 2021-04-17T07:10:42.971498+00:00 2021-04-17T07:10:46.566805+00:00 0:00:03.595307 18105 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-04-17T07:10:40.406360+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_booking-processing-job_v002 2021-04-17T06:00:00+00:00 TriggerDagRunOperator 2021-04-17T07:10:31.352980+00:00 2021-04-17T07:10:32.150650+00:00 0:00:00.797670 18104 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-17T07:10:28.457141+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_campaign-history-job_v002 2021-04-17T06:00:00+00:00 TriggerDagRunOperator 2021-04-17T07:10:30.988808+00:00 2021-04-17T07:10:31.552408+00:00 0:00:00.563600 18103 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-17T07:10:28.457092+00:00 2 default_pool
success vc-asset-import_v002 check_cluster_status 2021-04-17T06:05:00+00:00 EmrJobFlowSensor 2021-04-17T07:06:12.317362+00:00 2021-04-17T07:14:14.951140+00:00 0:08:02.633778 18102 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-17T07:06:10.014521+00:00 2 default_pool
success vc-asset-import_v002 create_cluster_and_add_emr_steps 2021-04-17T06:05:00+00:00 EmrCreateJobFlowOperator 2021-04-17T07:05:50.279286+00:00 2021-04-17T07:05:52.009001+00:00 0:00:01.729715 18101 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 2 default 2021-04-17T07:05:47.991200+00:00 2 default_pool
success vc-asset-import_v002 create_emr_steps 2021-04-17T06:05:00+00:00 PythonOperator 2021-04-17T07:05:28.054577+00:00 2021-04-17T07:05:30.897120+00:00 0:00:02.842543 18100 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-04-17T07:05:25.927979+00:00 2 default_pool
success campaign-flow-job_v002 check_cluster_status 2021-04-17T06:00:00+00:00 EmrJobFlowSensor 2021-04-17T07:01:13.585781+00:00 2021-04-17T07:10:16.346022+00:00 0:09:02.760241 18099 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-04-17T07:01:11.389543+00:00 2 default_pool
success campaign-flow-job_v002 create_cluster_and_add_emr_steps 2021-04-17T06:00:00+00:00 EmrCreateJobFlowOperator 2021-04-17T07:00:51.830598+00:00 2021-04-17T07:00:53.521800+00:00 0:00:01.691202 18098 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 4 default 2021-04-17T07:00:49.340521+00:00 2 default_pool
success campaign-flow-job_v002 create_emr_steps 2021-04-17T06:00:00+00:00 PythonOperator 2021-04-17T07:00:29.644011+00:00 2021-04-17T07:00:32.640024+00:00 0:00:02.996013 18097 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 5 default 2021-04-17T07:00:27.324441+00:00 2 default_pool
success booking-processing-job_v002 check_cluster_status 2021-04-17T05:00:00+00:00 EmrJobFlowSensor 2021-04-17T06:24:41.195648+00:00 2021-04-17T06:34:43.624009+00:00 0:10:02.428361 18096 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-17T06:24:39.081623+00:00 2 default_pool
success campaign-history-job_v002 check_cluster_status 2021-04-17T05:00:00+00:00 EmrJobFlowSensor 2021-04-17T06:24:37.280337+00:00 2021-04-17T06:34:39.984986+00:00 0:10:02.704649 18095 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-17T06:24:35.089440+00:00 2 default_pool
success booking-processing-job_v002 create_cluster_and_add_emr_steps 2021-04-17T05:00:00+00:00 EmrCreateJobFlowOperator 2021-04-17T06:24:22.040107+00:00 2021-04-17T06:24:23.904230+00:00 0:00:01.864123 18094 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 2 default 2021-04-17T06:24:19.063886+00:00 2 default_pool
success campaign-history-job_v002 create_cluster_and_add_emr_steps 2021-04-17T05:00:00+00:00 EmrCreateJobFlowOperator 2021-04-17T06:24:15.314497+00:00 2021-04-17T06:24:17.496373+00:00 0:00:02.181876 18093 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 2 default 2021-04-17T06:24:13.060081+00:00 2 default_pool
success booking-processing-job_v002 create_emr_steps 2021-04-17T05:00:00+00:00 PythonOperator 2021-04-17T06:24:00.078713+00:00 2021-04-17T06:24:03.419297+00:00 0:00:03.340584 18092 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-04-17T06:23:57.046980+00:00 2 default_pool
success campaign-history-job_v002 create_emr_steps 2021-04-17T05:00:00+00:00 PythonOperator 2021-04-17T06:23:55.474673+00:00 2021-04-17T06:23:59.561665+00:00 0:00:04.086992 18091 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-04-17T06:23:53.041714+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_campaign-history-job_v002 2021-04-17T05:00:00+00:00 TriggerDagRunOperator 2021-04-17T06:23:43.296917+00:00 2021-04-17T06:23:43.733350+00:00 0:00:00.436433 18090 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-17T06:23:41.016413+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_booking-processing-job_v002 2021-04-17T05:00:00+00:00 TriggerDagRunOperator 2021-04-17T06:23:43.287554+00:00 2021-04-17T06:23:43.843973+00:00 0:00:00.556419 18089 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-17T06:23:41.016444+00:00 2 default_pool
success campaign-flow-job_v002 check_cluster_status 2021-04-17T05:00:00+00:00 EmrJobFlowSensor 2021-04-17T06:14:22.815804+00:00 2021-04-17T06:23:25.441228+00:00 0:09:02.625424 18088 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-04-17T06:14:20.184026+00:00 2 default_pool