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 trigger_dagrun_booking-processing-job_v002 2023-03-22T07:00:00+00:00 TriggerDagRunOperator 2023-03-22T08:13:27.934916+00:00 2023-03-22T08:13:28.415068+00:00 0:00:00.480152 357419 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2023-03-22T08:13:25.481235+00:00 2 default_pool
success campaign-flow-job_v002 check_cluster_status 2023-03-22T07:00:00+00:00 EmrJobFlowSensor 2023-03-22T08:03:00.986068+00:00 2023-03-22T08:13:02.966724+00:00 0:10:01.980656 357413 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2023-03-22T08:02:58.615955+00:00 2 default_pool
success campaign-flow-job_v002 create_cluster_and_add_emr_steps 2023-03-22T07:00:00+00:00 EmrCreateJobFlowOperator 2023-03-22T08:02:39.005172+00:00 2023-03-22T08:02:39.901970+00:00 0:00:00.896798 357411 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 4 default 2023-03-22T08:02:36.586752+00:00 2 default_pool
success campaign-flow-job_v002 create_emr_steps 2023-03-22T07:00:00+00:00 PythonOperator 2023-03-22T08:02:18.752364+00:00 2023-03-22T08:02:22.795851+00:00 0:00:04.043487 357409 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 5 default 2023-03-22T08:02:16.574608+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_booking-processing-job_v002 2023-03-22T06:00:00+00:00 TriggerDagRunOperator 2023-03-22T07:19:42.673895+00:00 2023-03-22T07:19:43.180017+00:00 0:00:00.506122 357400 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2023-03-22T07:19:39.890720+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_campaign-history-job_v002 2023-03-22T06:00:00+00:00 TriggerDagRunOperator 2023-03-22T07:19:42.510769+00:00 2023-03-22T07:19:42.961056+00:00 0:00:00.450287 357399 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2023-03-22T07:19:39.890761+00:00 2 default_pool
success campaign-flow-job_v002 check_cluster_status 2023-03-22T06:00:00+00:00 EmrJobFlowSensor 2023-03-22T07:09:26.673292+00:00 2023-03-22T07:19:28.351421+00:00 0:10:01.678129 357396 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2023-03-22T07:09:24.304384+00:00 2 default_pool
success campaign-flow-job_v002 create_cluster_and_add_emr_steps 2023-03-22T06:00:00+00:00 EmrCreateJobFlowOperator 2023-03-22T07:09:06.366511+00:00 2023-03-22T07:09:07.201984+00:00 0:00:00.835473 357393 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 4 default 2023-03-22T07:09:04.181680+00:00 2 default_pool
success campaign-flow-job_v002 create_emr_steps 2023-03-22T06:00:00+00:00 PythonOperator 2023-03-22T07:08:44.875613+00:00 2023-03-22T07:08:48.209997+00:00 0:00:03.334384 357390 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 5 default 2023-03-22T07:08:42.163857+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_campaign-history-job_v002 2023-03-22T05:00:00+00:00 TriggerDagRunOperator 2023-03-22T06:24:06.327575+00:00 2023-03-22T06:24:06.796059+00:00 0:00:00.468484 357381 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2023-03-22T06:24:03.352797+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_booking-processing-job_v002 2023-03-22T05:00:00+00:00 TriggerDagRunOperator 2023-03-22T06:24:06.351252+00:00 2023-03-22T06:24:06.893214+00:00 0:00:00.541962 357380 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2023-03-22T06:24:03.352759+00:00 2 default_pool
success campaign-flow-job_v002 check_cluster_status 2023-03-22T05:00:00+00:00 EmrJobFlowSensor 2023-03-22T06:04:11.472833+00:00 2023-03-22T06:14:13.371316+00:00 0:10:01.898483 357374 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2023-03-22T06:04:09.082290+00:00 2 default_pool
success campaign-flow-job_v002 create_cluster_and_add_emr_steps 2023-03-22T05:00:00+00:00 EmrCreateJobFlowOperator 2023-03-22T06:03:49.415512+00:00 2023-03-22T06:03:50.363613+00:00 0:00:00.948101 357372 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 4 default 2023-03-22T06:03:47.056388+00:00 2 default_pool
success campaign-flow-job_v002 create_emr_steps 2023-03-22T05:00:00+00:00 PythonOperator 2023-03-22T06:03:27.925815+00:00 2023-03-22T06:03:31.171254+00:00 0:00:03.245439 357370 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 5 default 2023-03-22T06:03:25.034386+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_booking-processing-job_v002 2023-03-22T04:00:00+00:00 TriggerDagRunOperator 2023-03-22T05:24:55.452931+00:00 2023-03-22T05:24:56.243224+00:00 0:00:00.790293 357363 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2023-03-22T05:24:52.335210+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_campaign-history-job_v002 2023-03-22T04:00:00+00:00 TriggerDagRunOperator 2023-03-22T05:24:55.302081+00:00 2023-03-22T05:24:56.098302+00:00 0:00:00.796221 357362 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2023-03-22T05:24:52.335243+00:00 2 default_pool
success campaign-flow-job_v002 check_cluster_status 2023-03-22T04:00:00+00:00 EmrJobFlowSensor 2023-03-22T05:02:11.361382+00:00 2023-03-22T05:12:13.231965+00:00 0:10:01.870583 357355 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2023-03-22T05:02:09.003606+00:00 2 default_pool
success campaign-flow-job_v002 create_cluster_and_add_emr_steps 2023-03-22T04:00:00+00:00 EmrCreateJobFlowOperator 2023-03-22T05:01:49.386421+00:00 2023-03-22T05:01:50.302696+00:00 0:00:00.916275 357353 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 4 default 2023-03-22T05:01:46.981841+00:00 2 default_pool
success campaign-flow-job_v002 create_emr_steps 2023-03-22T04:00:00+00:00 PythonOperator 2023-03-22T05:01:29.533484+00:00 2023-03-22T05:01:33.598531+00:00 0:00:04.065047 357351 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 5 default 2023-03-22T05:01:27.017776+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_booking-processing-job_v002 2023-03-22T03:00:00+00:00 TriggerDagRunOperator 2023-03-22T04:16:30.713905+00:00 2023-03-22T04:16:31.238058+00:00 0:00:00.524153 357343 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2023-03-22T04:16:27.981776+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_campaign-history-job_v002 2023-03-22T03:00:00+00:00 TriggerDagRunOperator 2023-03-22T04:16:30.515323+00:00 2023-03-22T04:16:31.123285+00:00 0:00:00.607962 357342 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2023-03-22T04:16:27.981806+00:00 2 default_pool
success campaign-flow-job_v002 check_cluster_status 2023-03-22T03:00:00+00:00 EmrJobFlowSensor 2023-03-22T04:06:03.360223+00:00 2023-03-22T04:16:05.133480+00:00 0:10:01.773257 357338 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2023-03-22T04:06:01.049797+00:00 2 default_pool
success campaign-flow-job_v002 create_cluster_and_add_emr_steps 2023-03-22T03:00:00+00:00 EmrCreateJobFlowOperator 2023-03-22T04:05:45.322376+00:00 2023-03-22T04:05:46.711926+00:00 0:00:01.389550 357336 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 4 default 2023-03-22T04:05:40.994614+00:00 2 default_pool
success campaign-flow-job_v002 create_emr_steps 2023-03-22T03:00:00+00:00 PythonOperator 2023-03-22T04:05:24.327309+00:00 2023-03-22T04:05:27.485494+00:00 0:00:03.158185 357333 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 5 default 2023-03-22T04:05:18.983245+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_campaign-history-job_v002 2023-03-22T02:00:00+00:00 TriggerDagRunOperator 2023-03-22T03:14:53.948680+00:00 2023-03-22T03:14:54.456715+00:00 0:00:00.508035 357322 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2023-03-22T03:14:51.290998+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_booking-processing-job_v002 2023-03-22T02:00:00+00:00 TriggerDagRunOperator 2023-03-22T03:14:53.824237+00:00 2023-03-22T03:14:54.297928+00:00 0:00:00.473691 357321 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2023-03-22T03:14:51.290938+00:00 2 default_pool
success campaign-flow-job_v002 check_cluster_status 2023-03-22T02:00:00+00:00 EmrJobFlowSensor 2023-03-22T03:04:31.256873+00:00 2023-03-22T03:14:33.132638+00:00 0:10:01.875765 357315 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2023-03-22T03:04:28.989888+00:00 2 default_pool
success campaign-flow-job_v002 create_cluster_and_add_emr_steps 2023-03-22T02:00:00+00:00 EmrCreateJobFlowOperator 2023-03-22T03:04:09.351933+00:00 2023-03-22T03:04:10.219633+00:00 0:00:00.867700 357313 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 4 default 2023-03-22T03:04:06.963261+00:00 2 default_pool
success campaign-flow-job_v002 create_emr_steps 2023-03-22T02:00:00+00:00 PythonOperator 2023-03-22T03:03:47.292119+00:00 2023-03-22T03:03:50.535679+00:00 0:00:03.243560 357311 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 5 default 2023-03-22T03:03:44.942690+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_campaign-history-job_v002 2023-03-22T01:00:00+00:00 TriggerDagRunOperator 2023-03-22T02:11:19.220564+00:00 2023-03-22T02:11:20.115940+00:00 0:00:00.895376 357299 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2023-03-22T02:11:15.745831+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_booking-processing-job_v002 2023-03-22T01:00:00+00:00 TriggerDagRunOperator 2023-03-22T02:11:18.333173+00:00 2023-03-22T02:11:18.823871+00:00 0:00:00.490698 357298 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2023-03-22T02:11:15.745803+00:00 2 default_pool
success campaign-flow-job_v002 check_cluster_status 2023-03-22T01:00:00+00:00 EmrJobFlowSensor 2023-03-22T02:01:01.292028+00:00 2023-03-22T02:11:03.366543+00:00 0:10:02.074515 357295 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2023-03-22T02:00:59.051862+00:00 2 default_pool
success campaign-flow-job_v002 create_cluster_and_add_emr_steps 2023-03-22T01:00:00+00:00 EmrCreateJobFlowOperator 2023-03-22T02:00:41.306656+00:00 2023-03-22T02:00:42.182088+00:00 0:00:00.875432 357293 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 4 default 2023-03-22T02:00:39.031711+00:00 2 default_pool
success campaign-flow-job_v002 create_emr_steps 2023-03-22T01:00:00+00:00 PythonOperator 2023-03-22T02:00:19.166205+00:00 2023-03-22T02:00:22.600352+00:00 0:00:03.434147 357291 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 5 default 2023-03-22T02:00:16.987631+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_campaign-history-job_v002 2023-03-22T00:00:00+00:00 TriggerDagRunOperator 2023-03-22T01:17:32.142604+00:00 2023-03-22T01:17:32.634767+00:00 0:00:00.492163 357275 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2023-03-22T01:17:29.555241+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_booking-processing-job_v002 2023-03-22T00:00:00+00:00 TriggerDagRunOperator 2023-03-22T01:17:31.964774+00:00 2023-03-22T01:17:32.438555+00:00 0:00:00.473781 357274 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2023-03-22T01:17:29.555212+00:00 2 default_pool
success campaign-flow-job_v002 check_cluster_status 2023-03-22T00:00:00+00:00 EmrJobFlowSensor 2023-03-22T01:07:15.024486+00:00 2023-03-22T01:17:17.308213+00:00 0:10:02.283727 357269 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2023-03-22T01:07:12.576084+00:00 2 default_pool
success campaign-flow-job_v002 create_cluster_and_add_emr_steps 2023-03-22T00:00:00+00:00 EmrCreateJobFlowOperator 2023-03-22T01:06:52.990999+00:00 2023-03-22T01:06:54.372165+00:00 0:00:01.381166 357266 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 4 default 2023-03-22T01:06:50.554225+00:00 2 default_pool
success campaign-flow-job_v002 create_emr_steps 2023-03-22T00:00:00+00:00 PythonOperator 2023-03-22T01:06:31.100251+00:00 2023-03-22T01:06:36.710256+00:00 0:00:05.610005 357263 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 5 default 2023-03-22T01:06:28.534177+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_booking-processing-job_v002 2023-03-21T23:00:00+00:00 TriggerDagRunOperator 2023-03-22T00:18:43.816850+00:00 2023-03-22T00:18:44.351280+00:00 0:00:00.534430 357253 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2023-03-22T00:18:40.796473+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_campaign-history-job_v002 2023-03-21T23:00:00+00:00 TriggerDagRunOperator 2023-03-22T00:18:43.759332+00:00 2023-03-22T00:18:44.238503+00:00 0:00:00.479171 357252 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2023-03-22T00:18:40.796514+00:00 2 default_pool
success campaign-flow-job_v002 check_cluster_status 2023-03-21T23:00:00+00:00 EmrJobFlowSensor 2023-03-22T00:01:03.671430+00:00 2023-03-22T00:11:05.640413+00:00 0:10:01.968983 357249 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2023-03-22T00:01:01.320533+00:00 2 default_pool
success campaign-flow-job_v002 create_cluster_and_add_emr_steps 2023-03-21T23:00:00+00:00 EmrCreateJobFlowOperator 2023-03-22T00:00:41.759470+00:00 2023-03-22T00:00:42.656108+00:00 0:00:00.896638 357247 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 4 default 2023-03-22T00:00:39.302419+00:00 2 default_pool
success campaign-flow-job_v002 create_emr_steps 2023-03-21T23:00:00+00:00 PythonOperator 2023-03-22T00:00:19.756238+00:00 2023-03-22T00:00:23.814288+00:00 0:00:04.058050 357245 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 5 default 2023-03-22T00:00:17.320535+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_booking-processing-job_v002 2023-03-21T22:00:00+00:00 TriggerDagRunOperator 2023-03-21T23:11:18.247351+00:00 2023-03-21T23:11:18.816161+00:00 0:00:00.568810 357235 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2023-03-21T23:11:15.696484+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_campaign-history-job_v002 2023-03-21T22:00:00+00:00 TriggerDagRunOperator 2023-03-21T23:11:18.036526+00:00 2023-03-21T23:11:18.530007+00:00 0:00:00.493481 357234 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2023-03-21T23:11:15.696529+00:00 2 default_pool
success campaign-flow-job_v002 check_cluster_status 2023-03-21T22:00:00+00:00 EmrJobFlowSensor 2023-03-21T23:00:58.316559+00:00 2023-03-21T23:10:59.917303+00:00 0:10:01.600744 357228 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2023-03-21T23:00:55.819628+00:00 2 default_pool
success campaign-flow-job_v002 create_cluster_and_add_emr_steps 2023-03-21T22:00:00+00:00 EmrCreateJobFlowOperator 2023-03-21T23:00:38.211897+00:00 2023-03-21T23:00:39.500199+00:00 0:00:01.288302 357225 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 4 default 2023-03-21T23:00:33.725999+00:00 2 default_pool
success campaign-flow-job_v002 create_emr_steps 2023-03-21T22:00:00+00:00 PythonOperator 2023-03-21T23:00:16.207026+00:00 2023-03-21T23:00:19.884454+00:00 0:00:03.677428 357222 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 5 default 2023-03-21T23:00:13.705229+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_booking-processing-job_v002 2023-03-21T21:00:00+00:00 TriggerDagRunOperator 2023-03-21T22:11:17.712340+00:00 2023-03-21T22:11:18.223395+00:00 0:00:00.511055 357210 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2023-03-21T22:11:15.338504+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_campaign-history-job_v002 2023-03-21T21:00:00+00:00 TriggerDagRunOperator 2023-03-21T22:11:17.665810+00:00 2023-03-21T22:11:18.146470+00:00 0:00:00.480660 357209 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2023-03-21T22:11:15.338531+00:00 2 default_pool
success campaign-flow-job_v002 check_cluster_status 2023-03-21T21:00:00+00:00 EmrJobFlowSensor 2023-03-21T22:00:54.402809+00:00 2023-03-21T22:10:56.430587+00:00 0:10:02.027778 357202 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2023-03-21T22:00:52.009145+00:00 2 default_pool
success campaign-flow-job_v002 create_cluster_and_add_emr_steps 2023-03-21T21:00:00+00:00 EmrCreateJobFlowOperator 2023-03-21T22:00:32.418746+00:00 2023-03-21T22:00:33.252851+00:00 0:00:00.834105 357200 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 4 default 2023-03-21T22:00:29.987532+00:00 2 default_pool
success campaign-flow-job_v002 create_emr_steps 2023-03-21T21:00:00+00:00 PythonOperator 2023-03-21T22:00:12.742039+00:00 2023-03-21T22:00:16.730657+00:00 0:00:03.988618 357198 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 5 default 2023-03-21T22:00:09.990505+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_booking-processing-job_v002 2023-03-21T20:00:00+00:00 TriggerDagRunOperator 2023-03-21T21:11:14.776508+00:00 2023-03-21T21:11:15.351783+00:00 0:00:00.575275 357187 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2023-03-21T21:11:12.094704+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_campaign-history-job_v002 2023-03-21T20:00:00+00:00 TriggerDagRunOperator 2023-03-21T21:11:14.667875+00:00 2023-03-21T21:11:15.223007+00:00 0:00:00.555132 357186 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2023-03-21T21:11:12.094734+00:00 2 default_pool
success campaign-flow-job_v002 check_cluster_status 2023-03-21T20:00:00+00:00 EmrJobFlowSensor 2023-03-21T21:01:02.451440+00:00 2023-03-21T21:11:04.213124+00:00 0:10:01.761684 357180 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2023-03-21T21:01:00.226051+00:00 2 default_pool
success campaign-flow-job_v002 create_cluster_and_add_emr_steps 2023-03-21T20:00:00+00:00 EmrCreateJobFlowOperator 2023-03-21T21:00:42.646558+00:00 2023-03-21T21:00:43.504754+00:00 0:00:00.858196 357178 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 4 default 2023-03-21T21:00:40.155539+00:00 2 default_pool
success campaign-flow-job_v002 create_emr_steps 2023-03-21T20:00:00+00:00 PythonOperator 2023-03-21T21:00:20.418478+00:00 2023-03-21T21:00:24.683334+00:00 0:00:04.264856 357176 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 5 default 2023-03-21T21:00:18.135138+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_campaign-history-job_v002 2023-03-21T19:00:00+00:00 TriggerDagRunOperator 2023-03-21T20:11:10.642516+00:00 2023-03-21T20:11:11.207347+00:00 0:00:00.564831 357164 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2023-03-21T20:11:07.799370+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_booking-processing-job_v002 2023-03-21T19:00:00+00:00 TriggerDagRunOperator 2023-03-21T20:11:10.303815+00:00 2023-03-21T20:11:10.799352+00:00 0:00:00.495537 357163 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2023-03-21T20:11:07.799340+00:00 2 default_pool
success campaign-flow-job_v002 check_cluster_status 2023-03-21T19:00:00+00:00 EmrJobFlowSensor 2023-03-21T20:00:59.485102+00:00 2023-03-21T20:11:01.352663+00:00 0:10:01.867561 357157 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2023-03-21T20:00:57.164810+00:00 2 default_pool
success campaign-flow-job_v002 create_cluster_and_add_emr_steps 2023-03-21T19:00:00+00:00 EmrCreateJobFlowOperator 2023-03-21T20:00:39.326417+00:00 2023-03-21T20:00:40.170271+00:00 0:00:00.843854 357155 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 4 default 2023-03-21T20:00:37.143736+00:00 2 default_pool
success campaign-flow-job_v002 create_emr_steps 2023-03-21T19:00:00+00:00 PythonOperator 2023-03-21T20:00:17.316893+00:00 2023-03-21T20:00:21.269401+00:00 0:00:03.952508 357153 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 5 default 2023-03-21T20:00:15.124701+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_booking-processing-job_v002 2023-03-21T18:00:00+00:00 TriggerDagRunOperator 2023-03-21T19:12:10.986849+00:00 2023-03-21T19:12:11.506340+00:00 0:00:00.519491 357142 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2023-03-21T19:12:08.314415+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_campaign-history-job_v002 2023-03-21T18:00:00+00:00 TriggerDagRunOperator 2023-03-21T19:12:10.768333+00:00 2023-03-21T19:12:11.295990+00:00 0:00:00.527657 357141 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2023-03-21T19:12:08.314465+00:00 2 default_pool
success campaign-flow-job_v002 check_cluster_status 2023-03-21T18:00:00+00:00 EmrJobFlowSensor 2023-03-21T19:01:00.979290+00:00 2023-03-21T19:12:03.037465+00:00 0:11:02.058175 357135 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2023-03-21T19:00:58.610429+00:00 2 default_pool
success campaign-flow-job_v002 create_cluster_and_add_emr_steps 2023-03-21T18:00:00+00:00 EmrCreateJobFlowOperator 2023-03-21T19:00:38.910289+00:00 2023-03-21T19:00:39.711043+00:00 0:00:00.800754 357133 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 4 default 2023-03-21T19:00:36.577602+00:00 2 default_pool
success campaign-flow-job_v002 create_emr_steps 2023-03-21T18:00:00+00:00 PythonOperator 2023-03-21T19:00:18.984640+00:00 2023-03-21T19:00:23.126520+00:00 0:00:04.141880 357131 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 5 default 2023-03-21T19:00:16.607887+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_booking-processing-job_v002 2023-03-21T17:00:00+00:00 TriggerDagRunOperator 2023-03-21T18:10:08.433415+00:00 2023-03-21T18:10:08.926436+00:00 0:00:00.493021 357120 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2023-03-21T18:10:05.917776+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_campaign-history-job_v002 2023-03-21T17:00:00+00:00 TriggerDagRunOperator 2023-03-21T18:10:08.291704+00:00 2023-03-21T18:10:08.742708+00:00 0:00:00.451004 357119 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2023-03-21T18:10:05.917823+00:00 2 default_pool
success campaign-flow-job_v002 check_cluster_status 2023-03-21T17:00:00+00:00 EmrJobFlowSensor 2023-03-21T18:00:51.563977+00:00 2023-03-21T18:09:53.113722+00:00 0:09:01.549745 357112 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2023-03-21T18:00:49.021646+00:00 2 default_pool
success campaign-flow-job_v002 create_cluster_and_add_emr_steps 2023-03-21T17:00:00+00:00 EmrCreateJobFlowOperator 2023-03-21T18:00:29.255368+00:00 2023-03-21T18:00:30.142669+00:00 0:00:00.887301 357110 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 4 default 2023-03-21T18:00:27.004540+00:00 2 default_pool
success campaign-flow-job_v002 create_emr_steps 2023-03-21T17:00:00+00:00 PythonOperator 2023-03-21T18:00:09.228570+00:00 2023-03-21T18:00:13.342315+00:00 0:00:04.113745 357108 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 5 default 2023-03-21T18:00:06.928986+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_booking-processing-job_v002 2023-03-21T16:00:00+00:00 TriggerDagRunOperator 2023-03-21T17:18:12.347589+00:00 2023-03-21T17:18:12.834292+00:00 0:00:00.486703 357098 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2023-03-21T17:18:09.452090+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_campaign-history-job_v002 2023-03-21T16:00:00+00:00 TriggerDagRunOperator 2023-03-21T17:18:12.047777+00:00 2023-03-21T17:18:12.582886+00:00 0:00:00.535109 357097 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2023-03-21T17:18:09.452061+00:00 2 default_pool
success campaign-flow-job_v002 check_cluster_status 2023-03-21T16:00:00+00:00 EmrJobFlowSensor 2023-03-21T17:07:45.828926+00:00 2023-03-21T17:17:47.826946+00:00 0:10:01.998020 357094 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2023-03-21T17:07:43.257961+00:00 2 default_pool
success campaign-flow-job_v002 create_cluster_and_add_emr_steps 2023-03-21T16:00:00+00:00 EmrCreateJobFlowOperator 2023-03-21T17:07:23.415477+00:00 2023-03-21T17:07:24.210082+00:00 0:00:00.794605 357091 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 4 default 2023-03-21T17:07:21.236928+00:00 2 default_pool
success campaign-flow-job_v002 create_emr_steps 2023-03-21T16:00:00+00:00 PythonOperator 2023-03-21T17:07:05.450402+00:00 2023-03-21T17:07:10.734923+00:00 0:00:05.284521 357088 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 5 default 2023-03-21T17:07:01.204842+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_booking-processing-job_v002 2023-03-21T15:00:00+00:00 TriggerDagRunOperator 2023-03-21T16:20:44.413393+00:00 2023-03-21T16:20:44.907277+00:00 0:00:00.493884 357076 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2023-03-21T16:20:41.937815+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_campaign-history-job_v002 2023-03-21T15:00:00+00:00 TriggerDagRunOperator 2023-03-21T16:20:44.407838+00:00 2023-03-21T16:20:44.891070+00:00 0:00:00.483232 357075 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2023-03-21T16:20:41.937844+00:00 2 default_pool
success campaign-flow-job_v002 check_cluster_status 2023-03-21T15:00:00+00:00 EmrJobFlowSensor 2023-03-21T16:10:22.401006+00:00 2023-03-21T16:20:24.212897+00:00 0:10:01.811891 357071 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2023-03-21T16:10:20.191751+00:00 2 default_pool
success campaign-flow-job_v002 create_cluster_and_add_emr_steps 2023-03-21T15:00:00+00:00 EmrCreateJobFlowOperator 2023-03-21T16:10:02.488925+00:00 2023-03-21T16:10:03.581111+00:00 0:00:01.092186 357068 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 4 default 2023-03-21T16:10:00.236134+00:00 2 default_pool
success campaign-flow-job_v002 create_emr_steps 2023-03-21T15:00:00+00:00 PythonOperator 2023-03-21T16:09:43.148994+00:00 2023-03-21T16:09:46.244550+00:00 0:00:03.095556 357065 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 5 default 2023-03-21T16:09:38.156692+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_booking-processing-job_v002 2023-03-21T14:00:00+00:00 TriggerDagRunOperator 2023-03-21T15:15:59.119948+00:00 2023-03-21T15:15:59.597732+00:00 0:00:00.477784 357056 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2023-03-21T15:15:56.529208+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_campaign-history-job_v002 2023-03-21T14:00:00+00:00 TriggerDagRunOperator 2023-03-21T15:15:59.035610+00:00 2023-03-21T15:15:59.515114+00:00 0:00:00.479504 357055 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2023-03-21T15:15:56.529236+00:00 2 default_pool
success campaign-flow-job_v002 check_cluster_status 2023-03-21T14:00:00+00:00 EmrJobFlowSensor 2023-03-21T15:05:51.928860+00:00 2023-03-21T15:15:53.876570+00:00 0:10:01.947710 357050 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2023-03-21T15:05:49.636154+00:00 2 default_pool
success campaign-flow-job_v002 create_cluster_and_add_emr_steps 2023-03-21T14:00:00+00:00 EmrCreateJobFlowOperator 2023-03-21T15:05:29.780790+00:00 2023-03-21T15:05:30.707067+00:00 0:00:00.926277 357047 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 4 default 2023-03-21T15:05:27.614764+00:00 2 default_pool
success campaign-flow-job_v002 create_emr_steps 2023-03-21T14:00:00+00:00 PythonOperator 2023-03-21T15:05:10.223199+00:00 2023-03-21T15:05:13.583144+00:00 0:00:03.359945 357044 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 5 default 2023-03-21T15:05:07.596169+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_booking-processing-job_v002 2023-03-21T13:00:00+00:00 TriggerDagRunOperator 2023-03-21T14:12:16.668989+00:00 2023-03-21T14:12:17.166598+00:00 0:00:00.497609 357036 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2023-03-21T14:12:13.713688+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_campaign-history-job_v002 2023-03-21T13:00:00+00:00 TriggerDagRunOperator 2023-03-21T14:12:16.566237+00:00 2023-03-21T14:12:17.048068+00:00 0:00:00.481831 357035 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2023-03-21T14:12:13.713646+00:00 2 default_pool
success campaign-flow-job_v002 check_cluster_status 2023-03-21T13:00:00+00:00 EmrJobFlowSensor 2023-03-21T14:02:00.702608+00:00 2023-03-21T14:12:02.636205+00:00 0:10:01.933597 357028 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2023-03-21T14:01:58.369828+00:00 2 default_pool
success campaign-flow-job_v002 create_cluster_and_add_emr_steps 2023-03-21T13:00:00+00:00 EmrCreateJobFlowOperator 2023-03-21T14:01:38.664595+00:00 2023-03-21T14:01:39.525157+00:00 0:00:00.860562 357027 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 4 default 2023-03-21T14:01:36.353253+00:00 2 default_pool
success campaign-flow-job_v002 create_emr_steps 2023-03-21T13:00:00+00:00 PythonOperator 2023-03-21T14:01:19.140697+00:00 2023-03-21T14:01:22.637491+00:00 0:00:03.496794 357024 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 5 default 2023-03-21T14:01:16.040342+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_campaign-history-job_v002 2023-03-21T12:00:00+00:00 TriggerDagRunOperator 2023-03-21T13:53:24.566809+00:00 2023-03-21T13:53:25.151869+00:00 0:00:00.585060 357019 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2023-03-21T13:53:21.540589+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_booking-processing-job_v002 2023-03-21T12:00:00+00:00 TriggerDagRunOperator 2023-03-21T13:53:24.525161+00:00 2023-03-21T13:53:25.044048+00:00 0:00:00.518887 357018 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2023-03-21T13:53:21.540557+00:00 2 default_pool
success campaign-flow-job_v002 check_cluster_status 2023-03-21T12:00:00+00:00 EmrJobFlowSensor 2023-03-21T13:07:03.365026+00:00 2023-03-21T13:17:05.274845+00:00 0:10:01.909819 357013 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2023-03-21T13:07:01.109348+00:00 2 default_pool
success campaign-flow-job_v002 create_cluster_and_add_emr_steps 2023-03-21T12:00:00+00:00 EmrCreateJobFlowOperator 2023-03-21T13:06:43.650913+00:00 2023-03-21T13:06:44.788085+00:00 0:00:01.137172 357010 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 4 default 2023-03-21T13:06:41.089810+00:00 2 default_pool
success campaign-flow-job_v002 create_emr_steps 2023-03-21T12:00:00+00:00 PythonOperator 2023-03-21T13:06:21.848332+00:00 2023-03-21T13:06:25.828816+00:00 0:00:03.980484 357007 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 5 default 2023-03-21T13:06:19.073713+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_campaign-history-job_v002 2023-03-21T11:00:00+00:00 TriggerDagRunOperator 2023-03-21T12:26:20.429523+00:00 2023-03-21T12:26:21.043814+00:00 0:00:00.614291 357001 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2023-03-21T12:26:17.523434+00:00 2 default_pool