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-23T03:00:00+00:00 EmrJobFlowSensor 2023-02-23T04:49:31.569179+00:00 2023-02-23T04:59:33.292680+00:00 0:10:01.723501 344497 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2023-02-23T04:49:28.808636+00:00 2 default_pool
success campaign-flow-job_v002 create_cluster_and_add_emr_steps 2023-02-23T03:00:00+00:00 EmrCreateJobFlowOperator 2023-02-23T04:49:11.474746+00:00 2023-02-23T04:49:12.305500+00:00 0:00:00.830754 344492 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 4 default 2023-02-23T04:49:08.757792+00:00 2 default_pool
success campaign-flow-job_v002 create_emr_steps 2023-02-23T03:00:00+00:00 PythonOperator 2023-02-23T04:48:52.491730+00:00 2023-02-23T04:48:59.849972+00:00 0:00:07.358242 344489 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 5 default 2023-02-23T04:48:44.666629+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_booking-processing-job_v002 2023-02-23T02:00:00+00:00 TriggerDagRunOperator 2023-02-23T04:48:52.041996+00:00 2023-02-23T04:48:53.193913+00:00 0:00:01.151917 344488 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2023-02-23T04:48:44.666586+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_campaign-history-job_v002 2023-02-23T02:00:00+00:00 TriggerDagRunOperator 2023-02-23T04:48:49.507441+00:00 2023-02-23T04:48:50.158939+00:00 0:00:00.651498 344486 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2023-02-23T04:48:44.666615+00:00 2 default_pool
success campaign-flow-job_v002 check_cluster_status 2023-02-23T02:00:00+00:00 EmrJobFlowSensor 2023-02-23T03:12:04.182484+00:00 2023-02-23T03:22:06.012111+00:00 0:10:01.829627 344481 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2023-02-23T03:12:01.941182+00:00 2 default_pool
success campaign-flow-job_v002 create_cluster_and_add_emr_steps 2023-02-23T02:00:00+00:00 EmrCreateJobFlowOperator 2023-02-23T03:11:43.130580+00:00 2023-02-23T03:11:44.037662+00:00 0:00:00.907082 344477 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 4 default 2023-02-23T03:11:39.917772+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_booking-processing-job_v002 2023-02-23T01:00:00+00:00 TriggerDagRunOperator 2023-02-23T03:11:26.792070+00:00 2023-02-23T03:11:27.301669+00:00 0:00:00.509599 344473 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2023-02-23T03:11:19.852966+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_campaign-history-job_v002 2023-02-23T01:00:00+00:00 TriggerDagRunOperator 2023-02-23T03:11:26.511189+00:00 2023-02-23T03:11:27.099336+00:00 0:00:00.588147 344472 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2023-02-23T03:11:19.853002+00:00 2 default_pool
success campaign-flow-job_v002 create_emr_steps 2023-02-23T02:00:00+00:00 PythonOperator 2023-02-23T03:11:22.373186+00:00 2023-02-23T03:11:26.223284+00:00 0:00:03.850098 344471 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 5 default 2023-02-23T03:11:19.853016+00:00 2 default_pool
success campaign-flow-job_v002 check_cluster_status 2023-02-23T01:00:00+00:00 EmrJobFlowSensor 2023-02-23T02:06:03.728176+00:00 2023-02-23T02:16:05.425250+00:00 0:10:01.697074 344466 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2023-02-23T02:06:01.452543+00:00 2 default_pool
success campaign-flow-job_v002 create_cluster_and_add_emr_steps 2023-02-23T01:00:00+00:00 EmrCreateJobFlowOperator 2023-02-23T02:05:41.667017+00:00 2023-02-23T02:05:42.590573+00:00 0:00:00.923556 344463 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 4 default 2023-02-23T02:05:39.436502+00:00 2 default_pool
success campaign-flow-job_v002 create_emr_steps 2023-02-23T01:00:00+00:00 PythonOperator 2023-02-23T02:05:21.333799+00:00 2023-02-23T02:05:24.436868+00:00 0:00:03.103069 344460 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 5 default 2023-02-23T02:05:17.358297+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_booking-processing-job_v002 2023-02-23T00:00:00+00:00 TriggerDagRunOperator 2023-02-23T01:49:40.664274+00:00 2023-02-23T01:49:41.351726+00:00 0:00:00.687452 344447 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2023-02-23T01:49:35.514443+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_campaign-history-job_v002 2023-02-23T00:00:00+00:00 TriggerDagRunOperator 2023-02-23T01:49:40.001751+00:00 2023-02-23T01:49:40.611727+00:00 0:00:00.609976 344446 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2023-02-23T01:49:35.514472+00:00 2 default_pool
success campaign-flow-job_v002 check_cluster_status 2023-02-23T00:00:00+00:00 EmrJobFlowSensor 2023-02-23T01:13:15.057528+00:00 2023-02-23T01:23:17.102741+00:00 0:10:02.045213 344439 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2023-02-23T01:13:12.677709+00:00 2 default_pool
success campaign-flow-job_v002 create_cluster_and_add_emr_steps 2023-02-23T00:00:00+00:00 EmrCreateJobFlowOperator 2023-02-23T01:12:53.572919+00:00 2023-02-23T01:12:54.481675+00:00 0:00:00.908756 344436 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 4 default 2023-02-23T01:12:50.719914+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_campaign-history-job_v002 2023-02-22T23:00:00+00:00 TriggerDagRunOperator 2023-02-23T01:12:38.701709+00:00 2023-02-23T01:12:39.708150+00:00 0:00:01.006441 344433 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2023-02-23T01:12:30.723689+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_booking-processing-job_v002 2023-02-22T23:00:00+00:00 TriggerDagRunOperator 2023-02-23T01:12:35.331134+00:00 2023-02-23T01:12:36.066493+00:00 0:00:00.735359 344431 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2023-02-23T01:12:30.723635+00:00 2 default_pool
success campaign-flow-job_v002 create_emr_steps 2023-02-23T00:00:00+00:00 PythonOperator 2023-02-23T01:12:35.305528+00:00 2023-02-23T01:12:39.368804+00:00 0:00:04.063276 344430 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 5 default 2023-02-23T01:12:30.723713+00:00 2 default_pool
success campaign-flow-job_v002 check_cluster_status 2023-02-22T23:00:00+00:00 EmrJobFlowSensor 2023-02-23T00:34:18.919674+00:00 2023-02-23T00:44:20.790604+00:00 0:10:01.870930 344424 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2023-02-23T00:34:16.702753+00:00 2 default_pool
success campaign-flow-job_v002 create_cluster_and_add_emr_steps 2023-02-22T23:00:00+00:00 EmrCreateJobFlowOperator 2023-02-23T00:33:58.865981+00:00 2023-02-23T00:33:59.775378+00:00 0:00:00.909397 344421 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 4 default 2023-02-23T00:33:56.684273+00:00 2 default_pool
success campaign-flow-job_v002 create_emr_steps 2023-02-22T23:00:00+00:00 PythonOperator 2023-02-23T00:33:37.344718+00:00 2023-02-23T00:33:43.456974+00:00 0:00:06.112256 344418 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 5 default 2023-02-23T00:33:34.668985+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_booking-processing-job_v002 2023-02-22T22:00:00+00:00 TriggerDagRunOperator 2023-02-22T23:14:53.818206+00:00 2023-02-22T23:14:54.313623+00:00 0:00:00.495417 344412 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2023-02-22T23:14:51.001020+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_campaign-history-job_v002 2023-02-22T22:00:00+00:00 TriggerDagRunOperator 2023-02-22T23:14:53.621557+00:00 2023-02-22T23:14:54.123663+00:00 0:00:00.502106 344411 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2023-02-22T23:14:51.001050+00:00 2 default_pool
success campaign-flow-job_v002 check_cluster_status 2023-02-22T22:00:00+00:00 EmrJobFlowSensor 2023-02-22T23:02:05.221090+00:00 2023-02-22T23:12:06.913561+00:00 0:10:01.692471 344404 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2023-02-22T23:02:02.978360+00:00 2 default_pool
success campaign-flow-job_v002 create_cluster_and_add_emr_steps 2023-02-22T22:00:00+00:00 EmrCreateJobFlowOperator 2023-02-22T23:01:43.247020+00:00 2023-02-22T23:01:45.104643+00:00 0:00:01.857623 344401 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 4 default 2023-02-22T23:01:40.982838+00:00 2 default_pool
success campaign-flow-job_v002 create_emr_steps 2023-02-22T22:00:00+00:00 PythonOperator 2023-02-22T23:01:21.286528+00:00 2023-02-22T23:01:24.127663+00:00 0:00:02.841135 344398 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 5 default 2023-02-22T23:01:18.927688+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_booking-processing-job_v002 2023-02-22T21:00:00+00:00 TriggerDagRunOperator 2023-02-22T22:16:19.674525+00:00 2023-02-22T22:16:20.178947+00:00 0:00:00.504422 344385 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2023-02-22T22:16:14.684374+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_campaign-history-job_v002 2023-02-22T21:00:00+00:00 TriggerDagRunOperator 2023-02-22T22:16:16.923851+00:00 2023-02-22T22:16:17.459813+00:00 0:00:00.535962 344384 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2023-02-22T22:16:14.684409+00:00 2 default_pool
success campaign-flow-job_v002 check_cluster_status 2023-02-22T21:00:00+00:00 EmrJobFlowSensor 2023-02-22T22:00:48.567639+00:00 2023-02-22T22:09:50.288060+00:00 0:09:01.720421 344379 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2023-02-22T22:00:46.364894+00:00 2 default_pool
success campaign-flow-job_v002 create_cluster_and_add_emr_steps 2023-02-22T21:00:00+00:00 EmrCreateJobFlowOperator 2023-02-22T22:00:26.651699+00:00 2023-02-22T22:00:27.509976+00:00 0:00:00.858277 344377 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 4 default 2023-02-22T22:00:24.343159+00:00 2 default_pool
success campaign-flow-job_v002 create_emr_steps 2023-02-22T21:00:00+00:00 PythonOperator 2023-02-22T22:00:04.915689+00:00 2023-02-22T22:00:07.998638+00:00 0:00:03.082949 344375 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 5 default 2023-02-22T22:00:02.330816+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_booking-processing-job_v002 2023-02-22T20:00:00+00:00 TriggerDagRunOperator 2023-02-22T21:11:19.923899+00:00 2023-02-22T21:11:20.418651+00:00 0:00:00.494752 344367 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2023-02-22T21:11:17.508940+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_campaign-history-job_v002 2023-02-22T20:00:00+00:00 TriggerDagRunOperator 2023-02-22T21:11:19.808389+00:00 2023-02-22T21:11:20.277303+00:00 0:00:00.468914 344366 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2023-02-22T21:11:17.508995+00:00 2 default_pool
success campaign-flow-job_v002 check_cluster_status 2023-02-22T20:00:00+00:00 EmrJobFlowSensor 2023-02-22T21:00:59.442416+00:00 2023-02-22T21:11:01.249328+00:00 0:10:01.806912 344360 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2023-02-22T21:00:56.601056+00:00 2 default_pool
success campaign-flow-job_v002 create_cluster_and_add_emr_steps 2023-02-22T20:00:00+00:00 EmrCreateJobFlowOperator 2023-02-22T21:00:38.733245+00:00 2023-02-22T21:00:39.584696+00:00 0:00:00.851451 344358 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 4 default 2023-02-22T21:00:36.475476+00:00 2 default_pool
success campaign-flow-job_v002 create_emr_steps 2023-02-22T20:00:00+00:00 PythonOperator 2023-02-22T21:00:16.633280+00:00 2023-02-22T21:00:21.026208+00:00 0:00:04.392928 344356 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 5 default 2023-02-22T21:00:14.465417+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_booking-processing-job_v002 2023-02-22T19:00:00+00:00 TriggerDagRunOperator 2023-02-22T20:15:36.142046+00:00 2023-02-22T20:15:36.658287+00:00 0:00:00.516241 344347 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2023-02-22T20:15:32.648912+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_campaign-history-job_v002 2023-02-22T19:00:00+00:00 TriggerDagRunOperator 2023-02-22T20:15:35.321072+00:00 2023-02-22T20:15:35.758334+00:00 0:00:00.437262 344346 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2023-02-22T20:15:32.648941+00:00 2 default_pool
success campaign-flow-job_v002 check_cluster_status 2023-02-22T19:00:00+00:00 EmrJobFlowSensor 2023-02-22T20:00:54.648992+00:00 2023-02-22T20:10:56.482481+00:00 0:10:01.833489 344338 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2023-02-22T20:00:52.473679+00:00 2 default_pool
success campaign-flow-job_v002 create_cluster_and_add_emr_steps 2023-02-22T19:00:00+00:00 EmrCreateJobFlowOperator 2023-02-22T20:00:32.653651+00:00 2023-02-22T20:00:33.485391+00:00 0:00:00.831740 344336 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 4 default 2023-02-22T20:00:30.453282+00:00 2 default_pool
success campaign-flow-job_v002 create_emr_steps 2023-02-22T19:00:00+00:00 PythonOperator 2023-02-22T20:00:12.780239+00:00 2023-02-22T20:00:15.727640+00:00 0:00:02.947401 344334 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 5 default 2023-02-22T20:00:10.435214+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_campaign-history-job_v002 2023-02-22T18:00:00+00:00 TriggerDagRunOperator 2023-02-22T19:12:14.825491+00:00 2023-02-22T19:12:15.396902+00:00 0:00:00.571411 344325 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2023-02-22T19:12:12.447940+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_booking-processing-job_v002 2023-02-22T18:00:00+00:00 TriggerDagRunOperator 2023-02-22T19:12:14.820109+00:00 2023-02-22T19:12:15.484015+00:00 0:00:00.663906 344324 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2023-02-22T19:12:12.447909+00:00 2 default_pool
success campaign-flow-job_v002 check_cluster_status 2023-02-22T18:00:00+00:00 EmrJobFlowSensor 2023-02-22T19:00:50.626353+00:00 2023-02-22T19:10:52.570531+00:00 0:10:01.944178 344317 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2023-02-22T19:00:45.958913+00:00 2 default_pool
success campaign-flow-job_v002 create_cluster_and_add_emr_steps 2023-02-22T18:00:00+00:00 EmrCreateJobFlowOperator 2023-02-22T19:00:28.098332+00:00 2023-02-22T19:00:28.991443+00:00 0:00:00.893111 344315 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 4 default 2023-02-22T19:00:25.884424+00:00 2 default_pool
success campaign-flow-job_v002 create_emr_steps 2023-02-22T18:00:00+00:00 PythonOperator 2023-02-22T19:00:06.272744+00:00 2023-02-22T19:00:09.560055+00:00 0:00:03.287311 344313 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 5 default 2023-02-22T19:00:03.853181+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_booking-processing-job_v002 2023-02-22T17:00:00+00:00 TriggerDagRunOperator 2023-02-22T18:15:46.440830+00:00 2023-02-22T18:15:46.957779+00:00 0:00:00.516949 344305 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2023-02-22T18:15:43.637077+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_campaign-history-job_v002 2023-02-22T17:00:00+00:00 TriggerDagRunOperator 2023-02-22T18:15:46.359475+00:00 2023-02-22T18:15:46.909842+00:00 0:00:00.550367 344304 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2023-02-22T18:15:43.637105+00:00 2 default_pool
success campaign-flow-job_v002 check_cluster_status 2023-02-22T17:00:00+00:00 EmrJobFlowSensor 2023-02-22T18:05:33.784755+00:00 2023-02-22T18:15:35.667787+00:00 0:10:01.883032 344299 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2023-02-22T18:05:30.490682+00:00 2 default_pool
success campaign-flow-job_v002 create_cluster_and_add_emr_steps 2023-02-22T17:00:00+00:00 EmrCreateJobFlowOperator 2023-02-22T18:05:11.333349+00:00 2023-02-22T18:05:12.489324+00:00 0:00:01.155975 344296 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 4 default 2023-02-22T18:05:08.496178+00:00 2 default_pool
success campaign-flow-job_v002 create_emr_steps 2023-02-22T17:00:00+00:00 PythonOperator 2023-02-22T18:04:50.890135+00:00 2023-02-22T18:04:54.787241+00:00 0:00:03.897106 344294 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 5 default 2023-02-22T18:04:48.501493+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_campaign-history-job_v002 2023-02-22T16:00:00+00:00 TriggerDagRunOperator 2023-02-22T17:15:20.204243+00:00 2023-02-22T17:15:20.715807+00:00 0:00:00.511564 344285 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2023-02-22T17:15:17.211016+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_booking-processing-job_v002 2023-02-22T16:00:00+00:00 TriggerDagRunOperator 2023-02-22T17:15:19.884152+00:00 2023-02-22T17:15:20.386162+00:00 0:00:00.502010 344284 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2023-02-22T17:15:17.210947+00:00 2 default_pool
success campaign-flow-job_v002 check_cluster_status 2023-02-22T16:00:00+00:00 EmrJobFlowSensor 2023-02-22T17:05:13.538489+00:00 2023-02-22T17:15:15.823071+00:00 0:10:02.284582 344278 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2023-02-22T17:05:11.142006+00:00 2 default_pool
success campaign-flow-job_v002 create_cluster_and_add_emr_steps 2023-02-22T16:00:00+00:00 EmrCreateJobFlowOperator 2023-02-22T17:04:55.510450+00:00 2023-02-22T17:04:57.059296+00:00 0:00:01.548846 344276 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 4 default 2023-02-22T17:04:51.101608+00:00 2 default_pool
success campaign-flow-job_v002 create_emr_steps 2023-02-22T16:00:00+00:00 PythonOperator 2023-02-22T17:04:31.808592+00:00 2023-02-22T17:04:35.705025+00:00 0:00:03.896433 344273 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 5 default 2023-02-22T17:04:29.080193+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_campaign-history-job_v002 2023-02-22T15:00:00+00:00 TriggerDagRunOperator 2023-02-22T16:17:37.091232+00:00 2023-02-22T16:17:37.545975+00:00 0:00:00.454743 344264 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2023-02-22T16:17:34.247043+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_booking-processing-job_v002 2023-02-22T15:00:00+00:00 TriggerDagRunOperator 2023-02-22T16:17:36.900071+00:00 2023-02-22T16:17:37.370326+00:00 0:00:00.470255 344263 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2023-02-22T16:17:34.247014+00:00 2 default_pool
success campaign-flow-job_v002 check_cluster_status 2023-02-22T15:00:00+00:00 EmrJobFlowSensor 2023-02-22T16:04:04.960914+00:00 2023-02-22T16:14:06.750416+00:00 0:10:01.789502 344254 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2023-02-22T16:04:02.777451+00:00 2 default_pool
success campaign-flow-job_v002 create_cluster_and_add_emr_steps 2023-02-22T15:00:00+00:00 EmrCreateJobFlowOperator 2023-02-22T16:03:43.239108+00:00 2023-02-22T16:03:44.137755+00:00 0:00:00.898647 344251 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 4 default 2023-02-22T16:03:40.899142+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_campaign-history-job_v002 2023-02-22T14:00:00+00:00 TriggerDagRunOperator 2023-02-22T16:03:26.228918+00:00 2023-02-22T16:03:26.877596+00:00 0:00:00.648678 344249 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2023-02-22T16:03:20.268803+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_booking-processing-job_v002 2023-02-22T14:00:00+00:00 TriggerDagRunOperator 2023-02-22T16:03:26.125627+00:00 2023-02-22T16:03:26.773719+00:00 0:00:00.648092 344248 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2023-02-22T16:03:20.268767+00:00 2 default_pool
success campaign-flow-job_v002 create_emr_steps 2023-02-22T15:00:00+00:00 PythonOperator 2023-02-22T16:03:23.331443+00:00 2023-02-22T16:03:27.149666+00:00 0:00:03.818223 344247 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 5 default 2023-02-22T16:03:20.268817+00:00 2 default_pool
success campaign-flow-job_v002 check_cluster_status 2023-02-22T14:00:00+00:00 EmrJobFlowSensor 2023-02-22T15:43:47.994137+00:00 2023-02-22T15:53:49.912984+00:00 0:10:01.918847 344242 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2023-02-22T15:43:45.491579+00:00 2 default_pool
success campaign-flow-job_v002 create_cluster_and_add_emr_steps 2023-02-22T14:00:00+00:00 EmrCreateJobFlowOperator 2023-02-22T15:43:30.536642+00:00 2023-02-22T15:43:31.915949+00:00 0:00:01.379307 344238 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 4 default 2023-02-22T15:43:23.465778+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_campaign-history-job_v002 2023-02-22T13:00:00+00:00 TriggerDagRunOperator 2023-02-22T15:43:12.093319+00:00 2023-02-22T15:43:12.858003+00:00 0:00:00.764684 344234 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2023-02-22T15:43:03.448091+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_booking-processing-job_v002 2023-02-22T13:00:00+00:00 TriggerDagRunOperator 2023-02-22T15:43:11.894909+00:00 2023-02-22T15:43:12.718438+00:00 0:00:00.823529 344233 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2023-02-22T15:43:03.448061+00:00 2 default_pool
success campaign-flow-job_v002 create_emr_steps 2023-02-22T14:00:00+00:00 PythonOperator 2023-02-22T15:43:05.860164+00:00 2023-02-22T15:43:09.112338+00:00 0:00:03.252174 344232 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 5 default 2023-02-22T15:43:03.448105+00:00 2 default_pool
success campaign-flow-job_v002 check_cluster_status 2023-02-22T13:00:00+00:00 EmrJobFlowSensor 2023-02-22T14:01:05.610203+00:00 2023-02-22T14:11:07.521255+00:00 0:10:01.911052 344228 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2023-02-22T14:01:03.068891+00:00 2 default_pool
success campaign-flow-job_v002 create_cluster_and_add_emr_steps 2023-02-22T13:00:00+00:00 EmrCreateJobFlowOperator 2023-02-22T14:00:45.727875+00:00 2023-02-22T14:00:46.529507+00:00 0:00:00.801632 344226 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 4 default 2023-02-22T14:00:43.103046+00:00 2 default_pool
success campaign-flow-job_v002 create_emr_steps 2023-02-22T13:00:00+00:00 PythonOperator 2023-02-22T14:00:23.437866+00:00 2023-02-22T14:00:27.328897+00:00 0:00:03.891031 344224 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 5 default 2023-02-22T14:00:21.113570+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_campaign-history-job_v002 2023-02-22T12:00:00+00:00 TriggerDagRunOperator 2023-02-22T13:58:17.622124+00:00 2023-02-22T13:58:18.186534+00:00 0:00:00.564410 344219 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2023-02-22T13:58:14.604593+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_booking-processing-job_v002 2023-02-22T12:00:00+00:00 TriggerDagRunOperator 2023-02-22T13:58:17.512808+00:00 2023-02-22T13:58:18.019188+00:00 0:00:00.506380 344218 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2023-02-22T13:58:14.604559+00:00 2 default_pool
success campaign-flow-job_v002 check_cluster_status 2023-02-22T12:00:00+00:00 EmrJobFlowSensor 2023-02-22T13:04:00.369958+00:00 2023-02-22T13:14:02.717321+00:00 0:10:02.347363 344209 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2023-02-22T13:03:57.878685+00:00 2 default_pool
success campaign-flow-job_v002 create_cluster_and_add_emr_steps 2023-02-22T12:00:00+00:00 EmrCreateJobFlowOperator 2023-02-22T13:03:38.096045+00:00 2023-02-22T13:03:38.945174+00:00 0:00:00.849129 344205 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 4 default 2023-02-22T13:03:35.859849+00:00 2 default_pool
success campaign-flow-job_v002 create_emr_steps 2023-02-22T12:00:00+00:00 PythonOperator 2023-02-22T13:03:19.629901+00:00 2023-02-22T13:03:25.987520+00:00 0:00:06.357619 344203 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 5 default 2023-02-22T13:03:13.836589+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_campaign-history-job_v002 2023-02-22T11:00:00+00:00 TriggerDagRunOperator 2023-02-22T13:03:19.335000+00:00 2023-02-22T13:03:20.641345+00:00 0:00:01.306345 344202 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2023-02-22T13:03:13.836632+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_booking-processing-job_v002 2023-02-22T11:00:00+00:00 TriggerDagRunOperator 2023-02-22T13:03:16.527484+00:00 2023-02-22T13:03:16.994515+00:00 0:00:00.467031 344201 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2023-02-22T13:03:13.836618+00:00 2 default_pool
success campaign-flow-job_v002 check_cluster_status 2023-02-22T11:00:00+00:00 EmrJobFlowSensor 2023-02-22T12:22:52.229420+00:00 2023-02-22T12:32:54.664114+00:00 0:10:02.434694 344197 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2023-02-22T12:22:49.860464+00:00 2 default_pool
success campaign-flow-job_v002 create_cluster_and_add_emr_steps 2023-02-22T11:00:00+00:00 EmrCreateJobFlowOperator 2023-02-22T12:22:32.514900+00:00 2023-02-22T12:22:33.393508+00:00 0:00:00.878608 344193 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 4 default 2023-02-22T12:22:29.836840+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_campaign-history-job_v002 2023-02-22T10:00:00+00:00 TriggerDagRunOperator 2023-02-22T12:22:11.897430+00:00 2023-02-22T12:22:12.619548+00:00 0:00:00.722118 344189 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2023-02-22T12:22:07.787753+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_booking-processing-job_v002 2023-02-22T10:00:00+00:00 TriggerDagRunOperator 2023-02-22T12:22:11.881625+00:00 2023-02-22T12:22:12.578252+00:00 0:00:00.696627 344188 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2023-02-22T12:22:07.787739+00:00 2 default_pool
success campaign-flow-job_v002 create_emr_steps 2023-02-22T11:00:00+00:00 PythonOperator 2023-02-22T12:22:10.051059+00:00 2023-02-22T12:22:13.844857+00:00 0:00:03.793798 344187 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 5 default 2023-02-22T12:22:07.787706+00:00 2 default_pool
success campaign-flow-job_v002 check_cluster_status 2023-02-22T10:00:00+00:00 EmrJobFlowSensor 2023-02-22T11:39:20.463455+00:00 2023-02-22T11:49:22.260810+00:00 0:10:01.797355 344182 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2023-02-22T11:39:18.236688+00:00 2 default_pool
success campaign-flow-job_v002 create_cluster_and_add_emr_steps 2023-02-22T10:00:00+00:00 EmrCreateJobFlowOperator 2023-02-22T11:38:58.352366+00:00 2023-02-22T11:38:59.215970+00:00 0:00:00.863604 344179 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 4 default 2023-02-22T11:38:56.163958+00:00 2 default_pool
success campaign-flow-job_v002 create_emr_steps 2023-02-22T10:00:00+00:00 PythonOperator 2023-02-22T11:38:38.411669+00:00 2023-02-22T11:38:42.340983+00:00 0:00:03.929314 344176 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 5 default 2023-02-22T11:38:36.139833+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_campaign-history-job_v002 2023-02-22T09:00:00+00:00 TriggerDagRunOperator 2023-02-22T10:52:00.324417+00:00 2023-02-22T10:52:00.878859+00:00 0:00:00.554442 344169 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2023-02-22T10:51:57.093837+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_booking-processing-job_v002 2023-02-22T09:00:00+00:00 TriggerDagRunOperator 2023-02-22T10:51:59.975027+00:00 2023-02-22T10:52:00.677564+00:00 0:00:00.702537 344168 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2023-02-22T10:51:57.093800+00:00 2 default_pool
success campaign-flow-job_v002 check_cluster_status 2023-02-22T09:00:00+00:00 EmrJobFlowSensor 2023-02-22T10:39:17.332973+00:00 2023-02-22T10:49:19.475806+00:00 0:10:02.142833 344164 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2023-02-22T10:39:13.991910+00:00 2 default_pool
success campaign-flow-job_v002 create_cluster_and_add_emr_steps 2023-02-22T09:00:00+00:00 EmrCreateJobFlowOperator 2023-02-22T10:38:54.209226+00:00 2023-02-22T10:38:55.077186+00:00 0:00:00.867960 344161 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 4 default 2023-02-22T10:38:51.868164+00:00 2 default_pool
success campaign-flow-job_v002 create_emr_steps 2023-02-22T09:00:00+00:00 PythonOperator 2023-02-22T10:38:32.065770+00:00 2023-02-22T10:38:36.297015+00:00 0:00:04.231245 344158 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 5 default 2023-02-22T10:38:29.840100+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_booking-processing-job_v002 2023-02-22T08:00:00+00:00 TriggerDagRunOperator 2023-02-22T09:56:37.817755+00:00 2023-02-22T09:56:38.375996+00:00 0:00:00.558241 344152 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2023-02-22T09:56:34.792212+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_campaign-history-job_v002 2023-02-22T08:00:00+00:00 TriggerDagRunOperator 2023-02-22T09:56:37.756028+00:00 2023-02-22T09:56:38.234917+00:00 0:00:00.478889 344151 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2023-02-22T09:56:34.792252+00:00 2 default_pool
success campaign-flow-job_v002 check_cluster_status 2023-02-22T08:00:00+00:00 EmrJobFlowSensor 2023-02-22T09:36:27.132669+00:00 2023-02-22T09:46:28.813943+00:00 0:10:01.681274 344146 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2023-02-22T09:36:24.935180+00:00 2 default_pool
success campaign-flow-job_v002 create_cluster_and_add_emr_steps 2023-02-22T08:00:00+00:00 EmrCreateJobFlowOperator 2023-02-22T09:36:07.337966+00:00 2023-02-22T09:36:08.286130+00:00 0:00:00.948164 344142 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 4 default 2023-02-22T09:36:04.877532+00:00 2 default_pool
success campaign-flow-job_v002 create_emr_steps 2023-02-22T08:00:00+00:00 PythonOperator 2023-02-22T09:35:45.725680+00:00 2023-02-22T09:35:49.741614+00:00 0:00:04.015934 344138 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 5 default 2023-02-22T09:35:40.818589+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_campaign-history-job_v002 2023-02-22T07:00:00+00:00 TriggerDagRunOperator 2023-02-22T09:35:45.675115+00:00 2023-02-22T09:35:46.335367+00:00 0:00:00.660252 344137 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2023-02-22T09:35:40.818575+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_booking-processing-job_v002 2023-02-22T07:00:00+00:00 TriggerDagRunOperator 2023-02-22T09:35:44.869740+00:00 2023-02-22T09:35:45.716443+00:00 0:00:00.846703 344136 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2023-02-22T09:35:40.818539+00:00 2 default_pool