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-22T06:00:00+00:00 PythonOperator 2021-03-22T07:00:25.609097+00:00 2021-03-22T07:00:28.324927+00:00 0:00:02.715830 10458 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 5 default 2021-03-22T07:00:23.222929+00:00 2 default_pool
success campaign-history-job_v002 check_cluster_status 2021-03-22T05:00:00+00:00 EmrJobFlowSensor 2021-03-22T06:11:44.388661+00:00 2021-03-22T06:20:46.916183+00:00 0:09:02.527522 10456 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-03-22T06:11:41.985127+00:00 2 default_pool
success campaign-history-job_v002 create_cluster_and_add_emr_steps 2021-03-22T05:00:00+00:00 EmrCreateJobFlowOperator 2021-03-22T06:11:28.519245+00:00 2021-03-22T06:11:30.251915+00:00 0:00:01.732670 10455 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 2 default 2021-03-22T06:11:26.036377+00:00 2 default_pool
success campaign-history-job_v002 create_emr_steps 2021-03-22T05:00:00+00:00 PythonOperator 2021-03-22T06:11:12.449896+00:00 2021-03-22T06:11:15.309522+00:00 0:00:02.859626 10454 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-03-22T06:11:10.028052+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_campaign-history-job_v002 2021-03-22T05:00:00+00:00 TriggerDagRunOperator 2021-03-22T06:10:58.266815+00:00 2021-03-22T06:10:58.806556+00:00 0:00:00.539741 10453 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-03-22T06:10:55.889396+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_booking-processing-job_v002 2021-03-22T05:00:00+00:00 TriggerDagRunOperator 2021-03-22T06:10:58.070590+00:00 2021-03-22T06:10:58.463842+00:00 0:00:00.393252 10452 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-03-22T06:10:55.889426+00:00 2 default_pool
success campaign-flow-job_v002 check_cluster_status 2021-03-22T05:00:00+00:00 EmrJobFlowSensor 2021-03-22T06:00:36.886841+00:00 2021-03-22T06:10:39.654447+00:00 0:10:02.767606 10451 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-03-22T06:00:34.783054+00:00 2 default_pool
success campaign-flow-job_v002 create_cluster_and_add_emr_steps 2021-03-22T05:00:00+00:00 EmrCreateJobFlowOperator 2021-03-22T06:00:21.302710+00:00 2021-03-22T06:00:23.020600+00:00 0:00:01.717890 10450 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 4 default 2021-03-22T06:00:18.843940+00:00 2 default_pool
success campaign-flow-job_v002 create_emr_steps 2021-03-22T05:00:00+00:00 PythonOperator 2021-03-22T06:00:05.712930+00:00 2021-03-22T06:00:08.595848+00:00 0:00:02.882918 10449 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 5 default 2021-03-22T06:00:02.763115+00:00 2 default_pool
success campaign-history-job_v002 check_cluster_status 2021-03-22T04:00:00+00:00 EmrJobFlowSensor 2021-03-22T05:11:34.962588+00:00 2021-03-22T05:21:37.889159+00:00 0:10:02.926571 10447 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-03-22T05:11:32.496631+00:00 2 default_pool
success campaign-history-job_v002 create_cluster_and_add_emr_steps 2021-03-22T04:00:00+00:00 EmrCreateJobFlowOperator 2021-03-22T05:11:18.908453+00:00 2021-03-22T05:11:20.710269+00:00 0:00:01.801816 10446 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 2 default 2021-03-22T05:11:16.540356+00:00 2 default_pool
success campaign-history-job_v002 create_emr_steps 2021-03-22T04:00:00+00:00 PythonOperator 2021-03-22T05:11:02.734530+00:00 2021-03-22T05:11:05.443490+00:00 0:00:02.708960 10445 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-03-22T05:11:00.473210+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_booking-processing-job_v002 2021-03-22T04:00:00+00:00 TriggerDagRunOperator 2021-03-22T05:10:46.775644+00:00 2021-03-22T05:10:47.312784+00:00 0:00:00.537140 10444 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-03-22T05:10:44.433280+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_campaign-history-job_v002 2021-03-22T04:00:00+00:00 TriggerDagRunOperator 2021-03-22T05:10:46.698023+00:00 2021-03-22T05:10:47.093819+00:00 0:00:00.395796 10443 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-03-22T05:10:44.433237+00:00 2 default_pool
success campaign-flow-job_v002 check_cluster_status 2021-03-22T04:00:00+00:00 EmrJobFlowSensor 2021-03-22T05:00:35.881863+00:00 2021-03-22T05:10:38.594377+00:00 0:10:02.712514 10442 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-03-22T05:00:33.532412+00:00 2 default_pool
success campaign-flow-job_v002 create_cluster_and_add_emr_steps 2021-03-22T04:00:00+00:00 EmrCreateJobFlowOperator 2021-03-22T05:00:19.986352+00:00 2021-03-22T05:00:21.891215+00:00 0:00:01.904863 10441 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 4 default 2021-03-22T05:00:17.429801+00:00 2 default_pool
success campaign-flow-job_v002 create_emr_steps 2021-03-22T04:00:00+00:00 PythonOperator 2021-03-22T05:00:03.812537+00:00 2021-03-22T05:00:06.667898+00:00 0:00:02.855361 10440 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 5 default 2021-03-22T05:00:01.386840+00:00 2 default_pool
success campaign-history-job_v002 check_cluster_status 2021-03-22T03:00:00+00:00 EmrJobFlowSensor 2021-03-22T04:11:50.472603+00:00 2021-03-22T04:21:53.150539+00:00 0:10:02.677936 10438 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-03-22T04:11:48.326054+00:00 2 default_pool
success campaign-history-job_v002 create_cluster_and_add_emr_steps 2021-03-22T03:00:00+00:00 EmrCreateJobFlowOperator 2021-03-22T04:11:32.752249+00:00 2021-03-22T04:11:34.436330+00:00 0:00:01.684081 10437 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 2 default 2021-03-22T04:11:30.326304+00:00 2 default_pool
success campaign-history-job_v002 create_emr_steps 2021-03-22T03:00:00+00:00 PythonOperator 2021-03-22T04:11:16.774755+00:00 2021-03-22T04:11:19.605875+00:00 0:00:02.831120 10436 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-03-22T04:11:14.322678+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_campaign-history-job_v002 2021-03-22T03:00:00+00:00 TriggerDagRunOperator 2021-03-22T04:10:58.598947+00:00 2021-03-22T04:10:59.131255+00:00 0:00:00.532308 10435 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-03-22T04:10:56.189312+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_booking-processing-job_v002 2021-03-22T03:00:00+00:00 TriggerDagRunOperator 2021-03-22T04:10:58.383154+00:00 2021-03-22T04:10:58.794232+00:00 0:00:00.411078 10434 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-03-22T04:10:56.189342+00:00 2 default_pool
success campaign-flow-job_v002 check_cluster_status 2021-03-22T03:00:00+00:00 EmrJobFlowSensor 2021-03-22T04:00:41.309641+00:00 2021-03-22T04:10:44.192472+00:00 0:10:02.882831 10433 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-03-22T04:00:38.967369+00:00 2 default_pool
success campaign-flow-job_v002 create_cluster_and_add_emr_steps 2021-03-22T03:00:00+00:00 EmrCreateJobFlowOperator 2021-03-22T04:00:25.203110+00:00 2021-03-22T04:00:26.993316+00:00 0:00:01.790206 10432 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 4 default 2021-03-22T04:00:22.922097+00:00 2 default_pool
success campaign-flow-job_v002 create_emr_steps 2021-03-22T03:00:00+00:00 PythonOperator 2021-03-22T04:00:09.199208+00:00 2021-03-22T04:00:11.899770+00:00 0:00:02.700562 10431 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 5 default 2021-03-22T04:00:06.877219+00:00 2 default_pool
success campaign-history-job_v002 check_cluster_status 2021-03-22T02:00:00+00:00 EmrJobFlowSensor 2021-03-22T03:11:42.260489+00:00 2021-03-22T03:19:44.868070+00:00 0:08:02.607581 10429 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-03-22T03:11:40.038820+00:00 2 default_pool
success campaign-history-job_v002 create_cluster_and_add_emr_steps 2021-03-22T02:00:00+00:00 EmrCreateJobFlowOperator 2021-03-22T03:11:26.187316+00:00 2021-03-22T03:11:27.953891+00:00 0:00:01.766575 10428 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 2 default 2021-03-22T03:11:24.026839+00:00 2 default_pool
success campaign-history-job_v002 create_emr_steps 2021-03-22T02:00:00+00:00 PythonOperator 2021-03-22T03:11:10.495564+00:00 2021-03-22T03:11:13.221745+00:00 0:00:02.726181 10427 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-03-22T03:11:08.124240+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_campaign-history-job_v002 2021-03-22T02:00:00+00:00 TriggerDagRunOperator 2021-03-22T03:10:56.466147+00:00 2021-03-22T03:10:57.007727+00:00 0:00:00.541580 10426 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-03-22T03:10:54.057944+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_booking-processing-job_v002 2021-03-22T02:00:00+00:00 TriggerDagRunOperator 2021-03-22T03:10:56.274565+00:00 2021-03-22T03:10:56.690184+00:00 0:00:00.415619 10425 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-03-22T03:10:54.057981+00:00 2 default_pool
success campaign-flow-job_v002 check_cluster_status 2021-03-22T02:00:00+00:00 EmrJobFlowSensor 2021-03-22T03:00:48.922331+00:00 2021-03-22T03:10:51.709365+00:00 0:10:02.787034 10424 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-03-22T03:00:46.668754+00:00 2 default_pool
success campaign-flow-job_v002 create_cluster_and_add_emr_steps 2021-03-22T02:00:00+00:00 EmrCreateJobFlowOperator 2021-03-22T03:00:33.102953+00:00 2021-03-22T03:00:34.995774+00:00 0:00:01.892821 10423 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 4 default 2021-03-22T03:00:30.724224+00:00 2 default_pool
success campaign-flow-job_v002 create_emr_steps 2021-03-22T02:00:00+00:00 PythonOperator 2021-03-22T03:00:17.358625+00:00 2021-03-22T03:00:20.250647+00:00 0:00:02.892022 10422 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 5 default 2021-03-22T03:00:14.724019+00:00 2 default_pool
success campaign-history-job_v002 check_cluster_status 2021-03-22T01:00:00+00:00 EmrJobFlowSensor 2021-03-22T02:10:57.585464+00:00 2021-03-22T02:19:00.076373+00:00 0:08:02.490909 10420 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-03-22T02:10:55.421520+00:00 2 default_pool
success campaign-history-job_v002 create_cluster_and_add_emr_steps 2021-03-22T01:00:00+00:00 EmrCreateJobFlowOperator 2021-03-22T02:10:41.575257+00:00 2021-03-22T02:10:43.385112+00:00 0:00:01.809855 10419 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 2 default 2021-03-22T02:10:39.270643+00:00 2 default_pool
success campaign-history-job_v002 create_emr_steps 2021-03-22T01:00:00+00:00 PythonOperator 2021-03-22T02:10:25.670553+00:00 2021-03-22T02:10:28.369406+00:00 0:00:02.698853 10418 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-03-22T02:10:23.256583+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_booking-processing-job_v002 2021-03-22T01:00:00+00:00 TriggerDagRunOperator 2021-03-22T02:10:13.858346+00:00 2021-03-22T02:10:14.384315+00:00 0:00:00.525969 10417 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-03-22T02:10:11.223354+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_campaign-history-job_v002 2021-03-22T01:00:00+00:00 TriggerDagRunOperator 2021-03-22T02:10:13.593654+00:00 2021-03-22T02:10:14.016225+00:00 0:00:00.422571 10416 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-03-22T02:10:11.223311+00:00 2 default_pool
success campaign-flow-job_v002 check_cluster_status 2021-03-22T01:00:00+00:00 EmrJobFlowSensor 2021-03-22T02:00:52.510952+00:00 2021-03-22T02:09:55.145202+00:00 0:09:02.634250 10415 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-03-22T02:00:50.159072+00:00 2 default_pool
success campaign-flow-job_v002 create_cluster_and_add_emr_steps 2021-03-22T01:00:00+00:00 EmrCreateJobFlowOperator 2021-03-22T02:00:34.461289+00:00 2021-03-22T02:00:36.162819+00:00 0:00:01.701530 10414 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 4 default 2021-03-22T02:00:32.134582+00:00 2 default_pool
success campaign-flow-job_v002 create_emr_steps 2021-03-22T01:00:00+00:00 PythonOperator 2021-03-22T02:00:18.813553+00:00 2021-03-22T02:00:21.699055+00:00 0:00:02.885502 10413 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 5 default 2021-03-22T02:00:16.060516+00:00 2 default_pool
success campaign-history-job_v002 check_cluster_status 2021-03-22T00:00:00+00:00 EmrJobFlowSensor 2021-03-22T01:11:53.692242+00:00 2021-03-22T01:20:56.417591+00:00 0:09:02.725349 10411 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-03-22T01:11:51.526614+00:00 2 default_pool
success campaign-history-job_v002 create_cluster_and_add_emr_steps 2021-03-22T00:00:00+00:00 EmrCreateJobFlowOperator 2021-03-22T01:11:37.677236+00:00 2021-03-22T01:11:39.517348+00:00 0:00:01.840112 10410 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 2 default 2021-03-22T01:11:35.402429+00:00 2 default_pool
success campaign-history-job_v002 create_emr_steps 2021-03-22T00:00:00+00:00 PythonOperator 2021-03-22T01:11:21.667300+00:00 2021-03-22T01:11:24.578523+00:00 0:00:02.911223 10409 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-03-22T01:11:19.386746+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_campaign-history-job_v002 2021-03-22T00:00:00+00:00 TriggerDagRunOperator 2021-03-22T01:11:08.009342+00:00 2021-03-22T01:11:08.676979+00:00 0:00:00.667637 10408 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-03-22T01:11:05.425243+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_booking-processing-job_v002 2021-03-22T00:00:00+00:00 TriggerDagRunOperator 2021-03-22T01:11:07.994892+00:00 2021-03-22T01:11:08.429368+00:00 0:00:00.434476 10407 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-03-22T01:11:05.425279+00:00 2 default_pool
success campaign-flow-job_v002 check_cluster_status 2021-03-22T00:00:00+00:00 EmrJobFlowSensor 2021-03-22T01:00:54.591968+00:00 2021-03-22T01:10:57.437315+00:00 0:10:02.845347 10406 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-03-22T01:00:52.155715+00:00 2 default_pool
success campaign-flow-job_v002 create_cluster_and_add_emr_steps 2021-03-22T00:00:00+00:00 EmrCreateJobFlowOperator 2021-03-22T01:00:30.416670+00:00 2021-03-22T01:00:32.283991+00:00 0:00:01.867321 10405 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 4 default 2021-03-22T01:00:28.112686+00:00 2 default_pool
success campaign-flow-job_v002 create_emr_steps 2021-03-22T00:00:00+00:00 PythonOperator 2021-03-22T01:00:12.701874+00:00 2021-03-22T01:00:15.603819+00:00 0:00:02.901945 10404 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 5 default 2021-03-22T01:00:10.098243+00:00 2 default_pool
success campaign-history-job_v002 check_cluster_status 2021-03-21T23:00:00+00:00 EmrJobFlowSensor 2021-03-22T00:09:58.673187+00:00 2021-03-22T00:18:01.265461+00:00 0:08:02.592274 10402 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-03-22T00:09:56.268619+00:00 2 default_pool
success campaign-history-job_v002 create_cluster_and_add_emr_steps 2021-03-21T23:00:00+00:00 EmrCreateJobFlowOperator 2021-03-22T00:09:42.431876+00:00 2021-03-22T00:09:44.140773+00:00 0:00:01.708897 10401 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 2 default 2021-03-22T00:09:40.251568+00:00 2 default_pool
success campaign-history-job_v002 create_emr_steps 2021-03-21T23:00:00+00:00 PythonOperator 2021-03-22T00:09:26.446273+00:00 2021-03-22T00:09:29.200853+00:00 0:00:02.754580 10400 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-03-22T00:09:24.237946+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_booking-processing-job_v002 2021-03-21T23:00:00+00:00 TriggerDagRunOperator 2021-03-22T00:09:18.881538+00:00 2021-03-22T00:09:19.439166+00:00 0:00:00.557628 10399 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-03-22T00:09:16.237253+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_campaign-history-job_v002 2021-03-21T23:00:00+00:00 TriggerDagRunOperator 2021-03-22T00:09:18.615555+00:00 2021-03-22T00:09:19.038137+00:00 0:00:00.422582 10398 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-03-22T00:09:16.237211+00:00 2 default_pool
success campaign-flow-job_v002 check_cluster_status 2021-03-21T23:00:00+00:00 EmrJobFlowSensor 2021-03-22T00:00:59.776223+00:00 2021-03-22T00:09:02.565790+00:00 0:08:02.789567 10397 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-03-22T00:00:57.377615+00:00 2 default_pool
success campaign-flow-job_v002 create_cluster_and_add_emr_steps 2021-03-21T23:00:00+00:00 EmrCreateJobFlowOperator 2021-03-22T00:00:31.586583+00:00 2021-03-22T00:00:33.281976+00:00 0:00:01.695393 10396 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 4 default 2021-03-22T00:00:29.417787+00:00 2 default_pool
success campaign-flow-job_v002 create_emr_steps 2021-03-21T23:00:00+00:00 PythonOperator 2021-03-22T00:00:15.630735+00:00 2021-03-22T00:00:18.365557+00:00 0:00:02.734822 10395 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 5 default 2021-03-22T00:00:13.303517+00:00 2 default_pool
success campaign-history-job_v002 check_cluster_status 2021-03-21T22:00:00+00:00 EmrJobFlowSensor 2021-03-21T23:11:33.267227+00:00 2021-03-21T23:20:36.029104+00:00 0:09:02.761877 10393 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-03-21T23:11:30.954689+00:00 2 default_pool
success campaign-history-job_v002 create_cluster_and_add_emr_steps 2021-03-21T22:00:00+00:00 EmrCreateJobFlowOperator 2021-03-21T23:11:03.208259+00:00 2021-03-21T23:11:04.934639+00:00 0:00:01.726380 10392 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 2 default 2021-03-21T23:11:00.929529+00:00 2 default_pool
success campaign-history-job_v002 create_emr_steps 2021-03-21T22:00:00+00:00 PythonOperator 2021-03-21T23:10:39.282916+00:00 2021-03-21T23:10:42.184330+00:00 0:00:02.901414 10391 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-03-21T23:10:36.888322+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_campaign-history-job_v002 2021-03-21T22:00:00+00:00 TriggerDagRunOperator 2021-03-21T23:10:21.232081+00:00 2021-03-21T23:10:21.776001+00:00 0:00:00.543920 10390 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-03-21T23:10:18.860239+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_booking-processing-job_v002 2021-03-21T22:00:00+00:00 TriggerDagRunOperator 2021-03-21T23:10:21.159063+00:00 2021-03-21T23:10:21.575180+00:00 0:00:00.416117 10389 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-03-21T23:10:18.860286+00:00 2 default_pool
success campaign-flow-job_v002 check_cluster_status 2021-03-21T22:00:00+00:00 EmrJobFlowSensor 2021-03-21T23:01:02.017225+00:00 2021-03-21T23:10:04.745804+00:00 0:09:02.728579 10388 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-03-21T23:00:59.814462+00:00 2 default_pool
success campaign-flow-job_v002 create_cluster_and_add_emr_steps 2021-03-21T22:00:00+00:00 EmrCreateJobFlowOperator 2021-03-21T23:00:40.021452+00:00 2021-03-21T23:00:41.707738+00:00 0:00:01.686286 10387 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 4 default 2021-03-21T23:00:37.794258+00:00 2 default_pool
success campaign-flow-job_v002 create_emr_steps 2021-03-21T22:00:00+00:00 PythonOperator 2021-03-21T23:00:18.076724+00:00 2021-03-21T23:00:20.768070+00:00 0:00:02.691346 10386 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 5 default 2021-03-21T23:00:15.777523+00:00 2 default_pool
success campaign-history-job_v002 check_cluster_status 2021-03-21T21:00:00+00:00 EmrJobFlowSensor 2021-03-21T22:11:38.809831+00:00 2021-03-21T22:21:41.439056+00:00 0:10:02.629225 10384 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-03-21T22:11:36.360940+00:00 2 default_pool
success campaign-history-job_v002 create_cluster_and_add_emr_steps 2021-03-21T21:00:00+00:00 EmrCreateJobFlowOperator 2021-03-21T22:11:22.757959+00:00 2021-03-21T22:11:24.645430+00:00 0:00:01.887471 10383 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 2 default 2021-03-21T22:11:20.300205+00:00 2 default_pool
success campaign-history-job_v002 create_emr_steps 2021-03-21T21:00:00+00:00 PythonOperator 2021-03-21T22:11:06.398310+00:00 2021-03-21T22:11:09.182267+00:00 0:00:02.783957 10382 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-03-21T22:11:04.264916+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_campaign-history-job_v002 2021-03-21T21:00:00+00:00 TriggerDagRunOperator 2021-03-21T22:10:14.716500+00:00 2021-03-21T22:10:15.268492+00:00 0:00:00.551992 10381 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-03-21T22:10:12.197230+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_booking-processing-job_v002 2021-03-21T21:00:00+00:00 TriggerDagRunOperator 2021-03-21T22:10:14.632840+00:00 2021-03-21T22:10:15.083596+00:00 0:00:00.450756 10380 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-03-21T22:10:12.197262+00:00 2 default_pool
success campaign-flow-job_v002 check_cluster_status 2021-03-21T21:00:00+00:00 EmrJobFlowSensor 2021-03-21T22:00:55.630564+00:00 2021-03-21T22:09:58.279922+00:00 0:09:02.649358 10379 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-03-21T22:00:53.161999+00:00 2 default_pool
success campaign-flow-job_v002 create_cluster_and_add_emr_steps 2021-03-21T21:00:00+00:00 EmrCreateJobFlowOperator 2021-03-21T22:00:25.457803+00:00 2021-03-21T22:00:27.160162+00:00 0:00:01.702359 10378 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 4 default 2021-03-21T22:00:23.090309+00:00 2 default_pool
success campaign-flow-job_v002 create_emr_steps 2021-03-21T21:00:00+00:00 PythonOperator 2021-03-21T22:00:03.755822+00:00 2021-03-21T22:00:06.600945+00:00 0:00:02.845123 10377 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 5 default 2021-03-21T22:00:01.125042+00:00 2 default_pool
success campaign-history-job_v002 check_cluster_status 2021-03-21T20:00:00+00:00 EmrJobFlowSensor 2021-03-21T21:11:52.001658+00:00 2021-03-21T21:20:54.654108+00:00 0:09:02.652450 10375 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-03-21T21:11:49.795045+00:00 2 default_pool
success campaign-history-job_v002 create_cluster_and_add_emr_steps 2021-03-21T20:00:00+00:00 EmrCreateJobFlowOperator 2021-03-21T21:11:31.985039+00:00 2021-03-21T21:11:33.650326+00:00 0:00:01.665287 10374 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 2 default 2021-03-21T21:11:29.829208+00:00 2 default_pool
success campaign-history-job_v002 create_emr_steps 2021-03-21T20:00:00+00:00 PythonOperator 2021-03-21T21:11:16.163314+00:00 2021-03-21T21:11:18.918793+00:00 0:00:02.755479 10373 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-03-21T21:11:13.763894+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_booking-processing-job_v002 2021-03-21T20:00:00+00:00 TriggerDagRunOperator 2021-03-21T21:11:08.491940+00:00 2021-03-21T21:11:09.034354+00:00 0:00:00.542414 10372 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-03-21T21:11:05.817935+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_campaign-history-job_v002 2021-03-21T20:00:00+00:00 TriggerDagRunOperator 2021-03-21T21:11:08.216758+00:00 2021-03-21T21:11:08.642514+00:00 0:00:00.425756 10371 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-03-21T21:11:05.817900+00:00 2 default_pool
success campaign-flow-job_v002 check_cluster_status 2021-03-21T20:00:00+00:00 EmrJobFlowSensor 2021-03-21T21:00:51.098991+00:00 2021-03-21T21:10:53.780892+00:00 0:10:02.681901 10370 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-03-21T21:00:48.650678+00:00 2 default_pool
success campaign-flow-job_v002 create_cluster_and_add_emr_steps 2021-03-21T20:00:00+00:00 EmrCreateJobFlowOperator 2021-03-21T21:00:32.799299+00:00 2021-03-21T21:00:34.517956+00:00 0:00:01.718657 10369 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 4 default 2021-03-21T21:00:30.584909+00:00 2 default_pool
success campaign-flow-job_v002 create_emr_steps 2021-03-21T20:00:00+00:00 PythonOperator 2021-03-21T21:00:15.566626+00:00 2021-03-21T21:00:18.535971+00:00 0:00:02.969345 10368 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 5 default 2021-03-21T21:00:12.636972+00:00 2 default_pool
success campaign-history-job_v002 check_cluster_status 2021-03-21T19:00:00+00:00 EmrJobFlowSensor 2021-03-21T20:12:03.697134+00:00 2021-03-21T20:30:07.325076+00:00 0:18:03.627942 10366 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-03-21T20:12:01.507128+00:00 2 default_pool
success campaign-history-job_v002 create_cluster_and_add_emr_steps 2021-03-21T19:00:00+00:00 EmrCreateJobFlowOperator 2021-03-21T20:11:47.801956+00:00 2021-03-21T20:11:49.649150+00:00 0:00:01.847194 10365 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 2 default 2021-03-21T20:11:45.485219+00:00 2 default_pool
success campaign-history-job_v002 create_emr_steps 2021-03-21T19:00:00+00:00 PythonOperator 2021-03-21T20:11:29.885693+00:00 2021-03-21T20:11:32.670746+00:00 0:00:02.785053 10364 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-03-21T20:11:27.534171+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_campaign-history-job_v002 2021-03-21T19:00:00+00:00 TriggerDagRunOperator 2021-03-21T20:11:12.024103+00:00 2021-03-21T20:11:12.608188+00:00 0:00:00.584085 10363 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-03-21T20:11:09.524739+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_booking-processing-job_v002 2021-03-21T19:00:00+00:00 TriggerDagRunOperator 2021-03-21T20:11:11.900699+00:00 2021-03-21T20:11:12.280909+00:00 0:00:00.380210 10362 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-03-21T20:11:09.524786+00:00 2 default_pool
success campaign-flow-job_v002 check_cluster_status 2021-03-21T19:00:00+00:00 EmrJobFlowSensor 2021-03-21T20:00:54.392392+00:00 2021-03-21T20:10:57.313620+00:00 0:10:02.921228 10361 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-03-21T20:00:51.863126+00:00 2 default_pool
success campaign-flow-job_v002 create_cluster_and_add_emr_steps 2021-03-21T19:00:00+00:00 EmrCreateJobFlowOperator 2021-03-21T20:00:36.010966+00:00 2021-03-21T20:00:37.679310+00:00 0:00:01.668344 10360 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 4 default 2021-03-21T20:00:33.809998+00:00 2 default_pool
success campaign-flow-job_v002 create_emr_steps 2021-03-21T19:00:00+00:00 PythonOperator 2021-03-21T20:00:06.266310+00:00 2021-03-21T20:00:09.143104+00:00 0:00:02.876794 10359 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 5 default 2021-03-21T20:00:03.785565+00:00 2 default_pool
success campaign-history-job_v002 check_cluster_status 2021-03-21T18:00:00+00:00 EmrJobFlowSensor 2021-03-21T19:11:20.706293+00:00 2021-03-21T19:21:23.392458+00:00 0:10:02.686165 10357 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-03-21T19:11:18.455285+00:00 2 default_pool
success campaign-history-job_v002 create_cluster_and_add_emr_steps 2021-03-21T18:00:00+00:00 EmrCreateJobFlowOperator 2021-03-21T19:10:58.560392+00:00 2021-03-21T19:11:00.288228+00:00 0:00:01.727836 10356 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 2 default 2021-03-21T19:10:56.378642+00:00 2 default_pool
success campaign-history-job_v002 create_emr_steps 2021-03-21T18:00:00+00:00 PythonOperator 2021-03-21T19:10:32.589569+00:00 2021-03-21T19:10:35.271985+00:00 0:00:02.682416 10355 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-03-21T19:10:30.355505+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_campaign-history-job_v002 2021-03-21T18:00:00+00:00 TriggerDagRunOperator 2021-03-21T19:10:14.806912+00:00 2021-03-21T19:10:15.321429+00:00 0:00:00.514517 10354 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-03-21T19:10:12.333964+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_booking-processing-job_v002 2021-03-21T18:00:00+00:00 TriggerDagRunOperator 2021-03-21T19:10:14.678888+00:00 2021-03-21T19:10:15.103079+00:00 0:00:00.424191 10353 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-03-21T19:10:12.333993+00:00 2 default_pool
success campaign-flow-job_v002 check_cluster_status 2021-03-21T18:00:00+00:00 EmrJobFlowSensor 2021-03-21T19:00:53.400313+00:00 2021-03-21T19:09:56.034727+00:00 0:09:02.634414 10352 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-03-21T19:00:51.130533+00:00 2 default_pool
success campaign-flow-job_v002 create_cluster_and_add_emr_steps 2021-03-21T18:00:00+00:00 EmrCreateJobFlowOperator 2021-03-21T19:00:35.368209+00:00 2021-03-21T19:00:37.063169+00:00 0:00:01.694960 10351 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 4 default 2021-03-21T19:00:33.059213+00:00 2 default_pool
success campaign-flow-job_v002 create_emr_steps 2021-03-21T18:00:00+00:00 PythonOperator 2021-03-21T19:00:19.594289+00:00 2021-03-21T19:00:22.447039+00:00 0:00:02.852750 10350 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 5 default 2021-03-21T19:00:16.964395+00:00 2 default_pool
success campaign-history-job_v002 check_cluster_status 2021-03-21T17:00:00+00:00 EmrJobFlowSensor 2021-03-21T18:11:04.542880+00:00 2021-03-21T18:20:07.064322+00:00 0:09:02.521442 10348 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-03-21T18:11:02.164132+00:00 2 default_pool
success campaign-history-job_v002 create_cluster_and_add_emr_steps 2021-03-21T17:00:00+00:00 EmrCreateJobFlowOperator 2021-03-21T18:10:48.523552+00:00 2021-03-21T18:10:50.416500+00:00 0:00:01.892948 10347 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 2 default 2021-03-21T18:10:46.115259+00:00 2 default_pool
success campaign-history-job_v002 create_emr_steps 2021-03-21T17:00:00+00:00 PythonOperator 2021-03-21T18:10:33.072861+00:00 2021-03-21T18:10:35.769492+00:00 0:00:02.696631 10346 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-03-21T18:10:30.152575+00:00 2 default_pool