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 check_cluster_status 2023-02-13T21:00:00+00:00 EmrJobFlowSensor 2023-02-13T22:01:01.744664+00:00 2023-02-13T22:11:03.614344+00:00 0:10:01.869680 339231 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2023-02-13T22:00:59.503653+00:00 2 default_pool
success campaign-flow-job_v002 create_cluster_and_add_emr_steps 2023-02-13T21:00:00+00:00 EmrCreateJobFlowOperator 2023-02-13T22:00:41.707272+00:00 2023-02-13T22:00:42.586524+00:00 0:00:00.879252 339229 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 4 default 2023-02-13T22:00:39.485046+00:00 2 default_pool
success campaign-flow-job_v002 create_emr_steps 2023-02-13T21:00:00+00:00 PythonOperator 2023-02-13T22:00:17.631529+00:00 2023-02-13T22:00:20.520241+00:00 0:00:02.888712 339227 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 5 default 2023-02-13T22:00:15.438369+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_booking-processing-job_v002 2023-02-13T20:00:00+00:00 TriggerDagRunOperator 2023-02-13T21:10:54.891970+00:00 2023-02-13T21:10:55.426995+00:00 0:00:00.535025 339213 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2023-02-13T21:10:51.959032+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_campaign-history-job_v002 2023-02-13T20:00:00+00:00 TriggerDagRunOperator 2023-02-13T21:10:54.821430+00:00 2023-02-13T21:10:55.347160+00:00 0:00:00.525730 339212 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2023-02-13T21:10:51.959060+00:00 2 default_pool
success campaign-flow-job_v002 check_cluster_status 2023-02-13T20:00:00+00:00 EmrJobFlowSensor 2023-02-13T21:00:48.294729+00:00 2023-02-13T21:10:50.034106+00:00 0:10:01.739377 339204 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2023-02-13T21:00:46.058700+00:00 2 default_pool
success campaign-flow-job_v002 create_cluster_and_add_emr_steps 2023-02-13T20:00:00+00:00 EmrCreateJobFlowOperator 2023-02-13T21:00:26.372352+00:00 2023-02-13T21:00:27.210022+00:00 0:00:00.837670 339202 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 4 default 2023-02-13T21:00:24.036394+00:00 2 default_pool
success campaign-flow-job_v002 create_emr_steps 2023-02-13T20:00:00+00:00 PythonOperator 2023-02-13T21:00:04.360217+00:00 2023-02-13T21:00:10.496399+00:00 0:00:06.136182 339200 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 5 default 2023-02-13T21:00:01.971212+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_booking-processing-job_v002 2023-02-13T19:00:00+00:00 TriggerDagRunOperator 2023-02-13T20:11:14.672293+00:00 2023-02-13T20:11:15.240677+00:00 0:00:00.568384 339187 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2023-02-13T20:11:12.080878+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_campaign-history-job_v002 2023-02-13T19:00:00+00:00 TriggerDagRunOperator 2023-02-13T20:11:14.444795+00:00 2023-02-13T20:11:14.949791+00:00 0:00:00.504996 339186 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2023-02-13T20:11:12.080907+00:00 2 default_pool
success campaign-flow-job_v002 check_cluster_status 2023-02-13T19:00:00+00:00 EmrJobFlowSensor 2023-02-13T20:01:07.610003+00:00 2023-02-13T20:11:09.839977+00:00 0:10:02.229974 339179 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2023-02-13T20:01:05.192386+00:00 2 default_pool
success campaign-flow-job_v002 create_cluster_and_add_emr_steps 2023-02-13T19:00:00+00:00 EmrCreateJobFlowOperator 2023-02-13T20:00:45.617711+00:00 2023-02-13T20:00:46.422658+00:00 0:00:00.804947 339178 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 4 default 2023-02-13T20:00:43.160645+00:00 2 default_pool
success campaign-flow-job_v002 create_emr_steps 2023-02-13T19:00:00+00:00 PythonOperator 2023-02-13T20:00:23.452006+00:00 2023-02-13T20:00:27.252836+00:00 0:00:03.800830 339175 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 5 default 2023-02-13T20:00:21.189296+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_booking-processing-job_v002 2023-02-13T18:00:00+00:00 TriggerDagRunOperator 2023-02-13T19:11:10.303585+00:00 2023-02-13T19:11:10.789132+00:00 0:00:00.485547 339161 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2023-02-13T19:11:07.896045+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_campaign-history-job_v002 2023-02-13T18:00:00+00:00 TriggerDagRunOperator 2023-02-13T19:11:10.207845+00:00 2023-02-13T19:11:10.707924+00:00 0:00:00.500079 339160 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2023-02-13T19:11:07.896079+00:00 2 default_pool
success campaign-flow-job_v002 check_cluster_status 2023-02-13T18:00:00+00:00 EmrJobFlowSensor 2023-02-13T19:00:50.345432+00:00 2023-02-13T19:10:52.143147+00:00 0:10:01.797715 339151 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2023-02-13T19:00:48.104495+00:00 2 default_pool
success campaign-flow-job_v002 create_cluster_and_add_emr_steps 2023-02-13T18:00:00+00:00 EmrCreateJobFlowOperator 2023-02-13T19:00:28.366050+00:00 2023-02-13T19:00:29.319047+00:00 0:00:00.952997 339150 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 4 default 2023-02-13T19:00:26.081165+00:00 2 default_pool
success campaign-flow-job_v002 create_emr_steps 2023-02-13T18:00:00+00:00 PythonOperator 2023-02-13T19:00:06.382895+00:00 2023-02-13T19:00:10.116914+00:00 0:00:03.734019 339148 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 5 default 2023-02-13T19:00:04.060557+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_campaign-history-job_v002 2023-02-13T17:00:00+00:00 TriggerDagRunOperator 2023-02-13T18:11:09.324727+00:00 2023-02-13T18:11:09.819820+00:00 0:00:00.495093 339134 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2023-02-13T18:11:06.898522+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_booking-processing-job_v002 2023-02-13T17:00:00+00:00 TriggerDagRunOperator 2023-02-13T18:11:09.130014+00:00 2023-02-13T18:11:09.574854+00:00 0:00:00.444840 339133 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2023-02-13T18:11:06.898493+00:00 2 default_pool
success campaign-flow-job_v002 check_cluster_status 2023-02-13T17:00:00+00:00 EmrJobFlowSensor 2023-02-13T18:00:50.545201+00:00 2023-02-13T18:10:52.392935+00:00 0:10:01.847734 339127 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2023-02-13T18:00:47.585950+00:00 2 default_pool
success campaign-flow-job_v002 create_cluster_and_add_emr_steps 2023-02-13T17:00:00+00:00 EmrCreateJobFlowOperator 2023-02-13T18:00:30.329169+00:00 2023-02-13T18:00:31.530684+00:00 0:00:01.201515 339125 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 4 default 2023-02-13T18:00:25.626029+00:00 2 default_pool
success campaign-flow-job_v002 create_emr_steps 2023-02-13T17:00:00+00:00 PythonOperator 2023-02-13T18:00:06.468756+00:00 2023-02-13T18:00:09.357199+00:00 0:00:02.888443 339123 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 5 default 2023-02-13T18:00:03.399089+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_booking-processing-job_v002 2023-02-13T16:00:00+00:00 TriggerDagRunOperator 2023-02-13T17:11:04.668827+00:00 2023-02-13T17:11:05.165953+00:00 0:00:00.497126 339108 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2023-02-13T17:11:01.912571+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_campaign-history-job_v002 2023-02-13T16:00:00+00:00 TriggerDagRunOperator 2023-02-13T17:11:04.495914+00:00 2023-02-13T17:11:04.963568+00:00 0:00:00.467654 339107 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2023-02-13T17:11:01.912616+00:00 2 default_pool
success campaign-flow-job_v002 check_cluster_status 2023-02-13T16:00:00+00:00 EmrJobFlowSensor 2023-02-13T17:00:48.564975+00:00 2023-02-13T17:10:50.318457+00:00 0:10:01.753482 339101 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2023-02-13T17:00:46.002437+00:00 2 default_pool
success campaign-flow-job_v002 create_cluster_and_add_emr_steps 2023-02-13T16:00:00+00:00 EmrCreateJobFlowOperator 2023-02-13T17:00:26.573896+00:00 2023-02-13T17:00:27.437052+00:00 0:00:00.863156 339099 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 4 default 2023-02-13T17:00:24.002908+00:00 2 default_pool
success campaign-flow-job_v002 create_emr_steps 2023-02-13T16:00:00+00:00 PythonOperator 2023-02-13T17:00:04.568084+00:00 2023-02-13T17:00:07.495790+00:00 0:00:02.927706 339096 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 5 default 2023-02-13T17:00:01.592774+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_campaign-history-job_v002 2023-02-13T15:00:00+00:00 TriggerDagRunOperator 2023-02-13T16:11:16.465050+00:00 2023-02-13T16:11:16.966841+00:00 0:00:00.501791 339082 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2023-02-13T16:11:13.965348+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_booking-processing-job_v002 2023-02-13T15:00:00+00:00 TriggerDagRunOperator 2023-02-13T16:11:16.139290+00:00 2023-02-13T16:11:16.604296+00:00 0:00:00.465006 339081 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2023-02-13T16:11:13.965318+00:00 2 default_pool
success campaign-flow-job_v002 check_cluster_status 2023-02-13T15:00:00+00:00 EmrJobFlowSensor 2023-02-13T16:00:59.846744+00:00 2023-02-13T16:11:01.911194+00:00 0:10:02.064450 339075 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2023-02-13T16:00:57.552894+00:00 2 default_pool
success campaign-flow-job_v002 create_cluster_and_add_emr_steps 2023-02-13T15:00:00+00:00 EmrCreateJobFlowOperator 2023-02-13T16:00:37.800674+00:00 2023-02-13T16:00:38.697185+00:00 0:00:00.896511 339073 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 4 default 2023-02-13T16:00:35.534224+00:00 2 default_pool
success campaign-flow-job_v002 create_emr_steps 2023-02-13T15:00:00+00:00 PythonOperator 2023-02-13T16:00:17.734227+00:00 2023-02-13T16:00:20.682722+00:00 0:00:02.948495 339071 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 5 default 2023-02-13T16:00:15.517368+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_campaign-history-job_v002 2023-02-13T14:00:00+00:00 TriggerDagRunOperator 2023-02-13T15:11:11.237445+00:00 2023-02-13T15:11:11.720276+00:00 0:00:00.482831 339056 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2023-02-13T15:11:08.595250+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_booking-processing-job_v002 2023-02-13T14:00:00+00:00 TriggerDagRunOperator 2023-02-13T15:11:10.940620+00:00 2023-02-13T15:11:11.518024+00:00 0:00:00.577404 339055 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2023-02-13T15:11:08.595205+00:00 2 default_pool
success campaign-flow-job_v002 check_cluster_status 2023-02-13T14:00:00+00:00 EmrJobFlowSensor 2023-02-13T15:00:53.287801+00:00 2023-02-13T15:10:55.252029+00:00 0:10:01.964228 339048 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2023-02-13T15:00:51.025815+00:00 2 default_pool
success campaign-flow-job_v002 create_cluster_and_add_emr_steps 2023-02-13T14:00:00+00:00 EmrCreateJobFlowOperator 2023-02-13T15:00:33.345950+00:00 2023-02-13T15:00:34.245727+00:00 0:00:00.899777 339046 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 4 default 2023-02-13T15:00:31.003224+00:00 2 default_pool
success campaign-flow-job_v002 create_emr_steps 2023-02-13T14:00:00+00:00 PythonOperator 2023-02-13T15:00:11.507642+00:00 2023-02-13T15:00:14.466306+00:00 0:00:02.958664 339044 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 5 default 2023-02-13T15:00:08.958375+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_booking-processing-job_v002 2023-02-13T13:00:00+00:00 TriggerDagRunOperator 2023-02-13T14:11:55.773809+00:00 2023-02-13T14:11:56.232796+00:00 0:00:00.458987 339032 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2023-02-13T14:11:53.101181+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_campaign-history-job_v002 2023-02-13T13:00:00+00:00 TriggerDagRunOperator 2023-02-13T14:11:55.471513+00:00 2023-02-13T14:11:55.936827+00:00 0:00:00.465314 339031 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2023-02-13T14:11:53.101211+00:00 2 default_pool
success campaign-flow-job_v002 check_cluster_status 2023-02-13T13:00:00+00:00 EmrJobFlowSensor 2023-02-13T14:01:42.110614+00:00 2023-02-13T14:11:43.907763+00:00 0:10:01.797149 339024 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2023-02-13T14:01:39.795392+00:00 2 default_pool
success campaign-flow-job_v002 create_cluster_and_add_emr_steps 2023-02-13T13:00:00+00:00 EmrCreateJobFlowOperator 2023-02-13T14:01:20.075575+00:00 2023-02-13T14:01:21.007861+00:00 0:00:00.932286 339022 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 4 default 2023-02-13T14:01:17.765943+00:00 2 default_pool
success campaign-flow-job_v002 create_emr_steps 2023-02-13T13:00:00+00:00 PythonOperator 2023-02-13T14:01:00.533811+00:00 2023-02-13T14:01:06.492723+00:00 0:00:05.958912 339020 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 5 default 2023-02-13T14:00:57.796846+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_campaign-history-job_v002 2023-02-13T12:00:00+00:00 TriggerDagRunOperator 2023-02-13T13:11:19.305827+00:00 2023-02-13T13:11:20.172751+00:00 0:00:00.866924 339008 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2023-02-13T13:11:16.672894+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_booking-processing-job_v002 2023-02-13T12:00:00+00:00 TriggerDagRunOperator 2023-02-13T13:11:19.243194+00:00 2023-02-13T13:11:20.078114+00:00 0:00:00.834920 339007 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2023-02-13T13:11:16.672860+00:00 2 default_pool
success campaign-flow-job_v002 check_cluster_status 2023-02-13T12:00:00+00:00 EmrJobFlowSensor 2023-02-13T13:00:55.780745+00:00 2023-02-13T13:10:57.664206+00:00 0:10:01.883461 339001 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2023-02-13T13:00:53.439589+00:00 2 default_pool
success campaign-flow-job_v002 create_cluster_and_add_emr_steps 2023-02-13T12:00:00+00:00 EmrCreateJobFlowOperator 2023-02-13T13:00:36.437377+00:00 2023-02-13T13:00:37.272261+00:00 0:00:00.834884 338999 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 4 default 2023-02-13T13:00:33.333179+00:00 2 default_pool
success campaign-flow-job_v002 create_emr_steps 2023-02-13T12:00:00+00:00 PythonOperator 2023-02-13T13:00:13.862951+00:00 2023-02-13T13:00:17.635185+00:00 0:00:03.772234 338997 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 5 default 2023-02-13T13:00:11.262135+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_campaign-history-job_v002 2023-02-13T11:00:00+00:00 TriggerDagRunOperator 2023-02-13T12:11:47.869523+00:00 2023-02-13T12:11:48.402834+00:00 0:00:00.533311 338983 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2023-02-13T12:11:45.234244+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_booking-processing-job_v002 2023-02-13T11:00:00+00:00 TriggerDagRunOperator 2023-02-13T12:11:47.613823+00:00 2023-02-13T12:11:48.160200+00:00 0:00:00.546377 338982 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2023-02-13T12:11:45.234215+00:00 2 default_pool
success campaign-flow-job_v002 check_cluster_status 2023-02-13T11:00:00+00:00 EmrJobFlowSensor 2023-02-13T12:01:30.984567+00:00 2023-02-13T12:11:32.922064+00:00 0:10:01.937497 338975 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2023-02-13T12:01:28.659976+00:00 2 default_pool
success campaign-flow-job_v002 create_cluster_and_add_emr_steps 2023-02-13T11:00:00+00:00 EmrCreateJobFlowOperator 2023-02-13T12:01:11.005716+00:00 2023-02-13T12:01:11.981568+00:00 0:00:00.975852 338973 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 4 default 2023-02-13T12:01:08.637898+00:00 2 default_pool
success campaign-flow-job_v002 create_emr_steps 2023-02-13T11:00:00+00:00 PythonOperator 2023-02-13T12:00:49.737100+00:00 2023-02-13T12:00:52.995878+00:00 0:00:03.258778 338971 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 5 default 2023-02-13T12:00:46.601876+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_campaign-history-job_v002 2023-02-13T10:00:00+00:00 TriggerDagRunOperator 2023-02-13T11:10:58.197641+00:00 2023-02-13T11:10:58.716864+00:00 0:00:00.519223 338957 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2023-02-13T11:10:55.531466+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_booking-processing-job_v002 2023-02-13T10:00:00+00:00 TriggerDagRunOperator 2023-02-13T11:10:57.993586+00:00 2023-02-13T11:10:58.566330+00:00 0:00:00.572744 338956 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2023-02-13T11:10:55.531437+00:00 2 default_pool
success campaign-flow-job_v002 check_cluster_status 2023-02-13T10:00:00+00:00 EmrJobFlowSensor 2023-02-13T11:00:50.978945+00:00 2023-02-13T11:10:52.817470+00:00 0:10:01.838525 338949 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2023-02-13T11:00:48.807905+00:00 2 default_pool
success campaign-flow-job_v002 create_cluster_and_add_emr_steps 2023-02-13T10:00:00+00:00 EmrCreateJobFlowOperator 2023-02-13T11:00:31.012906+00:00 2023-02-13T11:00:31.956817+00:00 0:00:00.943911 338947 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 4 default 2023-02-13T11:00:28.754594+00:00 2 default_pool
success campaign-flow-job_v002 create_emr_steps 2023-02-13T10:00:00+00:00 PythonOperator 2023-02-13T11:00:09.038240+00:00 2023-02-13T11:00:13.013091+00:00 0:00:03.974851 338945 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 5 default 2023-02-13T11:00:06.735339+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_campaign-history-job_v002 2023-02-13T09:00:00+00:00 TriggerDagRunOperator 2023-02-13T10:11:05.691514+00:00 2023-02-13T10:11:06.212936+00:00 0:00:00.521422 338931 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2023-02-13T10:11:03.051608+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_booking-processing-job_v002 2023-02-13T09:00:00+00:00 TriggerDagRunOperator 2023-02-13T10:11:05.427241+00:00 2023-02-13T10:11:05.872014+00:00 0:00:00.444773 338930 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2023-02-13T10:11:03.051577+00:00 2 default_pool
success campaign-flow-job_v002 check_cluster_status 2023-02-13T09:00:00+00:00 EmrJobFlowSensor 2023-02-13T10:00:49.947147+00:00 2023-02-13T10:10:51.797838+00:00 0:10:01.850691 338923 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2023-02-13T10:00:47.590441+00:00 2 default_pool
success campaign-flow-job_v002 create_cluster_and_add_emr_steps 2023-02-13T09:00:00+00:00 EmrCreateJobFlowOperator 2023-02-13T10:00:27.754265+00:00 2023-02-13T10:00:28.625930+00:00 0:00:00.871665 338921 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 4 default 2023-02-13T10:00:25.501142+00:00 2 default_pool
success campaign-flow-job_v002 create_emr_steps 2023-02-13T09:00:00+00:00 PythonOperator 2023-02-13T10:00:07.976302+00:00 2023-02-13T10:00:11.990107+00:00 0:00:04.013805 338920 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 5 default 2023-02-13T10:00:05.426214+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_campaign-history-job_v002 2023-02-13T08:00:00+00:00 TriggerDagRunOperator 2023-02-13T09:11:23.194475+00:00 2023-02-13T09:11:23.909731+00:00 0:00:00.715256 338907 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2023-02-13T09:11:17.663507+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_booking-processing-job_v002 2023-02-13T08:00:00+00:00 TriggerDagRunOperator 2023-02-13T09:11:19.917626+00:00 2023-02-13T09:11:20.374050+00:00 0:00:00.456424 338905 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2023-02-13T09:11:17.663480+00:00 2 default_pool
success campaign-flow-job_v002 check_cluster_status 2023-02-13T08:00:00+00:00 EmrJobFlowSensor 2023-02-13T09:01:06.278223+00:00 2023-02-13T09:11:08.055242+00:00 0:10:01.777019 338900 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2023-02-13T09:01:03.853590+00:00 2 default_pool
success campaign-flow-job_v002 create_cluster_and_add_emr_steps 2023-02-13T08:00:00+00:00 EmrCreateJobFlowOperator 2023-02-13T09:00:46.256871+00:00 2023-02-13T09:00:47.109455+00:00 0:00:00.852584 338898 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 4 default 2023-02-13T09:00:43.904717+00:00 2 default_pool
success campaign-flow-job_v002 create_emr_steps 2023-02-13T08:00:00+00:00 PythonOperator 2023-02-13T09:00:24.487064+00:00 2023-02-13T09:00:27.282033+00:00 0:00:02.794969 338896 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 5 default 2023-02-13T09:00:21.799204+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_booking-processing-job_v002 2023-02-13T07:00:00+00:00 TriggerDagRunOperator 2023-02-13T08:17:01.326729+00:00 2023-02-13T08:17:02.034161+00:00 0:00:00.707432 338883 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2023-02-13T08:16:58.291310+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_campaign-history-job_v002 2023-02-13T07:00:00+00:00 TriggerDagRunOperator 2023-02-13T08:17:00.822955+00:00 2023-02-13T08:17:01.329282+00:00 0:00:00.506327 338882 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2023-02-13T08:16:58.291357+00:00 2 default_pool
success campaign-flow-job_v002 check_cluster_status 2023-02-13T07:00:00+00:00 EmrJobFlowSensor 2023-02-13T08:06:52.399932+00:00 2023-02-13T08:16:54.089258+00:00 0:10:01.689326 338877 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2023-02-13T08:06:50.165944+00:00 2 default_pool
success campaign-flow-job_v002 create_cluster_and_add_emr_steps 2023-02-13T07:00:00+00:00 EmrCreateJobFlowOperator 2023-02-13T08:06:30.633440+00:00 2023-02-13T08:06:31.506642+00:00 0:00:00.873202 338874 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 4 default 2023-02-13T08:06:28.149271+00:00 2 default_pool
success campaign-flow-job_v002 create_emr_steps 2023-02-13T07:00:00+00:00 PythonOperator 2023-02-13T08:06:08.661602+00:00 2023-02-13T08:06:12.464139+00:00 0:00:03.802537 338871 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 5 default 2023-02-13T08:06:06.161164+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_booking-processing-job_v002 2023-02-13T06:00:00+00:00 TriggerDagRunOperator 2023-02-13T07:19:08.511859+00:00 2023-02-13T07:19:08.996761+00:00 0:00:00.484902 338858 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2023-02-13T07:19:05.964748+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_campaign-history-job_v002 2023-02-13T06:00:00+00:00 TriggerDagRunOperator 2023-02-13T07:19:08.390214+00:00 2023-02-13T07:19:08.896246+00:00 0:00:00.506032 338857 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2023-02-13T07:19:05.964778+00:00 2 default_pool
success campaign-flow-job_v002 check_cluster_status 2023-02-13T06:00:00+00:00 EmrJobFlowSensor 2023-02-13T07:08:53.979715+00:00 2023-02-13T07:18:55.841981+00:00 0:10:01.862266 338853 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2023-02-13T07:08:51.602804+00:00 2 default_pool
success campaign-flow-job_v002 create_cluster_and_add_emr_steps 2023-02-13T06:00:00+00:00 EmrCreateJobFlowOperator 2023-02-13T07:08:31.762272+00:00 2023-02-13T07:08:32.597902+00:00 0:00:00.835630 338850 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 4 default 2023-02-13T07:08:29.551475+00:00 2 default_pool
success campaign-flow-job_v002 create_emr_steps 2023-02-13T06:00:00+00:00 PythonOperator 2023-02-13T07:08:12.433237+00:00 2023-02-13T07:08:17.251805+00:00 0:00:04.818568 338847 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 5 default 2023-02-13T07:08:09.500048+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_campaign-history-job_v002 2023-02-13T05:00:00+00:00 TriggerDagRunOperator 2023-02-13T06:12:48.502819+00:00 2023-02-13T06:12:49.197619+00:00 0:00:00.694800 338832 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2023-02-13T06:12:44.334762+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_booking-processing-job_v002 2023-02-13T05:00:00+00:00 TriggerDagRunOperator 2023-02-13T06:12:46.552497+00:00 2023-02-13T06:12:46.995869+00:00 0:00:00.443372 338831 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2023-02-13T06:12:44.334732+00:00 2 default_pool
success campaign-flow-job_v002 check_cluster_status 2023-02-13T05:00:00+00:00 EmrJobFlowSensor 2023-02-13T06:00:52.684859+00:00 2023-02-13T06:10:54.492361+00:00 0:10:01.807502 338826 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2023-02-13T06:00:50.426271+00:00 2 default_pool
success campaign-flow-job_v002 create_cluster_and_add_emr_steps 2023-02-13T05:00:00+00:00 EmrCreateJobFlowOperator 2023-02-13T06:00:30.582855+00:00 2023-02-13T06:00:31.431550+00:00 0:00:00.848695 338824 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 4 default 2023-02-13T06:00:28.350694+00:00 2 default_pool
success campaign-flow-job_v002 create_emr_steps 2023-02-13T05:00:00+00:00 PythonOperator 2023-02-13T06:00:08.672214+00:00 2023-02-13T06:00:12.530704+00:00 0:00:03.858490 338822 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 5 default 2023-02-13T06:00:06.333184+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_campaign-history-job_v002 2023-02-13T04:00:00+00:00 TriggerDagRunOperator 2023-02-13T05:11:21.482404+00:00 2023-02-13T05:11:21.963438+00:00 0:00:00.481034 338808 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2023-02-13T05:11:19.162840+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_booking-processing-job_v002 2023-02-13T04:00:00+00:00 TriggerDagRunOperator 2023-02-13T05:11:21.469599+00:00 2023-02-13T05:11:21.965954+00:00 0:00:00.496355 338807 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2023-02-13T05:11:19.162800+00:00 2 default_pool
success campaign-flow-job_v002 check_cluster_status 2023-02-13T04:00:00+00:00 EmrJobFlowSensor 2023-02-13T05:01:04.083766+00:00 2023-02-13T05:11:05.812847+00:00 0:10:01.729081 338801 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2023-02-13T05:01:01.861910+00:00 2 default_pool
success campaign-flow-job_v002 create_cluster_and_add_emr_steps 2023-02-13T04:00:00+00:00 EmrCreateJobFlowOperator 2023-02-13T05:00:44.249211+00:00 2023-02-13T05:00:45.236092+00:00 0:00:00.986881 338799 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 4 default 2023-02-13T05:00:41.847790+00:00 2 default_pool
success campaign-flow-job_v002 create_emr_steps 2023-02-13T04:00:00+00:00 PythonOperator 2023-02-13T05:00:22.409242+00:00 2023-02-13T05:00:26.254283+00:00 0:00:03.845041 338797 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 5 default 2023-02-13T05:00:19.834535+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_campaign-history-job_v002 2023-02-13T03:00:00+00:00 TriggerDagRunOperator 2023-02-13T04:11:09.136689+00:00 2023-02-13T04:11:09.676617+00:00 0:00:00.539928 338782 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2023-02-13T04:11:06.731981+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_booking-processing-job_v002 2023-02-13T03:00:00+00:00 TriggerDagRunOperator 2023-02-13T04:11:08.985367+00:00 2023-02-13T04:11:09.475689+00:00 0:00:00.490322 338781 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2023-02-13T04:11:06.731948+00:00 2 default_pool
success campaign-flow-job_v002 check_cluster_status 2023-02-13T03:00:00+00:00 EmrJobFlowSensor 2023-02-13T04:00:50.584993+00:00 2023-02-13T04:10:52.476583+00:00 0:10:01.891590 338774 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2023-02-13T04:00:48.148915+00:00 2 default_pool
success campaign-flow-job_v002 create_cluster_and_add_emr_steps 2023-02-13T03:00:00+00:00 EmrCreateJobFlowOperator 2023-02-13T04:00:28.440480+00:00 2023-02-13T04:00:29.776570+00:00 0:00:01.336090 338772 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 4 default 2023-02-13T04:00:26.072364+00:00 2 default_pool
success campaign-flow-job_v002 create_emr_steps 2023-02-13T03:00:00+00:00 PythonOperator 2023-02-13T04:00:09.038566+00:00 2023-02-13T04:00:14.545512+00:00 0:00:05.506946 338770 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 5 default 2023-02-13T04:00:06.042089+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_booking-processing-job_v002 2023-02-13T02:00:00+00:00 TriggerDagRunOperator 2023-02-13T03:11:10.819733+00:00 2023-02-13T03:11:11.387065+00:00 0:00:00.567332 338756 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2023-02-13T03:11:08.297897+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_campaign-history-job_v002 2023-02-13T02:00:00+00:00 TriggerDagRunOperator 2023-02-13T03:11:10.758105+00:00 2023-02-13T03:11:11.282784+00:00 0:00:00.524679 338755 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2023-02-13T03:11:08.297931+00:00 2 default_pool
success campaign-flow-job_v002 check_cluster_status 2023-02-13T02:00:00+00:00 EmrJobFlowSensor 2023-02-13T03:00:57.324430+00:00 2023-02-13T03:10:59.161807+00:00 0:10:01.837377 338749 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2023-02-13T03:00:54.802292+00:00 2 default_pool
success campaign-flow-job_v002 create_cluster_and_add_emr_steps 2023-02-13T02:00:00+00:00 EmrCreateJobFlowOperator 2023-02-13T03:00:35.549179+00:00 2023-02-13T03:00:36.590325+00:00 0:00:01.041146 338747 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 4 default 2023-02-13T03:00:30.782677+00:00 2 default_pool
success campaign-flow-job_v002 create_emr_steps 2023-02-13T02:00:00+00:00 PythonOperator 2023-02-13T03:00:10.984879+00:00 2023-02-13T03:00:14.940872+00:00 0:00:03.955993 338745 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 5 default 2023-02-13T03:00:08.760524+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_booking-processing-job_v002 2023-02-13T01:00:00+00:00 TriggerDagRunOperator 2023-02-13T02:11:13.730366+00:00 2023-02-13T02:11:14.245778+00:00 0:00:00.515412 338730 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2023-02-13T02:11:11.433604+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_campaign-history-job_v002 2023-02-13T01:00:00+00:00 TriggerDagRunOperator 2023-02-13T02:11:13.674228+00:00 2023-02-13T02:11:14.173310+00:00 0:00:00.499082 338729 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2023-02-13T02:11:11.433634+00:00 2 default_pool