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_cluster_and_add_emr_steps 2023-05-29T22:00:00+00:00 EmrCreateJobFlowOperator 2023-05-29T23:00:29.756517+00:00 2023-05-29T23:00:30.705059+00:00 0:00:00.948542 388014 airflow-worker-0.airflow-worker.data-eng.svc.cluster.local airflow 4 default 2023-05-29T23:00:27.633874+00:00 2 default_pool
success campaign-flow-job_v002 create_emr_steps 2023-05-29T22:00:00+00:00 PythonOperator 2023-05-29T23:00:10.050538+00:00 2023-05-29T23:00:11.009285+00:00 0:00:00.958747 388011 airflow-worker-0.airflow-worker.data-eng.svc.cluster.local airflow 5 default 2023-05-29T23:00:07.618279+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_campaign-history-job_v002 2023-05-29T21:00:00+00:00 TriggerDagRunOperator 2023-05-29T22:11:12.969771+00:00 2023-05-29T22:11:13.424065+00:00 0:00:00.454294 387999 airflow-worker-0.airflow-worker.data-eng.svc.cluster.local airflow 1 default 2023-05-29T22:11:10.677687+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_booking-processing-job_v002 2023-05-29T21:00:00+00:00 TriggerDagRunOperator 2023-05-29T22:11:12.893150+00:00 2023-05-29T22:11:13.346219+00:00 0:00:00.453069 387998 airflow-worker-1.airflow-worker.data-eng.svc.cluster.local airflow 1 default 2023-05-29T22:11:10.677658+00:00 2 default_pool
success campaign-flow-job_v002 check_cluster_status 2023-05-29T21:00:00+00:00 EmrJobFlowSensor 2023-05-29T22:00:51.273055+00:00 2023-05-29T22:10:53.100497+00:00 0:10:01.827442 387992 airflow-worker-1.airflow-worker.data-eng.svc.cluster.local airflow 3 default 2023-05-29T22:00:49.138277+00:00 2 default_pool
success campaign-flow-job_v002 create_cluster_and_add_emr_steps 2023-05-29T21:00:00+00:00 EmrCreateJobFlowOperator 2023-05-29T22:00:29.108718+00:00 2023-05-29T22:00:30.201255+00:00 0:00:01.092537 387990 airflow-worker-1.airflow-worker.data-eng.svc.cluster.local airflow 4 default 2023-05-29T22:00:27.088511+00:00 2 default_pool
success campaign-flow-job_v002 create_emr_steps 2023-05-29T21:00:00+00:00 PythonOperator 2023-05-29T22:00:07.311252+00:00 2023-05-29T22:00:08.248696+00:00 0:00:00.937444 387987 airflow-worker-1.airflow-worker.data-eng.svc.cluster.local airflow 5 default 2023-05-29T22:00:05.066250+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_campaign-history-job_v002 2023-05-29T20:00:00+00:00 TriggerDagRunOperator 2023-05-29T21:11:28.093528+00:00 2023-05-29T21:11:28.512813+00:00 0:00:00.419285 387976 airflow-worker-0.airflow-worker.data-eng.svc.cluster.local airflow 1 default 2023-05-29T21:11:25.711511+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_booking-processing-job_v002 2023-05-29T20:00:00+00:00 TriggerDagRunOperator 2023-05-29T21:11:27.974065+00:00 2023-05-29T21:11:28.411025+00:00 0:00:00.436960 387975 airflow-worker-1.airflow-worker.data-eng.svc.cluster.local airflow 1 default 2023-05-29T21:11:25.711482+00:00 2 default_pool
success campaign-flow-job_v002 check_cluster_status 2023-05-29T20:00:00+00:00 EmrJobFlowSensor 2023-05-29T21:01:01.396891+00:00 2023-05-29T21:11:03.253257+00:00 0:10:01.856366 387969 airflow-worker-0.airflow-worker.data-eng.svc.cluster.local airflow 3 default 2023-05-29T21:00:59.197735+00:00 2 default_pool
success campaign-flow-job_v002 create_cluster_and_add_emr_steps 2023-05-29T20:00:00+00:00 EmrCreateJobFlowOperator 2023-05-29T21:00:39.282768+00:00 2023-05-29T21:00:40.190982+00:00 0:00:00.908214 387967 airflow-worker-0.airflow-worker.data-eng.svc.cluster.local airflow 4 default 2023-05-29T21:00:37.131524+00:00 2 default_pool
success campaign-flow-job_v002 create_emr_steps 2023-05-29T20:00:00+00:00 PythonOperator 2023-05-29T21:00:19.188326+00:00 2023-05-29T21:00:20.109308+00:00 0:00:00.920982 387965 airflow-worker-1.airflow-worker.data-eng.svc.cluster.local airflow 5 default 2023-05-29T21:00:17.112201+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_booking-processing-job_v002 2023-05-29T19:00:00+00:00 TriggerDagRunOperator 2023-05-29T20:11:16.663535+00:00 2023-05-29T20:11:17.126798+00:00 0:00:00.463263 387953 airflow-worker-0.airflow-worker.data-eng.svc.cluster.local airflow 1 default 2023-05-29T20:11:14.398575+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_campaign-history-job_v002 2023-05-29T19:00:00+00:00 TriggerDagRunOperator 2023-05-29T20:11:16.614220+00:00 2023-05-29T20:11:17.090035+00:00 0:00:00.475815 387952 airflow-worker-1.airflow-worker.data-eng.svc.cluster.local airflow 1 default 2023-05-29T20:11:14.398602+00:00 2 default_pool
success campaign-flow-job_v002 check_cluster_status 2023-05-29T19:00:00+00:00 EmrJobFlowSensor 2023-05-29T20:00:53.314136+00:00 2023-05-29T20:10:55.185547+00:00 0:10:01.871411 387945 airflow-worker-1.airflow-worker.data-eng.svc.cluster.local airflow 3 default 2023-05-29T20:00:51.204196+00:00 2 default_pool
success campaign-flow-job_v002 create_cluster_and_add_emr_steps 2023-05-29T19:00:00+00:00 EmrCreateJobFlowOperator 2023-05-29T20:00:31.217368+00:00 2023-05-29T20:00:32.150583+00:00 0:00:00.933215 387943 airflow-worker-1.airflow-worker.data-eng.svc.cluster.local airflow 4 default 2023-05-29T20:00:29.130161+00:00 2 default_pool
success campaign-flow-job_v002 create_emr_steps 2023-05-29T19:00:00+00:00 PythonOperator 2023-05-29T20:00:11.386219+00:00 2023-05-29T20:00:12.289026+00:00 0:00:00.902807 387941 airflow-worker-0.airflow-worker.data-eng.svc.cluster.local airflow 5 default 2023-05-29T20:00:09.113056+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_booking-processing-job_v002 2023-05-29T18:00:00+00:00 TriggerDagRunOperator 2023-05-29T19:11:17.642752+00:00 2023-05-29T19:11:18.081510+00:00 0:00:00.438758 387928 airflow-worker-0.airflow-worker.data-eng.svc.cluster.local airflow 1 default 2023-05-29T19:11:15.524959+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_campaign-history-job_v002 2023-05-29T18:00:00+00:00 TriggerDagRunOperator 2023-05-29T19:11:17.565990+00:00 2023-05-29T19:11:18.013270+00:00 0:00:00.447280 387927 airflow-worker-1.airflow-worker.data-eng.svc.cluster.local airflow 1 default 2023-05-29T19:11:15.524985+00:00 2 default_pool
success campaign-flow-job_v002 check_cluster_status 2023-05-29T18:00:00+00:00 EmrJobFlowSensor 2023-05-29T19:01:06.710024+00:00 2023-05-29T19:11:08.539900+00:00 0:10:01.829876 387920 airflow-worker-0.airflow-worker.data-eng.svc.cluster.local airflow 3 default 2023-05-29T19:01:04.502415+00:00 2 default_pool
success campaign-flow-job_v002 create_cluster_and_add_emr_steps 2023-05-29T18:00:00+00:00 EmrCreateJobFlowOperator 2023-05-29T19:00:44.562290+00:00 2023-05-29T19:00:45.432157+00:00 0:00:00.869867 387919 airflow-worker-0.airflow-worker.data-eng.svc.cluster.local airflow 4 default 2023-05-29T19:00:42.486174+00:00 2 default_pool
success campaign-flow-job_v002 create_emr_steps 2023-05-29T18:00:00+00:00 PythonOperator 2023-05-29T19:00:22.552356+00:00 2023-05-29T19:00:23.442997+00:00 0:00:00.890641 387918 airflow-worker-0.airflow-worker.data-eng.svc.cluster.local airflow 5 default 2023-05-29T19:00:20.456301+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_booking-processing-job_v002 2023-05-29T17:00:00+00:00 TriggerDagRunOperator 2023-05-29T18:11:06.009130+00:00 2023-05-29T18:11:06.469080+00:00 0:00:00.459950 387904 airflow-worker-0.airflow-worker.data-eng.svc.cluster.local airflow 1 default 2023-05-29T18:11:03.874217+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_campaign-history-job_v002 2023-05-29T17:00:00+00:00 TriggerDagRunOperator 2023-05-29T18:11:05.869969+00:00 2023-05-29T18:11:06.438697+00:00 0:00:00.568728 387903 airflow-worker-1.airflow-worker.data-eng.svc.cluster.local airflow 1 default 2023-05-29T18:11:03.874244+00:00 2 default_pool
success campaign-flow-job_v002 check_cluster_status 2023-05-29T17:00:00+00:00 EmrJobFlowSensor 2023-05-29T18:00:58.174716+00:00 2023-05-29T18:10:59.945308+00:00 0:10:01.770592 387896 airflow-worker-0.airflow-worker.data-eng.svc.cluster.local airflow 3 default 2023-05-29T18:00:56.032182+00:00 2 default_pool
success campaign-flow-job_v002 create_cluster_and_add_emr_steps 2023-05-29T17:00:00+00:00 EmrCreateJobFlowOperator 2023-05-29T18:00:38.076924+00:00 2023-05-29T18:00:39.094395+00:00 0:00:01.017471 387895 airflow-worker-1.airflow-worker.data-eng.svc.cluster.local airflow 4 default 2023-05-29T18:00:36.022945+00:00 2 default_pool
success campaign-flow-job_v002 create_emr_steps 2023-05-29T17:00:00+00:00 PythonOperator 2023-05-29T18:00:16.161899+00:00 2023-05-29T18:00:17.060063+00:00 0:00:00.898164 387893 airflow-worker-1.airflow-worker.data-eng.svc.cluster.local airflow 5 default 2023-05-29T18:00:13.992294+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_booking-processing-job_v002 2023-05-29T16:00:00+00:00 TriggerDagRunOperator 2023-05-29T17:11:31.316948+00:00 2023-05-29T17:11:31.747455+00:00 0:00:00.430507 387882 airflow-worker-0.airflow-worker.data-eng.svc.cluster.local airflow 1 default 2023-05-29T17:11:29.003569+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_campaign-history-job_v002 2023-05-29T16:00:00+00:00 TriggerDagRunOperator 2023-05-29T17:11:31.243911+00:00 2023-05-29T17:11:31.675527+00:00 0:00:00.431616 387881 airflow-worker-1.airflow-worker.data-eng.svc.cluster.local airflow 1 default 2023-05-29T17:11:29.003597+00:00 2 default_pool
success campaign-flow-job_v002 check_cluster_status 2023-05-29T16:00:00+00:00 EmrJobFlowSensor 2023-05-29T17:01:06.303897+00:00 2023-05-29T17:11:07.988982+00:00 0:10:01.685085 387872 airflow-worker-0.airflow-worker.data-eng.svc.cluster.local airflow 3 default 2023-05-29T17:01:04.131496+00:00 2 default_pool
success campaign-flow-job_v002 create_cluster_and_add_emr_steps 2023-05-29T16:00:00+00:00 EmrCreateJobFlowOperator 2023-05-29T17:00:46.316750+00:00 2023-05-29T17:00:47.233240+00:00 0:00:00.916490 387871 airflow-worker-0.airflow-worker.data-eng.svc.cluster.local airflow 4 default 2023-05-29T17:00:44.112476+00:00 2 default_pool
success campaign-flow-job_v002 create_emr_steps 2023-05-29T16:00:00+00:00 PythonOperator 2023-05-29T17:00:24.176003+00:00 2023-05-29T17:00:25.157762+00:00 0:00:00.981759 387870 airflow-worker-0.airflow-worker.data-eng.svc.cluster.local airflow 5 default 2023-05-29T17:00:22.092262+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_campaign-history-job_v002 2023-05-29T15:00:00+00:00 TriggerDagRunOperator 2023-05-29T16:17:23.518990+00:00 2023-05-29T16:17:23.946152+00:00 0:00:00.427162 387858 airflow-worker-0.airflow-worker.data-eng.svc.cluster.local airflow 1 default 2023-05-29T16:17:20.506230+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_booking-processing-job_v002 2023-05-29T15:00:00+00:00 TriggerDagRunOperator 2023-05-29T16:17:22.518488+00:00 2023-05-29T16:17:23.031347+00:00 0:00:00.512859 387857 airflow-worker-1.airflow-worker.data-eng.svc.cluster.local airflow 1 default 2023-05-29T16:17:20.506197+00:00 2 default_pool
success campaign-flow-job_v002 check_cluster_status 2023-05-29T15:00:00+00:00 EmrJobFlowSensor 2023-05-29T16:01:05.635486+00:00 2023-05-29T16:10:07.463888+00:00 0:09:01.828402 387852 airflow-worker-1.airflow-worker.data-eng.svc.cluster.local airflow 3 default 2023-05-29T16:01:03.593663+00:00 2 default_pool
success campaign-flow-job_v002 create_cluster_and_add_emr_steps 2023-05-29T15:00:00+00:00 EmrCreateJobFlowOperator 2023-05-29T16:00:45.671071+00:00 2023-05-29T16:00:46.567434+00:00 0:00:00.896363 387850 airflow-worker-1.airflow-worker.data-eng.svc.cluster.local airflow 4 default 2023-05-29T16:00:43.574001+00:00 2 default_pool
success campaign-flow-job_v002 create_emr_steps 2023-05-29T15:00:00+00:00 PythonOperator 2023-05-29T16:00:24.112160+00:00 2023-05-29T16:00:25.136806+00:00 0:00:01.024646 387849 airflow-worker-0.airflow-worker.data-eng.svc.cluster.local airflow 5 default 2023-05-29T16:00:21.555873+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_booking-processing-job_v002 2023-05-29T14:00:00+00:00 TriggerDagRunOperator 2023-05-29T15:11:06.835491+00:00 2023-05-29T15:11:07.288105+00:00 0:00:00.452614 387838 airflow-worker-0.airflow-worker.data-eng.svc.cluster.local airflow 1 default 2023-05-29T15:11:04.597751+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_campaign-history-job_v002 2023-05-29T14:00:00+00:00 TriggerDagRunOperator 2023-05-29T15:11:06.770359+00:00 2023-05-29T15:11:07.224001+00:00 0:00:00.453642 387837 airflow-worker-1.airflow-worker.data-eng.svc.cluster.local airflow 1 default 2023-05-29T15:11:04.597778+00:00 2 default_pool
success campaign-flow-job_v002 check_cluster_status 2023-05-29T14:00:00+00:00 EmrJobFlowSensor 2023-05-29T15:00:52.539465+00:00 2023-05-29T15:10:54.515090+00:00 0:10:01.975625 387830 airflow-worker-0.airflow-worker.data-eng.svc.cluster.local airflow 3 default 2023-05-29T15:00:50.435083+00:00 2 default_pool
success campaign-flow-job_v002 create_cluster_and_add_emr_steps 2023-05-29T14:00:00+00:00 EmrCreateJobFlowOperator 2023-05-29T15:00:30.451197+00:00 2023-05-29T15:00:31.312955+00:00 0:00:00.861758 387828 airflow-worker-1.airflow-worker.data-eng.svc.cluster.local airflow 4 default 2023-05-29T15:00:28.414164+00:00 2 default_pool
success campaign-flow-job_v002 create_emr_steps 2023-05-29T14:00:00+00:00 PythonOperator 2023-05-29T15:00:08.993520+00:00 2023-05-29T15:00:09.933544+00:00 0:00:00.940024 387826 airflow-worker-0.airflow-worker.data-eng.svc.cluster.local airflow 5 default 2023-05-29T15:00:06.401952+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_booking-processing-job_v002 2023-05-29T13:00:00+00:00 TriggerDagRunOperator 2023-05-29T14:29:53.467382+00:00 2023-05-29T14:29:53.915155+00:00 0:00:00.447773 387820 airflow-worker-1.airflow-worker.data-eng.svc.cluster.local airflow 1 default 2023-05-29T14:29:51.124497+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_campaign-history-job_v002 2023-05-29T13:00:00+00:00 TriggerDagRunOperator 2023-05-29T14:29:53.332842+00:00 2023-05-29T14:29:53.765539+00:00 0:00:00.432697 387819 airflow-worker-0.airflow-worker.data-eng.svc.cluster.local airflow 1 default 2023-05-29T14:29:51.124527+00:00 2 default_pool
success campaign-flow-job_v002 check_cluster_status 2023-05-29T13:00:00+00:00 EmrJobFlowSensor 2023-05-29T14:19:47.686930+00:00 2023-05-29T14:29:49.395758+00:00 0:10:01.708828 387816 airflow-worker-1.airflow-worker.data-eng.svc.cluster.local airflow 3 default 2023-05-29T14:19:45.670139+00:00 2 default_pool
success campaign-flow-job_v002 create_cluster_and_add_emr_steps 2023-05-29T13:00:00+00:00 EmrCreateJobFlowOperator 2023-05-29T14:19:25.700890+00:00 2023-05-29T14:19:26.690540+00:00 0:00:00.989650 387813 airflow-worker-1.airflow-worker.data-eng.svc.cluster.local airflow 4 default 2023-05-29T14:19:23.648116+00:00 2 default_pool
success campaign-flow-job_v002 create_emr_steps 2023-05-29T13:00:00+00:00 PythonOperator 2023-05-29T14:19:05.759475+00:00 2023-05-29T14:19:06.711705+00:00 0:00:00.952230 387810 airflow-worker-0.airflow-worker.data-eng.svc.cluster.local airflow 5 default 2023-05-29T14:19:03.629431+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_campaign-history-job_v002 2023-05-29T12:00:00+00:00 TriggerDagRunOperator 2023-05-29T13:10:58.300311+00:00 2023-05-29T13:10:58.743658+00:00 0:00:00.443347 387798 airflow-worker-1.airflow-worker.data-eng.svc.cluster.local airflow 1 default 2023-05-29T13:10:56.224847+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_booking-processing-job_v002 2023-05-29T12:00:00+00:00 TriggerDagRunOperator 2023-05-29T13:10:58.211638+00:00 2023-05-29T13:10:58.630442+00:00 0:00:00.418804 387797 airflow-worker-0.airflow-worker.data-eng.svc.cluster.local airflow 1 default 2023-05-29T13:10:56.224814+00:00 2 default_pool
success campaign-flow-job_v002 check_cluster_status 2023-05-29T12:00:00+00:00 EmrJobFlowSensor 2023-05-29T13:00:47.213698+00:00 2023-05-29T13:10:49.066560+00:00 0:10:01.852862 387790 airflow-worker-1.airflow-worker.data-eng.svc.cluster.local airflow 3 default 2023-05-29T13:00:45.112623+00:00 2 default_pool
success campaign-flow-job_v002 create_cluster_and_add_emr_steps 2023-05-29T12:00:00+00:00 EmrCreateJobFlowOperator 2023-05-29T13:00:24.986363+00:00 2023-05-29T13:00:25.929370+00:00 0:00:00.943007 387788 airflow-worker-1.airflow-worker.data-eng.svc.cluster.local airflow 4 default 2023-05-29T13:00:23.005591+00:00 2 default_pool
success campaign-flow-job_v002 create_emr_steps 2023-05-29T12:00:00+00:00 PythonOperator 2023-05-29T13:00:05.181550+00:00 2023-05-29T13:00:06.113809+00:00 0:00:00.932259 387786 airflow-worker-0.airflow-worker.data-eng.svc.cluster.local airflow 5 default 2023-05-29T13:00:02.977012+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_campaign-history-job_v002 2023-05-29T11:00:00+00:00 TriggerDagRunOperator 2023-05-29T12:11:07.236139+00:00 2023-05-29T12:11:07.690634+00:00 0:00:00.454495 387779 airflow-worker-0.airflow-worker.data-eng.svc.cluster.local airflow 1 default 2023-05-29T12:11:05.158979+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_booking-processing-job_v002 2023-05-29T11:00:00+00:00 TriggerDagRunOperator 2023-05-29T12:11:07.157613+00:00 2023-05-29T12:11:07.618088+00:00 0:00:00.460475 387778 airflow-worker-1.airflow-worker.data-eng.svc.cluster.local airflow 1 default 2023-05-29T12:11:05.158950+00:00 2 default_pool
success campaign-flow-job_v002 check_cluster_status 2023-05-29T11:00:00+00:00 EmrJobFlowSensor 2023-05-29T12:00:49.924456+00:00 2023-05-29T12:10:51.668778+00:00 0:10:01.744322 387772 airflow-worker-0.airflow-worker.data-eng.svc.cluster.local airflow 3 default 2023-05-29T12:00:47.767986+00:00 2 default_pool
success campaign-flow-job_v002 create_cluster_and_add_emr_steps 2023-05-29T11:00:00+00:00 EmrCreateJobFlowOperator 2023-05-29T12:00:27.859781+00:00 2023-05-29T12:00:28.816192+00:00 0:00:00.956411 387770 airflow-worker-0.airflow-worker.data-eng.svc.cluster.local airflow 4 default 2023-05-29T12:00:25.750102+00:00 2 default_pool
success campaign-flow-job_v002 create_emr_steps 2023-05-29T11:00:00+00:00 PythonOperator 2023-05-29T12:00:06.563786+00:00 2023-05-29T12:00:07.487243+00:00 0:00:00.923457 387768 airflow-worker-0.airflow-worker.data-eng.svc.cluster.local airflow 5 default 2023-05-29T12:00:03.728082+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_campaign-history-job_v002 2023-05-29T10:00:00+00:00 TriggerDagRunOperator 2023-05-29T11:11:10.542031+00:00 2023-05-29T11:11:11.046851+00:00 0:00:00.504820 387759 airflow-worker-0.airflow-worker.data-eng.svc.cluster.local airflow 1 default 2023-05-29T11:11:08.261772+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_booking-processing-job_v002 2023-05-29T10:00:00+00:00 TriggerDagRunOperator 2023-05-29T11:11:10.399579+00:00 2023-05-29T11:11:10.840813+00:00 0:00:00.441234 387758 airflow-worker-1.airflow-worker.data-eng.svc.cluster.local airflow 1 default 2023-05-29T11:11:08.261740+00:00 2 default_pool
success campaign-flow-job_v002 check_cluster_status 2023-05-29T10:00:00+00:00 EmrJobFlowSensor 2023-05-29T11:01:03.618149+00:00 2023-05-29T11:11:05.479937+00:00 0:10:01.861788 387751 airflow-worker-1.airflow-worker.data-eng.svc.cluster.local airflow 3 default 2023-05-29T11:01:01.424543+00:00 2 default_pool
success campaign-flow-job_v002 create_cluster_and_add_emr_steps 2023-05-29T10:00:00+00:00 EmrCreateJobFlowOperator 2023-05-29T11:00:41.526598+00:00 2023-05-29T11:00:42.752035+00:00 0:00:01.225437 387749 airflow-worker-0.airflow-worker.data-eng.svc.cluster.local airflow 4 default 2023-05-29T11:00:39.405500+00:00 2 default_pool
success campaign-flow-job_v002 create_emr_steps 2023-05-29T10:00:00+00:00 PythonOperator 2023-05-29T11:00:19.666641+00:00 2023-05-29T11:00:20.652553+00:00 0:00:00.985912 387747 airflow-worker-0.airflow-worker.data-eng.svc.cluster.local airflow 5 default 2023-05-29T11:00:17.402620+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_booking-processing-job_v002 2023-05-29T09:00:00+00:00 TriggerDagRunOperator 2023-05-29T10:11:14.084579+00:00 2023-05-29T10:11:14.542564+00:00 0:00:00.457985 387736 airflow-worker-0.airflow-worker.data-eng.svc.cluster.local airflow 1 default 2023-05-29T10:11:11.782728+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_campaign-history-job_v002 2023-05-29T09:00:00+00:00 TriggerDagRunOperator 2023-05-29T10:11:13.979023+00:00 2023-05-29T10:11:14.484132+00:00 0:00:00.505109 387735 airflow-worker-1.airflow-worker.data-eng.svc.cluster.local airflow 1 default 2023-05-29T10:11:11.782757+00:00 2 default_pool
success campaign-flow-job_v002 check_cluster_status 2023-05-29T09:00:00+00:00 EmrJobFlowSensor 2023-05-29T10:00:49.789799+00:00 2023-05-29T10:10:51.602048+00:00 0:10:01.812249 387727 airflow-worker-0.airflow-worker.data-eng.svc.cluster.local airflow 3 default 2023-05-29T10:00:47.693184+00:00 2 default_pool
success campaign-flow-job_v002 create_cluster_and_add_emr_steps 2023-05-29T09:00:00+00:00 EmrCreateJobFlowOperator 2023-05-29T10:00:27.860944+00:00 2023-05-29T10:00:28.822291+00:00 0:00:00.961347 387725 airflow-worker-0.airflow-worker.data-eng.svc.cluster.local airflow 4 default 2023-05-29T10:00:25.703564+00:00 2 default_pool
success campaign-flow-job_v002 create_emr_steps 2023-05-29T09:00:00+00:00 PythonOperator 2023-05-29T10:00:06.155558+00:00 2023-05-29T10:00:07.075388+00:00 0:00:00.919830 387723 airflow-worker-1.airflow-worker.data-eng.svc.cluster.local airflow 5 default 2023-05-29T10:00:03.703623+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_campaign-history-job_v002 2023-05-29T08:00:00+00:00 TriggerDagRunOperator 2023-05-29T09:11:22.576184+00:00 2023-05-29T09:11:23.036161+00:00 0:00:00.459977 387713 airflow-worker-0.airflow-worker.data-eng.svc.cluster.local airflow 1 default 2023-05-29T09:11:20.311264+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_booking-processing-job_v002 2023-05-29T08:00:00+00:00 TriggerDagRunOperator 2023-05-29T09:11:22.482632+00:00 2023-05-29T09:11:22.914687+00:00 0:00:00.432055 387712 airflow-worker-1.airflow-worker.data-eng.svc.cluster.local airflow 1 default 2023-05-29T09:11:20.311237+00:00 2 default_pool
success campaign-flow-job_v002 check_cluster_status 2023-05-29T08:00:00+00:00 EmrJobFlowSensor 2023-05-29T09:01:03.169485+00:00 2023-05-29T09:11:05.056163+00:00 0:10:01.886678 387705 airflow-worker-0.airflow-worker.data-eng.svc.cluster.local airflow 3 default 2023-05-29T09:01:00.998075+00:00 2 default_pool
success campaign-flow-job_v002 create_cluster_and_add_emr_steps 2023-05-29T08:00:00+00:00 EmrCreateJobFlowOperator 2023-05-29T09:00:43.182467+00:00 2023-05-29T09:00:44.075922+00:00 0:00:00.893455 387703 airflow-worker-0.airflow-worker.data-eng.svc.cluster.local airflow 4 default 2023-05-29T09:00:40.986957+00:00 2 default_pool
success campaign-flow-job_v002 create_emr_steps 2023-05-29T08:00:00+00:00 PythonOperator 2023-05-29T09:00:21.173539+00:00 2023-05-29T09:00:22.104263+00:00 0:00:00.930724 387701 airflow-worker-0.airflow-worker.data-eng.svc.cluster.local airflow 5 default 2023-05-29T09:00:18.967896+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_booking-processing-job_v002 2023-05-29T07:00:00+00:00 TriggerDagRunOperator 2023-05-29T08:11:21.288746+00:00 2023-05-29T08:11:21.755574+00:00 0:00:00.466828 387693 airflow-worker-0.airflow-worker.data-eng.svc.cluster.local airflow 1 default 2023-05-29T08:11:18.703178+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_campaign-history-job_v002 2023-05-29T07:00:00+00:00 TriggerDagRunOperator 2023-05-29T08:11:21.181285+00:00 2023-05-29T08:11:21.628982+00:00 0:00:00.447697 387692 airflow-worker-1.airflow-worker.data-eng.svc.cluster.local airflow 1 default 2023-05-29T08:11:18.703208+00:00 2 default_pool
success campaign-flow-job_v002 check_cluster_status 2023-05-29T07:00:00+00:00 EmrJobFlowSensor 2023-05-29T08:00:56.153573+00:00 2023-05-29T08:10:58.197648+00:00 0:10:02.044075 387684 airflow-worker-1.airflow-worker.data-eng.svc.cluster.local airflow 3 default 2023-05-29T08:00:53.915650+00:00 2 default_pool
success campaign-flow-job_v002 create_cluster_and_add_emr_steps 2023-05-29T07:00:00+00:00 EmrCreateJobFlowOperator 2023-05-29T08:00:34.142810+00:00 2023-05-29T08:00:35.075739+00:00 0:00:00.932929 387682 airflow-worker-0.airflow-worker.data-eng.svc.cluster.local airflow 4 default 2023-05-29T08:00:31.902190+00:00 2 default_pool
success campaign-flow-job_v002 create_emr_steps 2023-05-29T07:00:00+00:00 PythonOperator 2023-05-29T08:00:12.050268+00:00 2023-05-29T08:00:13.039511+00:00 0:00:00.989243 387680 airflow-worker-0.airflow-worker.data-eng.svc.cluster.local airflow 5 default 2023-05-29T08:00:09.872052+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_campaign-history-job_v002 2023-05-29T06:00:00+00:00 TriggerDagRunOperator 2023-05-29T07:17:07.819940+00:00 2023-05-29T07:17:08.260605+00:00 0:00:00.440665 387671 airflow-worker-0.airflow-worker.data-eng.svc.cluster.local airflow 1 default 2023-05-29T07:17:05.490691+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_booking-processing-job_v002 2023-05-29T06:00:00+00:00 TriggerDagRunOperator 2023-05-29T07:17:07.736674+00:00 2023-05-29T07:17:08.185221+00:00 0:00:00.448547 387670 airflow-worker-1.airflow-worker.data-eng.svc.cluster.local airflow 1 default 2023-05-29T07:17:05.490662+00:00 2 default_pool
success campaign-flow-job_v002 check_cluster_status 2023-05-29T06:00:00+00:00 EmrJobFlowSensor 2023-05-29T07:04:37.472499+00:00 2023-05-29T07:14:39.157658+00:00 0:10:01.685159 387663 airflow-worker-0.airflow-worker.data-eng.svc.cluster.local airflow 3 default 2023-05-29T07:04:35.339593+00:00 2 default_pool
success campaign-flow-job_v002 create_cluster_and_add_emr_steps 2023-05-29T06:00:00+00:00 EmrCreateJobFlowOperator 2023-05-29T07:04:15.311135+00:00 2023-05-29T07:04:16.284296+00:00 0:00:00.973161 387661 airflow-worker-1.airflow-worker.data-eng.svc.cluster.local airflow 4 default 2023-05-29T07:04:13.310958+00:00 2 default_pool
success campaign-flow-job_v002 create_emr_steps 2023-05-29T06:00:00+00:00 PythonOperator 2023-05-29T07:03:55.684894+00:00 2023-05-29T07:03:56.614638+00:00 0:00:00.929744 387659 airflow-worker-0.airflow-worker.data-eng.svc.cluster.local airflow 5 default 2023-05-29T07:03:53.350010+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_campaign-history-job_v002 2023-05-29T05:00:00+00:00 TriggerDagRunOperator 2023-05-29T06:11:15.653077+00:00 2023-05-29T06:11:16.164457+00:00 0:00:00.511380 387649 airflow-worker-0.airflow-worker.data-eng.svc.cluster.local airflow 1 default 2023-05-29T06:11:13.418116+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_booking-processing-job_v002 2023-05-29T05:00:00+00:00 TriggerDagRunOperator 2023-05-29T06:11:15.592543+00:00 2023-05-29T06:11:16.068441+00:00 0:00:00.475898 387648 airflow-worker-1.airflow-worker.data-eng.svc.cluster.local airflow 1 default 2023-05-29T06:11:13.418088+00:00 2 default_pool
success campaign-flow-job_v002 check_cluster_status 2023-05-29T05:00:00+00:00 EmrJobFlowSensor 2023-05-29T06:00:55.206068+00:00 2023-05-29T06:10:57.202047+00:00 0:10:01.995979 387641 airflow-worker-0.airflow-worker.data-eng.svc.cluster.local airflow 3 default 2023-05-29T06:00:52.898361+00:00 2 default_pool
success campaign-flow-job_v002 create_cluster_and_add_emr_steps 2023-05-29T05:00:00+00:00 EmrCreateJobFlowOperator 2023-05-29T06:00:33.001783+00:00 2023-05-29T06:00:33.966207+00:00 0:00:00.964424 387639 airflow-worker-0.airflow-worker.data-eng.svc.cluster.local airflow 4 default 2023-05-29T06:00:30.875333+00:00 2 default_pool
success campaign-flow-job_v002 create_emr_steps 2023-05-29T05:00:00+00:00 PythonOperator 2023-05-29T06:00:13.704377+00:00 2023-05-29T06:00:15.297689+00:00 0:00:01.593312 387637 airflow-worker-0.airflow-worker.data-eng.svc.cluster.local airflow 5 default 2023-05-29T06:00:10.864679+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_campaign-history-job_v002 2023-05-29T04:00:00+00:00 TriggerDagRunOperator 2023-05-29T05:11:21.318991+00:00 2023-05-29T05:11:21.779959+00:00 0:00:00.460968 387627 airflow-worker-0.airflow-worker.data-eng.svc.cluster.local airflow 1 default 2023-05-29T05:11:18.822587+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_booking-processing-job_v002 2023-05-29T04:00:00+00:00 TriggerDagRunOperator 2023-05-29T05:11:21.182757+00:00 2023-05-29T05:11:21.649777+00:00 0:00:00.467020 387626 airflow-worker-1.airflow-worker.data-eng.svc.cluster.local airflow 1 default 2023-05-29T05:11:18.822559+00:00 2 default_pool
success campaign-flow-job_v002 check_cluster_status 2023-05-29T04:00:00+00:00 EmrJobFlowSensor 2023-05-29T05:00:59.868576+00:00 2023-05-29T05:11:02.007256+00:00 0:10:02.138680 387619 airflow-worker-0.airflow-worker.data-eng.svc.cluster.local airflow 3 default 2023-05-29T05:00:57.609738+00:00 2 default_pool
success campaign-flow-job_v002 create_cluster_and_add_emr_steps 2023-05-29T04:00:00+00:00 EmrCreateJobFlowOperator 2023-05-29T05:00:39.630112+00:00 2023-05-29T05:00:40.501497+00:00 0:00:00.871385 387617 airflow-worker-1.airflow-worker.data-eng.svc.cluster.local airflow 4 default 2023-05-29T05:00:37.579508+00:00 2 default_pool
success campaign-flow-job_v002 create_emr_steps 2023-05-29T04:00:00+00:00 PythonOperator 2023-05-29T05:00:17.638492+00:00 2023-05-29T05:00:18.587041+00:00 0:00:00.948549 387615 airflow-worker-1.airflow-worker.data-eng.svc.cluster.local airflow 5 default 2023-05-29T05:00:15.562377+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_booking-processing-job_v002 2023-05-29T03:00:00+00:00 TriggerDagRunOperator 2023-05-29T04:11:24.143553+00:00 2023-05-29T04:11:24.618922+00:00 0:00:00.475369 387605 airflow-worker-0.airflow-worker.data-eng.svc.cluster.local airflow 1 default 2023-05-29T04:11:21.928459+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_campaign-history-job_v002 2023-05-29T03:00:00+00:00 TriggerDagRunOperator 2023-05-29T04:11:24.140432+00:00 2023-05-29T04:11:24.573036+00:00 0:00:00.432604 387604 airflow-worker-1.airflow-worker.data-eng.svc.cluster.local airflow 1 default 2023-05-29T04:11:21.928490+00:00 2 default_pool
success campaign-flow-job_v002 check_cluster_status 2023-05-29T03:00:00+00:00 EmrJobFlowSensor 2023-05-29T04:01:08.360749+00:00 2023-05-29T04:11:10.125549+00:00 0:10:01.764800 387597 airflow-worker-0.airflow-worker.data-eng.svc.cluster.local airflow 3 default 2023-05-29T04:01:06.205169+00:00 2 default_pool
success campaign-flow-job_v002 create_cluster_and_add_emr_steps 2023-05-29T03:00:00+00:00 EmrCreateJobFlowOperator 2023-05-29T04:00:46.278450+00:00 2023-05-29T04:00:47.162135+00:00 0:00:00.883685 387595 airflow-worker-0.airflow-worker.data-eng.svc.cluster.local airflow 4 default 2023-05-29T04:00:44.155787+00:00 2 default_pool
success campaign-flow-job_v002 create_emr_steps 2023-05-29T03:00:00+00:00 PythonOperator 2023-05-29T04:00:24.605966+00:00 2023-05-29T04:00:25.500055+00:00 0:00:00.894089 387593 airflow-worker-0.airflow-worker.data-eng.svc.cluster.local airflow 5 default 2023-05-29T04:00:22.132062+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_campaign-history-job_v002 2023-05-29T02:00:00+00:00 TriggerDagRunOperator 2023-05-29T03:11:26.366988+00:00 2023-05-29T03:11:26.789042+00:00 0:00:00.422054 387582 airflow-worker-0.airflow-worker.data-eng.svc.cluster.local airflow 1 default 2023-05-29T03:11:24.105612+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_booking-processing-job_v002 2023-05-29T02:00:00+00:00 TriggerDagRunOperator 2023-05-29T03:11:26.271203+00:00 2023-05-29T03:11:26.728444+00:00 0:00:00.457241 387581 airflow-worker-1.airflow-worker.data-eng.svc.cluster.local airflow 1 default 2023-05-29T03:11:24.105585+00:00 2 default_pool
success campaign-flow-job_v002 check_cluster_status 2023-05-29T02:00:00+00:00 EmrJobFlowSensor 2023-05-29T03:01:01.891017+00:00 2023-05-29T03:11:03.779638+00:00 0:10:01.888621 387574 airflow-worker-0.airflow-worker.data-eng.svc.cluster.local airflow 3 default 2023-05-29T03:00:59.602033+00:00 2 default_pool