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-29T19:00:00+00:00 TriggerDagRunOperator 2021-04-29T20:09:23.981763+00:00 2021-04-29T20:09:24.405782+00:00 0:00:00.424019 22672 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-29T20:09:20.891599+00:00 2 default_pool
success vc-asset-import_v002 create_cluster_and_add_emr_steps 2021-04-29T19:05:00+00:00 EmrCreateJobFlowOperator 2021-04-29T20:05:36.913916+00:00 2021-04-29T20:05:38.646427+00:00 0:00:01.732511 22669 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 2 default 2021-04-29T20:05:34.692338+00:00 2 default_pool
success vc-asset-import_v002 create_emr_steps 2021-04-29T19:05:00+00:00 PythonOperator 2021-04-29T20:05:16.778545+00:00 2021-04-29T20:05:19.744514+00:00 0:00:02.965969 22668 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-04-29T20:05:14.642903+00:00 2 default_pool
success campaign-flow-job_v002 check_cluster_status 2021-04-29T19:00:00+00:00 EmrJobFlowSensor 2021-04-29T20:01:00.913622+00:00 2021-04-29T20:09:03.453446+00:00 0:08:02.539824 22667 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-04-29T20:00:58.189765+00:00 2 default_pool
success campaign-flow-job_v002 create_cluster_and_add_emr_steps 2021-04-29T19:00:00+00:00 EmrCreateJobFlowOperator 2021-04-29T20:00:38.737906+00:00 2021-04-29T20:00:40.410078+00:00 0:00:01.672172 22666 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 4 default 2021-04-29T20:00:36.166218+00:00 2 default_pool
success campaign-flow-job_v002 create_emr_steps 2021-04-29T19:00:00+00:00 PythonOperator 2021-04-29T20:00:18.598125+00:00 2021-04-29T20:00:21.649459+00:00 0:00:03.051334 22665 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 5 default 2021-04-29T20:00:16.150901+00:00 2 default_pool
success booking-processing-job_v002 check_cluster_status 2021-04-29T18:00:00+00:00 EmrJobFlowSensor 2021-04-29T19:12:13.857884+00:00 2021-04-29T19:22:16.771389+00:00 0:10:02.913505 22664 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-29T19:12:11.377741+00:00 2 default_pool
success campaign-history-job_v002 check_cluster_status 2021-04-29T18:00:00+00:00 EmrJobFlowSensor 2021-04-29T19:12:05.880685+00:00 2021-04-29T19:20:08.568656+00:00 0:08:02.687971 22663 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-29T19:12:03.364519+00:00 2 default_pool
success booking-processing-job_v002 create_cluster_and_add_emr_steps 2021-04-29T18:00:00+00:00 EmrCreateJobFlowOperator 2021-04-29T19:11:51.416267+00:00 2021-04-29T19:11:53.116853+00:00 0:00:01.700586 22662 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 2 default 2021-04-29T19:11:49.293481+00:00 2 default_pool
success campaign-history-job_v002 create_cluster_and_add_emr_steps 2021-04-29T18:00:00+00:00 EmrCreateJobFlowOperator 2021-04-29T19:11:41.493831+00:00 2021-04-29T19:11:43.331122+00:00 0:00:01.837291 22661 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 2 default 2021-04-29T19:11:39.285184+00:00 2 default_pool
success booking-processing-job_v002 create_emr_steps 2021-04-29T18:00:00+00:00 PythonOperator 2021-04-29T19:11:31.497256+00:00 2021-04-29T19:11:34.741697+00:00 0:00:03.244441 22660 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-04-29T19:11:29.274157+00:00 2 default_pool
success campaign-history-job_v002 create_emr_steps 2021-04-29T18:00:00+00:00 PythonOperator 2021-04-29T19:11:21.868711+00:00 2021-04-29T19:11:24.868762+00:00 0:00:03.000051 22659 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-04-29T19:11:19.249068+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_campaign-history-job_v002 2021-04-29T18:00:00+00:00 TriggerDagRunOperator 2021-04-29T19:11:13.532917+00:00 2021-04-29T19:11:14.087284+00:00 0:00:00.554367 22658 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-29T19:11:11.243224+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_booking-processing-job_v002 2021-04-29T18:00:00+00:00 TriggerDagRunOperator 2021-04-29T19:11:13.500429+00:00 2021-04-29T19:11:13.955974+00:00 0:00:00.455545 22657 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-29T19:11:11.243261+00:00 2 default_pool
success vc-asset-import_v002 check_cluster_status 2021-04-29T18:05:00+00:00 EmrJobFlowSensor 2021-04-29T19:06:39.459066+00:00 2021-04-29T19:15:42.099810+00:00 0:09:02.640744 22656 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-29T19:06:36.858065+00:00 2 default_pool
success vc-asset-import_v002 create_cluster_and_add_emr_steps 2021-04-29T18:05:00+00:00 EmrCreateJobFlowOperator 2021-04-29T19:05:41.390915+00:00 2021-04-29T19:05:43.038728+00:00 0:00:01.647813 22654 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 2 default 2021-04-29T19:05:39.235231+00:00 2 default_pool
success vc-asset-import_v002 create_emr_steps 2021-04-29T18:05:00+00:00 PythonOperator 2021-04-29T19:05:13.515587+00:00 2021-04-29T19:05:16.476170+00:00 0:00:02.960583 22653 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-04-29T19:05:11.211726+00:00 2 default_pool
success campaign-flow-job_v002 check_cluster_status 2021-04-29T18:00:00+00:00 EmrJobFlowSensor 2021-04-29T19:00:55.009509+00:00 2021-04-29T19:10:57.826758+00:00 0:10:02.817249 22652 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-04-29T19:00:52.832004+00:00 2 default_pool
success campaign-flow-job_v002 create_cluster_and_add_emr_steps 2021-04-29T18:00:00+00:00 EmrCreateJobFlowOperator 2021-04-29T19:00:33.157171+00:00 2021-04-29T19:00:34.988962+00:00 0:00:01.831791 22651 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 4 default 2021-04-29T19:00:30.808996+00:00 2 default_pool
success campaign-flow-job_v002 create_emr_steps 2021-04-29T18:00:00+00:00 PythonOperator 2021-04-29T19:00:11.237645+00:00 2021-04-29T19:00:14.312643+00:00 0:00:03.074998 22650 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 5 default 2021-04-29T19:00:08.848456+00:00 2 default_pool
success booking-processing-job_v002 check_cluster_status 2021-04-29T17:00:00+00:00 EmrJobFlowSensor 2021-04-29T18:11:09.873656+00:00 2021-04-29T18:20:12.559523+00:00 0:09:02.685867 22649 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-29T18:11:07.388057+00:00 2 default_pool
success campaign-history-job_v002 check_cluster_status 2021-04-29T17:00:00+00:00 EmrJobFlowSensor 2021-04-29T18:11:09.796427+00:00 2021-04-29T18:20:12.554483+00:00 0:09:02.758056 22648 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-29T18:11:07.388088+00:00 2 default_pool
success booking-processing-job_v002 create_cluster_and_add_emr_steps 2021-04-29T17:00:00+00:00 EmrCreateJobFlowOperator 2021-04-29T18:10:49.703374+00:00 2021-04-29T18:10:51.496350+00:00 0:00:01.792976 22647 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 2 default 2021-04-29T18:10:47.362113+00:00 2 default_pool
success campaign-history-job_v002 create_cluster_and_add_emr_steps 2021-04-29T17:00:00+00:00 EmrCreateJobFlowOperator 2021-04-29T18:10:47.629512+00:00 2021-04-29T18:10:49.342434+00:00 0:00:01.712922 22646 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 2 default 2021-04-29T18:10:45.362254+00:00 2 default_pool
success booking-processing-job_v002 create_emr_steps 2021-04-29T17:00:00+00:00 PythonOperator 2021-04-29T18:10:28.108184+00:00 2021-04-29T18:10:31.316706+00:00 0:00:03.208522 22645 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-04-29T18:10:25.362947+00:00 2 default_pool
success campaign-history-job_v002 create_emr_steps 2021-04-29T17:00:00+00:00 PythonOperator 2021-04-29T18:10:25.709482+00:00 2021-04-29T18:10:29.076674+00:00 0:00:03.367192 22644 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-04-29T18:10:23.367899+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_campaign-history-job_v002 2021-04-29T17:00:00+00:00 TriggerDagRunOperator 2021-04-29T18:10:14.057143+00:00 2021-04-29T18:10:14.520213+00:00 0:00:00.463070 22643 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-29T18:10:11.360645+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_booking-processing-job_v002 2021-04-29T17:00:00+00:00 TriggerDagRunOperator 2021-04-29T18:10:14.017196+00:00 2021-04-29T18:10:14.560583+00:00 0:00:00.543387 22642 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-29T18:10:11.360689+00:00 2 default_pool
success vc-asset-import_v002 check_cluster_status 2021-04-29T17:05:00+00:00 EmrJobFlowSensor 2021-04-29T18:06:35.394544+00:00 2021-04-29T18:15:38.009369+00:00 0:09:02.614825 22641 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-29T18:06:33.084146+00:00 2 default_pool
success vc-asset-import_v002 create_cluster_and_add_emr_steps 2021-04-29T17:05:00+00:00 EmrCreateJobFlowOperator 2021-04-29T18:06:13.500794+00:00 2021-04-29T18:06:15.263397+00:00 0:00:01.762603 22640 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 2 default 2021-04-29T18:06:11.001256+00:00 2 default_pool
success vc-asset-import_v002 create_emr_steps 2021-04-29T17:05:00+00:00 PythonOperator 2021-04-29T18:05:20.890830+00:00 2021-04-29T18:05:23.956306+00:00 0:00:03.065476 22638 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-04-29T18:05:18.566179+00:00 2 default_pool
success campaign-flow-job_v002 check_cluster_status 2021-04-29T17:00:00+00:00 EmrJobFlowSensor 2021-04-29T18:01:04.752157+00:00 2021-04-29T18:10:07.436243+00:00 0:09:02.684086 22637 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-04-29T18:01:02.066398+00:00 2 default_pool
success campaign-flow-job_v002 create_cluster_and_add_emr_steps 2021-04-29T17:00:00+00:00 EmrCreateJobFlowOperator 2021-04-29T18:00:42.449883+00:00 2021-04-29T18:00:44.279682+00:00 0:00:01.829799 22636 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 4 default 2021-04-29T18:00:40.044170+00:00 2 default_pool
success campaign-flow-job_v002 create_emr_steps 2021-04-29T17:00:00+00:00 PythonOperator 2021-04-29T18:00:12.116658+00:00 2021-04-29T18:00:15.171509+00:00 0:00:03.054851 22635 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 5 default 2021-04-29T18:00:09.917314+00:00 2 default_pool
success booking-processing-job_v002 check_cluster_status 2021-04-29T16:00:00+00:00 EmrJobFlowSensor 2021-04-29T17:11:17.028509+00:00 2021-04-29T17:21:19.826750+00:00 0:10:02.798241 22634 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-29T17:11:14.554574+00:00 2 default_pool
success campaign-history-job_v002 check_cluster_status 2021-04-29T16:00:00+00:00 EmrJobFlowSensor 2021-04-29T17:11:03.084331+00:00 2021-04-29T17:20:05.750814+00:00 0:09:02.666483 22633 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-29T17:11:00.488249+00:00 2 default_pool
success booking-processing-job_v002 create_cluster_and_add_emr_steps 2021-04-29T16:00:00+00:00 EmrCreateJobFlowOperator 2021-04-29T17:10:55.142186+00:00 2021-04-29T17:10:56.836171+00:00 0:00:01.693985 22632 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 2 default 2021-04-29T17:10:52.565667+00:00 2 default_pool
success campaign-history-job_v002 create_cluster_and_add_emr_steps 2021-04-29T16:00:00+00:00 EmrCreateJobFlowOperator 2021-04-29T17:10:42.709682+00:00 2021-04-29T17:10:44.421394+00:00 0:00:01.711712 22631 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 2 default 2021-04-29T17:10:40.470223+00:00 2 default_pool
success booking-processing-job_v002 create_emr_steps 2021-04-29T16:00:00+00:00 PythonOperator 2021-04-29T17:10:34.721658+00:00 2021-04-29T17:10:38.042614+00:00 0:00:03.320956 22630 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-04-29T17:10:32.415389+00:00 2 default_pool
success campaign-history-job_v002 create_emr_steps 2021-04-29T16:00:00+00:00 PythonOperator 2021-04-29T17:10:20.716250+00:00 2021-04-29T17:10:23.715406+00:00 0:00:02.999156 22629 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-04-29T17:10:18.403831+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_campaign-history-job_v002 2021-04-29T16:00:00+00:00 TriggerDagRunOperator 2021-04-29T17:10:09.063335+00:00 2021-04-29T17:10:09.605171+00:00 0:00:00.541836 22628 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-29T17:10:06.462740+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_booking-processing-job_v002 2021-04-29T16:00:00+00:00 TriggerDagRunOperator 2021-04-29T17:10:08.911662+00:00 2021-04-29T17:10:09.317779+00:00 0:00:00.406117 22627 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-29T17:10:06.462784+00:00 2 default_pool
success vc-asset-import_v002 check_cluster_status 2021-04-29T16:05:00+00:00 EmrJobFlowSensor 2021-04-29T17:06:22.318836+00:00 2021-04-29T17:15:25.051511+00:00 0:09:02.732675 22626 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-29T17:06:20.060335+00:00 2 default_pool
success vc-asset-import_v002 create_cluster_and_add_emr_steps 2021-04-29T16:05:00+00:00 EmrCreateJobFlowOperator 2021-04-29T17:06:02.199123+00:00 2021-04-29T17:06:03.928924+00:00 0:00:01.729801 22625 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 2 default 2021-04-29T17:06:00.030187+00:00 2 default_pool
success vc-asset-import_v002 create_emr_steps 2021-04-29T16:05:00+00:00 PythonOperator 2021-04-29T17:05:40.565171+00:00 2021-04-29T17:05:43.514515+00:00 0:00:02.949344 22624 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-04-29T17:05:38.002774+00:00 2 default_pool
success campaign-flow-job_v002 check_cluster_status 2021-04-29T16:00:00+00:00 EmrJobFlowSensor 2021-04-29T17:01:00.202465+00:00 2021-04-29T17:10:03.094517+00:00 0:09:02.892052 22622 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-04-29T17:00:57.560459+00:00 2 default_pool
success campaign-flow-job_v002 create_cluster_and_add_emr_steps 2021-04-29T16:00:00+00:00 EmrCreateJobFlowOperator 2021-04-29T17:00:39.831237+00:00 2021-04-29T17:00:41.633854+00:00 0:00:01.802617 22621 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 4 default 2021-04-29T17:00:37.484452+00:00 2 default_pool
success campaign-flow-job_v002 create_emr_steps 2021-04-29T16:00:00+00:00 PythonOperator 2021-04-29T17:00:17.593719+00:00 2021-04-29T17:00:20.664353+00:00 0:00:03.070634 22620 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 5 default 2021-04-29T17:00:15.400017+00:00 2 default_pool
success campaign-history-job_v002 check_cluster_status 2021-04-29T15:00:00+00:00 EmrJobFlowSensor 2021-04-29T16:11:10.494152+00:00 2021-04-29T16:21:13.359923+00:00 0:10:02.865771 22619 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-29T16:11:08.133308+00:00 2 default_pool
success booking-processing-job_v002 check_cluster_status 2021-04-29T15:00:00+00:00 EmrJobFlowSensor 2021-04-29T16:10:56.377735+00:00 2021-04-29T16:20:59.244418+00:00 0:10:02.866683 22618 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-29T16:10:54.120227+00:00 2 default_pool
success campaign-history-job_v002 create_cluster_and_add_emr_steps 2021-04-29T15:00:00+00:00 EmrCreateJobFlowOperator 2021-04-29T16:10:48.608878+00:00 2021-04-29T16:10:50.488976+00:00 0:00:01.880098 22617 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 2 default 2021-04-29T16:10:46.150908+00:00 2 default_pool
success booking-processing-job_v002 create_cluster_and_add_emr_steps 2021-04-29T15:00:00+00:00 EmrCreateJobFlowOperator 2021-04-29T16:10:34.658414+00:00 2021-04-29T16:10:36.432497+00:00 0:00:01.774083 22616 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 2 default 2021-04-29T16:10:32.164903+00:00 2 default_pool
success campaign-history-job_v002 create_emr_steps 2021-04-29T15:00:00+00:00 PythonOperator 2021-04-29T16:10:26.528841+00:00 2021-04-29T16:10:29.560529+00:00 0:00:03.031688 22615 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-04-29T16:10:24.094023+00:00 2 default_pool
success booking-processing-job_v002 create_emr_steps 2021-04-29T15:00:00+00:00 PythonOperator 2021-04-29T16:10:12.454361+00:00 2021-04-29T16:10:15.885518+00:00 0:00:03.431157 22614 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-04-29T16:10:10.144202+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_campaign-history-job_v002 2021-04-29T15:00:00+00:00 TriggerDagRunOperator 2021-04-29T16:10:08.415953+00:00 2021-04-29T16:10:08.914262+00:00 0:00:00.498309 22613 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-29T16:10:06.025856+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_booking-processing-job_v002 2021-04-29T15:00:00+00:00 TriggerDagRunOperator 2021-04-29T16:10:08.286282+00:00 2021-04-29T16:10:08.875922+00:00 0:00:00.589640 22612 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-29T16:10:06.025887+00:00 2 default_pool
success vc-asset-import_v002 check_cluster_status 2021-04-29T15:05:00+00:00 EmrJobFlowSensor 2021-04-29T16:05:58.184951+00:00 2021-04-29T16:15:00.890766+00:00 0:09:02.705815 22611 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-29T16:05:55.849930+00:00 2 default_pool
success vc-asset-import_v002 create_cluster_and_add_emr_steps 2021-04-29T15:05:00+00:00 EmrCreateJobFlowOperator 2021-04-29T16:05:38.023769+00:00 2021-04-29T16:05:39.800356+00:00 0:00:01.776587 22610 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 2 default 2021-04-29T16:05:35.725226+00:00 2 default_pool
success vc-asset-import_v002 create_emr_steps 2021-04-29T15:05:00+00:00 PythonOperator 2021-04-29T16:05:16.168171+00:00 2021-04-29T16:05:19.160211+00:00 0:00:02.992040 22609 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-04-29T16:05:13.705734+00:00 2 default_pool
success campaign-flow-job_v002 check_cluster_status 2021-04-29T15:00:00+00:00 EmrJobFlowSensor 2021-04-29T16:00:59.226668+00:00 2021-04-29T16:10:01.843094+00:00 0:09:02.616426 22607 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-04-29T16:00:56.964602+00:00 2 default_pool
success campaign-flow-job_v002 create_cluster_and_add_emr_steps 2021-04-29T15:00:00+00:00 EmrCreateJobFlowOperator 2021-04-29T16:00:39.180251+00:00 2021-04-29T16:00:40.910129+00:00 0:00:01.729878 22606 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 4 default 2021-04-29T16:00:36.893052+00:00 2 default_pool
success campaign-flow-job_v002 create_emr_steps 2021-04-29T15:00:00+00:00 PythonOperator 2021-04-29T16:00:17.110493+00:00 2021-04-29T16:00:20.116429+00:00 0:00:03.005936 22605 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 5 default 2021-04-29T16:00:14.824067+00:00 2 default_pool
success booking-processing-job_v002 check_cluster_status 2021-04-29T14:00:00+00:00 EmrJobFlowSensor 2021-04-29T15:12:15.994310+00:00 2021-04-29T15:22:18.771886+00:00 0:10:02.777576 22604 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-29T15:12:13.797055+00:00 2 default_pool
success campaign-history-job_v002 check_cluster_status 2021-04-29T14:00:00+00:00 EmrJobFlowSensor 2021-04-29T15:12:07.969780+00:00 2021-04-29T15:35:12.612639+00:00 0:23:04.642859 22603 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-29T15:12:05.793193+00:00 2 default_pool
success booking-processing-job_v002 create_cluster_and_add_emr_steps 2021-04-29T14:00:00+00:00 EmrCreateJobFlowOperator 2021-04-29T15:11:56.112205+00:00 2021-04-29T15:11:57.799827+00:00 0:00:01.687622 22602 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 2 default 2021-04-29T15:11:53.738502+00:00 2 default_pool
success campaign-history-job_v002 create_cluster_and_add_emr_steps 2021-04-29T14:00:00+00:00 EmrCreateJobFlowOperator 2021-04-29T15:11:45.927385+00:00 2021-04-29T15:11:47.580308+00:00 0:00:01.652923 22601 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 2 default 2021-04-29T15:11:43.729457+00:00 2 default_pool
success booking-processing-job_v002 create_emr_steps 2021-04-29T14:00:00+00:00 PythonOperator 2021-04-29T15:11:34.085599+00:00 2021-04-29T15:11:37.352261+00:00 0:00:03.266662 22600 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-04-29T15:11:31.715493+00:00 2 default_pool
success campaign-history-job_v002 create_emr_steps 2021-04-29T14:00:00+00:00 PythonOperator 2021-04-29T15:11:24.202772+00:00 2021-04-29T15:11:27.245980+00:00 0:00:03.043208 22599 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-04-29T15:11:21.706334+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_campaign-history-job_v002 2021-04-29T14:00:00+00:00 TriggerDagRunOperator 2021-04-29T15:11:18.128092+00:00 2021-04-29T15:11:18.721134+00:00 0:00:00.593042 22598 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-29T15:11:15.700018+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_booking-processing-job_v002 2021-04-29T14:00:00+00:00 TriggerDagRunOperator 2021-04-29T15:11:17.996145+00:00 2021-04-29T15:11:18.447381+00:00 0:00:00.451236 22597 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-29T15:11:15.700052+00:00 2 default_pool
success vc-asset-import_v002 check_cluster_status 2021-04-29T14:05:00+00:00 EmrJobFlowSensor 2021-04-29T15:06:01.240769+00:00 2021-04-29T15:16:04.012624+00:00 0:10:02.771855 22596 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-29T15:05:59.118730+00:00 2 default_pool
success vc-asset-import_v002 create_cluster_and_add_emr_steps 2021-04-29T14:05:00+00:00 EmrCreateJobFlowOperator 2021-04-29T15:05:39.508732+00:00 2021-04-29T15:05:41.163092+00:00 0:00:01.654360 22595 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 2 default 2021-04-29T15:05:37.160203+00:00 2 default_pool
success vc-asset-import_v002 create_emr_steps 2021-04-29T14:05:00+00:00 PythonOperator 2021-04-29T15:05:19.940184+00:00 2021-04-29T15:05:22.913684+00:00 0:00:02.973500 22594 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-04-29T15:05:17.089566+00:00 2 default_pool
success campaign-flow-job_v002 check_cluster_status 2021-04-29T14:00:00+00:00 EmrJobFlowSensor 2021-04-29T15:01:09.188673+00:00 2021-04-29T15:11:12.068350+00:00 0:10:02.879677 22592 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-04-29T15:01:06.306110+00:00 2 default_pool
success campaign-flow-job_v002 create_cluster_and_add_emr_steps 2021-04-29T14:00:00+00:00 EmrCreateJobFlowOperator 2021-04-29T15:00:46.686944+00:00 2021-04-29T15:00:48.572432+00:00 0:00:01.885488 22591 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 4 default 2021-04-29T15:00:44.349702+00:00 2 default_pool
success campaign-flow-job_v002 create_emr_steps 2021-04-29T14:00:00+00:00 PythonOperator 2021-04-29T15:00:24.406036+00:00 2021-04-29T15:00:27.440241+00:00 0:00:03.034205 22590 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 5 default 2021-04-29T15:00:22.205478+00:00 2 default_pool
success booking-processing-job_v002 check_cluster_status 2021-04-29T13:00:00+00:00 EmrJobFlowSensor 2021-04-29T14:13:51.231250+00:00 2021-04-29T14:23:53.937063+00:00 0:10:02.705813 22589 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-29T14:13:49.062027+00:00 2 default_pool
success campaign-history-job_v002 check_cluster_status 2021-04-29T13:00:00+00:00 EmrJobFlowSensor 2021-04-29T14:13:41.238663+00:00 2021-04-29T14:22:43.898206+00:00 0:09:02.659543 22588 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-29T14:13:39.047321+00:00 2 default_pool
success booking-processing-job_v002 create_cluster_and_add_emr_steps 2021-04-29T13:00:00+00:00 EmrCreateJobFlowOperator 2021-04-29T14:13:31.255891+00:00 2021-04-29T14:13:32.939572+00:00 0:00:01.683681 22587 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 2 default 2021-04-29T14:13:29.050728+00:00 2 default_pool
success campaign-history-job_v002 create_cluster_and_add_emr_steps 2021-04-29T13:00:00+00:00 EmrCreateJobFlowOperator 2021-04-29T14:13:21.217693+00:00 2021-04-29T14:13:22.958820+00:00 0:00:01.741127 22586 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 2 default 2021-04-29T14:13:19.035967+00:00 2 default_pool
success booking-processing-job_v002 create_emr_steps 2021-04-29T13:00:00+00:00 PythonOperator 2021-04-29T14:13:09.845477+00:00 2021-04-29T14:13:13.083959+00:00 0:00:03.238482 22585 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-04-29T14:13:07.021477+00:00 2 default_pool
success campaign-history-job_v002 create_emr_steps 2021-04-29T13:00:00+00:00 PythonOperator 2021-04-29T14:12:59.628903+00:00 2021-04-29T14:13:02.648028+00:00 0:00:03.019125 22584 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-04-29T14:12:57.014256+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_campaign-history-job_v002 2021-04-29T13:00:00+00:00 TriggerDagRunOperator 2021-04-29T14:12:51.282121+00:00 2021-04-29T14:12:51.876209+00:00 0:00:00.594088 22583 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-29T14:12:49.010551+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_booking-processing-job_v002 2021-04-29T13:00:00+00:00 TriggerDagRunOperator 2021-04-29T14:12:51.226757+00:00 2021-04-29T14:12:51.687213+00:00 0:00:00.460456 22582 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-29T14:12:49.010592+00:00 2 default_pool
success vc-asset-import_v002 check_cluster_status 2021-04-29T13:05:00+00:00 EmrJobFlowSensor 2021-04-29T14:05:46.377556+00:00 2021-04-29T14:14:48.931158+00:00 0:09:02.553602 22581 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-29T14:05:44.192936+00:00 2 default_pool
success vc-asset-import_v002 create_cluster_and_add_emr_steps 2021-04-29T13:05:00+00:00 EmrCreateJobFlowOperator 2021-04-29T14:05:24.481249+00:00 2021-04-29T14:05:26.130585+00:00 0:00:01.649336 22580 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 2 default 2021-04-29T14:05:22.163574+00:00 2 default_pool
success vc-asset-import_v002 create_emr_steps 2021-04-29T13:05:00+00:00 PythonOperator 2021-04-29T14:05:04.392360+00:00 2021-04-29T14:05:07.527875+00:00 0:00:03.135515 22579 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-04-29T14:05:02.091588+00:00 2 default_pool
success campaign-flow-job_v002 check_cluster_status 2021-04-29T13:00:00+00:00 EmrJobFlowSensor 2021-04-29T14:02:30.683178+00:00 2021-04-29T14:12:33.566880+00:00 0:10:02.883702 22578 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-04-29T14:02:28.051546+00:00 2 default_pool
success campaign-flow-job_v002 create_cluster_and_add_emr_steps 2021-04-29T13:00:00+00:00 EmrCreateJobFlowOperator 2021-04-29T14:02:08.028123+00:00 2021-04-29T14:02:09.861402+00:00 0:00:01.833279 22577 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 4 default 2021-04-29T14:02:05.858324+00:00 2 default_pool
success campaign-flow-job_v002 create_emr_steps 2021-04-29T13:00:00+00:00 PythonOperator 2021-04-29T14:01:48.321573+00:00 2021-04-29T14:01:51.359501+00:00 0:00:03.037928 22576 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 5 default 2021-04-29T14:01:45.841949+00:00 2 default_pool
success booking-processing-job_v002 check_cluster_status 2021-04-29T12:00:00+00:00 EmrJobFlowSensor 2021-04-29T13:12:19.105584+00:00 2021-04-29T13:22:21.883495+00:00 0:10:02.777911 22574 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-29T13:12:16.597923+00:00 2 default_pool
success campaign-history-job_v002 check_cluster_status 2021-04-29T12:00:00+00:00 EmrJobFlowSensor 2021-04-29T13:12:02.819607+00:00 2021-04-29T13:22:05.643312+00:00 0:10:02.823705 22573 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-29T13:12:00.587482+00:00 2 default_pool
success booking-processing-job_v002 create_cluster_and_add_emr_steps 2021-04-29T12:00:00+00:00 EmrCreateJobFlowOperator 2021-04-29T13:11:58.830782+00:00 2021-04-29T13:12:00.546448+00:00 0:00:01.715666 22572 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 2 default 2021-04-29T13:11:56.582900+00:00 2 default_pool
success campaign-history-job_v002 create_cluster_and_add_emr_steps 2021-04-29T12:00:00+00:00 EmrCreateJobFlowOperator 2021-04-29T13:11:41.231446+00:00 2021-04-29T13:11:42.911448+00:00 0:00:01.680002 22571 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 2 default 2021-04-29T13:11:38.561848+00:00 2 default_pool
success booking-processing-job_v002 create_emr_steps 2021-04-29T12:00:00+00:00 PythonOperator 2021-04-29T13:11:36.738330+00:00 2021-04-29T13:11:40.733896+00:00 0:00:03.995566 22570 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-04-29T13:11:34.557743+00:00 2 default_pool
success campaign-history-job_v002 create_emr_steps 2021-04-29T12:00:00+00:00 PythonOperator 2021-04-29T13:11:19.015040+00:00 2021-04-29T13:11:22.069902+00:00 0:00:03.054862 22569 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-04-29T13:11:16.577457+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_booking-processing-job_v002 2021-04-29T12:00:00+00:00 TriggerDagRunOperator 2021-04-29T13:11:15.169430+00:00 2021-04-29T13:11:15.744805+00:00 0:00:00.575375 22568 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-29T13:11:12.574500+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_campaign-history-job_v002 2021-04-29T12:00:00+00:00 TriggerDagRunOperator 2021-04-29T13:11:15.021897+00:00 2021-04-29T13:11:15.439215+00:00 0:00:00.417318 22567 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-29T13:11:12.574470+00:00 2 default_pool
success vc-asset-import_v002 check_cluster_status 2021-04-29T12:05:00+00:00 EmrJobFlowSensor 2021-04-29T13:05:56.145686+00:00 2021-04-29T13:14:58.644948+00:00 0:09:02.499262 22566 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-29T13:05:54.028944+00:00 2 default_pool
success vc-asset-import_v002 create_cluster_and_add_emr_steps 2021-04-29T12:05:00+00:00 EmrCreateJobFlowOperator 2021-04-29T13:05:34.318921+00:00 2021-04-29T13:05:36.061293+00:00 0:00:01.742372 22565 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 2 default 2021-04-29T13:05:32.008292+00:00 2 default_pool