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-03-08T23:00:00+00:00 EmrJobFlowSensor 2023-03-09T00:02:06.577304+00:00 2023-03-09T00:12:08.425101+00:00 0:10:01.847797 350512 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2023-03-09T00:02:04.202190+00:00 2 default_pool
success campaign-flow-job_v002 create_cluster_and_add_emr_steps 2023-03-08T23:00:00+00:00 EmrCreateJobFlowOperator 2023-03-09T00:01:44.702432+00:00 2023-03-09T00:01:45.780428+00:00 0:00:01.077996 350510 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 4 default 2023-03-09T00:01:42.182194+00:00 2 default_pool
success campaign-flow-job_v002 create_emr_steps 2023-03-08T23:00:00+00:00 PythonOperator 2023-03-09T00:01:24.651319+00:00 2023-03-09T00:01:27.825626+00:00 0:00:03.174307 350508 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 5 default 2023-03-09T00:01:22.161924+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_booking-processing-job_v002 2023-03-08T22:00:00+00:00 TriggerDagRunOperator 2023-03-08T23:11:05.352846+00:00 2023-03-08T23:11:05.806721+00:00 0:00:00.453875 350496 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2023-03-08T23:11:02.195219+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_campaign-history-job_v002 2023-03-08T22:00:00+00:00 TriggerDagRunOperator 2023-03-08T23:11:05.180330+00:00 2023-03-08T23:11:05.663817+00:00 0:00:00.483487 350495 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2023-03-08T23:11:02.195267+00:00 2 default_pool
success campaign-flow-job_v002 check_cluster_status 2023-03-08T22:00:00+00:00 EmrJobFlowSensor 2023-03-08T23:00:57.103059+00:00 2023-03-08T23:10:58.918672+00:00 0:10:01.815613 350487 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2023-03-08T23:00:54.869839+00:00 2 default_pool
success campaign-flow-job_v002 create_cluster_and_add_emr_steps 2023-03-08T22:00:00+00:00 EmrCreateJobFlowOperator 2023-03-08T23:00:35.274254+00:00 2023-03-08T23:00:36.152737+00:00 0:00:00.878483 350484 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 4 default 2023-03-08T23:00:32.849290+00:00 2 default_pool
success campaign-flow-job_v002 create_emr_steps 2023-03-08T22:00:00+00:00 PythonOperator 2023-03-08T23:00:13.795439+00:00 2023-03-08T23:00:20.313522+00:00 0:00:06.518083 350481 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 5 default 2023-03-08T23:00:10.885147+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_booking-processing-job_v002 2023-03-08T21:00:00+00:00 TriggerDagRunOperator 2023-03-08T22:11:24.845881+00:00 2023-03-08T22:11:25.462243+00:00 0:00:00.616362 350470 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2023-03-08T22:11:22.352033+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_campaign-history-job_v002 2023-03-08T21:00:00+00:00 TriggerDagRunOperator 2023-03-08T22:11:24.829521+00:00 2023-03-08T22:11:25.386624+00:00 0:00:00.557103 350469 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2023-03-08T22:11:22.352064+00:00 2 default_pool
success campaign-flow-job_v002 check_cluster_status 2023-03-08T21:00:00+00:00 EmrJobFlowSensor 2023-03-08T22:01:04.416183+00:00 2023-03-08T22:11:06.208017+00:00 0:10:01.791834 350463 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2023-03-08T22:01:01.998912+00:00 2 default_pool
success campaign-flow-job_v002 create_cluster_and_add_emr_steps 2023-03-08T21:00:00+00:00 EmrCreateJobFlowOperator 2023-03-08T22:00:42.274086+00:00 2023-03-08T22:00:43.158343+00:00 0:00:00.884257 350461 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 4 default 2023-03-08T22:00:39.855625+00:00 2 default_pool
success campaign-flow-job_v002 create_emr_steps 2023-03-08T21:00:00+00:00 PythonOperator 2023-03-08T22:00:22.243406+00:00 2023-03-08T22:00:25.447320+00:00 0:00:03.203914 350459 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 5 default 2023-03-08T22:00:19.837386+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_campaign-history-job_v002 2023-03-08T20:00:00+00:00 TriggerDagRunOperator 2023-03-08T21:11:10.425359+00:00 2023-03-08T21:11:11.052228+00:00 0:00:00.626869 350446 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2023-03-08T21:11:07.834470+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_booking-processing-job_v002 2023-03-08T20:00:00+00:00 TriggerDagRunOperator 2023-03-08T21:11:10.208690+00:00 2023-03-08T21:11:10.718886+00:00 0:00:00.510196 350445 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2023-03-08T21:11:07.834437+00:00 2 default_pool
success campaign-flow-job_v002 check_cluster_status 2023-03-08T20:00:00+00:00 EmrJobFlowSensor 2023-03-08T21:00:59.066116+00:00 2023-03-08T21:11:00.835674+00:00 0:10:01.769558 350438 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2023-03-08T21:00:56.809866+00:00 2 default_pool
success campaign-flow-job_v002 create_cluster_and_add_emr_steps 2023-03-08T20:00:00+00:00 EmrCreateJobFlowOperator 2023-03-08T21:00:37.000358+00:00 2023-03-08T21:00:37.841905+00:00 0:00:00.841547 350436 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 4 default 2023-03-08T21:00:34.732163+00:00 2 default_pool
success campaign-flow-job_v002 create_emr_steps 2023-03-08T20:00:00+00:00 PythonOperator 2023-03-08T21:00:15.388482+00:00 2023-03-08T21:00:19.772631+00:00 0:00:04.384149 350434 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 5 default 2023-03-08T21:00:12.706719+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_booking-processing-job_v002 2023-03-08T19:00:00+00:00 TriggerDagRunOperator 2023-03-08T20:10:56.773234+00:00 2023-03-08T20:10:57.278856+00:00 0:00:00.505622 350423 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2023-03-08T20:10:54.234918+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_campaign-history-job_v002 2023-03-08T19:00:00+00:00 TriggerDagRunOperator 2023-03-08T20:10:56.647070+00:00 2023-03-08T20:10:57.135380+00:00 0:00:00.488310 350422 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2023-03-08T20:10:54.234948+00:00 2 default_pool
success campaign-flow-job_v002 check_cluster_status 2023-03-08T19:00:00+00:00 EmrJobFlowSensor 2023-03-08T20:00:48.883036+00:00 2023-03-08T20:10:50.748182+00:00 0:10:01.865146 350415 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2023-03-08T20:00:46.639717+00:00 2 default_pool
success campaign-flow-job_v002 create_cluster_and_add_emr_steps 2023-03-08T19:00:00+00:00 EmrCreateJobFlowOperator 2023-03-08T20:00:26.912987+00:00 2023-03-08T20:00:27.817477+00:00 0:00:00.904490 350413 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 4 default 2023-03-08T20:00:24.582667+00:00 2 default_pool
success campaign-flow-job_v002 create_emr_steps 2023-03-08T19:00:00+00:00 PythonOperator 2023-03-08T20:00:05.381829+00:00 2023-03-08T20:00:10.429781+00:00 0:00:05.047952 350411 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 5 default 2023-03-08T20:00:02.562452+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_booking-processing-job_v002 2023-03-08T18:00:00+00:00 TriggerDagRunOperator 2023-03-08T19:11:21.463195+00:00 2023-03-08T19:11:21.918415+00:00 0:00:00.455220 350400 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2023-03-08T19:11:18.988041+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_campaign-history-job_v002 2023-03-08T18:00:00+00:00 TriggerDagRunOperator 2023-03-08T19:11:21.295175+00:00 2023-03-08T19:11:21.767803+00:00 0:00:00.472628 350399 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2023-03-08T19:11:18.988068+00:00 2 default_pool
success campaign-flow-job_v002 check_cluster_status 2023-03-08T18:00:00+00:00 EmrJobFlowSensor 2023-03-08T19:01:07.554067+00:00 2023-03-08T19:11:09.384537+00:00 0:10:01.830470 350393 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2023-03-08T19:01:05.369856+00:00 2 default_pool
success campaign-flow-job_v002 create_cluster_and_add_emr_steps 2023-03-08T18:00:00+00:00 EmrCreateJobFlowOperator 2023-03-08T19:00:45.596235+00:00 2023-03-08T19:00:46.483671+00:00 0:00:00.887436 350391 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 4 default 2023-03-08T19:00:43.349079+00:00 2 default_pool
success campaign-flow-job_v002 create_emr_steps 2023-03-08T18:00:00+00:00 PythonOperator 2023-03-08T19:00:23.866001+00:00 2023-03-08T19:00:27.910742+00:00 0:00:04.044741 350388 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 5 default 2023-03-08T19:00:21.329055+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_campaign-history-job_v002 2023-03-08T17:00:00+00:00 TriggerDagRunOperator 2023-03-08T18:11:35.202487+00:00 2023-03-08T18:11:35.668216+00:00 0:00:00.465729 350377 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2023-03-08T18:11:32.596210+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_booking-processing-job_v002 2023-03-08T17:00:00+00:00 TriggerDagRunOperator 2023-03-08T18:11:35.045850+00:00 2023-03-08T18:11:35.517363+00:00 0:00:00.471513 350376 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2023-03-08T18:11:32.596181+00:00 2 default_pool
success campaign-flow-job_v002 check_cluster_status 2023-03-08T17:00:00+00:00 EmrJobFlowSensor 2023-03-08T18:01:07.678237+00:00 2023-03-08T18:11:09.498458+00:00 0:10:01.820221 350367 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2023-03-08T18:01:05.436996+00:00 2 default_pool
success campaign-flow-job_v002 create_cluster_and_add_emr_steps 2023-03-08T17:00:00+00:00 EmrCreateJobFlowOperator 2023-03-08T18:00:45.661699+00:00 2023-03-08T18:00:46.697048+00:00 0:00:01.035349 350366 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 4 default 2023-03-08T18:00:43.419560+00:00 2 default_pool
success campaign-flow-job_v002 create_emr_steps 2023-03-08T17:00:00+00:00 PythonOperator 2023-03-08T18:00:23.732731+00:00 2023-03-08T18:00:26.769721+00:00 0:00:03.036990 350364 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 5 default 2023-03-08T18:00:21.403344+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_campaign-history-job_v002 2023-03-08T16:00:00+00:00 TriggerDagRunOperator 2023-03-08T17:11:14.586068+00:00 2023-03-08T17:11:15.260007+00:00 0:00:00.673939 350353 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2023-03-08T17:11:11.803765+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_booking-processing-job_v002 2023-03-08T16:00:00+00:00 TriggerDagRunOperator 2023-03-08T17:11:14.147660+00:00 2023-03-08T17:11:14.820380+00:00 0:00:00.672720 350352 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2023-03-08T17:11:11.803737+00:00 2 default_pool
success campaign-flow-job_v002 check_cluster_status 2023-03-08T16:00:00+00:00 EmrJobFlowSensor 2023-03-08T17:00:49.104739+00:00 2023-03-08T17:10:50.960892+00:00 0:10:01.856153 350345 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2023-03-08T17:00:46.493469+00:00 2 default_pool
success campaign-flow-job_v002 create_cluster_and_add_emr_steps 2023-03-08T16:00:00+00:00 EmrCreateJobFlowOperator 2023-03-08T17:00:27.037242+00:00 2023-03-08T17:00:27.954557+00:00 0:00:00.917315 350343 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 4 default 2023-03-08T17:00:24.418803+00:00 2 default_pool
success campaign-flow-job_v002 create_emr_steps 2023-03-08T16:00:00+00:00 PythonOperator 2023-03-08T17:00:05.114652+00:00 2023-03-08T17:00:08.532135+00:00 0:00:03.417483 350341 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 5 default 2023-03-08T17:00:02.414416+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_campaign-history-job_v002 2023-03-08T15:00:00+00:00 TriggerDagRunOperator 2023-03-08T16:11:15.316210+00:00 2023-03-08T16:11:15.782070+00:00 0:00:00.465860 350332 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2023-03-08T16:11:12.648249+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_booking-processing-job_v002 2023-03-08T15:00:00+00:00 TriggerDagRunOperator 2023-03-08T16:11:15.120072+00:00 2023-03-08T16:11:15.583852+00:00 0:00:00.463780 350331 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2023-03-08T16:11:12.648217+00:00 2 default_pool
success campaign-flow-job_v002 check_cluster_status 2023-03-08T15:00:00+00:00 EmrJobFlowSensor 2023-03-08T16:00:57.893652+00:00 2023-03-08T16:10:59.787749+00:00 0:10:01.894097 350324 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2023-03-08T16:00:55.595497+00:00 2 default_pool
success campaign-flow-job_v002 create_cluster_and_add_emr_steps 2023-03-08T15:00:00+00:00 EmrCreateJobFlowOperator 2023-03-08T16:00:37.850006+00:00 2023-03-08T16:00:38.810020+00:00 0:00:00.960014 350322 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 4 default 2023-03-08T16:00:35.572909+00:00 2 default_pool
success campaign-flow-job_v002 create_emr_steps 2023-03-08T15:00:00+00:00 PythonOperator 2023-03-08T16:00:17.217691+00:00 2023-03-08T16:00:22.241681+00:00 0:00:05.023990 350320 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 5 default 2023-03-08T16:00:13.608348+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_campaign-history-job_v002 2023-03-08T14:00:00+00:00 TriggerDagRunOperator 2023-03-08T15:11:18.813586+00:00 2023-03-08T15:11:19.314977+00:00 0:00:00.501391 350310 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2023-03-08T15:11:15.958544+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_booking-processing-job_v002 2023-03-08T14:00:00+00:00 TriggerDagRunOperator 2023-03-08T15:11:18.571401+00:00 2023-03-08T15:11:19.125295+00:00 0:00:00.553894 350309 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2023-03-08T15:11:15.958516+00:00 2 default_pool
success campaign-flow-job_v002 check_cluster_status 2023-03-08T14:00:00+00:00 EmrJobFlowSensor 2023-03-08T15:01:10.833509+00:00 2023-03-08T15:11:12.774572+00:00 0:10:01.941063 350302 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2023-03-08T15:01:08.405869+00:00 2 default_pool
success campaign-flow-job_v002 create_cluster_and_add_emr_steps 2023-03-08T14:00:00+00:00 EmrCreateJobFlowOperator 2023-03-08T15:00:48.566181+00:00 2023-03-08T15:00:49.363855+00:00 0:00:00.797674 350300 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 4 default 2023-03-08T15:00:46.355667+00:00 2 default_pool
success campaign-flow-job_v002 create_emr_steps 2023-03-08T14:00:00+00:00 PythonOperator 2023-03-08T15:00:29.121555+00:00 2023-03-08T15:00:33.216220+00:00 0:00:04.094665 350298 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 5 default 2023-03-08T15:00:26.340050+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_booking-processing-job_v002 2023-03-08T13:00:00+00:00 TriggerDagRunOperator 2023-03-08T14:23:53.678394+00:00 2023-03-08T14:23:54.213032+00:00 0:00:00.534638 350292 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2023-03-08T14:23:51.144729+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_campaign-history-job_v002 2023-03-08T13:00:00+00:00 TriggerDagRunOperator 2023-03-08T14:23:53.610678+00:00 2023-03-08T14:23:54.134357+00:00 0:00:00.523679 350291 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2023-03-08T14:23:51.144757+00:00 2 default_pool
success campaign-flow-job_v002 check_cluster_status 2023-03-08T13:00:00+00:00 EmrJobFlowSensor 2023-03-08T14:13:31.302075+00:00 2023-03-08T14:23:33.196144+00:00 0:10:01.894069 350288 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2023-03-08T14:13:28.523415+00:00 2 default_pool
success campaign-flow-job_v002 create_cluster_and_add_emr_steps 2023-03-08T13:00:00+00:00 EmrCreateJobFlowOperator 2023-03-08T14:13:08.746231+00:00 2023-03-08T14:13:09.580101+00:00 0:00:00.833870 350284 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 4 default 2023-03-08T14:13:06.498268+00:00 2 default_pool
success campaign-flow-job_v002 create_emr_steps 2023-03-08T13:00:00+00:00 PythonOperator 2023-03-08T14:12:46.866069+00:00 2023-03-08T14:12:49.776383+00:00 0:00:02.910314 350282 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 5 default 2023-03-08T14:12:44.484117+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_campaign-history-job_v002 2023-03-08T12:00:00+00:00 TriggerDagRunOperator 2023-03-08T13:11:36.792120+00:00 2023-03-08T13:11:37.312128+00:00 0:00:00.520008 350270 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2023-03-08T13:11:33.902330+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_booking-processing-job_v002 2023-03-08T12:00:00+00:00 TriggerDagRunOperator 2023-03-08T13:11:36.741678+00:00 2023-03-08T13:11:37.233567+00:00 0:00:00.491889 350269 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2023-03-08T13:11:33.902301+00:00 2 default_pool
success campaign-flow-job_v002 check_cluster_status 2023-03-08T12:00:00+00:00 EmrJobFlowSensor 2023-03-08T13:01:09.189301+00:00 2023-03-08T13:11:11.097990+00:00 0:10:01.908689 350262 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2023-03-08T13:01:06.832038+00:00 2 default_pool
success campaign-flow-job_v002 create_cluster_and_add_emr_steps 2023-03-08T12:00:00+00:00 EmrCreateJobFlowOperator 2023-03-08T13:00:47.085439+00:00 2023-03-08T13:00:47.897257+00:00 0:00:00.811818 350260 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 4 default 2023-03-08T13:00:44.800785+00:00 2 default_pool
success campaign-flow-job_v002 create_emr_steps 2023-03-08T12:00:00+00:00 PythonOperator 2023-03-08T13:00:25.164114+00:00 2023-03-08T13:00:29.342864+00:00 0:00:04.178750 350258 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 5 default 2023-03-08T13:00:22.769224+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_booking-processing-job_v002 2023-03-08T11:00:00+00:00 TriggerDagRunOperator 2023-03-08T12:11:45.474386+00:00 2023-03-08T12:11:46.203421+00:00 0:00:00.729035 350248 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2023-03-08T12:11:42.190350+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_campaign-history-job_v002 2023-03-08T11:00:00+00:00 TriggerDagRunOperator 2023-03-08T12:11:45.414882+00:00 2023-03-08T12:11:45.896409+00:00 0:00:00.481527 350247 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2023-03-08T12:11:42.190385+00:00 2 default_pool
success campaign-flow-job_v002 check_cluster_status 2023-03-08T11:00:00+00:00 EmrJobFlowSensor 2023-03-08T12:01:02.816617+00:00 2023-03-08T12:11:04.735462+00:00 0:10:01.918845 350239 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2023-03-08T12:01:00.449780+00:00 2 default_pool
success campaign-flow-job_v002 create_cluster_and_add_emr_steps 2023-03-08T11:00:00+00:00 EmrCreateJobFlowOperator 2023-03-08T12:00:40.760951+00:00 2023-03-08T12:00:41.649046+00:00 0:00:00.888095 350237 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 4 default 2023-03-08T12:00:38.429905+00:00 2 default_pool
success campaign-flow-job_v002 create_emr_steps 2023-03-08T11:00:00+00:00 PythonOperator 2023-03-08T12:00:19.171707+00:00 2023-03-08T12:00:22.180750+00:00 0:00:03.009043 350235 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 5 default 2023-03-08T12:00:16.396865+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_booking-processing-job_v002 2023-03-08T10:00:00+00:00 TriggerDagRunOperator 2023-03-08T11:17:45.759291+00:00 2023-03-08T11:17:46.259745+00:00 0:00:00.500454 350226 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2023-03-08T11:17:42.916745+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_campaign-history-job_v002 2023-03-08T10:00:00+00:00 TriggerDagRunOperator 2023-03-08T11:17:45.697013+00:00 2023-03-08T11:17:46.224264+00:00 0:00:00.527251 350225 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2023-03-08T11:17:42.916786+00:00 2 default_pool
success campaign-flow-job_v002 check_cluster_status 2023-03-08T10:00:00+00:00 EmrJobFlowSensor 2023-03-08T11:07:21.582124+00:00 2023-03-08T11:17:23.474816+00:00 0:10:01.892692 350220 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2023-03-08T11:07:19.235168+00:00 2 default_pool
success campaign-flow-job_v002 create_cluster_and_add_emr_steps 2023-03-08T10:00:00+00:00 EmrCreateJobFlowOperator 2023-03-08T11:06:59.618526+00:00 2023-03-08T11:07:00.646086+00:00 0:00:01.027560 350217 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 4 default 2023-03-08T11:06:57.214330+00:00 2 default_pool
success campaign-flow-job_v002 create_emr_steps 2023-03-08T10:00:00+00:00 PythonOperator 2023-03-08T11:06:39.979013+00:00 2023-03-08T11:06:44.149953+00:00 0:00:04.170940 350214 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 5 default 2023-03-08T11:06:37.196786+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_booking-processing-job_v002 2023-03-08T09:00:00+00:00 TriggerDagRunOperator 2023-03-08T10:11:33.811591+00:00 2023-03-08T10:11:34.274393+00:00 0:00:00.462802 350205 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2023-03-08T10:11:31.185564+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_campaign-history-job_v002 2023-03-08T09:00:00+00:00 TriggerDagRunOperator 2023-03-08T10:11:33.592754+00:00 2023-03-08T10:11:34.081667+00:00 0:00:00.488913 350204 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2023-03-08T10:11:31.185593+00:00 2 default_pool
success campaign-flow-job_v002 check_cluster_status 2023-03-08T09:00:00+00:00 EmrJobFlowSensor 2023-03-08T10:01:08.581063+00:00 2023-03-08T10:11:10.329416+00:00 0:10:01.748353 350197 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2023-03-08T10:01:06.331566+00:00 2 default_pool
success campaign-flow-job_v002 create_cluster_and_add_emr_steps 2023-03-08T09:00:00+00:00 EmrCreateJobFlowOperator 2023-03-08T10:00:46.572582+00:00 2023-03-08T10:00:47.427657+00:00 0:00:00.855075 350195 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 4 default 2023-03-08T10:00:44.285759+00:00 2 default_pool
success campaign-flow-job_v002 create_emr_steps 2023-03-08T09:00:00+00:00 PythonOperator 2023-03-08T10:00:22.374507+00:00 2023-03-08T10:00:25.340889+00:00 0:00:02.966382 350193 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 5 default 2023-03-08T10:00:20.147326+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_booking-processing-job_v002 2023-03-08T08:00:00+00:00 TriggerDagRunOperator 2023-03-08T09:17:02.453627+00:00 2023-03-08T09:17:03.062614+00:00 0:00:00.608987 350185 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2023-03-08T09:16:59.430296+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_campaign-history-job_v002 2023-03-08T08:00:00+00:00 TriggerDagRunOperator 2023-03-08T09:17:02.430358+00:00 2023-03-08T09:17:03.031428+00:00 0:00:00.601070 350184 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2023-03-08T09:16:59.430325+00:00 2 default_pool
success campaign-flow-job_v002 check_cluster_status 2023-03-08T08:00:00+00:00 EmrJobFlowSensor 2023-03-08T09:03:10.115638+00:00 2023-03-08T09:13:11.873042+00:00 0:10:01.757404 350177 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2023-03-08T09:03:07.773609+00:00 2 default_pool
success campaign-flow-job_v002 create_cluster_and_add_emr_steps 2023-03-08T08:00:00+00:00 EmrCreateJobFlowOperator 2023-03-08T09:02:50.083891+00:00 2023-03-08T09:02:50.989193+00:00 0:00:00.905302 350175 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 4 default 2023-03-08T09:02:47.757311+00:00 2 default_pool
success campaign-flow-job_v002 create_emr_steps 2023-03-08T08:00:00+00:00 PythonOperator 2023-03-08T09:02:28.642643+00:00 2023-03-08T09:02:31.703465+00:00 0:00:03.060822 350174 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 5 default 2023-03-08T09:02:25.556641+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_booking-processing-job_v002 2023-03-08T07:00:00+00:00 TriggerDagRunOperator 2023-03-08T08:11:20.412659+00:00 2023-03-08T08:11:20.946874+00:00 0:00:00.534215 350163 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2023-03-08T08:11:17.455458+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_campaign-history-job_v002 2023-03-08T07:00:00+00:00 TriggerDagRunOperator 2023-03-08T08:11:20.225297+00:00 2023-03-08T08:11:20.736063+00:00 0:00:00.510766 350162 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2023-03-08T08:11:17.455492+00:00 2 default_pool
success campaign-flow-job_v002 check_cluster_status 2023-03-08T07:00:00+00:00 EmrJobFlowSensor 2023-03-08T08:00:50.201542+00:00 2023-03-08T08:10:52.043208+00:00 0:10:01.841666 350154 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2023-03-08T08:00:47.770048+00:00 2 default_pool
success campaign-flow-job_v002 create_cluster_and_add_emr_steps 2023-03-08T07:00:00+00:00 EmrCreateJobFlowOperator 2023-03-08T08:00:28.399609+00:00 2023-03-08T08:00:29.281728+00:00 0:00:00.882119 350152 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 4 default 2023-03-08T08:00:25.743396+00:00 2 default_pool
success campaign-flow-job_v002 create_emr_steps 2023-03-08T07:00:00+00:00 PythonOperator 2023-03-08T08:00:08.191988+00:00 2023-03-08T08:00:11.226148+00:00 0:00:03.034160 350150 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 5 default 2023-03-08T08:00:05.686719+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_booking-processing-job_v002 2023-03-08T06:00:00+00:00 TriggerDagRunOperator 2023-03-08T07:21:21.467775+00:00 2023-03-08T07:21:21.975762+00:00 0:00:00.507987 350142 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2023-03-08T07:21:18.471630+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_campaign-history-job_v002 2023-03-08T06:00:00+00:00 TriggerDagRunOperator 2023-03-08T07:21:21.218052+00:00 2023-03-08T07:21:21.705456+00:00 0:00:00.487404 350141 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2023-03-08T07:21:18.471666+00:00 2 default_pool
success campaign-flow-job_v002 check_cluster_status 2023-03-08T06:00:00+00:00 EmrJobFlowSensor 2023-03-08T07:00:51.260947+00:00 2023-03-08T07:10:53.155647+00:00 0:10:01.894700 350134 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2023-03-08T07:00:48.941961+00:00 2 default_pool
success campaign-flow-job_v002 create_cluster_and_add_emr_steps 2023-03-08T06:00:00+00:00 EmrCreateJobFlowOperator 2023-03-08T07:00:31.301876+00:00 2023-03-08T07:00:32.330545+00:00 0:00:01.028669 350132 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 4 default 2023-03-08T07:00:28.841979+00:00 2 default_pool
success campaign-flow-job_v002 create_emr_steps 2023-03-08T06:00:00+00:00 PythonOperator 2023-03-08T07:00:09.176988+00:00 2023-03-08T07:00:13.075917+00:00 0:00:03.898929 350130 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 5 default 2023-03-08T07:00:06.814076+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_booking-processing-job_v002 2023-03-08T05:00:00+00:00 TriggerDagRunOperator 2023-03-08T06:15:37.450561+00:00 2023-03-08T06:15:38.031797+00:00 0:00:00.581236 350121 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2023-03-08T06:15:34.949963+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_campaign-history-job_v002 2023-03-08T05:00:00+00:00 TriggerDagRunOperator 2023-03-08T06:15:37.431787+00:00 2023-03-08T06:15:37.934901+00:00 0:00:00.503114 350120 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2023-03-08T06:15:34.949991+00:00 2 default_pool
success campaign-flow-job_v002 check_cluster_status 2023-03-08T05:00:00+00:00 EmrJobFlowSensor 2023-03-08T06:05:28.825245+00:00 2023-03-08T06:15:30.673076+00:00 0:10:01.847831 350114 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2023-03-08T06:05:26.448397+00:00 2 default_pool
success campaign-flow-job_v002 create_cluster_and_add_emr_steps 2023-03-08T05:00:00+00:00 EmrCreateJobFlowOperator 2023-03-08T06:05:06.671015+00:00 2023-03-08T06:05:07.557735+00:00 0:00:00.886720 350111 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 4 default 2023-03-08T06:05:04.419226+00:00 2 default_pool
success campaign-flow-job_v002 create_emr_steps 2023-03-08T05:00:00+00:00 PythonOperator 2023-03-08T06:04:44.841838+00:00 2023-03-08T06:04:51.964356+00:00 0:00:07.122518 350109 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 5 default 2023-03-08T06:04:42.399656+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_booking-processing-job_v002 2023-03-08T04:00:00+00:00 TriggerDagRunOperator 2023-03-08T05:10:56.838471+00:00 2023-03-08T05:10:57.350375+00:00 0:00:00.511904 350100 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2023-03-08T05:10:54.415441+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_campaign-history-job_v002 2023-03-08T04:00:00+00:00 TriggerDagRunOperator 2023-03-08T05:10:56.833900+00:00 2023-03-08T05:10:57.371870+00:00 0:00:00.537970 350099 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2023-03-08T05:10:54.415482+00:00 2 default_pool
success campaign-flow-job_v002 check_cluster_status 2023-03-08T04:00:00+00:00 EmrJobFlowSensor 2023-03-08T05:00:48.115913+00:00 2023-03-08T05:10:50.025653+00:00 0:10:01.909740 350092 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2023-03-08T05:00:45.595904+00:00 2 default_pool
success campaign-flow-job_v002 create_cluster_and_add_emr_steps 2023-03-08T04:00:00+00:00 EmrCreateJobFlowOperator 2023-03-08T05:00:25.732133+00:00 2023-03-08T05:00:26.677791+00:00 0:00:00.945658 350090 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 4 default 2023-03-08T05:00:23.520593+00:00 2 default_pool
success campaign-flow-job_v002 create_emr_steps 2023-03-08T04:00:00+00:00 PythonOperator 2023-03-08T05:00:06.088654+00:00 2023-03-08T05:00:09.051714+00:00 0:00:02.963060 350088 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 5 default 2023-03-08T05:00:03.448796+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_campaign-history-job_v002 2023-03-08T03:00:00+00:00 TriggerDagRunOperator 2023-03-08T04:12:06.890950+00:00 2023-03-08T04:12:07.399184+00:00 0:00:00.508234 350080 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2023-03-08T04:12:04.244065+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_booking-processing-job_v002 2023-03-08T03:00:00+00:00 TriggerDagRunOperator 2023-03-08T04:12:06.654001+00:00 2023-03-08T04:12:07.174392+00:00 0:00:00.520391 350079 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2023-03-08T04:12:04.244035+00:00 2 default_pool