Task Instances

Reset Filters
  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-05-13T21:00:00+00:00 PythonOperator 2021-05-13T22:00:12.313530+00:00 2021-05-13T22:00:15.428495+00:00 0:00:03.114965 27773 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 5 default 2021-05-13T22:00:10.020411+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_booking-processing-job_v002 2021-05-13T20:00:00+00:00 TriggerDagRunOperator 2021-05-13T21:10:24.863034+00:00 2021-05-13T21:10:25.384044+00:00 0:00:00.521010 27765 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-05-13T21:10:22.410408+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_campaign-history-job_v002 2021-05-13T20:00:00+00:00 TriggerDagRunOperator 2021-05-13T21:10:24.722064+00:00 2021-05-13T21:10:25.124783+00:00 0:00:00.402719 27764 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-05-13T21:10:22.410359+00:00 2 default_pool
success campaign-flow-job_v002 check_cluster_status 2021-05-13T20:00:00+00:00 EmrJobFlowSensor 2021-05-13T21:00:57.886797+00:00 2021-05-13T21:10:00.632377+00:00 0:09:02.745580 27760 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-05-13T21:00:55.461394+00:00 2 default_pool
success campaign-flow-job_v002 create_cluster_and_add_emr_steps 2021-05-13T20:00:00+00:00 EmrCreateJobFlowOperator 2021-05-13T21:00:37.738958+00:00 2021-05-13T21:00:39.608274+00:00 0:00:01.869316 27759 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 4 default 2021-05-13T21:00:35.395633+00:00 2 default_pool
success campaign-flow-job_v002 create_emr_steps 2021-05-13T20:00:00+00:00 PythonOperator 2021-05-13T21:00:15.709189+00:00 2021-05-13T21:00:18.893688+00:00 0:00:03.184499 27758 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 5 default 2021-05-13T21:00:13.357486+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_booking-processing-job_v002 2021-05-13T19:00:00+00:00 TriggerDagRunOperator 2021-05-13T20:10:10.298361+00:00 2021-05-13T20:10:10.811849+00:00 0:00:00.513488 27750 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-05-13T20:10:07.844152+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_campaign-history-job_v002 2021-05-13T19:00:00+00:00 TriggerDagRunOperator 2021-05-13T20:10:10.074528+00:00 2021-05-13T20:10:10.489379+00:00 0:00:00.414851 27749 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-05-13T20:10:07.844115+00:00 2 default_pool
success campaign-flow-job_v002 check_cluster_status 2021-05-13T19:00:00+00:00 EmrJobFlowSensor 2021-05-13T20:00:46.878421+00:00 2021-05-13T20:09:49.467255+00:00 0:09:02.588834 27745 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-05-13T20:00:44.794858+00:00 2 default_pool
success campaign-flow-job_v002 create_cluster_and_add_emr_steps 2021-05-13T19:00:00+00:00 EmrCreateJobFlowOperator 2021-05-13T20:00:26.877943+00:00 2021-05-13T20:00:28.574690+00:00 0:00:01.696747 27744 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 4 default 2021-05-13T20:00:24.754448+00:00 2 default_pool
success campaign-flow-job_v002 create_emr_steps 2021-05-13T19:00:00+00:00 PythonOperator 2021-05-13T20:00:05.357601+00:00 2021-05-13T20:00:08.530992+00:00 0:00:03.173391 27743 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 5 default 2021-05-13T20:00:02.735948+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_booking-processing-job_v002 2021-05-13T18:00:00+00:00 TriggerDagRunOperator 2021-05-13T19:11:40.619332+00:00 2021-05-13T19:11:41.115720+00:00 0:00:00.496388 27735 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-05-13T19:11:38.221859+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_campaign-history-job_v002 2021-05-13T18:00:00+00:00 TriggerDagRunOperator 2021-05-13T19:11:40.510770+00:00 2021-05-13T19:11:41.039016+00:00 0:00:00.528246 27734 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-05-13T19:11:38.221823+00:00 2 default_pool
success campaign-flow-job_v002 check_cluster_status 2021-05-13T18:00:00+00:00 EmrJobFlowSensor 2021-05-13T19:00:47.576395+00:00 2021-05-13T19:10:50.608896+00:00 0:10:03.032501 27730 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-05-13T19:00:45.331018+00:00 2 default_pool
success campaign-flow-job_v002 create_cluster_and_add_emr_steps 2021-05-13T18:00:00+00:00 EmrCreateJobFlowOperator 2021-05-13T19:00:25.697676+00:00 2021-05-13T19:00:27.426965+00:00 0:00:01.729289 27729 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 4 default 2021-05-13T19:00:23.375172+00:00 2 default_pool
success campaign-flow-job_v002 create_emr_steps 2021-05-13T18:00:00+00:00 PythonOperator 2021-05-13T19:00:05.757629+00:00 2021-05-13T19:00:08.885235+00:00 0:00:03.127606 27728 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 5 default 2021-05-13T19:00:03.353046+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_campaign-history-job_v002 2021-05-13T17:00:00+00:00 TriggerDagRunOperator 2021-05-13T18:10:10.883353+00:00 2021-05-13T18:10:11.411424+00:00 0:00:00.528071 27720 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-05-13T18:10:07.475890+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_booking-processing-job_v002 2021-05-13T17:00:00+00:00 TriggerDagRunOperator 2021-05-13T18:10:10.378715+00:00 2021-05-13T18:10:10.753320+00:00 0:00:00.374605 27719 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-05-13T18:10:07.475938+00:00 2 default_pool
success campaign-flow-job_v002 check_cluster_status 2021-05-13T17:00:00+00:00 EmrJobFlowSensor 2021-05-13T18:00:58.914849+00:00 2021-05-13T18:10:01.709583+00:00 0:09:02.794734 27715 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-05-13T18:00:56.445381+00:00 2 default_pool
success campaign-flow-job_v002 create_cluster_and_add_emr_steps 2021-05-13T17:00:00+00:00 EmrCreateJobFlowOperator 2021-05-13T18:00:36.691732+00:00 2021-05-13T18:00:38.574611+00:00 0:00:01.882879 27714 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 4 default 2021-05-13T18:00:34.351021+00:00 2 default_pool
success campaign-flow-job_v002 create_emr_steps 2021-05-13T17:00:00+00:00 PythonOperator 2021-05-13T18:00:08.486686+00:00 2021-05-13T18:00:11.617269+00:00 0:00:03.130583 27713 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 5 default 2021-05-13T18:00:06.218078+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_campaign-history-job_v002 2021-05-13T16:00:00+00:00 TriggerDagRunOperator 2021-05-13T17:10:20.435259+00:00 2021-05-13T17:10:20.966437+00:00 0:00:00.531178 27705 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-05-13T17:10:18.183541+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_booking-processing-job_v002 2021-05-13T16:00:00+00:00 TriggerDagRunOperator 2021-05-13T17:10:20.385350+00:00 2021-05-13T17:10:20.775368+00:00 0:00:00.390018 27704 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-05-13T17:10:18.183568+00:00 2 default_pool
success campaign-flow-job_v002 check_cluster_status 2021-05-13T16:00:00+00:00 EmrJobFlowSensor 2021-05-13T17:01:01.496223+00:00 2021-05-13T17:10:04.251524+00:00 0:09:02.755301 27700 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-05-13T17:00:59.344920+00:00 2 default_pool
success campaign-flow-job_v002 create_cluster_and_add_emr_steps 2021-05-13T16:00:00+00:00 EmrCreateJobFlowOperator 2021-05-13T17:00:39.717175+00:00 2021-05-13T17:00:41.557073+00:00 0:00:01.839898 27699 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 4 default 2021-05-13T17:00:37.320166+00:00 2 default_pool
success campaign-flow-job_v002 create_emr_steps 2021-05-13T16:00:00+00:00 PythonOperator 2021-05-13T17:00:18.069314+00:00 2021-05-13T17:00:21.188185+00:00 0:00:03.118871 27698 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 5 default 2021-05-13T17:00:15.348649+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_booking-processing-job_v002 2021-05-13T15:00:00+00:00 TriggerDagRunOperator 2021-05-13T16:11:20.116116+00:00 2021-05-13T16:11:20.516461+00:00 0:00:00.400345 27690 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-05-13T16:11:17.565487+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_campaign-history-job_v002 2021-05-13T15:00:00+00:00 TriggerDagRunOperator 2021-05-13T16:11:20.114309+00:00 2021-05-13T16:11:20.631449+00:00 0:00:00.517140 27689 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-05-13T16:11:17.565456+00:00 2 default_pool
success campaign-flow-job_v002 check_cluster_status 2021-05-13T15:00:00+00:00 EmrJobFlowSensor 2021-05-13T16:01:06.566249+00:00 2021-05-13T16:11:09.578429+00:00 0:10:03.012180 27685 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-05-13T16:01:04.275270+00:00 2 default_pool
success campaign-flow-job_v002 create_cluster_and_add_emr_steps 2021-05-13T15:00:00+00:00 EmrCreateJobFlowOperator 2021-05-13T16:00:44.446606+00:00 2021-05-13T16:00:46.128116+00:00 0:00:01.681510 27684 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 4 default 2021-05-13T16:00:42.194095+00:00 2 default_pool
success campaign-flow-job_v002 create_emr_steps 2021-05-13T15:00:00+00:00 PythonOperator 2021-05-13T16:00:22.398609+00:00 2021-05-13T16:00:25.536131+00:00 0:00:03.137522 27683 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 5 default 2021-05-13T16:00:20.135414+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_booking-processing-job_v002 2021-05-13T14:00:00+00:00 TriggerDagRunOperator 2021-05-13T15:12:18.683137+00:00 2021-05-13T15:12:19.202453+00:00 0:00:00.519316 27675 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-05-13T15:12:16.367417+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_campaign-history-job_v002 2021-05-13T14:00:00+00:00 TriggerDagRunOperator 2021-05-13T15:12:18.563824+00:00 2021-05-13T15:12:19.004425+00:00 0:00:00.440601 27674 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-05-13T15:12:16.367380+00:00 2 default_pool
success campaign-flow-job_v002 check_cluster_status 2021-05-13T14:00:00+00:00 EmrJobFlowSensor 2021-05-13T15:00:57.257125+00:00 2021-05-13T15:12:00.329451+00:00 0:11:03.072326 27670 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-05-13T15:00:54.954124+00:00 2 default_pool
success campaign-flow-job_v002 create_cluster_and_add_emr_steps 2021-05-13T14:00:00+00:00 EmrCreateJobFlowOperator 2021-05-13T15:00:36.991094+00:00 2021-05-13T15:00:38.681624+00:00 0:00:01.690530 27669 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 4 default 2021-05-13T15:00:34.818959+00:00 2 default_pool
success campaign-flow-job_v002 create_emr_steps 2021-05-13T14:00:00+00:00 PythonOperator 2021-05-13T15:00:15.170298+00:00 2021-05-13T15:00:18.285239+00:00 0:00:03.114941 27668 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 5 default 2021-05-13T15:00:12.866162+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_campaign-history-job_v002 2021-05-13T13:00:00+00:00 TriggerDagRunOperator 2021-05-13T14:25:10.994672+00:00 2021-05-13T14:25:11.545613+00:00 0:00:00.550941 27660 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-05-13T14:25:08.555872+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_booking-processing-job_v002 2021-05-13T13:00:00+00:00 TriggerDagRunOperator 2021-05-13T14:25:10.935517+00:00 2021-05-13T14:25:11.373583+00:00 0:00:00.438066 27659 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-05-13T14:25:08.555919+00:00 2 default_pool
success campaign-flow-job_v002 check_cluster_status 2021-05-13T13:00:00+00:00 EmrJobFlowSensor 2021-05-13T14:00:49.242285+00:00 2021-05-13T14:24:54.277048+00:00 0:24:05.034763 27655 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-05-13T14:00:47.038963+00:00 2 default_pool
success campaign-flow-job_v002 create_cluster_and_add_emr_steps 2021-05-13T13:00:00+00:00 EmrCreateJobFlowOperator 2021-05-13T14:00:29.123427+00:00 2021-05-13T14:00:30.786161+00:00 0:00:01.662734 27654 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 4 default 2021-05-13T14:00:27.020663+00:00 2 default_pool
success campaign-flow-job_v002 create_emr_steps 2021-05-13T13:00:00+00:00 PythonOperator 2021-05-13T14:00:07.885542+00:00 2021-05-13T14:00:11.028650+00:00 0:00:03.143108 27653 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 5 default 2021-05-13T14:00:05.058886+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_booking-processing-job_v002 2021-05-13T12:00:00+00:00 TriggerDagRunOperator 2021-05-13T13:11:10.430960+00:00 2021-05-13T13:11:10.949021+00:00 0:00:00.518061 27645 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-05-13T13:11:08.095117+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_campaign-history-job_v002 2021-05-13T12:00:00+00:00 TriggerDagRunOperator 2021-05-13T13:11:10.283902+00:00 2021-05-13T13:11:10.697169+00:00 0:00:00.413267 27644 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-05-13T13:11:08.095070+00:00 2 default_pool
success campaign-flow-job_v002 check_cluster_status 2021-05-13T12:00:00+00:00 EmrJobFlowSensor 2021-05-13T13:00:46.837731+00:00 2021-05-13T13:10:49.629297+00:00 0:10:02.791566 27640 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-05-13T13:00:44.693430+00:00 2 default_pool
success campaign-flow-job_v002 create_cluster_and_add_emr_steps 2021-05-13T12:00:00+00:00 EmrCreateJobFlowOperator 2021-05-13T13:00:24.907562+00:00 2021-05-13T13:00:26.662054+00:00 0:00:01.754492 27639 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 4 default 2021-05-13T13:00:22.669372+00:00 2 default_pool
success campaign-flow-job_v002 create_emr_steps 2021-05-13T12:00:00+00:00 PythonOperator 2021-05-13T13:00:04.999805+00:00 2021-05-13T13:00:08.164037+00:00 0:00:03.164232 27638 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 5 default 2021-05-13T13:00:02.535928+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_booking-processing-job_v002 2021-05-13T11:00:00+00:00 TriggerDagRunOperator 2021-05-13T12:31:20.013065+00:00 2021-05-13T12:31:20.526476+00:00 0:00:00.513411 27631 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-05-13T12:31:17.265994+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_campaign-history-job_v002 2021-05-13T11:00:00+00:00 TriggerDagRunOperator 2021-05-13T12:31:19.653185+00:00 2021-05-13T12:31:20.092082+00:00 0:00:00.438897 27630 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-05-13T12:31:17.265952+00:00 2 default_pool
success campaign-flow-job_v002 check_cluster_status 2021-05-13T11:00:00+00:00 EmrJobFlowSensor 2021-05-13T12:00:58.925665+00:00 2021-05-13T12:31:04.867688+00:00 0:30:05.942023 27625 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-05-13T12:00:56.591800+00:00 2 default_pool
success campaign-flow-job_v002 create_cluster_and_add_emr_steps 2021-05-13T11:00:00+00:00 EmrCreateJobFlowOperator 2021-05-13T12:00:36.937267+00:00 2021-05-13T12:00:38.634951+00:00 0:00:01.697684 27624 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 4 default 2021-05-13T12:00:34.556279+00:00 2 default_pool
success campaign-flow-job_v002 create_emr_steps 2021-05-13T11:00:00+00:00 PythonOperator 2021-05-13T12:00:16.475982+00:00 2021-05-13T12:00:19.717420+00:00 0:00:03.241438 27623 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 5 default 2021-05-13T12:00:14.384710+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_campaign-history-job_v002 2021-05-13T10:00:00+00:00 TriggerDagRunOperator 2021-05-13T11:10:24.411295+00:00 2021-05-13T11:10:24.931468+00:00 0:00:00.520173 27613 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-05-13T11:10:21.643759+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_booking-processing-job_v002 2021-05-13T10:00:00+00:00 TriggerDagRunOperator 2021-05-13T11:10:24.110917+00:00 2021-05-13T11:10:24.522754+00:00 0:00:00.411837 27612 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-05-13T11:10:21.643788+00:00 2 default_pool
success campaign-flow-job_v002 check_cluster_status 2021-05-13T10:00:00+00:00 EmrJobFlowSensor 2021-05-13T11:00:55.689146+00:00 2021-05-13T11:09:58.504220+00:00 0:09:02.815074 27610 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-05-13T11:00:53.488383+00:00 2 default_pool
success campaign-flow-job_v002 create_cluster_and_add_emr_steps 2021-05-13T10:00:00+00:00 EmrCreateJobFlowOperator 2021-05-13T11:00:33.909924+00:00 2021-05-13T11:00:35.774452+00:00 0:00:01.864528 27609 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 4 default 2021-05-13T11:00:31.456979+00:00 2 default_pool
success campaign-flow-job_v002 create_emr_steps 2021-05-13T10:00:00+00:00 PythonOperator 2021-05-13T11:00:11.623688+00:00 2021-05-13T11:00:14.745020+00:00 0:00:03.121332 27608 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 5 default 2021-05-13T11:00:09.390989+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_booking-processing-job_v002 2021-05-13T09:00:00+00:00 TriggerDagRunOperator 2021-05-13T10:10:27.127193+00:00 2021-05-13T10:10:27.657267+00:00 0:00:00.530074 27601 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-05-13T10:10:24.671621+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_campaign-history-job_v002 2021-05-13T09:00:00+00:00 TriggerDagRunOperator 2021-05-13T10:10:27.028249+00:00 2021-05-13T10:10:27.434561+00:00 0:00:00.406312 27600 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-05-13T10:10:24.671590+00:00 2 default_pool
success campaign-flow-job_v002 check_cluster_status 2021-05-13T09:00:00+00:00 EmrJobFlowSensor 2021-05-13T10:01:00.787272+00:00 2021-05-13T10:10:03.491498+00:00 0:09:02.704226 27595 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-05-13T10:00:58.368269+00:00 2 default_pool
success campaign-flow-job_v002 create_cluster_and_add_emr_steps 2021-05-13T09:00:00+00:00 EmrCreateJobFlowOperator 2021-05-13T10:00:38.394201+00:00 2021-05-13T10:00:40.115101+00:00 0:00:01.720900 27594 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 4 default 2021-05-13T10:00:36.181505+00:00 2 default_pool
success campaign-flow-job_v002 create_emr_steps 2021-05-13T09:00:00+00:00 PythonOperator 2021-05-13T10:00:18.270521+00:00 2021-05-13T10:00:21.445821+00:00 0:00:03.175300 27593 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 5 default 2021-05-13T10:00:16.142883+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_booking-processing-job_v002 2021-05-13T08:00:00+00:00 TriggerDagRunOperator 2021-05-13T09:12:06.556352+00:00 2021-05-13T09:12:07.077687+00:00 0:00:00.521335 27586 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-05-13T09:12:04.204775+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_campaign-history-job_v002 2021-05-13T08:00:00+00:00 TriggerDagRunOperator 2021-05-13T09:12:06.413176+00:00 2021-05-13T09:12:06.818405+00:00 0:00:00.405229 27585 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-05-13T09:12:04.204728+00:00 2 default_pool
success campaign-flow-job_v002 check_cluster_status 2021-05-13T08:00:00+00:00 EmrJobFlowSensor 2021-05-13T09:02:44.933298+00:00 2021-05-13T09:11:47.762984+00:00 0:09:02.829686 27581 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-05-13T09:02:42.532741+00:00 2 default_pool
success campaign-flow-job_v002 create_cluster_and_add_emr_steps 2021-05-13T08:00:00+00:00 EmrCreateJobFlowOperator 2021-05-13T09:02:22.711359+00:00 2021-05-13T09:02:24.417328+00:00 0:00:01.705969 27580 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 4 default 2021-05-13T09:02:20.502869+00:00 2 default_pool
success campaign-flow-job_v002 create_emr_steps 2021-05-13T08:00:00+00:00 PythonOperator 2021-05-13T09:02:02.874171+00:00 2021-05-13T09:02:05.964496+00:00 0:00:03.090325 27579 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 5 default 2021-05-13T09:02:00.470189+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_booking-processing-job_v002 2021-05-13T07:00:00+00:00 TriggerDagRunOperator 2021-05-13T08:10:07.342160+00:00 2021-05-13T08:10:07.868666+00:00 0:00:00.526506 27571 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-05-13T08:10:04.655477+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_campaign-history-job_v002 2021-05-13T07:00:00+00:00 TriggerDagRunOperator 2021-05-13T08:10:06.773606+00:00 2021-05-13T08:10:07.170987+00:00 0:00:00.397381 27570 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-05-13T08:10:04.655432+00:00 2 default_pool
success campaign-flow-job_v002 check_cluster_status 2021-05-13T07:00:00+00:00 EmrJobFlowSensor 2021-05-13T08:00:55.732582+00:00 2021-05-13T08:09:58.720821+00:00 0:09:02.988239 27566 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-05-13T08:00:53.352104+00:00 2 default_pool
success campaign-flow-job_v002 create_cluster_and_add_emr_steps 2021-05-13T07:00:00+00:00 EmrCreateJobFlowOperator 2021-05-13T08:00:33.530081+00:00 2021-05-13T08:00:35.258163+00:00 0:00:01.728082 27565 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 4 default 2021-05-13T08:00:31.297334+00:00 2 default_pool
success campaign-flow-job_v002 create_emr_steps 2021-05-13T07:00:00+00:00 PythonOperator 2021-05-13T08:00:14.107977+00:00 2021-05-13T08:00:17.493375+00:00 0:00:03.385398 27564 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 5 default 2021-05-13T08:00:11.174833+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_booking-processing-job_v002 2021-05-13T06:00:00+00:00 TriggerDagRunOperator 2021-05-13T07:10:19.527204+00:00 2021-05-13T07:10:20.015703+00:00 0:00:00.488499 27556 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-05-13T07:10:16.766616+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_campaign-history-job_v002 2021-05-13T06:00:00+00:00 TriggerDagRunOperator 2021-05-13T07:10:19.119311+00:00 2021-05-13T07:10:19.516477+00:00 0:00:00.397166 27555 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-05-13T07:10:16.766566+00:00 2 default_pool
success campaign-flow-job_v002 check_cluster_status 2021-05-13T06:00:00+00:00 EmrJobFlowSensor 2021-05-13T07:01:03.798443+00:00 2021-05-13T07:10:06.542230+00:00 0:09:02.743787 27551 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-05-13T07:01:01.691349+00:00 2 default_pool
success campaign-flow-job_v002 create_cluster_and_add_emr_steps 2021-05-13T06:00:00+00:00 EmrCreateJobFlowOperator 2021-05-13T07:00:41.711698+00:00 2021-05-13T07:00:43.518626+00:00 0:00:01.806928 27550 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 4 default 2021-05-13T07:00:39.540755+00:00 2 default_pool
success campaign-flow-job_v002 create_emr_steps 2021-05-13T06:00:00+00:00 PythonOperator 2021-05-13T07:00:21.745561+00:00 2021-05-13T07:00:24.929044+00:00 0:00:03.183483 27549 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 5 default 2021-05-13T07:00:19.524650+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_booking-processing-job_v002 2021-05-13T05:00:00+00:00 TriggerDagRunOperator 2021-05-13T06:09:13.067511+00:00 2021-05-13T06:09:13.635653+00:00 0:00:00.568142 27541 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-05-13T06:09:10.817059+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_campaign-history-job_v002 2021-05-13T05:00:00+00:00 TriggerDagRunOperator 2021-05-13T06:09:13.033997+00:00 2021-05-13T06:09:13.452393+00:00 0:00:00.418396 27540 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-05-13T06:09:10.817006+00:00 2 default_pool
success campaign-flow-job_v002 check_cluster_status 2021-05-13T05:00:00+00:00 EmrJobFlowSensor 2021-05-13T06:01:06.009285+00:00 2021-05-13T06:09:08.618808+00:00 0:08:02.609523 27536 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-05-13T06:01:03.886868+00:00 2 default_pool
success campaign-flow-job_v002 create_cluster_and_add_emr_steps 2021-05-13T05:00:00+00:00 EmrCreateJobFlowOperator 2021-05-13T06:00:46.381671+00:00 2021-05-13T06:00:48.085599+00:00 0:00:01.703928 27535 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 4 default 2021-05-13T06:00:43.857878+00:00 2 default_pool
success campaign-flow-job_v002 create_emr_steps 2021-05-13T05:00:00+00:00 PythonOperator 2021-05-13T06:00:24.304921+00:00 2021-05-13T06:00:27.584849+00:00 0:00:03.279928 27534 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 5 default 2021-05-13T06:00:21.836673+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_booking-processing-job_v002 2021-05-13T04:00:00+00:00 TriggerDagRunOperator 2021-05-13T05:10:36.454532+00:00 2021-05-13T05:10:36.953148+00:00 0:00:00.498616 27526 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-05-13T05:10:34.096135+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_campaign-history-job_v002 2021-05-13T04:00:00+00:00 TriggerDagRunOperator 2021-05-13T05:10:36.232685+00:00 2021-05-13T05:10:36.647153+00:00 0:00:00.414468 27525 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-05-13T05:10:34.096093+00:00 2 default_pool
success campaign-flow-job_v002 check_cluster_status 2021-05-13T04:00:00+00:00 EmrJobFlowSensor 2021-05-13T05:01:09.460555+00:00 2021-05-13T05:10:12.279498+00:00 0:09:02.818943 27521 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-05-13T05:01:06.971502+00:00 2 default_pool
success campaign-flow-job_v002 create_cluster_and_add_emr_steps 2021-05-13T04:00:00+00:00 EmrCreateJobFlowOperator 2021-05-13T05:00:45.244169+00:00 2021-05-13T05:00:46.990232+00:00 0:00:01.746063 27520 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 4 default 2021-05-13T05:00:42.894837+00:00 2 default_pool
success campaign-flow-job_v002 create_emr_steps 2021-05-13T04:00:00+00:00 PythonOperator 2021-05-13T05:00:23.083959+00:00 2021-05-13T05:00:26.306150+00:00 0:00:03.222191 27519 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 5 default 2021-05-13T05:00:20.825499+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_booking-processing-job_v002 2021-05-13T03:00:00+00:00 TriggerDagRunOperator 2021-05-13T04:10:22.635980+00:00 2021-05-13T04:10:23.170299+00:00 0:00:00.534319 27511 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-05-13T04:10:20.253411+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_campaign-history-job_v002 2021-05-13T03:00:00+00:00 TriggerDagRunOperator 2021-05-13T04:10:22.510740+00:00 2021-05-13T04:10:22.927026+00:00 0:00:00.416286 27510 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-05-13T04:10:20.253374+00:00 2 default_pool
success campaign-flow-job_v002 check_cluster_status 2021-05-13T03:00:00+00:00 EmrJobFlowSensor 2021-05-13T04:00:51.179692+00:00 2021-05-13T04:09:54.106203+00:00 0:09:02.926511 27506 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-05-13T04:00:48.784091+00:00 2 default_pool
success campaign-flow-job_v002 create_cluster_and_add_emr_steps 2021-05-13T03:00:00+00:00 EmrCreateJobFlowOperator 2021-05-13T04:00:29.133323+00:00 2021-05-13T04:00:30.886942+00:00 0:00:01.753619 27505 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 4 default 2021-05-13T04:00:26.690203+00:00 2 default_pool
success campaign-flow-job_v002 create_emr_steps 2021-05-13T03:00:00+00:00 PythonOperator 2021-05-13T04:00:08.958116+00:00 2021-05-13T04:00:12.111812+00:00 0:00:03.153696 27504 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 5 default 2021-05-13T04:00:06.654750+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_booking-processing-job_v002 2021-05-13T02:00:00+00:00 TriggerDagRunOperator 2021-05-13T03:09:20.235938+00:00 2021-05-13T03:09:20.748418+00:00 0:00:00.512480 27496 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-05-13T03:09:17.874120+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_campaign-history-job_v002 2021-05-13T02:00:00+00:00 TriggerDagRunOperator 2021-05-13T03:09:20.017658+00:00 2021-05-13T03:09:20.436016+00:00 0:00:00.418358 27495 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-05-13T03:09:17.874088+00:00 2 default_pool
success campaign-flow-job_v002 check_cluster_status 2021-05-13T02:00:00+00:00 EmrJobFlowSensor 2021-05-13T03:00:53.560634+00:00 2021-05-13T03:08:56.253604+00:00 0:08:02.692970 27491 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-05-13T03:00:51.230919+00:00 2 default_pool
success campaign-flow-job_v002 create_cluster_and_add_emr_steps 2021-05-13T02:00:00+00:00 EmrCreateJobFlowOperator 2021-05-13T03:00:31.595632+00:00 2021-05-13T03:00:33.317841+00:00 0:00:01.722209 27490 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 4 default 2021-05-13T03:00:29.279252+00:00 2 default_pool
success campaign-flow-job_v002 create_emr_steps 2021-05-13T02:00:00+00:00 PythonOperator 2021-05-13T03:00:05.491633+00:00 2021-05-13T03:00:08.635505+00:00 0:00:03.143872 27489 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 5 default 2021-05-13T03:00:03.184930+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_booking-processing-job_v002 2021-05-13T01:00:00+00:00 TriggerDagRunOperator 2021-05-13T02:09:22.713595+00:00 2021-05-13T02:09:23.208771+00:00 0:00:00.495176 27481 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-05-13T02:09:20.205578+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_campaign-history-job_v002 2021-05-13T01:00:00+00:00 TriggerDagRunOperator 2021-05-13T02:09:22.488055+00:00 2021-05-13T02:09:22.910948+00:00 0:00:00.422893 27480 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-05-13T02:09:20.205545+00:00 2 default_pool
success campaign-flow-job_v002 check_cluster_status 2021-05-13T01:00:00+00:00 EmrJobFlowSensor 2021-05-13T02:00:59.763935+00:00 2021-05-13T02:09:02.483596+00:00 0:08:02.719661 27476 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-05-13T02:00:57.302293+00:00 2 default_pool
success campaign-flow-job_v002 create_cluster_and_add_emr_steps 2021-05-13T01:00:00+00:00 EmrCreateJobFlowOperator 2021-05-13T02:00:37.740019+00:00 2021-05-13T02:00:39.455495+00:00 0:00:01.715476 27475 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 4 default 2021-05-13T02:00:35.343615+00:00 2 default_pool