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 create_emr_steps 2021-03-22T21:00:00+00:00 PythonOperator 2021-03-22T22:00:15.323201+00:00 2021-03-22T22:00:18.033273+00:00 0:00:02.710072 10676 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 5 default 2021-03-22T22:00:13.169575+00:00 2 default_pool
success campaign-history-job_v002 check_cluster_status 2021-03-22T20:00:00+00:00 EmrJobFlowSensor 2021-03-22T21:12:14.293053+00:00 2021-03-22T21:20:16.929794+00:00 0:08:02.636741 10675 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-03-22T21:12:12.037600+00:00 2 default_pool
success booking-processing-job_v002 check_cluster_status 2021-03-22T20:00:00+00:00 EmrJobFlowSensor 2021-03-22T21:12:10.177614+00:00 2021-03-22T21:46:16.319279+00:00 0:34:06.141665 10674 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-03-22T21:12:08.049128+00:00 2 default_pool
success campaign-history-job_v002 create_cluster_and_add_emr_steps 2021-03-22T20:00:00+00:00 EmrCreateJobFlowOperator 2021-03-22T21:11:52.281567+00:00 2021-03-22T21:11:53.971988+00:00 0:00:01.690421 10673 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 2 default 2021-03-22T21:11:50.015714+00:00 2 default_pool
success booking-processing-job_v002 create_cluster_and_add_emr_steps 2021-03-22T20:00:00+00:00 EmrCreateJobFlowOperator 2021-03-22T21:11:48.353025+00:00 2021-03-22T21:11:50.175073+00:00 0:00:01.822048 10672 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 2 default 2021-03-22T21:11:46.011885+00:00 2 default_pool
success campaign-history-job_v002 create_emr_steps 2021-03-22T20:00:00+00:00 PythonOperator 2021-03-22T21:11:30.707028+00:00 2021-03-22T21:11:33.410720+00:00 0:00:02.703692 10671 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-03-22T21:11:27.997300+00:00 2 default_pool
success booking-processing-job_v002 create_emr_steps 2021-03-22T20:00:00+00:00 PythonOperator 2021-03-22T21:11:26.570958+00:00 2021-03-22T21:11:29.993279+00:00 0:00:03.422321 10670 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-03-22T21:11:24.061537+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_booking-processing-job_v002 2021-03-22T20:00:00+00:00 TriggerDagRunOperator 2021-03-22T21:11:06.424868+00:00 2021-03-22T21:11:06.928144+00:00 0:00:00.503276 10669 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-03-22T21:11:03.948563+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_campaign-history-job_v002 2021-03-22T20:00:00+00:00 TriggerDagRunOperator 2021-03-22T21:11:06.418397+00:00 2021-03-22T21:11:06.949668+00:00 0:00:00.531271 10668 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-03-22T21:11:03.948534+00:00 2 default_pool
success vc-asset-import_v002 check_cluster_status 2021-03-22T20:05:00+00:00 EmrJobFlowSensor 2021-03-22T21:05:56.453080+00:00 2021-03-22T21:15:59.123765+00:00 0:10:02.670685 10666 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-03-22T21:05:54.164704+00:00 2 default_pool
success vc-asset-import_v002 create_cluster_and_add_emr_steps 2021-03-22T20:05:00+00:00 EmrCreateJobFlowOperator 2021-03-22T21:05:34.372581+00:00 2021-03-22T21:05:36.069502+00:00 0:00:01.696921 10665 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 2 default 2021-03-22T21:05:32.147997+00:00 2 default_pool
success vc-asset-import_v002 create_emr_steps 2021-03-22T20:05:00+00:00 PythonOperator 2021-03-22T21:05:12.242654+00:00 2021-03-22T21:05:15.037465+00:00 0:00:02.794811 10664 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-03-22T21:05:10.050653+00:00 2 default_pool
success campaign-flow-job_v002 check_cluster_status 2021-03-22T20:00:00+00:00 EmrJobFlowSensor 2021-03-22T21:00:56.078670+00:00 2021-03-22T21:10:58.825368+00:00 0:10:02.746698 10663 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-03-22T21:00:53.731703+00:00 2 default_pool
success campaign-flow-job_v002 create_cluster_and_add_emr_steps 2021-03-22T20:00:00+00:00 EmrCreateJobFlowOperator 2021-03-22T21:00:34.098527+00:00 2021-03-22T21:00:35.752328+00:00 0:00:01.653801 10662 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 4 default 2021-03-22T21:00:31.749986+00:00 2 default_pool
success campaign-flow-job_v002 create_emr_steps 2021-03-22T20:00:00+00:00 PythonOperator 2021-03-22T21:00:12.170487+00:00 2021-03-22T21:00:14.909496+00:00 0:00:02.739009 10661 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 5 default 2021-03-22T21:00:09.690460+00:00 2 default_pool
success booking-processing-job_v002 check_cluster_status 2021-03-22T19:00:00+00:00 EmrJobFlowSensor 2021-03-22T20:10:18.849604+00:00 2021-03-22T20:44:24.805419+00:00 0:34:05.955815 10660 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-03-22T20:10:16.619853+00:00 2 default_pool
success campaign-history-job_v002 check_cluster_status 2021-03-22T19:00:00+00:00 EmrJobFlowSensor 2021-03-22T20:10:10.827308+00:00 2021-03-22T20:18:13.278447+00:00 0:08:02.451139 10659 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-03-22T20:10:08.612212+00:00 2 default_pool
success booking-processing-job_v002 create_cluster_and_add_emr_steps 2021-03-22T19:00:00+00:00 EmrCreateJobFlowOperator 2021-03-22T20:09:57.097922+00:00 2021-03-22T20:09:58.778106+00:00 0:00:01.680184 10658 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 2 default 2021-03-22T20:09:54.658981+00:00 2 default_pool
success campaign-history-job_v002 create_cluster_and_add_emr_steps 2021-03-22T19:00:00+00:00 EmrCreateJobFlowOperator 2021-03-22T20:09:49.490072+00:00 2021-03-22T20:09:51.285725+00:00 0:00:01.795653 10657 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 2 default 2021-03-22T20:09:46.665909+00:00 2 default_pool
success booking-processing-job_v002 create_emr_steps 2021-03-22T19:00:00+00:00 PythonOperator 2021-03-22T20:09:36.984064+00:00 2021-03-22T20:09:40.039586+00:00 0:00:03.055522 10656 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-03-22T20:09:34.584154+00:00 2 default_pool
success campaign-history-job_v002 create_emr_steps 2021-03-22T19:00:00+00:00 PythonOperator 2021-03-22T20:09:27.190076+00:00 2021-03-22T20:09:29.944819+00:00 0:00:02.754743 10655 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-03-22T20:09:24.524634+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_booking-processing-job_v002 2021-03-22T19:00:00+00:00 TriggerDagRunOperator 2021-03-22T20:09:15.219289+00:00 2021-03-22T20:09:15.853035+00:00 0:00:00.633746 10654 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-03-22T20:09:12.640782+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_campaign-history-job_v002 2021-03-22T19:00:00+00:00 TriggerDagRunOperator 2021-03-22T20:09:15.200741+00:00 2021-03-22T20:09:15.645280+00:00 0:00:00.444539 10653 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-03-22T20:09:12.640752+00:00 2 default_pool
success vc-asset-import_v002 check_cluster_status 2021-03-22T19:05:00+00:00 EmrJobFlowSensor 2021-03-22T20:05:51.253503+00:00 2021-03-22T20:15:54.018588+00:00 0:10:02.765085 10651 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-03-22T20:05:49.095270+00:00 2 default_pool
success vc-asset-import_v002 create_cluster_and_add_emr_steps 2021-03-22T19:05:00+00:00 EmrCreateJobFlowOperator 2021-03-22T20:05:29.167166+00:00 2021-03-22T20:05:30.825329+00:00 0:00:01.658163 10650 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 2 default 2021-03-22T20:05:27.076890+00:00 2 default_pool
success vc-asset-import_v002 create_emr_steps 2021-03-22T19:05:00+00:00 PythonOperator 2021-03-22T20:05:07.391229+00:00 2021-03-22T20:05:10.140144+00:00 0:00:02.748915 10649 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-03-22T20:05:05.056337+00:00 2 default_pool
success campaign-flow-job_v002 check_cluster_status 2021-03-22T19:00:00+00:00 EmrJobFlowSensor 2021-03-22T20:00:50.900528+00:00 2021-03-22T20:08:53.375676+00:00 0:08:02.475148 10648 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-03-22T20:00:48.683932+00:00 2 default_pool
success campaign-flow-job_v002 create_cluster_and_add_emr_steps 2021-03-22T19:00:00+00:00 EmrCreateJobFlowOperator 2021-03-22T20:00:28.864242+00:00 2021-03-22T20:00:30.678651+00:00 0:00:01.814409 10647 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 4 default 2021-03-22T20:00:26.602325+00:00 2 default_pool
success campaign-flow-job_v002 create_emr_steps 2021-03-22T19:00:00+00:00 PythonOperator 2021-03-22T20:00:07.067625+00:00 2021-03-22T20:00:09.882093+00:00 0:00:02.814468 10646 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 5 default 2021-03-22T20:00:04.649563+00:00 2 default_pool
success campaign-history-job_v002 check_cluster_status 2021-03-22T18:00:00+00:00 EmrJobFlowSensor 2021-03-22T19:12:54.742663+00:00 2021-03-22T19:22:57.492612+00:00 0:10:02.749949 10645 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-03-22T19:12:52.122567+00:00 2 default_pool
success booking-processing-job_v002 check_cluster_status 2021-03-22T18:00:00+00:00 EmrJobFlowSensor 2021-03-22T19:12:52.344735+00:00 2021-03-22T19:45:58.627311+00:00 0:33:06.282576 10644 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-03-22T19:12:50.119369+00:00 2 default_pool
success campaign-history-job_v002 create_cluster_and_add_emr_steps 2021-03-22T18:00:00+00:00 EmrCreateJobFlowOperator 2021-03-22T19:12:32.555813+00:00 2021-03-22T19:12:34.244080+00:00 0:00:01.688267 10643 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 2 default 2021-03-22T19:12:30.243764+00:00 2 default_pool
success booking-processing-job_v002 create_cluster_and_add_emr_steps 2021-03-22T18:00:00+00:00 EmrCreateJobFlowOperator 2021-03-22T19:12:30.712947+00:00 2021-03-22T19:12:32.515140+00:00 0:00:01.802193 10642 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 2 default 2021-03-22T19:12:28.162611+00:00 2 default_pool
success campaign-history-job_v002 create_emr_steps 2021-03-22T18:00:00+00:00 PythonOperator 2021-03-22T19:12:10.548943+00:00 2021-03-22T19:12:13.266674+00:00 0:00:02.717731 10641 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-03-22T19:12:08.054470+00:00 2 default_pool
success booking-processing-job_v002 create_emr_steps 2021-03-22T18:00:00+00:00 PythonOperator 2021-03-22T19:12:10.529058+00:00 2021-03-22T19:12:13.599253+00:00 0:00:03.070195 10640 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-03-22T19:12:08.054522+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_campaign-history-job_v002 2021-03-22T18:00:00+00:00 TriggerDagRunOperator 2021-03-22T19:11:48.566918+00:00 2021-03-22T19:11:49.051932+00:00 0:00:00.485014 10639 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-03-22T19:11:45.963681+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_booking-processing-job_v002 2021-03-22T18:00:00+00:00 TriggerDagRunOperator 2021-03-22T19:11:48.398421+00:00 2021-03-22T19:11:48.824872+00:00 0:00:00.426451 10638 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-03-22T19:11:45.963720+00:00 2 default_pool
success vc-asset-import_v002 check_cluster_status 2021-03-22T18:05:00+00:00 EmrJobFlowSensor 2021-03-22T19:06:40.012059+00:00 2021-03-22T19:15:42.507212+00:00 0:09:02.495153 10637 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-03-22T19:06:37.497364+00:00 2 default_pool
success vc-asset-import_v002 create_cluster_and_add_emr_steps 2021-03-22T18:05:00+00:00 EmrCreateJobFlowOperator 2021-03-22T19:05:40.065716+00:00 2021-03-22T19:05:41.722237+00:00 0:00:01.656521 10635 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 2 default 2021-03-22T19:05:37.872695+00:00 2 default_pool
success vc-asset-import_v002 create_emr_steps 2021-03-22T18:05:00+00:00 PythonOperator 2021-03-22T19:05:17.855740+00:00 2021-03-22T19:05:20.613772+00:00 0:00:02.758032 10634 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-03-22T19:05:15.533397+00:00 2 default_pool
success campaign-flow-job_v002 check_cluster_status 2021-03-22T18:00:00+00:00 EmrJobFlowSensor 2021-03-22T19:02:25.650921+00:00 2021-03-22T19:11:28.391538+00:00 0:09:02.740617 10633 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-03-22T19:02:23.330571+00:00 2 default_pool
success campaign-flow-job_v002 create_cluster_and_add_emr_steps 2021-03-22T18:00:00+00:00 EmrCreateJobFlowOperator 2021-03-22T19:01:55.523315+00:00 2021-03-22T19:01:57.236701+00:00 0:00:01.713386 10632 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 4 default 2021-03-22T19:01:53.302605+00:00 2 default_pool
success campaign-flow-job_v002 create_emr_steps 2021-03-22T18:00:00+00:00 PythonOperator 2021-03-22T19:01:29.914920+00:00 2021-03-22T19:01:32.758836+00:00 0:00:02.843916 10631 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 5 default 2021-03-22T19:01:27.265317+00:00 2 default_pool
success booking-processing-job_v002 check_cluster_status 2021-03-22T17:00:00+00:00 EmrJobFlowSensor 2021-03-22T18:12:30.942804+00:00 2021-03-22T18:45:36.691085+00:00 0:33:05.748281 10630 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-03-22T18:12:28.465123+00:00 2 default_pool
success campaign-history-job_v002 check_cluster_status 2021-03-22T17:00:00+00:00 EmrJobFlowSensor 2021-03-22T18:12:24.663392+00:00 2021-03-22T18:21:27.230426+00:00 0:09:02.567034 10629 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-03-22T18:12:22.349087+00:00 2 default_pool
success booking-processing-job_v002 create_cluster_and_add_emr_steps 2021-03-22T17:00:00+00:00 EmrCreateJobFlowOperator 2021-03-22T18:12:00.688648+00:00 2021-03-22T18:12:02.483052+00:00 0:00:01.794404 10628 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 2 default 2021-03-22T18:11:58.359648+00:00 2 default_pool
success campaign-history-job_v002 create_cluster_and_add_emr_steps 2021-03-22T17:00:00+00:00 EmrCreateJobFlowOperator 2021-03-22T18:11:52.532431+00:00 2021-03-22T18:11:54.303948+00:00 0:00:01.771517 10627 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 2 default 2021-03-22T18:11:50.315714+00:00 2 default_pool
success booking-processing-job_v002 create_emr_steps 2021-03-22T17:00:00+00:00 PythonOperator 2021-03-22T18:11:30.914472+00:00 2021-03-22T18:11:33.951233+00:00 0:00:03.036761 10626 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-03-22T18:11:28.362700+00:00 2 default_pool
success campaign-history-job_v002 create_emr_steps 2021-03-22T17:00:00+00:00 PythonOperator 2021-03-22T18:11:28.841217+00:00 2021-03-22T18:11:31.596478+00:00 0:00:02.755261 10625 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-03-22T18:11:26.348233+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_campaign-history-job_v002 2021-03-22T17:00:00+00:00 TriggerDagRunOperator 2021-03-22T18:11:12.574615+00:00 2021-03-22T18:11:13.076502+00:00 0:00:00.501887 10624 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-03-22T18:11:10.245882+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_booking-processing-job_v002 2021-03-22T17:00:00+00:00 TriggerDagRunOperator 2021-03-22T18:11:12.497023+00:00 2021-03-22T18:11:12.887488+00:00 0:00:00.390465 10623 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-03-22T18:11:10.245924+00:00 2 default_pool
success vc-asset-import_v002 check_cluster_status 2021-03-22T17:05:00+00:00 EmrJobFlowSensor 2021-03-22T18:06:09.994653+00:00 2021-03-22T18:18:13.056125+00:00 0:12:03.061472 10622 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-03-22T18:06:07.743939+00:00 2 default_pool
success vc-asset-import_v002 create_cluster_and_add_emr_steps 2021-03-22T17:05:00+00:00 EmrCreateJobFlowOperator 2021-03-22T18:05:48.130605+00:00 2021-03-22T18:05:49.893326+00:00 0:00:01.762721 10621 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 2 default 2021-03-22T18:05:45.727519+00:00 2 default_pool
success vc-asset-import_v002 create_emr_steps 2021-03-22T17:05:00+00:00 PythonOperator 2021-03-22T18:05:11.953968+00:00 2021-03-22T18:05:14.684800+00:00 0:00:02.730832 10619 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-03-22T18:05:09.652730+00:00 2 default_pool
success campaign-flow-job_v002 check_cluster_status 2021-03-22T17:00:00+00:00 EmrJobFlowSensor 2021-03-22T18:00:51.609316+00:00 2021-03-22T18:10:54.519562+00:00 0:10:02.910246 10618 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-03-22T18:00:49.256413+00:00 2 default_pool
success campaign-flow-job_v002 create_cluster_and_add_emr_steps 2021-03-22T17:00:00+00:00 EmrCreateJobFlowOperator 2021-03-22T18:00:29.615746+00:00 2021-03-22T18:00:31.329707+00:00 0:00:01.713961 10617 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 4 default 2021-03-22T18:00:27.243213+00:00 2 default_pool
success campaign-flow-job_v002 create_emr_steps 2021-03-22T17:00:00+00:00 PythonOperator 2021-03-22T18:00:07.681297+00:00 2021-03-22T18:00:10.578416+00:00 0:00:02.897119 10616 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 5 default 2021-03-22T18:00:05.240824+00:00 2 default_pool
success campaign-history-job_v002 check_cluster_status 2021-03-22T16:00:00+00:00 EmrJobFlowSensor 2021-03-22T17:16:20.558642+00:00 2021-03-22T17:26:23.301303+00:00 0:10:02.742661 10615 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-03-22T17:16:18.295324+00:00 2 default_pool
success booking-processing-job_v002 check_cluster_status 2021-03-22T16:00:00+00:00 EmrJobFlowSensor 2021-03-22T17:16:16.613259+00:00 2021-03-22T17:48:22.055516+00:00 0:32:05.442257 10614 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-03-22T17:16:14.348603+00:00 2 default_pool
success campaign-history-job_v002 create_cluster_and_add_emr_steps 2021-03-22T16:00:00+00:00 EmrCreateJobFlowOperator 2021-03-22T17:16:00.709673+00:00 2021-03-22T17:16:02.546689+00:00 0:00:01.837016 10613 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 2 default 2021-03-22T17:15:58.345671+00:00 2 default_pool
success booking-processing-job_v002 create_cluster_and_add_emr_steps 2021-03-22T16:00:00+00:00 EmrCreateJobFlowOperator 2021-03-22T17:15:56.483359+00:00 2021-03-22T17:15:58.193908+00:00 0:00:01.710549 10612 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 2 default 2021-03-22T17:15:54.277960+00:00 2 default_pool
success campaign-history-job_v002 create_emr_steps 2021-03-22T16:00:00+00:00 PythonOperator 2021-03-22T17:15:38.521905+00:00 2021-03-22T17:15:41.283308+00:00 0:00:02.761403 10611 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-03-22T17:15:36.247365+00:00 2 default_pool
success booking-processing-job_v002 create_emr_steps 2021-03-22T16:00:00+00:00 PythonOperator 2021-03-22T17:15:32.432125+00:00 2021-03-22T17:15:35.546077+00:00 0:00:03.113952 10610 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-03-22T17:15:30.241189+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_booking-processing-job_v002 2021-03-22T16:00:00+00:00 TriggerDagRunOperator 2021-03-22T17:15:16.681182+00:00 2021-03-22T17:15:17.177303+00:00 0:00:00.496121 10609 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-03-22T17:15:14.244500+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_campaign-history-job_v002 2021-03-22T16:00:00+00:00 TriggerDagRunOperator 2021-03-22T17:15:16.617304+00:00 2021-03-22T17:15:17.037541+00:00 0:00:00.420237 10608 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-03-22T17:15:14.244449+00:00 2 default_pool
success vc-asset-import_v002 check_cluster_status 2021-03-22T16:05:00+00:00 EmrJobFlowSensor 2021-03-22T17:06:05.839876+00:00 2021-03-22T17:16:08.495460+00:00 0:10:02.655584 10607 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-03-22T17:06:03.547615+00:00 2 default_pool
success campaign-flow-job_v002 check_cluster_status 2021-03-22T16:00:00+00:00 EmrJobFlowSensor 2021-03-22T17:05:49.693534+00:00 2021-03-22T17:14:52.425273+00:00 0:09:02.731739 10606 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-03-22T17:05:47.444365+00:00 2 default_pool
success vc-asset-import_v002 create_cluster_and_add_emr_steps 2021-03-22T16:05:00+00:00 EmrCreateJobFlowOperator 2021-03-22T17:05:41.578227+00:00 2021-03-22T17:05:43.230645+00:00 0:00:01.652418 10605 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 2 default 2021-03-22T17:05:39.435947+00:00 2 default_pool
success campaign-flow-job_v002 create_cluster_and_add_emr_steps 2021-03-22T16:00:00+00:00 EmrCreateJobFlowOperator 2021-03-22T17:05:27.636519+00:00 2021-03-22T17:05:29.484812+00:00 0:00:01.848293 10604 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 4 default 2021-03-22T17:05:25.421290+00:00 2 default_pool
success vc-asset-import_v002 create_emr_steps 2021-03-22T16:05:00+00:00 PythonOperator 2021-03-22T17:05:21.968794+00:00 2021-03-22T17:05:24.636631+00:00 0:00:02.667837 10603 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-03-22T17:05:19.474121+00:00 2 default_pool
success campaign-flow-job_v002 create_emr_steps 2021-03-22T16:00:00+00:00 PythonOperator 2021-03-22T17:00:17.000027+00:00 2021-03-22T17:00:19.758395+00:00 0:00:02.758368 10601 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 5 default 2021-03-22T17:00:14.656198+00:00 2 default_pool
success booking-processing-job_v002 check_cluster_status 2021-03-22T15:00:00+00:00 EmrJobFlowSensor 2021-03-22T16:11:36.230082+00:00 2021-03-22T16:44:41.975127+00:00 0:33:05.745045 10600 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-03-22T16:11:33.796510+00:00 2 default_pool
success campaign-history-job_v002 check_cluster_status 2021-03-22T15:00:00+00:00 EmrJobFlowSensor 2021-03-22T16:11:36.100106+00:00 2021-03-22T16:19:38.763918+00:00 0:08:02.663812 10599 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-03-22T16:11:33.796441+00:00 2 default_pool
success campaign-history-job_v002 create_cluster_and_add_emr_steps 2021-03-22T15:00:00+00:00 EmrCreateJobFlowOperator 2021-03-22T16:11:16.022530+00:00 2021-03-22T16:11:17.776655+00:00 0:00:01.754125 10598 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 2 default 2021-03-22T16:11:13.752009+00:00 2 default_pool
success booking-processing-job_v002 create_cluster_and_add_emr_steps 2021-03-22T15:00:00+00:00 EmrCreateJobFlowOperator 2021-03-22T16:11:16.046710+00:00 2021-03-22T16:11:17.986939+00:00 0:00:01.940229 10597 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 2 default 2021-03-22T16:11:13.752056+00:00 2 default_pool
success booking-processing-job_v002 create_emr_steps 2021-03-22T15:00:00+00:00 PythonOperator 2021-03-22T16:10:54.284514+00:00 2021-03-22T16:10:57.398809+00:00 0:00:03.114295 10596 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-03-22T16:10:51.734118+00:00 2 default_pool
success campaign-history-job_v002 create_emr_steps 2021-03-22T15:00:00+00:00 PythonOperator 2021-03-22T16:10:54.147493+00:00 2021-03-22T16:10:57.050074+00:00 0:00:02.902581 10595 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-03-22T16:10:51.734153+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_campaign-history-job_v002 2021-03-22T15:00:00+00:00 TriggerDagRunOperator 2021-03-22T16:10:44.138312+00:00 2021-03-22T16:10:44.548474+00:00 0:00:00.410162 10594 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-03-22T16:10:41.721497+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_booking-processing-job_v002 2021-03-22T15:00:00+00:00 TriggerDagRunOperator 2021-03-22T16:10:43.932985+00:00 2021-03-22T16:10:44.444482+00:00 0:00:00.511497 10593 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-03-22T16:10:41.721545+00:00 2 default_pool
success vc-asset-import_v002 check_cluster_status 2021-03-22T15:05:00+00:00 EmrJobFlowSensor 2021-03-22T16:05:49.746565+00:00 2021-03-22T16:15:52.343386+00:00 0:10:02.596821 10592 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-03-22T16:05:47.463721+00:00 2 default_pool
success vc-asset-import_v002 create_cluster_and_add_emr_steps 2021-03-22T15:05:00+00:00 EmrCreateJobFlowOperator 2021-03-22T16:05:29.593969+00:00 2021-03-22T16:05:31.303742+00:00 0:00:01.709773 10591 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 2 default 2021-03-22T16:05:27.355578+00:00 2 default_pool
success vc-asset-import_v002 create_emr_steps 2021-03-22T15:05:00+00:00 PythonOperator 2021-03-22T16:05:07.442990+00:00 2021-03-22T16:05:10.136316+00:00 0:00:02.693326 10590 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-03-22T16:05:05.335987+00:00 2 default_pool
success campaign-flow-job_v002 check_cluster_status 2021-03-22T15:00:00+00:00 EmrJobFlowSensor 2021-03-22T16:01:19.299123+00:00 2021-03-22T16:10:21.953417+00:00 0:09:02.654294 10589 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-03-22T16:01:17.055807+00:00 2 default_pool
success campaign-flow-job_v002 create_cluster_and_add_emr_steps 2021-03-22T15:00:00+00:00 EmrCreateJobFlowOperator 2021-03-22T16:00:59.207235+00:00 2021-03-22T16:01:00.982374+00:00 0:00:01.775139 10588 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 4 default 2021-03-22T16:00:56.949977+00:00 2 default_pool
success campaign-flow-job_v002 create_emr_steps 2021-03-22T15:00:00+00:00 PythonOperator 2021-03-22T16:00:37.742429+00:00 2021-03-22T16:00:40.545175+00:00 0:00:02.802746 10587 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 5 default 2021-03-22T16:00:35.016374+00:00 2 default_pool
success campaign-history-job_v002 check_cluster_status 2021-03-22T14:00:00+00:00 EmrJobFlowSensor 2021-03-22T15:11:30.409695+00:00 2021-03-22T15:19:32.957951+00:00 0:08:02.548256 10585 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-03-22T15:11:28.040927+00:00 2 default_pool
success booking-processing-job_v002 check_cluster_status 2021-03-22T14:00:00+00:00 EmrJobFlowSensor 2021-03-22T15:11:07.990206+00:00 2021-03-22T15:44:13.870999+00:00 0:33:05.880793 10584 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-03-22T15:11:05.840434+00:00 2 default_pool
success campaign-history-job_v002 create_cluster_and_add_emr_steps 2021-03-22T14:00:00+00:00 EmrCreateJobFlowOperator 2021-03-22T15:11:02.021300+00:00 2021-03-22T15:11:03.696097+00:00 0:00:01.674797 10583 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 2 default 2021-03-22T15:10:59.833569+00:00 2 default_pool
success booking-processing-job_v002 create_cluster_and_add_emr_steps 2021-03-22T14:00:00+00:00 EmrCreateJobFlowOperator 2021-03-22T15:10:38.184790+00:00 2021-03-22T15:10:39.989138+00:00 0:00:01.804348 10582 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 2 default 2021-03-22T15:10:35.810471+00:00 2 default_pool
success campaign-history-job_v002 create_emr_steps 2021-03-22T14:00:00+00:00 PythonOperator 2021-03-22T15:10:32.187217+00:00 2021-03-22T15:10:35.063306+00:00 0:00:02.876089 10581 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-03-22T15:10:29.869559+00:00 2 default_pool
success booking-processing-job_v002 create_emr_steps 2021-03-22T14:00:00+00:00 PythonOperator 2021-03-22T15:10:16.087466+00:00 2021-03-22T15:10:19.098036+00:00 0:00:03.010570 10580 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-03-22T15:10:13.797726+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_campaign-history-job_v002 2021-03-22T14:00:00+00:00 TriggerDagRunOperator 2021-03-22T15:10:12.088810+00:00 2021-03-22T15:10:12.626399+00:00 0:00:00.537589 10579 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-03-22T15:10:09.791566+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_booking-processing-job_v002 2021-03-22T14:00:00+00:00 TriggerDagRunOperator 2021-03-22T15:10:12.054796+00:00 2021-03-22T15:10:12.437866+00:00 0:00:00.383070 10578 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-03-22T15:10:09.791601+00:00 2 default_pool
success vc-asset-import_v002 check_cluster_status 2021-03-22T14:05:00+00:00 EmrJobFlowSensor 2021-03-22T15:06:02.086190+00:00 2021-03-22T15:16:04.915572+00:00 0:10:02.829382 10577 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-03-22T15:05:59.646495+00:00 2 default_pool
success vc-asset-import_v002 create_cluster_and_add_emr_steps 2021-03-22T14:05:00+00:00 EmrCreateJobFlowOperator 2021-03-22T15:05:39.669671+00:00 2021-03-22T15:05:41.297292+00:00 0:00:01.627621 10576 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 2 default 2021-03-22T15:05:37.407713+00:00 2 default_pool
success vc-asset-import_v002 create_emr_steps 2021-03-22T14:05:00+00:00 PythonOperator 2021-03-22T15:05:19.575757+00:00 2021-03-22T15:05:22.234534+00:00 0:00:02.658777 10575 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-03-22T15:05:17.385685+00:00 2 default_pool
success campaign-flow-job_v002 check_cluster_status 2021-03-22T14:00:00+00:00 EmrJobFlowSensor 2021-03-22T15:01:05.442543+00:00 2021-03-22T15:10:08.176205+00:00 0:09:02.733662 10574 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-03-22T15:01:03.049192+00:00 2 default_pool
success campaign-flow-job_v002 create_cluster_and_add_emr_steps 2021-03-22T14:00:00+00:00 EmrCreateJobFlowOperator 2021-03-22T15:00:43.093915+00:00 2021-03-22T15:00:44.775905+00:00 0:00:01.681990 10573 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 4 default 2021-03-22T15:00:40.987301+00:00 2 default_pool
success campaign-flow-job_v002 create_emr_steps 2021-03-22T14:00:00+00:00 PythonOperator 2021-03-22T15:00:21.111108+00:00 2021-03-22T15:00:23.829549+00:00 0:00:02.718441 10572 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 5 default 2021-03-22T15:00:18.885284+00:00 2 default_pool
success booking-processing-job_v002 check_cluster_status 2021-03-22T14:26:26.975226+00:00 EmrJobFlowSensor 2021-03-22T14:27:27.411368+00:00 2021-03-22T14:57:32.703355+00:00 0:30:05.291987 10570 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-03-22T14:27:25.275888+00:00 2 default_pool