Task Instances

Reset Filters
  State Dag Id Task Id Execution Date Operator Start Date End Date Duration Job Id Hostname Unixname Priority Weight Queue Queued Dttm Try Number Pool Log Url
success campaign-flow-job_v002 create_cluster_and_add_emr_steps 2023-05-29T02:00:00+00:00 EmrCreateJobFlowOperator 2023-05-29T03:00:39.728381+00:00 2023-05-29T03:00:40.529557+00:00 0:00:00.801176 387572 airflow-worker-1.airflow-worker.data-eng.svc.cluster.local airflow 4 default 2023-05-29T03:00:37.589706+00:00 2 default_pool
success campaign-flow-job_v002 create_emr_steps 2023-05-29T02:00:00+00:00 PythonOperator 2023-05-29T03:00:19.777951+00:00 2023-05-29T03:00:20.682604+00:00 0:00:00.904653 387570 airflow-worker-0.airflow-worker.data-eng.svc.cluster.local airflow 5 default 2023-05-29T03:00:17.513195+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_campaign-history-job_v002 2023-05-29T01:00:00+00:00 TriggerDagRunOperator 2023-05-29T02:11:34.350668+00:00 2023-05-29T02:11:34.807244+00:00 0:00:00.456576 387559 airflow-worker-1.airflow-worker.data-eng.svc.cluster.local airflow 1 default 2023-05-29T02:11:32.102030+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_booking-processing-job_v002 2023-05-29T01:00:00+00:00 TriggerDagRunOperator 2023-05-29T02:11:34.328517+00:00 2023-05-29T02:11:34.753130+00:00 0:00:00.424613 387558 airflow-worker-0.airflow-worker.data-eng.svc.cluster.local airflow 1 default 2023-05-29T02:11:32.102002+00:00 2 default_pool
success campaign-flow-job_v002 check_cluster_status 2023-05-29T01:00:00+00:00 EmrJobFlowSensor 2023-05-29T02:01:01.797965+00:00 2023-05-29T02:11:03.820378+00:00 0:10:02.022413 387550 airflow-worker-0.airflow-worker.data-eng.svc.cluster.local airflow 3 default 2023-05-29T02:00:59.695380+00:00 2 default_pool
success campaign-flow-job_v002 create_cluster_and_add_emr_steps 2023-05-29T01:00:00+00:00 EmrCreateJobFlowOperator 2023-05-29T02:00:39.791525+00:00 2023-05-29T02:00:40.730968+00:00 0:00:00.939443 387548 airflow-worker-0.airflow-worker.data-eng.svc.cluster.local airflow 4 default 2023-05-29T02:00:37.620166+00:00 2 default_pool
success campaign-flow-job_v002 create_emr_steps 2023-05-29T01:00:00+00:00 PythonOperator 2023-05-29T02:00:17.829756+00:00 2023-05-29T02:00:19.264753+00:00 0:00:01.434997 387546 airflow-worker-0.airflow-worker.data-eng.svc.cluster.local airflow 5 default 2023-05-29T02:00:15.601606+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_campaign-history-job_v002 2023-05-29T00:00:00+00:00 TriggerDagRunOperator 2023-05-29T01:11:18.654566+00:00 2023-05-29T01:11:19.139336+00:00 0:00:00.484770 387526 airflow-worker-1.airflow-worker.data-eng.svc.cluster.local airflow 1 default 2023-05-29T01:11:15.996321+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_booking-processing-job_v002 2023-05-29T00:00:00+00:00 TriggerDagRunOperator 2023-05-29T01:11:18.620023+00:00 2023-05-29T01:11:19.101067+00:00 0:00:00.481044 387525 airflow-worker-0.airflow-worker.data-eng.svc.cluster.local airflow 1 default 2023-05-29T01:11:15.996292+00:00 2 default_pool
success campaign-flow-job_v002 check_cluster_status 2023-05-29T00:00:00+00:00 EmrJobFlowSensor 2023-05-29T01:00:49.743484+00:00 2023-05-29T01:10:51.449612+00:00 0:10:01.706128 387517 airflow-worker-1.airflow-worker.data-eng.svc.cluster.local airflow 3 default 2023-05-29T01:00:47.614162+00:00 2 default_pool
success campaign-flow-job_v002 create_cluster_and_add_emr_steps 2023-05-29T00:00:00+00:00 EmrCreateJobFlowOperator 2023-05-29T01:00:29.753688+00:00 2023-05-29T01:00:30.732300+00:00 0:00:00.978612 387515 airflow-worker-0.airflow-worker.data-eng.svc.cluster.local airflow 4 default 2023-05-29T01:00:27.603915+00:00 2 default_pool
success campaign-flow-job_v002 create_emr_steps 2023-05-29T00:00:00+00:00 PythonOperator 2023-05-29T01:00:07.867420+00:00 2023-05-29T01:00:08.737407+00:00 0:00:00.869987 387513 airflow-worker-0.airflow-worker.data-eng.svc.cluster.local airflow 5 default 2023-05-29T01:00:05.604356+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_campaign-history-job_v002 2023-05-28T23:00:00+00:00 TriggerDagRunOperator 2023-05-29T00:11:36.325843+00:00 2023-05-29T00:11:36.766174+00:00 0:00:00.440331 387503 airflow-worker-0.airflow-worker.data-eng.svc.cluster.local airflow 1 default 2023-05-29T00:11:33.815135+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_booking-processing-job_v002 2023-05-28T23:00:00+00:00 TriggerDagRunOperator 2023-05-29T00:11:36.299230+00:00 2023-05-29T00:11:36.757326+00:00 0:00:00.458096 387502 airflow-worker-1.airflow-worker.data-eng.svc.cluster.local airflow 1 default 2023-05-29T00:11:33.815093+00:00 2 default_pool
success campaign-flow-job_v002 check_cluster_status 2023-05-28T23:00:00+00:00 EmrJobFlowSensor 2023-05-29T00:01:01.334425+00:00 2023-05-29T00:11:03.246061+00:00 0:10:01.911636 387495 airflow-worker-0.airflow-worker.data-eng.svc.cluster.local airflow 3 default 2023-05-29T00:00:59.253176+00:00 2 default_pool
success campaign-flow-job_v002 create_cluster_and_add_emr_steps 2023-05-28T23:00:00+00:00 EmrCreateJobFlowOperator 2023-05-29T00:00:41.303236+00:00 2023-05-29T00:00:42.260249+00:00 0:00:00.957013 387493 airflow-worker-0.airflow-worker.data-eng.svc.cluster.local airflow 4 default 2023-05-29T00:00:39.230864+00:00 2 default_pool
success campaign-flow-job_v002 create_emr_steps 2023-05-28T23:00:00+00:00 PythonOperator 2023-05-29T00:00:19.209180+00:00 2023-05-29T00:00:20.132388+00:00 0:00:00.923208 387491 airflow-worker-1.airflow-worker.data-eng.svc.cluster.local airflow 5 default 2023-05-29T00:00:17.208002+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_campaign-history-job_v002 2023-05-28T22:00:00+00:00 TriggerDagRunOperator 2023-05-28T23:11:12.051382+00:00 2023-05-28T23:11:12.636541+00:00 0:00:00.585159 387480 airflow-worker-0.airflow-worker.data-eng.svc.cluster.local airflow 1 default 2023-05-28T23:11:09.745988+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_booking-processing-job_v002 2023-05-28T22:00:00+00:00 TriggerDagRunOperator 2023-05-28T23:11:11.867160+00:00 2023-05-28T23:11:12.357357+00:00 0:00:00.490197 387479 airflow-worker-1.airflow-worker.data-eng.svc.cluster.local airflow 1 default 2023-05-28T23:11:09.745960+00:00 2 default_pool
success campaign-flow-job_v002 check_cluster_status 2023-05-28T22:00:00+00:00 EmrJobFlowSensor 2023-05-28T23:01:01.601394+00:00 2023-05-28T23:11:03.508919+00:00 0:10:01.907525 387472 airflow-worker-0.airflow-worker.data-eng.svc.cluster.local airflow 3 default 2023-05-28T23:00:59.448615+00:00 2 default_pool
success campaign-flow-job_v002 create_cluster_and_add_emr_steps 2023-05-28T22:00:00+00:00 EmrCreateJobFlowOperator 2023-05-28T23:00:39.672293+00:00 2023-05-28T23:00:40.649770+00:00 0:00:00.977477 387469 airflow-worker-0.airflow-worker.data-eng.svc.cluster.local airflow 4 default 2023-05-28T23:00:37.426543+00:00 2 default_pool
success campaign-flow-job_v002 create_emr_steps 2023-05-28T22:00:00+00:00 PythonOperator 2023-05-28T23:00:19.502080+00:00 2023-05-28T23:00:20.439884+00:00 0:00:00.937804 387466 airflow-worker-1.airflow-worker.data-eng.svc.cluster.local airflow 5 default 2023-05-28T23:00:17.408869+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_booking-processing-job_v002 2023-05-28T21:00:00+00:00 TriggerDagRunOperator 2023-05-28T22:11:12.900896+00:00 2023-05-28T22:11:13.369420+00:00 0:00:00.468524 387454 airflow-worker-0.airflow-worker.data-eng.svc.cluster.local airflow 1 default 2023-05-28T22:11:10.596142+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_campaign-history-job_v002 2023-05-28T21:00:00+00:00 TriggerDagRunOperator 2023-05-28T22:11:12.845013+00:00 2023-05-28T22:11:13.311760+00:00 0:00:00.466747 387453 airflow-worker-1.airflow-worker.data-eng.svc.cluster.local airflow 1 default 2023-05-28T22:11:10.596170+00:00 2 default_pool
success campaign-flow-job_v002 check_cluster_status 2023-05-28T21:00:00+00:00 EmrJobFlowSensor 2023-05-28T22:00:57.100787+00:00 2023-05-28T22:10:58.837010+00:00 0:10:01.736223 387445 airflow-worker-0.airflow-worker.data-eng.svc.cluster.local airflow 3 default 2023-05-28T22:00:54.941964+00:00 2 default_pool
success campaign-flow-job_v002 create_cluster_and_add_emr_steps 2023-05-28T21:00:00+00:00 EmrCreateJobFlowOperator 2023-05-28T22:00:35.129710+00:00 2023-05-28T22:00:36.049726+00:00 0:00:00.920016 387443 airflow-worker-0.airflow-worker.data-eng.svc.cluster.local airflow 4 default 2023-05-28T22:00:32.920167+00:00 2 default_pool
success campaign-flow-job_v002 create_emr_steps 2023-05-28T21:00:00+00:00 PythonOperator 2023-05-28T22:00:15.190968+00:00 2023-05-28T22:00:16.137301+00:00 0:00:00.946333 387441 airflow-worker-1.airflow-worker.data-eng.svc.cluster.local airflow 5 default 2023-05-28T22:00:12.885647+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_campaign-history-job_v002 2023-05-28T20:00:00+00:00 TriggerDagRunOperator 2023-05-28T21:10:58.628060+00:00 2023-05-28T21:10:59.102415+00:00 0:00:00.474355 387431 airflow-worker-0.airflow-worker.data-eng.svc.cluster.local airflow 1 default 2023-05-28T21:10:56.289625+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_booking-processing-job_v002 2023-05-28T20:00:00+00:00 TriggerDagRunOperator 2023-05-28T21:10:58.586759+00:00 2023-05-28T21:10:59.049202+00:00 0:00:00.462443 387430 airflow-worker-1.airflow-worker.data-eng.svc.cluster.local airflow 1 default 2023-05-28T21:10:56.289586+00:00 2 default_pool
success campaign-flow-job_v002 check_cluster_status 2023-05-28T20:00:00+00:00 EmrJobFlowSensor 2023-05-28T21:00:52.282201+00:00 2023-05-28T21:10:54.200619+00:00 0:10:01.918418 387423 airflow-worker-0.airflow-worker.data-eng.svc.cluster.local airflow 3 default 2023-05-28T21:00:50.097414+00:00 2 default_pool
success campaign-flow-job_v002 create_cluster_and_add_emr_steps 2023-05-28T20:00:00+00:00 EmrCreateJobFlowOperator 2023-05-28T21:00:30.389654+00:00 2023-05-28T21:00:31.319094+00:00 0:00:00.929440 387421 airflow-worker-0.airflow-worker.data-eng.svc.cluster.local airflow 4 default 2023-05-28T21:00:28.098065+00:00 2 default_pool
success campaign-flow-job_v002 create_emr_steps 2023-05-28T20:00:00+00:00 PythonOperator 2023-05-28T21:00:08.563239+00:00 2023-05-28T21:00:09.507555+00:00 0:00:00.944316 387418 airflow-worker-0.airflow-worker.data-eng.svc.cluster.local airflow 5 default 2023-05-28T21:00:06.088201+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_booking-processing-job_v002 2023-05-28T19:00:00+00:00 TriggerDagRunOperator 2023-05-28T20:11:17.242448+00:00 2023-05-28T20:11:17.684357+00:00 0:00:00.441909 387408 airflow-worker-0.airflow-worker.data-eng.svc.cluster.local airflow 1 default 2023-05-28T20:11:14.934699+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_campaign-history-job_v002 2023-05-28T19:00:00+00:00 TriggerDagRunOperator 2023-05-28T20:11:17.109340+00:00 2023-05-28T20:11:17.546937+00:00 0:00:00.437597 387407 airflow-worker-1.airflow-worker.data-eng.svc.cluster.local airflow 1 default 2023-05-28T20:11:14.934727+00:00 2 default_pool
success campaign-flow-job_v002 check_cluster_status 2023-05-28T19:00:00+00:00 EmrJobFlowSensor 2023-05-28T20:00:53.003950+00:00 2023-05-28T20:10:54.716597+00:00 0:10:01.712647 387399 airflow-worker-0.airflow-worker.data-eng.svc.cluster.local airflow 3 default 2023-05-28T20:00:50.827845+00:00 2 default_pool
success campaign-flow-job_v002 create_cluster_and_add_emr_steps 2023-05-28T19:00:00+00:00 EmrCreateJobFlowOperator 2023-05-28T20:00:30.898843+00:00 2023-05-28T20:00:31.969388+00:00 0:00:01.070545 387397 airflow-worker-1.airflow-worker.data-eng.svc.cluster.local airflow 4 default 2023-05-28T20:00:28.806612+00:00 2 default_pool
success campaign-flow-job_v002 create_emr_steps 2023-05-28T19:00:00+00:00 PythonOperator 2023-05-28T20:00:11.163002+00:00 2023-05-28T20:00:12.076005+00:00 0:00:00.913003 387395 airflow-worker-0.airflow-worker.data-eng.svc.cluster.local airflow 5 default 2023-05-28T20:00:08.789562+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_campaign-history-job_v002 2023-05-28T18:00:00+00:00 TriggerDagRunOperator 2023-05-28T19:10:58.992279+00:00 2023-05-28T19:10:59.438447+00:00 0:00:00.446168 387382 airflow-worker-0.airflow-worker.data-eng.svc.cluster.local airflow 1 default 2023-05-28T19:10:56.667741+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_booking-processing-job_v002 2023-05-28T18:00:00+00:00 TriggerDagRunOperator 2023-05-28T19:10:58.902512+00:00 2023-05-28T19:10:59.397180+00:00 0:00:00.494668 387381 airflow-worker-1.airflow-worker.data-eng.svc.cluster.local airflow 1 default 2023-05-28T19:10:56.667713+00:00 2 default_pool
success campaign-flow-job_v002 check_cluster_status 2023-05-28T18:00:00+00:00 EmrJobFlowSensor 2023-05-28T19:00:50.032188+00:00 2023-05-28T19:10:51.879979+00:00 0:10:01.847791 387374 airflow-worker-0.airflow-worker.data-eng.svc.cluster.local airflow 3 default 2023-05-28T19:00:47.866111+00:00 2 default_pool
success campaign-flow-job_v002 create_cluster_and_add_emr_steps 2023-05-28T18:00:00+00:00 EmrCreateJobFlowOperator 2023-05-28T19:00:28.077706+00:00 2023-05-28T19:00:29.045776+00:00 0:00:00.968070 387373 airflow-worker-0.airflow-worker.data-eng.svc.cluster.local airflow 4 default 2023-05-28T19:00:25.847539+00:00 2 default_pool
success campaign-flow-job_v002 create_emr_steps 2023-05-28T18:00:00+00:00 PythonOperator 2023-05-28T19:00:06.264854+00:00 2023-05-28T19:00:07.191649+00:00 0:00:00.926795 387371 airflow-worker-1.airflow-worker.data-eng.svc.cluster.local airflow 5 default 2023-05-28T19:00:03.823357+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_campaign-history-job_v002 2023-05-28T17:00:00+00:00 TriggerDagRunOperator 2023-05-28T18:11:18.254146+00:00 2023-05-28T18:11:18.687228+00:00 0:00:00.433082 387358 airflow-worker-0.airflow-worker.data-eng.svc.cluster.local airflow 1 default 2023-05-28T18:11:15.763610+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_booking-processing-job_v002 2023-05-28T17:00:00+00:00 TriggerDagRunOperator 2023-05-28T18:11:18.104099+00:00 2023-05-28T18:11:18.550782+00:00 0:00:00.446683 387357 airflow-worker-1.airflow-worker.data-eng.svc.cluster.local airflow 1 default 2023-05-28T18:11:15.763577+00:00 2 default_pool
success campaign-flow-job_v002 check_cluster_status 2023-05-28T17:00:00+00:00 EmrJobFlowSensor 2023-05-28T18:01:06.287900+00:00 2023-05-28T18:11:07.999982+00:00 0:10:01.712082 387350 airflow-worker-0.airflow-worker.data-eng.svc.cluster.local airflow 3 default 2023-05-28T18:01:04.086159+00:00 2 default_pool
success campaign-flow-job_v002 create_cluster_and_add_emr_steps 2023-05-28T17:00:00+00:00 EmrCreateJobFlowOperator 2023-05-28T18:00:46.135089+00:00 2023-05-28T18:00:47.060430+00:00 0:00:00.925341 387349 airflow-worker-1.airflow-worker.data-eng.svc.cluster.local airflow 4 default 2023-05-28T18:00:44.030491+00:00 2 default_pool
success campaign-flow-job_v002 create_emr_steps 2023-05-28T17:00:00+00:00 PythonOperator 2023-05-28T18:00:24.069741+00:00 2023-05-28T18:00:24.990197+00:00 0:00:00.920456 387348 airflow-worker-1.airflow-worker.data-eng.svc.cluster.local airflow 5 default 2023-05-28T18:00:22.003519+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_booking-processing-job_v002 2023-05-28T16:00:00+00:00 TriggerDagRunOperator 2023-05-28T17:10:09.083623+00:00 2023-05-28T17:10:09.515087+00:00 0:00:00.431464 387336 airflow-worker-0.airflow-worker.data-eng.svc.cluster.local airflow 1 default 2023-05-28T17:10:07.005714+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_campaign-history-job_v002 2023-05-28T16:00:00+00:00 TriggerDagRunOperator 2023-05-28T17:10:09.091406+00:00 2023-05-28T17:10:09.531926+00:00 0:00:00.440520 387335 airflow-worker-1.airflow-worker.data-eng.svc.cluster.local airflow 1 default 2023-05-28T17:10:07.005757+00:00 2 default_pool
success campaign-flow-job_v002 check_cluster_status 2023-05-28T16:00:00+00:00 EmrJobFlowSensor 2023-05-28T17:00:56.733571+00:00 2023-05-28T17:09:58.316974+00:00 0:09:01.583403 387326 airflow-worker-0.airflow-worker.data-eng.svc.cluster.local airflow 3 default 2023-05-28T17:00:54.597110+00:00 2 default_pool
success campaign-flow-job_v002 create_cluster_and_add_emr_steps 2023-05-28T16:00:00+00:00 EmrCreateJobFlowOperator 2023-05-28T17:00:36.745837+00:00 2023-05-28T17:00:37.599676+00:00 0:00:00.853839 387325 airflow-worker-0.airflow-worker.data-eng.svc.cluster.local airflow 4 default 2023-05-28T17:00:34.601296+00:00 2 default_pool
success campaign-flow-job_v002 create_emr_steps 2023-05-28T16:00:00+00:00 PythonOperator 2023-05-28T17:00:14.784222+00:00 2023-05-28T17:00:15.684948+00:00 0:00:00.900726 387323 airflow-worker-0.airflow-worker.data-eng.svc.cluster.local airflow 5 default 2023-05-28T17:00:12.540229+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_booking-processing-job_v002 2023-05-28T15:00:00+00:00 TriggerDagRunOperator 2023-05-28T16:15:39.176613+00:00 2023-05-28T16:15:39.623020+00:00 0:00:00.446407 387313 airflow-worker-0.airflow-worker.data-eng.svc.cluster.local airflow 1 default 2023-05-28T16:15:36.596502+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_campaign-history-job_v002 2023-05-28T15:00:00+00:00 TriggerDagRunOperator 2023-05-28T16:15:39.158277+00:00 2023-05-28T16:15:39.594430+00:00 0:00:00.436153 387312 airflow-worker-1.airflow-worker.data-eng.svc.cluster.local airflow 1 default 2023-05-28T16:15:36.596528+00:00 2 default_pool
success campaign-flow-job_v002 check_cluster_status 2023-05-28T15:00:00+00:00 EmrJobFlowSensor 2023-05-28T16:04:32.252235+00:00 2023-05-28T16:15:34.210877+00:00 0:11:01.958642 387306 airflow-worker-0.airflow-worker.data-eng.svc.cluster.local airflow 3 default 2023-05-28T16:04:30.173431+00:00 2 default_pool
success campaign-flow-job_v002 create_cluster_and_add_emr_steps 2023-05-28T15:00:00+00:00 EmrCreateJobFlowOperator 2023-05-28T16:04:10.196645+00:00 2023-05-28T16:04:11.320160+00:00 0:00:01.123515 387304 airflow-worker-0.airflow-worker.data-eng.svc.cluster.local airflow 4 default 2023-05-28T16:04:08.133865+00:00 2 default_pool
success campaign-flow-job_v002 create_emr_steps 2023-05-28T15:00:00+00:00 PythonOperator 2023-05-28T16:03:50.147796+00:00 2023-05-28T16:03:51.211417+00:00 0:00:01.063621 387302 airflow-worker-0.airflow-worker.data-eng.svc.cluster.local airflow 5 default 2023-05-28T16:03:48.108950+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_campaign-history-job_v002 2023-05-28T14:00:00+00:00 TriggerDagRunOperator 2023-05-28T15:12:06.217636+00:00 2023-05-28T15:12:06.647462+00:00 0:00:00.429826 387293 airflow-worker-0.airflow-worker.data-eng.svc.cluster.local airflow 1 default 2023-05-28T15:12:03.939275+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_booking-processing-job_v002 2023-05-28T14:00:00+00:00 TriggerDagRunOperator 2023-05-28T15:12:06.196677+00:00 2023-05-28T15:12:06.631893+00:00 0:00:00.435216 387292 airflow-worker-1.airflow-worker.data-eng.svc.cluster.local airflow 1 default 2023-05-28T15:12:03.939247+00:00 2 default_pool
success campaign-flow-job_v002 check_cluster_status 2023-05-28T14:00:00+00:00 EmrJobFlowSensor 2023-05-28T15:01:53.471242+00:00 2023-05-28T15:11:55.235978+00:00 0:10:01.764736 387285 airflow-worker-0.airflow-worker.data-eng.svc.cluster.local airflow 3 default 2023-05-28T15:01:51.292125+00:00 2 default_pool
success campaign-flow-job_v002 create_cluster_and_add_emr_steps 2023-05-28T14:00:00+00:00 EmrCreateJobFlowOperator 2023-05-28T15:01:31.292949+00:00 2023-05-28T15:01:32.234036+00:00 0:00:00.941087 387283 airflow-worker-0.airflow-worker.data-eng.svc.cluster.local airflow 4 default 2023-05-28T15:01:29.034253+00:00 2 default_pool
success campaign-flow-job_v002 create_emr_steps 2023-05-28T14:00:00+00:00 PythonOperator 2023-05-28T15:00:11.295839+00:00 2023-05-28T15:00:12.191606+00:00 0:00:00.895767 387281 airflow-worker-0.airflow-worker.data-eng.svc.cluster.local airflow 5 default 2023-05-28T15:00:09.157767+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_booking-processing-job_v002 2023-05-28T13:00:00+00:00 TriggerDagRunOperator 2023-05-28T14:10:58.893550+00:00 2023-05-28T14:10:59.352696+00:00 0:00:00.459146 387272 airflow-worker-1.airflow-worker.data-eng.svc.cluster.local airflow 1 default 2023-05-28T14:10:56.505412+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_campaign-history-job_v002 2023-05-28T13:00:00+00:00 TriggerDagRunOperator 2023-05-28T14:10:58.888968+00:00 2023-05-28T14:10:59.349607+00:00 0:00:00.460639 387271 airflow-worker-0.airflow-worker.data-eng.svc.cluster.local airflow 1 default 2023-05-28T14:10:56.505440+00:00 2 default_pool
success campaign-flow-job_v002 check_cluster_status 2023-05-28T13:00:00+00:00 EmrJobFlowSensor 2023-05-28T14:00:48.703310+00:00 2023-05-28T14:10:50.553625+00:00 0:10:01.850315 387264 airflow-worker-1.airflow-worker.data-eng.svc.cluster.local airflow 3 default 2023-05-28T14:00:46.495481+00:00 2 default_pool
success campaign-flow-job_v002 create_cluster_and_add_emr_steps 2023-05-28T13:00:00+00:00 EmrCreateJobFlowOperator 2023-05-28T14:00:26.552678+00:00 2023-05-28T14:00:27.622308+00:00 0:00:01.069630 387262 airflow-worker-0.airflow-worker.data-eng.svc.cluster.local airflow 4 default 2023-05-28T14:00:24.474861+00:00 2 default_pool
success campaign-flow-job_v002 create_emr_steps 2023-05-28T13:00:00+00:00 PythonOperator 2023-05-28T14:00:06.846366+00:00 2023-05-28T14:00:07.772548+00:00 0:00:00.926182 387260 airflow-worker-1.airflow-worker.data-eng.svc.cluster.local airflow 5 default 2023-05-28T14:00:04.509189+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_campaign-history-job_v002 2023-05-28T12:00:00+00:00 TriggerDagRunOperator 2023-05-28T13:11:16.915140+00:00 2023-05-28T13:11:17.398727+00:00 0:00:00.483587 387252 airflow-worker-1.airflow-worker.data-eng.svc.cluster.local airflow 1 default 2023-05-28T13:11:14.928149+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_booking-processing-job_v002 2023-05-28T12:00:00+00:00 TriggerDagRunOperator 2023-05-28T13:11:16.887235+00:00 2023-05-28T13:11:17.363989+00:00 0:00:00.476754 387251 airflow-worker-0.airflow-worker.data-eng.svc.cluster.local airflow 1 default 2023-05-28T13:11:14.928120+00:00 2 default_pool
success campaign-flow-job_v002 check_cluster_status 2023-05-28T12:00:00+00:00 EmrJobFlowSensor 2023-05-28T13:01:01.465831+00:00 2023-05-28T13:11:03.316666+00:00 0:10:01.850835 387244 airflow-worker-0.airflow-worker.data-eng.svc.cluster.local airflow 3 default 2023-05-28T13:00:59.480050+00:00 2 default_pool
success campaign-flow-job_v002 create_cluster_and_add_emr_steps 2023-05-28T12:00:00+00:00 EmrCreateJobFlowOperator 2023-05-28T13:00:39.439701+00:00 2023-05-28T13:00:40.333175+00:00 0:00:00.893474 387242 airflow-worker-0.airflow-worker.data-eng.svc.cluster.local airflow 4 default 2023-05-28T13:00:37.461305+00:00 2 default_pool
success campaign-flow-job_v002 create_emr_steps 2023-05-28T12:00:00+00:00 PythonOperator 2023-05-28T13:00:19.618696+00:00 2023-05-28T13:00:20.492419+00:00 0:00:00.873723 387240 airflow-worker-0.airflow-worker.data-eng.svc.cluster.local airflow 5 default 2023-05-28T13:00:17.444708+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_campaign-history-job_v002 2023-05-28T11:00:00+00:00 TriggerDagRunOperator 2023-05-28T12:21:12.666004+00:00 2023-05-28T12:21:13.216554+00:00 0:00:00.550550 387229 airflow-worker-1.airflow-worker.data-eng.svc.cluster.local airflow 1 default 2023-05-28T12:21:10.474584+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_booking-processing-job_v002 2023-05-28T11:00:00+00:00 TriggerDagRunOperator 2023-05-28T12:21:12.698923+00:00 2023-05-28T12:21:13.175930+00:00 0:00:00.477007 387228 airflow-worker-0.airflow-worker.data-eng.svc.cluster.local airflow 1 default 2023-05-28T12:21:10.474554+00:00 2 default_pool
success campaign-flow-job_v002 check_cluster_status 2023-05-28T11:00:00+00:00 EmrJobFlowSensor 2023-05-28T12:01:00.721064+00:00 2023-05-28T12:11:02.513888+00:00 0:10:01.792824 387223 airflow-worker-1.airflow-worker.data-eng.svc.cluster.local airflow 3 default 2023-05-28T12:00:58.512351+00:00 2 default_pool
success campaign-flow-job_v002 create_cluster_and_add_emr_steps 2023-05-28T11:00:00+00:00 EmrCreateJobFlowOperator 2023-05-28T12:00:40.551674+00:00 2023-05-28T12:00:41.534596+00:00 0:00:00.982922 387221 airflow-worker-0.airflow-worker.data-eng.svc.cluster.local airflow 4 default 2023-05-28T12:00:38.491710+00:00 2 default_pool
success campaign-flow-job_v002 create_emr_steps 2023-05-28T11:00:00+00:00 PythonOperator 2023-05-28T12:00:18.739976+00:00 2023-05-28T12:00:19.671493+00:00 0:00:00.931517 387219 airflow-worker-0.airflow-worker.data-eng.svc.cluster.local airflow 5 default 2023-05-28T12:00:16.472078+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_booking-processing-job_v002 2023-05-28T10:00:00+00:00 TriggerDagRunOperator 2023-05-28T11:11:11.878265+00:00 2023-05-28T11:11:12.433113+00:00 0:00:00.554848 387211 airflow-worker-1.airflow-worker.data-eng.svc.cluster.local airflow 1 default 2023-05-28T11:11:09.818252+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_campaign-history-job_v002 2023-05-28T10:00:00+00:00 TriggerDagRunOperator 2023-05-28T11:11:11.876278+00:00 2023-05-28T11:11:12.438683+00:00 0:00:00.562405 387210 airflow-worker-0.airflow-worker.data-eng.svc.cluster.local airflow 1 default 2023-05-28T11:11:09.818283+00:00 2 default_pool
success campaign-flow-job_v002 check_cluster_status 2023-05-28T10:00:00+00:00 EmrJobFlowSensor 2023-05-28T11:00:58.614818+00:00 2023-05-28T11:11:00.415051+00:00 0:10:01.800233 387204 airflow-worker-0.airflow-worker.data-eng.svc.cluster.local airflow 3 default 2023-05-28T11:00:56.639755+00:00 2 default_pool
success campaign-flow-job_v002 create_cluster_and_add_emr_steps 2023-05-28T10:00:00+00:00 EmrCreateJobFlowOperator 2023-05-28T11:00:38.714579+00:00 2023-05-28T11:00:39.664792+00:00 0:00:00.950213 387202 airflow-worker-1.airflow-worker.data-eng.svc.cluster.local airflow 4 default 2023-05-28T11:00:36.608148+00:00 2 default_pool
success campaign-flow-job_v002 create_emr_steps 2023-05-28T10:00:00+00:00 PythonOperator 2023-05-28T11:00:16.638331+00:00 2023-05-28T11:00:17.514896+00:00 0:00:00.876565 387200 airflow-worker-0.airflow-worker.data-eng.svc.cluster.local airflow 5 default 2023-05-28T11:00:14.587947+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_campaign-history-job_v002 2023-05-28T09:00:00+00:00 TriggerDagRunOperator 2023-05-28T10:11:52.373073+00:00 2023-05-28T10:11:52.962788+00:00 0:00:00.589715 387187 airflow-worker-0.airflow-worker.data-eng.svc.cluster.local airflow 1 default 2023-05-28T10:11:49.882614+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_booking-processing-job_v002 2023-05-28T09:00:00+00:00 TriggerDagRunOperator 2023-05-28T10:11:52.297173+00:00 2023-05-28T10:11:52.722118+00:00 0:00:00.424945 387186 airflow-worker-1.airflow-worker.data-eng.svc.cluster.local airflow 1 default 2023-05-28T10:11:49.882575+00:00 2 default_pool
success campaign-flow-job_v002 check_cluster_status 2023-05-28T09:00:00+00:00 EmrJobFlowSensor 2023-05-28T10:01:03.023943+00:00 2023-05-28T10:11:04.834359+00:00 0:10:01.810416 387183 airflow-worker-0.airflow-worker.data-eng.svc.cluster.local airflow 3 default 2023-05-28T10:01:00.987664+00:00 2 default_pool
success campaign-flow-job_v002 create_cluster_and_add_emr_steps 2023-05-28T09:00:00+00:00 EmrCreateJobFlowOperator 2023-05-28T10:00:41.106886+00:00 2023-05-28T10:00:42.209985+00:00 0:00:01.103099 387181 airflow-worker-0.airflow-worker.data-eng.svc.cluster.local airflow 4 default 2023-05-28T10:00:38.901832+00:00 2 default_pool
success campaign-flow-job_v002 create_emr_steps 2023-05-28T09:00:00+00:00 PythonOperator 2023-05-28T10:00:21.286894+00:00 2023-05-28T10:00:22.190974+00:00 0:00:00.904080 387179 airflow-worker-1.airflow-worker.data-eng.svc.cluster.local airflow 5 default 2023-05-28T10:00:18.902117+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_booking-processing-job_v002 2023-05-28T08:00:00+00:00 TriggerDagRunOperator 2023-05-28T09:18:04.065622+00:00 2023-05-28T09:18:04.503187+00:00 0:00:00.437565 387170 airflow-worker-1.airflow-worker.data-eng.svc.cluster.local airflow 1 default 2023-05-28T09:18:01.576212+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_campaign-history-job_v002 2023-05-28T08:00:00+00:00 TriggerDagRunOperator 2023-05-28T09:18:04.011384+00:00 2023-05-28T09:18:04.442246+00:00 0:00:00.430862 387169 airflow-worker-0.airflow-worker.data-eng.svc.cluster.local airflow 1 default 2023-05-28T09:18:01.576248+00:00 2 default_pool
success campaign-flow-job_v002 check_cluster_status 2023-05-28T08:00:00+00:00 EmrJobFlowSensor 2023-05-28T09:00:48.813422+00:00 2023-05-28T09:10:50.583690+00:00 0:10:01.770268 387161 airflow-worker-1.airflow-worker.data-eng.svc.cluster.local airflow 3 default 2023-05-28T09:00:46.739675+00:00 2 default_pool
success campaign-flow-job_v002 create_cluster_and_add_emr_steps 2023-05-28T08:00:00+00:00 EmrCreateJobFlowOperator 2023-05-28T09:00:28.806944+00:00 2023-05-28T09:00:29.789101+00:00 0:00:00.982157 387159 airflow-worker-0.airflow-worker.data-eng.svc.cluster.local airflow 4 default 2023-05-28T09:00:26.721259+00:00 2 default_pool
success campaign-flow-job_v002 create_emr_steps 2023-05-28T08:00:00+00:00 PythonOperator 2023-05-28T09:00:06.857956+00:00 2023-05-28T09:00:07.743688+00:00 0:00:00.885732 387157 airflow-worker-0.airflow-worker.data-eng.svc.cluster.local airflow 5 default 2023-05-28T09:00:04.658756+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_campaign-history-job_v002 2023-05-28T07:00:00+00:00 TriggerDagRunOperator 2023-05-28T08:17:01.913753+00:00 2023-05-28T08:17:02.359948+00:00 0:00:00.446195 387148 airflow-worker-0.airflow-worker.data-eng.svc.cluster.local airflow 1 default 2023-05-28T08:16:59.729863+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_booking-processing-job_v002 2023-05-28T07:00:00+00:00 TriggerDagRunOperator 2023-05-28T08:17:01.879737+00:00 2023-05-28T08:17:02.381293+00:00 0:00:00.501556 387147 airflow-worker-1.airflow-worker.data-eng.svc.cluster.local airflow 1 default 2023-05-28T08:16:59.729834+00:00 2 default_pool
success campaign-flow-job_v002 check_cluster_status 2023-05-28T07:00:00+00:00 EmrJobFlowSensor 2023-05-28T08:06:44.025403+00:00 2023-05-28T08:16:46.275724+00:00 0:10:02.250321 387142 airflow-worker-0.airflow-worker.data-eng.svc.cluster.local airflow 3 default 2023-05-28T08:06:42.049187+00:00 2 default_pool
success campaign-flow-job_v002 create_cluster_and_add_emr_steps 2023-05-28T07:00:00+00:00 EmrCreateJobFlowOperator 2023-05-28T08:06:24.095975+00:00 2023-05-28T08:06:24.998448+00:00 0:00:00.902473 387140 airflow-worker-1.airflow-worker.data-eng.svc.cluster.local airflow 4 default 2023-05-28T08:06:21.982344+00:00 2 default_pool
success campaign-flow-job_v002 create_emr_steps 2023-05-28T07:00:00+00:00 PythonOperator 2023-05-28T08:06:02.532006+00:00 2023-05-28T08:06:04.058179+00:00 0:00:01.526173 387136 airflow-worker-0.airflow-worker.data-eng.svc.cluster.local airflow 5 default 2023-05-28T08:05:59.963457+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_campaign-history-job_v002 2023-05-28T06:00:00+00:00 TriggerDagRunOperator 2023-05-28T07:24:35.845332+00:00 2023-05-28T07:24:36.353201+00:00 0:00:00.507869 387128 airflow-worker-1.airflow-worker.data-eng.svc.cluster.local airflow 1 default 2023-05-28T07:24:33.502884+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_booking-processing-job_v002 2023-05-28T06:00:00+00:00 TriggerDagRunOperator 2023-05-28T07:24:35.722294+00:00 2023-05-28T07:24:36.181348+00:00 0:00:00.459054 387127 airflow-worker-0.airflow-worker.data-eng.svc.cluster.local airflow 1 default 2023-05-28T07:24:33.502856+00:00 2 default_pool
success campaign-flow-job_v002 check_cluster_status 2023-05-28T06:00:00+00:00 EmrJobFlowSensor 2023-05-28T07:12:12.193024+00:00 2023-05-28T07:22:14.091434+00:00 0:10:01.898410 387124 airflow-worker-0.airflow-worker.data-eng.svc.cluster.local airflow 3 default 2023-05-28T07:12:10.121043+00:00 2 default_pool