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-history-job_v002 create_emr_steps 2021-04-02T00:00:00+00:00 PythonOperator 2021-04-02T01:10:16.175018+00:00 2021-04-02T01:10:18.917455+00:00 0:00:02.742437 12591 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-04-02T01:10:13.589224+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_campaign-history-job_v002 2021-04-02T00:00:00+00:00 TriggerDagRunOperator 2021-04-02T01:10:08.083768+00:00 2021-04-02T01:10:08.508176+00:00 0:00:00.424408 12590 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-02T01:10:05.525327+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_booking-processing-job_v002 2021-04-02T00:00:00+00:00 TriggerDagRunOperator 2021-04-02T01:10:08.085985+00:00 2021-04-02T01:10:08.701554+00:00 0:00:00.615569 12589 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-02T01:10:05.525359+00:00 2 default_pool
success vc-asset-import_v002 check_cluster_status 2021-04-02T00:05:00+00:00 EmrJobFlowSensor 2021-04-02T01:05:55.623786+00:00 2021-04-02T01:14:58.381495+00:00 0:09:02.757709 12588 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-02T01:05:53.149483+00:00 2 default_pool
success vc-asset-import_v002 create_cluster_and_add_emr_steps 2021-04-02T00:05:00+00:00 EmrCreateJobFlowOperator 2021-04-02T01:05:33.380944+00:00 2021-04-02T01:05:35.091053+00:00 0:00:01.710109 12587 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 2 default 2021-04-02T01:05:31.155700+00:00 2 default_pool
success vc-asset-import_v002 create_emr_steps 2021-04-02T00:05:00+00:00 PythonOperator 2021-04-02T01:05:11.155588+00:00 2021-04-02T01:05:13.852411+00:00 0:00:02.696823 12586 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-04-02T01:05:08.982645+00:00 2 default_pool
success campaign-flow-job_v002 check_cluster_status 2021-04-02T00:00:00+00:00 EmrJobFlowSensor 2021-04-02T01:00:52.746840+00:00 2021-04-02T01:09:55.332775+00:00 0:09:02.585935 12585 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-04-02T01:00:50.570730+00:00 2 default_pool
success campaign-flow-job_v002 create_cluster_and_add_emr_steps 2021-04-02T00:00:00+00:00 EmrCreateJobFlowOperator 2021-04-02T01:00:31.139286+00:00 2021-04-02T01:00:32.948713+00:00 0:00:01.809427 12584 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 4 default 2021-04-02T01:00:28.672616+00:00 2 default_pool
success campaign-flow-job_v002 create_emr_steps 2021-04-02T00:00:00+00:00 PythonOperator 2021-04-02T01:00:09.342706+00:00 2021-04-02T01:00:12.193352+00:00 0:00:02.850646 12583 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 5 default 2021-04-02T01:00:06.564940+00:00 2 default_pool
success campaign-history-job_v002 check_cluster_status 2021-04-01T23:00:00+00:00 EmrJobFlowSensor 2021-04-02T00:12:23.184879+00:00 2021-04-02T00:20:25.891838+00:00 0:08:02.706959 12581 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-02T00:12:20.932167+00:00 2 default_pool
success booking-processing-job_v002 check_cluster_status 2021-04-01T23:00:00+00:00 EmrJobFlowSensor 2021-04-02T00:12:13.239511+00:00 2021-04-02T00:22:16.178973+00:00 0:10:02.939462 12580 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-02T00:12:10.922028+00:00 2 default_pool
success campaign-history-job_v002 create_cluster_and_add_emr_steps 2021-04-01T23:00:00+00:00 EmrCreateJobFlowOperator 2021-04-02T00:12:01.357834+00:00 2021-04-02T00:12:03.244784+00:00 0:00:01.886950 12579 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 2 default 2021-04-02T00:11:58.960337+00:00 2 default_pool
success booking-processing-job_v002 create_cluster_and_add_emr_steps 2021-04-01T23:00:00+00:00 EmrCreateJobFlowOperator 2021-04-02T00:11:51.305836+00:00 2021-04-02T00:11:53.029146+00:00 0:00:01.723310 12578 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 2 default 2021-04-02T00:11:48.901679+00:00 2 default_pool
success campaign-history-job_v002 create_emr_steps 2021-04-01T23:00:00+00:00 PythonOperator 2021-04-02T00:11:39.190909+00:00 2021-04-02T00:11:41.916264+00:00 0:00:02.725355 12577 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-04-02T00:11:36.900876+00:00 2 default_pool
success booking-processing-job_v002 create_emr_steps 2021-04-01T23:00:00+00:00 PythonOperator 2021-04-02T00:11:17.061567+00:00 2021-04-02T00:11:20.073255+00:00 0:00:03.011688 12576 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-04-02T00:11:14.804175+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_booking-processing-job_v002 2021-04-01T23:00:00+00:00 TriggerDagRunOperator 2021-04-02T00:11:09.535667+00:00 2021-04-02T00:11:10.193411+00:00 0:00:00.657744 12575 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-02T00:11:06.796048+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_campaign-history-job_v002 2021-04-01T23:00:00+00:00 TriggerDagRunOperator 2021-04-02T00:11:09.360993+00:00 2021-04-02T00:11:09.769387+00:00 0:00:00.408394 12574 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-02T00:11:06.796016+00:00 2 default_pool
success vc-asset-import_v002 check_cluster_status 2021-04-01T23:05:00+00:00 EmrJobFlowSensor 2021-04-02T00:06:00.886360+00:00 2021-04-02T00:15:03.410912+00:00 0:09:02.524552 12573 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-02T00:05:58.463856+00:00 2 default_pool
success vc-asset-import_v002 create_cluster_and_add_emr_steps 2021-04-01T23:05:00+00:00 EmrCreateJobFlowOperator 2021-04-02T00:05:38.461004+00:00 2021-04-02T00:05:40.164201+00:00 0:00:01.703197 12572 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 2 default 2021-04-02T00:05:36.223344+00:00 2 default_pool
success vc-asset-import_v002 create_emr_steps 2021-04-01T23:05:00+00:00 PythonOperator 2021-04-02T00:05:16.563410+00:00 2021-04-02T00:05:19.248613+00:00 0:00:02.685203 12571 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-04-02T00:05:14.266849+00:00 2 default_pool
success campaign-flow-job_v002 check_cluster_status 2021-04-01T23:00:00+00:00 EmrJobFlowSensor 2021-04-02T00:00:56.095907+00:00 2021-04-02T00:10:59.095372+00:00 0:10:02.999465 12570 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-04-02T00:00:53.804387+00:00 2 default_pool
success campaign-flow-job_v002 create_cluster_and_add_emr_steps 2021-04-01T23:00:00+00:00 EmrCreateJobFlowOperator 2021-04-02T00:00:34.367907+00:00 2021-04-02T00:00:36.181938+00:00 0:00:01.814031 12569 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 4 default 2021-04-02T00:00:31.851216+00:00 2 default_pool
success campaign-flow-job_v002 create_emr_steps 2021-04-01T23:00:00+00:00 PythonOperator 2021-04-02T00:00:12.395948+00:00 2021-04-02T00:00:15.112676+00:00 0:00:02.716728 12568 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 5 default 2021-04-02T00:00:09.766765+00:00 2 default_pool
success campaign-history-job_v002 check_cluster_status 2021-04-01T22:00:00+00:00 EmrJobFlowSensor 2021-04-01T23:12:09.401943+00:00 2021-04-01T23:21:12.046646+00:00 0:09:02.644703 12566 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-01T23:12:07.254924+00:00 2 default_pool
success booking-processing-job_v002 check_cluster_status 2021-04-01T22:00:00+00:00 EmrJobFlowSensor 2021-04-01T23:12:01.535566+00:00 2021-04-01T23:22:04.326308+00:00 0:10:02.790742 12565 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-01T23:11:59.260583+00:00 2 default_pool
success campaign-history-job_v002 create_cluster_and_add_emr_steps 2021-04-01T22:00:00+00:00 EmrCreateJobFlowOperator 2021-04-01T23:11:47.332363+00:00 2021-04-01T23:11:49.026426+00:00 0:00:01.694063 12564 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 2 default 2021-04-01T23:11:45.187238+00:00 2 default_pool
success booking-processing-job_v002 create_cluster_and_add_emr_steps 2021-04-01T22:00:00+00:00 EmrCreateJobFlowOperator 2021-04-01T23:11:39.483630+00:00 2021-04-01T23:11:41.289630+00:00 0:00:01.806000 12563 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 2 default 2021-04-01T23:11:37.154766+00:00 2 default_pool
success campaign-history-job_v002 create_emr_steps 2021-04-01T22:00:00+00:00 PythonOperator 2021-04-01T23:11:27.320058+00:00 2021-04-01T23:11:30.093955+00:00 0:00:02.773897 12562 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-04-01T23:11:25.139578+00:00 2 default_pool
success booking-processing-job_v002 create_emr_steps 2021-04-01T22:00:00+00:00 PythonOperator 2021-04-01T23:11:17.657806+00:00 2021-04-01T23:11:20.830873+00:00 0:00:03.173067 12561 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-04-01T23:11:15.166633+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_booking-processing-job_v002 2021-04-01T22:00:00+00:00 TriggerDagRunOperator 2021-04-01T23:11:09.745192+00:00 2021-04-01T23:11:10.168810+00:00 0:00:00.423618 12560 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-01T23:11:07.124408+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_campaign-history-job_v002 2021-04-01T22:00:00+00:00 TriggerDagRunOperator 2021-04-01T23:11:09.597860+00:00 2021-04-01T23:11:10.150757+00:00 0:00:00.552897 12559 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-01T23:11:07.124380+00:00 2 default_pool
success vc-asset-import_v002 check_cluster_status 2021-04-01T22:05:00+00:00 EmrJobFlowSensor 2021-04-01T23:06:01.197971+00:00 2021-04-01T23:14:03.702838+00:00 0:08:02.504867 12558 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-01T23:05:58.766294+00:00 2 default_pool
success vc-asset-import_v002 create_cluster_and_add_emr_steps 2021-04-01T22:05:00+00:00 EmrCreateJobFlowOperator 2021-04-01T23:05:38.889129+00:00 2021-04-01T23:05:40.622907+00:00 0:00:01.733778 12557 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 2 default 2021-04-01T23:05:36.595628+00:00 2 default_pool
success vc-asset-import_v002 create_emr_steps 2021-04-01T22:05:00+00:00 PythonOperator 2021-04-01T23:05:18.734909+00:00 2021-04-01T23:05:21.447936+00:00 0:00:02.713027 12556 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-04-01T23:05:16.539122+00:00 2 default_pool
success campaign-flow-job_v002 check_cluster_status 2021-04-01T22:00:00+00:00 EmrJobFlowSensor 2021-04-01T23:00:56.104182+00:00 2021-04-01T23:10:58.904699+00:00 0:10:02.800517 12555 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-04-01T23:00:53.976251+00:00 2 default_pool
success campaign-flow-job_v002 create_cluster_and_add_emr_steps 2021-04-01T22:00:00+00:00 EmrCreateJobFlowOperator 2021-04-01T23:00:36.115034+00:00 2021-04-01T23:00:37.840330+00:00 0:00:01.725296 12554 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 4 default 2021-04-01T23:00:33.950386+00:00 2 default_pool
success campaign-flow-job_v002 create_emr_steps 2021-04-01T22:00:00+00:00 PythonOperator 2021-04-01T23:00:12.314302+00:00 2021-04-01T23:00:15.066986+00:00 0:00:02.752684 12553 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 5 default 2021-04-01T23:00:09.887844+00:00 2 default_pool
success booking-processing-job_v002 check_cluster_status 2021-04-01T21:00:00+00:00 EmrJobFlowSensor 2021-04-01T22:11:19.620808+00:00 2021-04-01T22:21:22.411410+00:00 0:10:02.790602 12551 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-01T22:11:17.362075+00:00 2 default_pool
success campaign-history-job_v002 check_cluster_status 2021-04-01T21:00:00+00:00 EmrJobFlowSensor 2021-04-01T22:11:11.531147+00:00 2021-04-01T22:21:14.352470+00:00 0:10:02.821323 12550 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-01T22:11:09.300661+00:00 2 default_pool
success booking-processing-job_v002 create_cluster_and_add_emr_steps 2021-04-01T21:00:00+00:00 EmrCreateJobFlowOperator 2021-04-01T22:10:59.694266+00:00 2021-04-01T22:11:01.406071+00:00 0:00:01.711805 12549 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 2 default 2021-04-01T22:10:57.291001+00:00 2 default_pool
success campaign-history-job_v002 create_cluster_and_add_emr_steps 2021-04-01T21:00:00+00:00 EmrCreateJobFlowOperator 2021-04-01T22:10:49.761190+00:00 2021-04-01T22:10:51.424746+00:00 0:00:01.663556 12548 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 2 default 2021-04-01T22:10:47.231036+00:00 2 default_pool
success booking-processing-job_v002 create_emr_steps 2021-04-01T21:00:00+00:00 PythonOperator 2021-04-01T22:10:37.519023+00:00 2021-04-01T22:10:40.537906+00:00 0:00:03.018883 12547 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-04-01T22:10:35.219059+00:00 2 default_pool
success campaign-history-job_v002 create_emr_steps 2021-04-01T21:00:00+00:00 PythonOperator 2021-04-01T22:10:29.537882+00:00 2021-04-01T22:10:32.237754+00:00 0:00:02.699872 12546 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-04-01T22:10:27.212010+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_booking-processing-job_v002 2021-04-01T21:00:00+00:00 TriggerDagRunOperator 2021-04-01T22:10:21.562441+00:00 2021-04-01T22:10:22.093544+00:00 0:00:00.531103 12545 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-01T22:10:19.206279+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_campaign-history-job_v002 2021-04-01T21:00:00+00:00 TriggerDagRunOperator 2021-04-01T22:10:21.395726+00:00 2021-04-01T22:10:21.833680+00:00 0:00:00.437954 12544 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-01T22:10:19.206247+00:00 2 default_pool
success vc-asset-import_v002 check_cluster_status 2021-04-01T21:05:00+00:00 EmrJobFlowSensor 2021-04-01T22:05:54.979395+00:00 2021-04-01T22:14:57.653068+00:00 0:09:02.673673 12543 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-01T22:05:52.702943+00:00 2 default_pool
success vc-asset-import_v002 create_cluster_and_add_emr_steps 2021-04-01T21:05:00+00:00 EmrCreateJobFlowOperator 2021-04-01T22:05:35.144464+00:00 2021-04-01T22:05:36.884257+00:00 0:00:01.739793 12542 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 2 default 2021-04-01T22:05:32.685543+00:00 2 default_pool
success vc-asset-import_v002 create_emr_steps 2021-04-01T21:05:00+00:00 PythonOperator 2021-04-01T22:05:12.799513+00:00 2021-04-01T22:05:15.515050+00:00 0:00:02.715537 12541 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-04-01T22:05:10.638139+00:00 2 default_pool
success campaign-flow-job_v002 check_cluster_status 2021-04-01T21:00:00+00:00 EmrJobFlowSensor 2021-04-01T22:01:06.450178+00:00 2021-04-01T22:10:09.302108+00:00 0:09:02.851930 12540 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-04-01T22:01:04.285240+00:00 2 default_pool
success campaign-flow-job_v002 create_cluster_and_add_emr_steps 2021-04-01T21:00:00+00:00 EmrCreateJobFlowOperator 2021-04-01T22:00:44.648337+00:00 2021-04-01T22:00:46.541508+00:00 0:00:01.893171 12539 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 4 default 2021-04-01T22:00:42.204622+00:00 2 default_pool
success campaign-flow-job_v002 create_emr_steps 2021-04-01T21:00:00+00:00 PythonOperator 2021-04-01T22:00:22.905132+00:00 2021-04-01T22:00:25.644472+00:00 0:00:02.739340 12538 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 5 default 2021-04-01T22:00:20.243962+00:00 2 default_pool
success campaign-history-job_v002 check_cluster_status 2021-04-01T20:00:00+00:00 EmrJobFlowSensor 2021-04-01T21:12:43.199596+00:00 2021-04-01T21:21:45.926072+00:00 0:09:02.726476 12536 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-01T21:12:40.818116+00:00 2 default_pool
success booking-processing-job_v002 check_cluster_status 2021-04-01T20:00:00+00:00 EmrJobFlowSensor 2021-04-01T21:12:41.462527+00:00 2021-04-01T21:21:44.095271+00:00 0:09:02.632744 12535 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-01T21:12:38.846276+00:00 2 default_pool
success campaign-history-job_v002 create_cluster_and_add_emr_steps 2021-04-01T20:00:00+00:00 EmrCreateJobFlowOperator 2021-04-01T21:12:23.140403+00:00 2021-04-01T21:12:24.991693+00:00 0:00:01.851290 12534 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 2 default 2021-04-01T21:12:20.866436+00:00 2 default_pool
success booking-processing-job_v002 create_cluster_and_add_emr_steps 2021-04-01T20:00:00+00:00 EmrCreateJobFlowOperator 2021-04-01T21:12:21.298796+00:00 2021-04-01T21:12:23.173516+00:00 0:00:01.874720 12533 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 2 default 2021-04-01T21:12:18.867546+00:00 2 default_pool
success campaign-history-job_v002 create_emr_steps 2021-04-01T20:00:00+00:00 PythonOperator 2021-04-01T21:12:01.564317+00:00 2021-04-01T21:12:04.379685+00:00 0:00:02.815368 12532 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-04-01T21:11:58.863378+00:00 2 default_pool
success booking-processing-job_v002 create_emr_steps 2021-04-01T20:00:00+00:00 PythonOperator 2021-04-01T21:11:58.934199+00:00 2021-04-01T21:12:02.080472+00:00 0:00:03.146273 12531 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-04-01T21:11:56.735096+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_campaign-history-job_v002 2021-04-01T20:00:00+00:00 TriggerDagRunOperator 2021-04-01T21:11:43.167708+00:00 2021-04-01T21:11:43.709998+00:00 0:00:00.542290 12530 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-01T21:11:40.724855+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_booking-processing-job_v002 2021-04-01T20:00:00+00:00 TriggerDagRunOperator 2021-04-01T21:11:43.001335+00:00 2021-04-01T21:11:43.413336+00:00 0:00:00.412001 12529 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-01T21:11:40.724900+00:00 2 default_pool
success vc-asset-import_v002 check_cluster_status 2021-04-01T20:05:00+00:00 EmrJobFlowSensor 2021-04-01T21:05:54.422998+00:00 2021-04-01T21:14:57.019635+00:00 0:09:02.596637 12528 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-01T21:05:52.223844+00:00 2 default_pool
success vc-asset-import_v002 create_cluster_and_add_emr_steps 2021-04-01T20:05:00+00:00 EmrCreateJobFlowOperator 2021-04-01T21:05:32.548228+00:00 2021-04-01T21:05:34.243407+00:00 0:00:01.695179 12527 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 2 default 2021-04-01T21:05:30.246601+00:00 2 default_pool
success vc-asset-import_v002 create_emr_steps 2021-04-01T20:05:00+00:00 PythonOperator 2021-04-01T21:05:10.379516+00:00 2021-04-01T21:05:13.155537+00:00 0:00:02.776021 12526 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-04-01T21:05:08.184694+00:00 2 default_pool
success campaign-flow-job_v002 check_cluster_status 2021-04-01T20:00:00+00:00 EmrJobFlowSensor 2021-04-01T21:01:06.234057+00:00 2021-04-01T21:11:09.142288+00:00 0:10:02.908231 12525 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-04-01T21:01:03.867349+00:00 2 default_pool
success campaign-flow-job_v002 create_cluster_and_add_emr_steps 2021-04-01T20:00:00+00:00 EmrCreateJobFlowOperator 2021-04-01T21:00:45.997707+00:00 2021-04-01T21:00:47.692572+00:00 0:00:01.694865 12524 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 4 default 2021-04-01T21:00:43.795821+00:00 2 default_pool
success campaign-flow-job_v002 create_emr_steps 2021-04-01T20:00:00+00:00 PythonOperator 2021-04-01T21:00:24.285050+00:00 2021-04-01T21:00:27.055720+00:00 0:00:02.770670 12523 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 5 default 2021-04-01T21:00:21.740604+00:00 2 default_pool
success campaign-history-job_v002 check_cluster_status 2021-04-01T19:00:00+00:00 EmrJobFlowSensor 2021-04-01T20:12:06.029516+00:00 2021-04-01T20:20:08.588440+00:00 0:08:02.558924 12521 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-01T20:12:03.547619+00:00 2 default_pool
success booking-processing-job_v002 check_cluster_status 2021-04-01T19:00:00+00:00 EmrJobFlowSensor 2021-04-01T20:11:57.953525+00:00 2021-04-01T20:22:00.744226+00:00 0:10:02.790701 12520 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-01T20:11:55.550594+00:00 2 default_pool
success campaign-history-job_v002 create_cluster_and_add_emr_steps 2021-04-01T19:00:00+00:00 EmrCreateJobFlowOperator 2021-04-01T20:11:43.817545+00:00 2021-04-01T20:11:45.589529+00:00 0:00:01.771984 12519 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 2 default 2021-04-01T20:11:41.532047+00:00 2 default_pool
success booking-processing-job_v002 create_cluster_and_add_emr_steps 2021-04-01T19:00:00+00:00 EmrCreateJobFlowOperator 2021-04-01T20:11:36.001545+00:00 2021-04-01T20:11:37.710340+00:00 0:00:01.708795 12518 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 2 default 2021-04-01T20:11:33.524650+00:00 2 default_pool
success campaign-history-job_v002 create_emr_steps 2021-04-01T19:00:00+00:00 PythonOperator 2021-04-01T20:11:24.307607+00:00 2021-04-01T20:11:27.009011+00:00 0:00:02.701404 12517 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-04-01T20:11:21.511109+00:00 2 default_pool
success booking-processing-job_v002 create_emr_steps 2021-04-01T19:00:00+00:00 PythonOperator 2021-04-01T20:11:13.806375+00:00 2021-04-01T20:11:16.808855+00:00 0:00:03.002480 12516 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-04-01T20:11:11.505800+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_campaign-history-job_v002 2021-04-01T19:00:00+00:00 TriggerDagRunOperator 2021-04-01T20:11:08.066553+00:00 2021-04-01T20:11:08.712758+00:00 0:00:00.646205 12515 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-01T20:11:05.483693+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_booking-processing-job_v002 2021-04-01T19:00:00+00:00 TriggerDagRunOperator 2021-04-01T20:11:07.628398+00:00 2021-04-01T20:11:08.063001+00:00 0:00:00.434603 12514 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-01T20:11:05.483722+00:00 2 default_pool
success vc-asset-import_v002 check_cluster_status 2021-04-01T19:05:00+00:00 EmrJobFlowSensor 2021-04-01T20:05:47.053501+00:00 2021-04-01T20:14:49.737105+00:00 0:09:02.683604 12513 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-01T20:05:44.756509+00:00 2 default_pool
success vc-asset-import_v002 create_cluster_and_add_emr_steps 2021-04-01T19:05:00+00:00 EmrCreateJobFlowOperator 2021-04-01T20:05:26.852442+00:00 2021-04-01T20:05:28.647872+00:00 0:00:01.795430 12512 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 2 default 2021-04-01T20:05:24.630527+00:00 2 default_pool
success vc-asset-import_v002 create_emr_steps 2021-04-01T19:05:00+00:00 PythonOperator 2021-04-01T20:05:04.761699+00:00 2021-04-01T20:05:07.470341+00:00 0:00:02.708642 12511 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-04-01T20:05:02.612476+00:00 2 default_pool
success campaign-flow-job_v002 check_cluster_status 2021-04-01T19:00:00+00:00 EmrJobFlowSensor 2021-04-01T20:00:52.583263+00:00 2021-04-01T20:10:55.503177+00:00 0:10:02.919914 12510 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-04-01T20:00:50.242929+00:00 2 default_pool
success campaign-flow-job_v002 create_cluster_and_add_emr_steps 2021-04-01T19:00:00+00:00 EmrCreateJobFlowOperator 2021-04-01T20:00:30.739327+00:00 2021-04-01T20:00:32.440818+00:00 0:00:01.701491 12509 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 4 default 2021-04-01T20:00:28.353612+00:00 2 default_pool
success campaign-flow-job_v002 create_emr_steps 2021-04-01T19:00:00+00:00 PythonOperator 2021-04-01T20:00:06.621476+00:00 2021-04-01T20:00:09.414309+00:00 0:00:02.792833 12508 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 5 default 2021-04-01T20:00:04.220894+00:00 2 default_pool
success booking-processing-job_v002 check_cluster_status 2021-04-01T18:00:00+00:00 EmrJobFlowSensor 2021-04-01T19:11:42.103574+00:00 2021-04-01T19:21:44.785008+00:00 0:10:02.681434 12506 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-01T19:11:39.955210+00:00 2 default_pool
success campaign-history-job_v002 check_cluster_status 2021-04-01T18:00:00+00:00 EmrJobFlowSensor 2021-04-01T19:11:32.585057+00:00 2021-04-01T19:21:35.309576+00:00 0:10:02.724519 12505 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-01T19:11:29.944335+00:00 2 default_pool
success booking-processing-job_v002 create_cluster_and_add_emr_steps 2021-04-01T18:00:00+00:00 EmrCreateJobFlowOperator 2021-04-01T19:11:20.204742+00:00 2021-04-01T19:11:21.971506+00:00 0:00:01.766764 12504 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 2 default 2021-04-01T19:11:17.936601+00:00 2 default_pool
success campaign-history-job_v002 create_cluster_and_add_emr_steps 2021-04-01T18:00:00+00:00 EmrCreateJobFlowOperator 2021-04-01T19:11:10.385833+00:00 2021-04-01T19:11:12.241403+00:00 0:00:01.855570 12503 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 2 default 2021-04-01T19:11:07.985595+00:00 2 default_pool
success booking-processing-job_v002 create_emr_steps 2021-04-01T18:00:00+00:00 PythonOperator 2021-04-01T19:10:58.112083+00:00 2021-04-01T19:11:01.048666+00:00 0:00:02.936583 12502 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-04-01T19:10:55.919071+00:00 2 default_pool
success campaign-history-job_v002 create_emr_steps 2021-04-01T18:00:00+00:00 PythonOperator 2021-04-01T19:10:42.127756+00:00 2021-04-01T19:10:44.852989+00:00 0:00:02.725233 12501 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-04-01T19:10:39.899364+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_booking-processing-job_v002 2021-04-01T18:00:00+00:00 TriggerDagRunOperator 2021-04-01T19:10:36.220004+00:00 2021-04-01T19:10:36.763646+00:00 0:00:00.543642 12500 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-01T19:10:33.895425+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_campaign-history-job_v002 2021-04-01T18:00:00+00:00 TriggerDagRunOperator 2021-04-01T19:10:36.098678+00:00 2021-04-01T19:10:36.508638+00:00 0:00:00.409960 12499 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-01T19:10:33.895391+00:00 2 default_pool
success vc-asset-import_v002 check_cluster_status 2021-04-01T18:05:00+00:00 EmrJobFlowSensor 2021-04-01T19:05:55.663379+00:00 2021-04-01T19:14:58.316432+00:00 0:09:02.653053 12498 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-01T19:05:53.520980+00:00 2 default_pool
success vc-asset-import_v002 create_cluster_and_add_emr_steps 2021-04-01T18:05:00+00:00 EmrCreateJobFlowOperator 2021-04-01T19:05:33.898078+00:00 2021-04-01T19:05:35.618737+00:00 0:00:01.720659 12497 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 2 default 2021-04-01T19:05:31.518858+00:00 2 default_pool
success vc-asset-import_v002 create_emr_steps 2021-04-01T18:05:00+00:00 PythonOperator 2021-04-01T19:05:11.948713+00:00 2021-04-01T19:05:14.633504+00:00 0:00:02.684791 12496 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-04-01T19:05:09.554670+00:00 2 default_pool
success campaign-flow-job_v002 check_cluster_status 2021-04-01T18:00:00+00:00 EmrJobFlowSensor 2021-04-01T19:01:07.107809+00:00 2021-04-01T19:10:09.764630+00:00 0:09:02.656821 12495 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-04-01T19:01:04.908687+00:00 2 default_pool
success campaign-flow-job_v002 create_cluster_and_add_emr_steps 2021-04-01T18:00:00+00:00 EmrCreateJobFlowOperator 2021-04-01T19:00:45.281939+00:00 2021-04-01T19:00:46.988306+00:00 0:00:01.706367 12494 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 4 default 2021-04-01T19:00:42.901150+00:00 2 default_pool
success campaign-flow-job_v002 create_emr_steps 2021-04-01T18:00:00+00:00 PythonOperator 2021-04-01T19:00:25.104855+00:00 2021-04-01T19:00:27.874495+00:00 0:00:02.769640 12493 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 5 default 2021-04-01T19:00:22.845482+00:00 2 default_pool
success campaign-history-job_v002 check_cluster_status 2021-04-01T17:00:00+00:00 EmrJobFlowSensor 2021-04-01T18:11:40.298330+00:00 2021-04-01T18:21:43.090368+00:00 0:10:02.792038 12491 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-01T18:11:38.057053+00:00 2 default_pool
success booking-processing-job_v002 check_cluster_status 2021-04-01T17:00:00+00:00 EmrJobFlowSensor 2021-04-01T18:11:36.422225+00:00 2021-04-01T18:20:39.209546+00:00 0:09:02.787321 12490 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-01T18:11:34.045183+00:00 2 default_pool
success campaign-history-job_v002 create_cluster_and_add_emr_steps 2021-04-01T17:00:00+00:00 EmrCreateJobFlowOperator 2021-04-01T18:11:18.288186+00:00 2021-04-01T18:11:20.017102+00:00 0:00:01.728916 12489 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 2 default 2021-04-01T18:11:15.919951+00:00 2 default_pool
success booking-processing-job_v002 create_cluster_and_add_emr_steps 2021-04-01T17:00:00+00:00 EmrCreateJobFlowOperator 2021-04-01T18:11:14.349614+00:00 2021-04-01T18:11:16.203143+00:00 0:00:01.853529 12488 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 2 default 2021-04-01T18:11:11.916838+00:00 2 default_pool
success campaign-history-job_v002 create_emr_steps 2021-04-01T17:00:00+00:00 PythonOperator 2021-04-01T18:10:56.580374+00:00 2021-04-01T18:10:59.267561+00:00 0:00:02.687187 12487 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-04-01T18:10:53.967573+00:00 2 default_pool
success booking-processing-job_v002 create_emr_steps 2021-04-01T17:00:00+00:00 PythonOperator 2021-04-01T18:10:52.516737+00:00 2021-04-01T18:10:55.620894+00:00 0:00:03.104157 12486 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-04-01T18:10:49.960906+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_booking-processing-job_v002 2021-04-01T17:00:00+00:00 TriggerDagRunOperator 2021-04-01T18:10:40.542926+00:00 2021-04-01T18:10:41.044391+00:00 0:00:00.501465 12485 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-01T18:10:37.891882+00:00 2 default_pool