Task Instances

  State Dag Id Task Id Execution Date Operator Start Date End Date Duration Job Id Hostname Unixname Priority Weight Queue Queued Dttm Try Number Pool Log Url
success vc-asset-import_v002 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
success booking-processing-job_v002 create_cluster_and_add_emr_steps 2021-03-22T14:26:26.975226+00:00 EmrCreateJobFlowOperator 2021-03-22T14:27:05.672411+00:00 2021-03-22T14:27:07.377095+00:00 0:00:01.704684 10569 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 2 default 2021-03-22T14:27:03.256083+00:00 2 default_pool
success booking-processing-job_v002 create_emr_steps 2021-03-22T14:26:26.975226+00:00 PythonOperator 2021-03-22T14:26:31.529350+00:00 2021-03-22T14:26:34.547761+00:00 0:00:03.018411 10568 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-03-22T14:26:29.273683+00:00 2 default_pool
success vc-asset-import_v002 check_cluster_status 2021-03-22T14:13:06.041896+00:00 EmrJobFlowSensor 2021-03-22T14:14:03.997357+00:00 2021-03-22T14:24:06.676503+00:00 0:10:02.679146 10567 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-03-22T14:14:01.812410+00:00 2 default_pool
success vc-asset-import_v002 create_cluster_and_add_emr_steps 2021-03-22T14:13:06.041896+00:00 EmrCreateJobFlowOperator 2021-03-22T14:13:44.045595+00:00 2021-03-22T14:13:45.753436+00:00 0:00:01.707841 10566 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 2 default 2021-03-22T14:13:41.796801+00:00 2 default_pool
success vc-asset-import_v002 create_emr_steps 2021-03-22T14:13:06.041896+00:00 PythonOperator 2021-03-22T14:13:21.875275+00:00 2021-03-22T14:13:24.541522+00:00 0:00:02.666247 10565 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-03-22T14:13:19.731436+00:00 2 default_pool
success booking-processing-job_v002 check_cluster_status 2021-03-22T13:00:00+00:00 EmrJobFlowSensor 2021-03-22T14:11:11.618688+00:00 2021-03-22T14:23:14.679256+00:00 0:12:03.060568 10564 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-03-22T14:11:09.493253+00:00 2 default_pool
success campaign-history-job_v002 check_cluster_status 2021-03-22T13:00:00+00:00 EmrJobFlowSensor 2021-03-22T14:11:05.890740+00:00 2021-03-22T14:20:08.479907+00:00 0:09:02.589167 10563 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-03-22T14:11:03.490656+00:00 2 default_pool
success booking-processing-job_v002 create_cluster_and_add_emr_steps 2021-03-22T13:00:00+00:00 EmrCreateJobFlowOperator 2021-03-22T14:10:49.792154+00:00 2021-03-22T14:10:51.504158+00:00 0:00:01.712004 10562 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 2 default 2021-03-22T14:10:47.457540+00:00 2 default_pool
success campaign-history-job_v002 create_cluster_and_add_emr_steps 2021-03-22T13:00:00+00:00 EmrCreateJobFlowOperator 2021-03-22T14:10:41.684436+00:00 2021-03-22T14:10:43.483715+00:00 0:00:01.799279 10561 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 2 default 2021-03-22T14:10:39.456033+00:00 2 default_pool
success booking-processing-job_v002 create_emr_steps 2021-03-22T13:00:00+00:00 PythonOperator 2021-03-22T14:10:27.640887+00:00 2021-03-22T14:10:30.724089+00:00 0:00:03.083202 10560 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-03-22T14:10:25.359689+00:00 2 default_pool
success campaign-history-job_v002 create_emr_steps 2021-03-22T13:00:00+00:00 PythonOperator 2021-03-22T14:10:21.616365+00:00 2021-03-22T14:10:24.322486+00:00 0:00:02.706121 10559 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-03-22T14:10:19.348840+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_booking-processing-job_v002 2021-03-22T13:00:00+00:00 TriggerDagRunOperator 2021-03-22T14:10:13.601321+00:00 2021-03-22T14:10:14.114788+00:00 0:00:00.513467 10558 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-03-22T14:10:11.341145+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_campaign-history-job_v002 2021-03-22T13:00:00+00:00 TriggerDagRunOperator 2021-03-22T14:10:13.564767+00:00 2021-03-22T14:10:13.999064+00:00 0:00:00.434297 10557 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-03-22T14:10:11.341117+00:00 2 default_pool
success vc-asset-import_v002 check_cluster_status 2021-03-22T13:05:00+00:00 EmrJobFlowSensor 2021-03-22T14:06:05.201310+00:00 2021-03-22T14:17:08.072242+00:00 0:11:02.870932 10556 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-03-22T14:06:02.919719+00:00 2 default_pool
success vc-asset-import_v002 create_cluster_and_add_emr_steps 2021-03-22T13:05:00+00:00 EmrCreateJobFlowOperator 2021-03-22T14:05:43.124328+00:00 2021-03-22T14:05:44.877736+00:00 0:00:01.753408 10555 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 2 default 2021-03-22T14:05:40.890784+00:00 2 default_pool
success vc-asset-import_v002 create_emr_steps 2021-03-22T13:05:00+00:00 PythonOperator 2021-03-22T14:05:20.903996+00:00 2021-03-22T14:05:23.686452+00:00 0:00:02.782456 10554 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-03-22T14:05:18.786194+00:00 2 default_pool
success campaign-flow-job_v002 check_cluster_status 2021-03-22T13:00:00+00:00 EmrJobFlowSensor 2021-03-22T14:00:52.602752+00:00 2021-03-22T14:09:55.254990+00:00 0:09:02.652238 10553 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-03-22T14:00:50.312799+00:00 2 default_pool
success campaign-flow-job_v002 create_cluster_and_add_emr_steps 2021-03-22T13:00:00+00:00 EmrCreateJobFlowOperator 2021-03-22T14:00:30.909070+00:00 2021-03-22T14:00:32.594054+00:00 0:00:01.684984 10552 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 4 default 2021-03-22T14:00:28.373202+00:00 2 default_pool
success campaign-flow-job_v002 create_emr_steps 2021-03-22T13:00:00+00:00 PythonOperator 2021-03-22T14:00:08.583858+00:00 2021-03-22T14:00:11.455505+00:00 0:00:02.871647 10551 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 5 default 2021-03-22T14:00:06.246899+00:00 2 default_pool
success booking-processing-job_v002 check_cluster_status 2021-03-22T12:00:00+00:00 EmrJobFlowSensor 2021-03-22T13:13:04.855332+00:00 2021-03-22T13:17:06.775025+00:00 0:04:01.919693 10549 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-03-22T13:13:02.684831+00:00 2 default_pool
success campaign-history-job_v002 check_cluster_status 2021-03-22T12:00:00+00:00 EmrJobFlowSensor 2021-03-22T13:12:40.913069+00:00 2021-03-22T13:22:43.653991+00:00 0:10:02.740922 10548 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-03-22T13:12:38.650680+00:00 2 default_pool
success booking-processing-job_v002 create_cluster_and_add_emr_steps 2021-03-22T12:00:00+00:00 EmrCreateJobFlowOperator 2021-03-22T13:12:38.919465+00:00 2021-03-22T13:12:40.596594+00:00 0:00:01.677129 10547 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 2 default 2021-03-22T13:12:36.674618+00:00 2 default_pool
success campaign-history-job_v002 create_cluster_and_add_emr_steps 2021-03-22T12:00:00+00:00 EmrCreateJobFlowOperator 2021-03-22T13:12:21.341782+00:00 2021-03-22T13:12:23.325037+00:00 0:00:01.983255 10546 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 2 default 2021-03-22T13:12:18.603432+00:00 2 default_pool