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-06-02T06:00:00+00:00 EmrCreateJobFlowOperator 2023-06-02T07:08:15.691948+00:00 2023-06-02T07:08:16.739308+00:00 0:00:01.047360 389795 airflow-worker-1.airflow-worker.data-eng.svc.cluster.local airflow 4 default 2023-06-02T07:08:13.626681+00:00 2 default_pool
success campaign-flow-job_v002 create_emr_steps 2023-06-02T06:00:00+00:00 PythonOperator 2023-06-02T07:00:13.862240+00:00 2023-06-02T07:00:14.801230+00:00 0:00:00.938990 389791 airflow-worker-1.airflow-worker.data-eng.svc.cluster.local airflow 5 default 2023-06-02T07:00:11.550526+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_campaign-history-job_v002 2023-06-02T05:00:00+00:00 TriggerDagRunOperator 2023-06-02T06:11:04.080899+00:00 2023-06-02T06:11:04.513805+00:00 0:00:00.432906 389783 airflow-worker-1.airflow-worker.data-eng.svc.cluster.local airflow 1 default 2023-06-02T06:11:01.859014+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_booking-processing-job_v002 2023-06-02T05:00:00+00:00 TriggerDagRunOperator 2023-06-02T06:11:03.992245+00:00 2023-06-02T06:11:04.397430+00:00 0:00:00.405185 389782 airflow-worker-0.airflow-worker.data-eng.svc.cluster.local airflow 1 default 2023-06-02T06:11:01.858985+00:00 2 default_pool
success campaign-flow-job_v002 check_cluster_status 2023-06-02T05:00:00+00:00 EmrJobFlowSensor 2023-06-02T06:00:52.803667+00:00 2023-06-02T06:10:54.532131+00:00 0:10:01.728464 389776 airflow-worker-0.airflow-worker.data-eng.svc.cluster.local airflow 3 default 2023-06-02T06:00:50.807621+00:00 2 default_pool
success campaign-flow-job_v002 create_cluster_and_add_emr_steps 2023-06-02T05:00:00+00:00 EmrCreateJobFlowOperator 2023-06-02T06:00:32.761603+00:00 2023-06-02T06:00:33.702022+00:00 0:00:00.940419 389774 airflow-worker-0.airflow-worker.data-eng.svc.cluster.local airflow 4 default 2023-06-02T06:00:30.736775+00:00 2 default_pool
success campaign-flow-job_v002 create_emr_steps 2023-06-02T05:00:00+00:00 PythonOperator 2023-06-02T06:00:10.970334+00:00 2023-06-02T06:00:11.965617+00:00 0:00:00.995283 389772 airflow-worker-0.airflow-worker.data-eng.svc.cluster.local airflow 5 default 2023-06-02T06:00:08.717024+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_booking-processing-job_v002 2023-06-02T04:00:00+00:00 TriggerDagRunOperator 2023-06-02T05:12:05.011659+00:00 2023-06-02T05:12:05.411566+00:00 0:00:00.399907 389764 airflow-worker-0.airflow-worker.data-eng.svc.cluster.local airflow 1 default 2023-06-02T05:12:02.789231+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_campaign-history-job_v002 2023-06-02T04:00:00+00:00 TriggerDagRunOperator 2023-06-02T05:12:05.010380+00:00 2023-06-02T05:12:05.446123+00:00 0:00:00.435743 389763 airflow-worker-1.airflow-worker.data-eng.svc.cluster.local airflow 1 default 2023-06-02T05:12:02.789259+00:00 2 default_pool
success campaign-flow-job_v002 check_cluster_status 2023-06-02T04:00:00+00:00 EmrJobFlowSensor 2023-06-02T05:00:49.481610+00:00 2023-06-02T05:11:51.304860+00:00 0:11:01.823250 389755 airflow-worker-0.airflow-worker.data-eng.svc.cluster.local airflow 3 default 2023-06-02T05:00:47.485060+00:00 2 default_pool
success campaign-flow-job_v002 create_cluster_and_add_emr_steps 2023-06-02T04:00:00+00:00 EmrCreateJobFlowOperator 2023-06-02T05:00:27.511001+00:00 2023-06-02T05:00:28.352595+00:00 0:00:00.841594 389753 airflow-worker-0.airflow-worker.data-eng.svc.cluster.local airflow 4 default 2023-06-02T05:00:25.463852+00:00 2 default_pool
success campaign-flow-job_v002 create_emr_steps 2023-06-02T04:00:00+00:00 PythonOperator 2023-06-02T05:00:07.508472+00:00 2023-06-02T05:00:08.419337+00:00 0:00:00.910865 389751 airflow-worker-0.airflow-worker.data-eng.svc.cluster.local airflow 5 default 2023-06-02T05:00:05.448497+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_booking-processing-job_v002 2023-06-02T03:00:00+00:00 TriggerDagRunOperator 2023-06-02T04:11:17.413522+00:00 2023-06-02T04:11:17.856520+00:00 0:00:00.442998 389743 airflow-worker-1.airflow-worker.data-eng.svc.cluster.local airflow 1 default 2023-06-02T04:11:15.207292+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_campaign-history-job_v002 2023-06-02T03:00:00+00:00 TriggerDagRunOperator 2023-06-02T04:11:17.377089+00:00 2023-06-02T04:11:17.770199+00:00 0:00:00.393110 389742 airflow-worker-0.airflow-worker.data-eng.svc.cluster.local airflow 1 default 2023-06-02T04:11:15.207320+00:00 2 default_pool
success campaign-flow-job_v002 check_cluster_status 2023-06-02T03:00:00+00:00 EmrJobFlowSensor 2023-06-02T04:00:59.520496+00:00 2023-06-02T04:11:01.286796+00:00 0:10:01.766300 389734 airflow-worker-0.airflow-worker.data-eng.svc.cluster.local airflow 3 default 2023-06-02T04:00:57.402013+00:00 2 default_pool
success campaign-flow-job_v002 create_cluster_and_add_emr_steps 2023-06-02T03:00:00+00:00 EmrCreateJobFlowOperator 2023-06-02T04:00:39.868277+00:00 2023-06-02T04:00:40.822521+00:00 0:00:00.954244 389733 airflow-worker-0.airflow-worker.data-eng.svc.cluster.local airflow 4 default 2023-06-02T04:00:37.311824+00:00 2 default_pool
success campaign-flow-job_v002 create_emr_steps 2023-06-02T03:00:00+00:00 PythonOperator 2023-06-02T04:00:17.464352+00:00 2023-06-02T04:00:18.391601+00:00 0:00:00.927249 389730 airflow-worker-0.airflow-worker.data-eng.svc.cluster.local airflow 5 default 2023-06-02T04:00:15.292069+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_booking-processing-job_v002 2023-06-02T02:00:00+00:00 TriggerDagRunOperator 2023-06-02T03:11:07.624859+00:00 2023-06-02T03:11:08.060347+00:00 0:00:00.435488 389722 airflow-worker-1.airflow-worker.data-eng.svc.cluster.local airflow 1 default 2023-06-02T03:11:05.400162+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_campaign-history-job_v002 2023-06-02T02:00:00+00:00 TriggerDagRunOperator 2023-06-02T03:11:07.512279+00:00 2023-06-02T03:11:07.928823+00:00 0:00:00.416544 389721 airflow-worker-0.airflow-worker.data-eng.svc.cluster.local airflow 1 default 2023-06-02T03:11:05.400190+00:00 2 default_pool
success campaign-flow-job_v002 check_cluster_status 2023-06-02T02:00:00+00:00 EmrJobFlowSensor 2023-06-02T03:01:01.704144+00:00 2023-06-02T03:11:03.571155+00:00 0:10:01.867011 389715 airflow-worker-0.airflow-worker.data-eng.svc.cluster.local airflow 3 default 2023-06-02T03:00:59.702644+00:00 2 default_pool
success campaign-flow-job_v002 create_cluster_and_add_emr_steps 2023-06-02T02:00:00+00:00 EmrCreateJobFlowOperator 2023-06-02T03:00:41.731674+00:00 2023-06-02T03:00:42.749884+00:00 0:00:01.018210 389713 airflow-worker-0.airflow-worker.data-eng.svc.cluster.local airflow 4 default 2023-06-02T03:00:39.685997+00:00 2 default_pool
success campaign-flow-job_v002 create_emr_steps 2023-06-02T02:00:00+00:00 PythonOperator 2023-06-02T03:00:19.606288+00:00 2023-06-02T03:00:20.531968+00:00 0:00:00.925680 389711 airflow-worker-0.airflow-worker.data-eng.svc.cluster.local airflow 5 default 2023-06-02T03:00:17.663112+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_booking-processing-job_v002 2023-06-02T01:00:00+00:00 TriggerDagRunOperator 2023-06-02T02:13:30.551322+00:00 2023-06-02T02:13:31.093718+00:00 0:00:00.542396 389702 airflow-worker-1.airflow-worker.data-eng.svc.cluster.local airflow 1 default 2023-06-02T02:13:28.174215+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_campaign-history-job_v002 2023-06-02T01:00:00+00:00 TriggerDagRunOperator 2023-06-02T02:13:30.517945+00:00 2023-06-02T02:13:31.014180+00:00 0:00:00.496235 389701 airflow-worker-0.airflow-worker.data-eng.svc.cluster.local airflow 1 default 2023-06-02T02:13:28.174250+00:00 2 default_pool
success campaign-flow-job_v002 check_cluster_status 2023-06-02T01:00:00+00:00 EmrJobFlowSensor 2023-06-02T02:01:23.150821+00:00 2023-06-02T02:11:25.105543+00:00 0:10:01.954722 389695 airflow-worker-1.airflow-worker.data-eng.svc.cluster.local airflow 3 default 2023-06-02T02:01:21.061866+00:00 2 default_pool
success campaign-flow-job_v002 create_cluster_and_add_emr_steps 2023-06-02T01:00:00+00:00 EmrCreateJobFlowOperator 2023-06-02T02:01:01.070427+00:00 2023-06-02T02:01:02.237751+00:00 0:00:01.167324 389693 airflow-worker-1.airflow-worker.data-eng.svc.cluster.local airflow 4 default 2023-06-02T02:00:59.041280+00:00 2 default_pool
success campaign-flow-job_v002 create_emr_steps 2023-06-02T01:00:00+00:00 PythonOperator 2023-06-02T02:00:39.050999+00:00 2023-06-02T02:00:39.969491+00:00 0:00:00.918492 389691 airflow-worker-0.airflow-worker.data-eng.svc.cluster.local airflow 5 default 2023-06-02T02:00:37.020260+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_booking-processing-job_v002 2023-06-02T00:00:00+00:00 TriggerDagRunOperator 2023-06-02T01:24:52.028641+00:00 2023-06-02T01:24:52.480929+00:00 0:00:00.452288 389672 airflow-worker-1.airflow-worker.data-eng.svc.cluster.local airflow 1 default 2023-06-02T01:24:49.648189+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_campaign-history-job_v002 2023-06-02T00:00:00+00:00 TriggerDagRunOperator 2023-06-02T01:24:51.988636+00:00 2023-06-02T01:24:52.430633+00:00 0:00:00.441997 389671 airflow-worker-0.airflow-worker.data-eng.svc.cluster.local airflow 1 default 2023-06-02T01:24:49.648225+00:00 2 default_pool
success campaign-flow-job_v002 check_cluster_status 2023-06-02T00:00:00+00:00 EmrJobFlowSensor 2023-06-02T01:12:25.160467+00:00 2023-06-02T01:22:26.973198+00:00 0:10:01.812731 389668 airflow-worker-0.airflow-worker.data-eng.svc.cluster.local airflow 3 default 2023-06-02T01:12:22.946031+00:00 2 default_pool
success campaign-flow-job_v002 create_cluster_and_add_emr_steps 2023-06-02T00:00:00+00:00 EmrCreateJobFlowOperator 2023-06-02T01:12:03.080296+00:00 2023-06-02T01:12:03.927395+00:00 0:00:00.847099 389665 airflow-worker-0.airflow-worker.data-eng.svc.cluster.local airflow 4 default 2023-06-02T01:12:00.938994+00:00 2 default_pool
success campaign-flow-job_v002 create_emr_steps 2023-06-02T00:00:00+00:00 PythonOperator 2023-06-02T01:11:43.413273+00:00 2023-06-02T01:11:44.458063+00:00 0:00:01.044790 389662 airflow-worker-0.airflow-worker.data-eng.svc.cluster.local airflow 5 default 2023-06-02T01:11:40.900893+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_campaign-history-job_v002 2023-06-01T23:00:00+00:00 TriggerDagRunOperator 2023-06-02T00:11:22.983245+00:00 2023-06-02T00:11:23.420427+00:00 0:00:00.437182 389651 airflow-worker-1.airflow-worker.data-eng.svc.cluster.local airflow 1 default 2023-06-02T00:11:20.585890+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_booking-processing-job_v002 2023-06-01T23:00:00+00:00 TriggerDagRunOperator 2023-06-02T00:11:22.889736+00:00 2023-06-02T00:11:23.333314+00:00 0:00:00.443578 389650 airflow-worker-0.airflow-worker.data-eng.svc.cluster.local airflow 1 default 2023-06-02T00:11:20.585861+00:00 2 default_pool
success campaign-flow-job_v002 check_cluster_status 2023-06-01T23:00:00+00:00 EmrJobFlowSensor 2023-06-02T00:01:04.234481+00:00 2023-06-02T00:11:05.839570+00:00 0:10:01.605089 389643 airflow-worker-0.airflow-worker.data-eng.svc.cluster.local airflow 3 default 2023-06-02T00:01:02.214466+00:00 2 default_pool
success campaign-flow-job_v002 create_cluster_and_add_emr_steps 2023-06-01T23:00:00+00:00 EmrCreateJobFlowOperator 2023-06-02T00:00:42.181044+00:00 2023-06-02T00:00:43.186068+00:00 0:00:01.005024 389641 airflow-worker-0.airflow-worker.data-eng.svc.cluster.local airflow 4 default 2023-06-02T00:00:40.164584+00:00 2 default_pool
success campaign-flow-job_v002 create_emr_steps 2023-06-01T23:00:00+00:00 PythonOperator 2023-06-02T00:00:22.137174+00:00 2023-06-02T00:00:23.038750+00:00 0:00:00.901576 389639 airflow-worker-0.airflow-worker.data-eng.svc.cluster.local airflow 5 default 2023-06-02T00:00:20.147166+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_campaign-history-job_v002 2023-06-01T22:00:00+00:00 TriggerDagRunOperator 2023-06-01T23:12:08.624671+00:00 2023-06-01T23:12:09.096268+00:00 0:00:00.471597 389628 airflow-worker-1.airflow-worker.data-eng.svc.cluster.local airflow 1 default 2023-06-01T23:12:06.386074+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_booking-processing-job_v002 2023-06-01T22:00:00+00:00 TriggerDagRunOperator 2023-06-01T23:12:08.611542+00:00 2023-06-01T23:12:09.031523+00:00 0:00:00.419981 389627 airflow-worker-0.airflow-worker.data-eng.svc.cluster.local airflow 1 default 2023-06-01T23:12:06.386045+00:00 2 default_pool
success campaign-flow-job_v002 check_cluster_status 2023-06-01T22:00:00+00:00 EmrJobFlowSensor 2023-06-01T23:00:48.372900+00:00 2023-06-01T23:11:50.225508+00:00 0:11:01.852608 389618 airflow-worker-1.airflow-worker.data-eng.svc.cluster.local airflow 3 default 2023-06-01T23:00:46.386278+00:00 2 default_pool
success campaign-flow-job_v002 create_cluster_and_add_emr_steps 2023-06-01T22:00:00+00:00 EmrCreateJobFlowOperator 2023-06-01T23:00:26.562460+00:00 2023-06-01T23:00:27.513293+00:00 0:00:00.950833 389615 airflow-worker-1.airflow-worker.data-eng.svc.cluster.local airflow 4 default 2023-06-01T23:00:24.399734+00:00 2 default_pool
success campaign-flow-job_v002 create_emr_steps 2023-06-01T22:00:00+00:00 PythonOperator 2023-06-01T23:00:06.437000+00:00 2023-06-01T23:00:07.313247+00:00 0:00:00.876247 389612 airflow-worker-0.airflow-worker.data-eng.svc.cluster.local airflow 5 default 2023-06-01T23:00:04.328141+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_campaign-history-job_v002 2023-06-01T21:00:00+00:00 TriggerDagRunOperator 2023-06-01T22:11:22.541865+00:00 2023-06-01T22:11:22.999214+00:00 0:00:00.457349 389602 airflow-worker-1.airflow-worker.data-eng.svc.cluster.local airflow 1 default 2023-06-01T22:11:20.362829+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_booking-processing-job_v002 2023-06-01T21:00:00+00:00 TriggerDagRunOperator 2023-06-01T22:11:22.492009+00:00 2023-06-01T22:11:22.898235+00:00 0:00:00.406226 389601 airflow-worker-0.airflow-worker.data-eng.svc.cluster.local airflow 1 default 2023-06-01T22:11:20.362801+00:00 2 default_pool
success campaign-flow-job_v002 check_cluster_status 2023-06-01T21:00:00+00:00 EmrJobFlowSensor 2023-06-01T22:01:04.410034+00:00 2023-06-01T22:11:06.082842+00:00 0:10:01.672808 389594 airflow-worker-0.airflow-worker.data-eng.svc.cluster.local airflow 3 default 2023-06-01T22:01:02.414447+00:00 2 default_pool
success campaign-flow-job_v002 create_cluster_and_add_emr_steps 2023-06-01T21:00:00+00:00 EmrCreateJobFlowOperator 2023-06-01T22:00:42.582028+00:00 2023-06-01T22:00:43.445581+00:00 0:00:00.863553 389592 airflow-worker-0.airflow-worker.data-eng.svc.cluster.local airflow 4 default 2023-06-01T22:00:40.393282+00:00 2 default_pool
success campaign-flow-job_v002 create_emr_steps 2023-06-01T21:00:00+00:00 PythonOperator 2023-06-01T22:00:20.447907+00:00 2023-06-01T22:00:21.356198+00:00 0:00:00.908291 389590 airflow-worker-0.airflow-worker.data-eng.svc.cluster.local airflow 5 default 2023-06-01T22:00:18.402326+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_campaign-history-job_v002 2023-06-01T20:00:00+00:00 TriggerDagRunOperator 2023-06-01T21:11:13.313707+00:00 2023-06-01T21:11:13.765911+00:00 0:00:00.452204 389579 airflow-worker-1.airflow-worker.data-eng.svc.cluster.local airflow 1 default 2023-06-01T21:11:11.111622+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_booking-processing-job_v002 2023-06-01T20:00:00+00:00 TriggerDagRunOperator 2023-06-01T21:11:13.281630+00:00 2023-06-01T21:11:13.693147+00:00 0:00:00.411517 389578 airflow-worker-0.airflow-worker.data-eng.svc.cluster.local airflow 1 default 2023-06-01T21:11:11.111592+00:00 2 default_pool
success campaign-flow-job_v002 check_cluster_status 2023-06-01T20:00:00+00:00 EmrJobFlowSensor 2023-06-01T21:01:00.816178+00:00 2023-06-01T21:11:02.682588+00:00 0:10:01.866410 389570 airflow-worker-0.airflow-worker.data-eng.svc.cluster.local airflow 3 default 2023-06-01T21:00:58.828135+00:00 2 default_pool
success campaign-flow-job_v002 create_cluster_and_add_emr_steps 2023-06-01T20:00:00+00:00 EmrCreateJobFlowOperator 2023-06-01T21:00:38.810379+00:00 2023-06-01T21:00:39.670452+00:00 0:00:00.860073 389568 airflow-worker-0.airflow-worker.data-eng.svc.cluster.local airflow 4 default 2023-06-01T21:00:36.807224+00:00 2 default_pool
success campaign-flow-job_v002 create_emr_steps 2023-06-01T20:00:00+00:00 PythonOperator 2023-06-01T21:00:19.204519+00:00 2023-06-01T21:00:20.134980+00:00 0:00:00.930461 389566 airflow-worker-1.airflow-worker.data-eng.svc.cluster.local airflow 5 default 2023-06-01T21:00:16.806480+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_booking-processing-job_v002 2023-06-01T19:00:00+00:00 TriggerDagRunOperator 2023-06-01T20:11:32.530776+00:00 2023-06-01T20:11:32.988331+00:00 0:00:00.457555 389556 airflow-worker-1.airflow-worker.data-eng.svc.cluster.local airflow 1 default 2023-06-01T20:11:30.297303+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_campaign-history-job_v002 2023-06-01T19:00:00+00:00 TriggerDagRunOperator 2023-06-01T20:11:32.421089+00:00 2023-06-01T20:11:32.819034+00:00 0:00:00.397945 389555 airflow-worker-0.airflow-worker.data-eng.svc.cluster.local airflow 1 default 2023-06-01T20:11:30.297332+00:00 2 default_pool
success campaign-flow-job_v002 check_cluster_status 2023-06-01T19:00:00+00:00 EmrJobFlowSensor 2023-06-01T20:01:06.806488+00:00 2023-06-01T20:11:08.669832+00:00 0:10:01.863344 389548 airflow-worker-1.airflow-worker.data-eng.svc.cluster.local airflow 3 default 2023-06-01T20:01:04.760753+00:00 2 default_pool
success campaign-flow-job_v002 create_cluster_and_add_emr_steps 2023-06-01T19:00:00+00:00 EmrCreateJobFlowOperator 2023-06-01T20:00:44.917619+00:00 2023-06-01T20:00:46.062598+00:00 0:00:01.144979 389546 airflow-worker-1.airflow-worker.data-eng.svc.cluster.local airflow 4 default 2023-06-01T20:00:42.786133+00:00 2 default_pool
success campaign-flow-job_v002 create_emr_steps 2023-06-01T19:00:00+00:00 PythonOperator 2023-06-01T20:00:25.050187+00:00 2023-06-01T20:00:25.999857+00:00 0:00:00.949670 389544 airflow-worker-0.airflow-worker.data-eng.svc.cluster.local airflow 5 default 2023-06-01T20:00:22.718578+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_booking-processing-job_v002 2023-06-01T18:00:00+00:00 TriggerDagRunOperator 2023-06-01T19:10:53.924681+00:00 2023-06-01T19:10:54.408715+00:00 0:00:00.484034 389530 airflow-worker-0.airflow-worker.data-eng.svc.cluster.local airflow 1 default 2023-06-01T19:10:51.371888+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_campaign-history-job_v002 2023-06-01T18:00:00+00:00 TriggerDagRunOperator 2023-06-01T19:10:53.827866+00:00 2023-06-01T19:10:54.344001+00:00 0:00:00.516135 389529 airflow-worker-1.airflow-worker.data-eng.svc.cluster.local airflow 1 default 2023-06-01T19:10:51.371920+00:00 2 default_pool
success campaign-flow-job_v002 check_cluster_status 2023-06-01T18:00:00+00:00 EmrJobFlowSensor 2023-06-01T19:00:48.134764+00:00 2023-06-01T19:10:49.864275+00:00 0:10:01.729511 389522 airflow-worker-0.airflow-worker.data-eng.svc.cluster.local airflow 3 default 2023-06-01T19:00:46.045931+00:00 2 default_pool
success campaign-flow-job_v002 create_cluster_and_add_emr_steps 2023-06-01T18:00:00+00:00 EmrCreateJobFlowOperator 2023-06-01T19:00:28.055198+00:00 2023-06-01T19:00:28.929895+00:00 0:00:00.874697 389521 airflow-worker-1.airflow-worker.data-eng.svc.cluster.local airflow 4 default 2023-06-01T19:00:26.030980+00:00 2 default_pool
success campaign-flow-job_v002 create_emr_steps 2023-06-01T18:00:00+00:00 PythonOperator 2023-06-01T19:00:06.204256+00:00 2023-06-01T19:00:07.147982+00:00 0:00:00.943726 389519 airflow-worker-0.airflow-worker.data-eng.svc.cluster.local airflow 5 default 2023-06-01T19:00:04.007667+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_booking-processing-job_v002 2023-06-01T17:00:00+00:00 TriggerDagRunOperator 2023-06-01T18:11:09.282460+00:00 2023-06-01T18:11:09.803101+00:00 0:00:00.520641 389506 airflow-worker-1.airflow-worker.data-eng.svc.cluster.local airflow 1 default 2023-06-01T18:11:05.359484+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_campaign-history-job_v002 2023-06-01T17:00:00+00:00 TriggerDagRunOperator 2023-06-01T18:11:07.715257+00:00 2023-06-01T18:11:08.117590+00:00 0:00:00.402333 389505 airflow-worker-0.airflow-worker.data-eng.svc.cluster.local airflow 1 default 2023-06-01T18:11:05.359497+00:00 2 default_pool
success campaign-flow-job_v002 check_cluster_status 2023-06-01T17:00:00+00:00 EmrJobFlowSensor 2023-06-01T18:00:51.263757+00:00 2023-06-01T18:10:53.133257+00:00 0:10:01.869500 389498 airflow-worker-1.airflow-worker.data-eng.svc.cluster.local airflow 3 default 2023-06-01T18:00:49.234954+00:00 2 default_pool
success campaign-flow-job_v002 create_cluster_and_add_emr_steps 2023-06-01T17:00:00+00:00 EmrCreateJobFlowOperator 2023-06-01T18:00:31.250162+00:00 2023-06-01T18:00:32.249145+00:00 0:00:00.998983 389497 airflow-worker-0.airflow-worker.data-eng.svc.cluster.local airflow 4 default 2023-06-01T18:00:29.213564+00:00 2 default_pool
success campaign-flow-job_v002 create_emr_steps 2023-06-01T17:00:00+00:00 PythonOperator 2023-06-01T18:00:09.541598+00:00 2023-06-01T18:00:10.500738+00:00 0:00:00.959140 389496 airflow-worker-0.airflow-worker.data-eng.svc.cluster.local airflow 5 default 2023-06-01T18:00:07.181324+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_campaign-history-job_v002 2023-06-01T16:00:00+00:00 TriggerDagRunOperator 2023-06-01T17:11:11.566994+00:00 2023-06-01T17:11:12.008487+00:00 0:00:00.441493 389485 airflow-worker-0.airflow-worker.data-eng.svc.cluster.local airflow 1 default 2023-06-01T17:11:09.454339+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_booking-processing-job_v002 2023-06-01T16:00:00+00:00 TriggerDagRunOperator 2023-06-01T17:11:11.499570+00:00 2023-06-01T17:11:11.960491+00:00 0:00:00.460921 389484 airflow-worker-1.airflow-worker.data-eng.svc.cluster.local airflow 1 default 2023-06-01T17:11:09.454303+00:00 2 default_pool
success campaign-flow-job_v002 check_cluster_status 2023-06-01T16:00:00+00:00 EmrJobFlowSensor 2023-06-01T17:00:47.299133+00:00 2023-06-01T17:10:49.060492+00:00 0:10:01.761359 389475 airflow-worker-0.airflow-worker.data-eng.svc.cluster.local airflow 3 default 2023-06-01T17:00:45.228497+00:00 2 default_pool
success campaign-flow-job_v002 create_cluster_and_add_emr_steps 2023-06-01T16:00:00+00:00 EmrCreateJobFlowOperator 2023-06-01T17:00:27.286366+00:00 2023-06-01T17:00:28.125180+00:00 0:00:00.838814 389474 airflow-worker-0.airflow-worker.data-eng.svc.cluster.local airflow 4 default 2023-06-01T17:00:25.208654+00:00 2 default_pool
success campaign-flow-job_v002 create_emr_steps 2023-06-01T16:00:00+00:00 PythonOperator 2023-06-01T17:00:05.386815+00:00 2023-06-01T17:00:06.313007+00:00 0:00:00.926192 389472 airflow-worker-0.airflow-worker.data-eng.svc.cluster.local airflow 5 default 2023-06-01T17:00:03.184033+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_booking-processing-job_v002 2023-06-01T15:00:00+00:00 TriggerDagRunOperator 2023-06-01T16:11:10.447473+00:00 2023-06-01T16:11:10.882934+00:00 0:00:00.435461 389463 airflow-worker-1.airflow-worker.data-eng.svc.cluster.local airflow 1 default 2023-06-01T16:11:08.283044+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_campaign-history-job_v002 2023-06-01T15:00:00+00:00 TriggerDagRunOperator 2023-06-01T16:11:10.425977+00:00 2023-06-01T16:11:10.880855+00:00 0:00:00.454878 389462 airflow-worker-0.airflow-worker.data-eng.svc.cluster.local airflow 1 default 2023-06-01T16:11:08.283084+00:00 2 default_pool
success campaign-flow-job_v002 check_cluster_status 2023-06-01T15:00:00+00:00 EmrJobFlowSensor 2023-06-01T16:00:58.604750+00:00 2023-06-01T16:11:00.431493+00:00 0:10:01.826743 389456 airflow-worker-1.airflow-worker.data-eng.svc.cluster.local airflow 3 default 2023-06-01T16:00:56.505723+00:00 2 default_pool
success campaign-flow-job_v002 create_cluster_and_add_emr_steps 2023-06-01T15:00:00+00:00 EmrCreateJobFlowOperator 2023-06-01T16:00:36.555845+00:00 2023-06-01T16:00:37.517959+00:00 0:00:00.962114 389453 airflow-worker-0.airflow-worker.data-eng.svc.cluster.local airflow 4 default 2023-06-01T16:00:34.482067+00:00 2 default_pool
success campaign-flow-job_v002 create_emr_steps 2023-06-01T15:00:00+00:00 PythonOperator 2023-06-01T16:00:14.998051+00:00 2023-06-01T16:00:15.983193+00:00 0:00:00.985142 389451 airflow-worker-1.airflow-worker.data-eng.svc.cluster.local airflow 5 default 2023-06-01T16:00:12.474209+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_campaign-history-job_v002 2023-06-01T14:00:00+00:00 TriggerDagRunOperator 2023-06-01T15:18:57.186993+00:00 2023-06-01T15:18:57.620964+00:00 0:00:00.433971 389444 airflow-worker-0.airflow-worker.data-eng.svc.cluster.local airflow 1 default 2023-06-01T15:18:54.904648+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_booking-processing-job_v002 2023-06-01T14:00:00+00:00 TriggerDagRunOperator 2023-06-01T15:18:57.161870+00:00 2023-06-01T15:18:57.593355+00:00 0:00:00.431485 389443 airflow-worker-1.airflow-worker.data-eng.svc.cluster.local airflow 1 default 2023-06-01T15:18:54.904618+00:00 2 default_pool
success campaign-flow-job_v002 check_cluster_status 2023-06-01T14:00:00+00:00 EmrJobFlowSensor 2023-06-01T15:08:33.385716+00:00 2023-06-01T15:18:35.245635+00:00 0:10:01.859919 389439 airflow-worker-1.airflow-worker.data-eng.svc.cluster.local airflow 3 default 2023-06-01T15:08:31.354058+00:00 2 default_pool
success campaign-flow-job_v002 create_cluster_and_add_emr_steps 2023-06-01T14:00:00+00:00 EmrCreateJobFlowOperator 2023-06-01T15:08:11.922072+00:00 2023-06-01T15:08:12.888138+00:00 0:00:00.966066 389436 airflow-worker-0.airflow-worker.data-eng.svc.cluster.local airflow 4 default 2023-06-01T15:08:09.330011+00:00 2 default_pool
success campaign-flow-job_v002 create_emr_steps 2023-06-01T14:00:00+00:00 PythonOperator 2023-06-01T15:07:51.645089+00:00 2023-06-01T15:07:52.715736+00:00 0:00:01.070647 389433 airflow-worker-0.airflow-worker.data-eng.svc.cluster.local airflow 5 default 2023-06-01T15:07:49.311919+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_booking-processing-job_v002 2023-06-01T13:00:00+00:00 TriggerDagRunOperator 2023-06-01T14:21:40.387774+00:00 2023-06-01T14:21:40.814250+00:00 0:00:00.426476 389425 airflow-worker-1.airflow-worker.data-eng.svc.cluster.local airflow 1 default 2023-06-01T14:21:38.183039+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_campaign-history-job_v002 2023-06-01T13:00:00+00:00 TriggerDagRunOperator 2023-06-01T14:21:40.326895+00:00 2023-06-01T14:21:40.736081+00:00 0:00:00.409186 389424 airflow-worker-0.airflow-worker.data-eng.svc.cluster.local airflow 1 default 2023-06-01T14:21:38.183068+00:00 2 default_pool
success campaign-flow-job_v002 check_cluster_status 2023-06-01T13:00:00+00:00 EmrJobFlowSensor 2023-06-01T14:02:58.268010+00:00 2023-06-01T14:13:00.250134+00:00 0:10:01.982124 389418 airflow-worker-0.airflow-worker.data-eng.svc.cluster.local airflow 3 default 2023-06-01T14:02:56.126745+00:00 2 default_pool
success campaign-flow-job_v002 create_cluster_and_add_emr_steps 2023-06-01T13:00:00+00:00 EmrCreateJobFlowOperator 2023-06-01T14:02:38.196278+00:00 2023-06-01T14:02:39.175705+00:00 0:00:00.979427 389416 airflow-worker-0.airflow-worker.data-eng.svc.cluster.local airflow 4 default 2023-06-01T14:02:36.110365+00:00 2 default_pool
success campaign-flow-job_v002 create_emr_steps 2023-06-01T13:00:00+00:00 PythonOperator 2023-06-01T14:02:16.152839+00:00 2023-06-01T14:02:17.081559+00:00 0:00:00.928720 389414 airflow-worker-0.airflow-worker.data-eng.svc.cluster.local airflow 5 default 2023-06-01T14:02:14.086827+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_campaign-history-job_v002 2023-06-01T12:00:00+00:00 TriggerDagRunOperator 2023-06-01T13:11:18.446187+00:00 2023-06-01T13:11:18.910692+00:00 0:00:00.464505 389403 airflow-worker-1.airflow-worker.data-eng.svc.cluster.local airflow 1 default 2023-06-01T13:11:16.060776+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_booking-processing-job_v002 2023-06-01T12:00:00+00:00 TriggerDagRunOperator 2023-06-01T13:11:18.328814+00:00 2023-06-01T13:11:18.762848+00:00 0:00:00.434034 389402 airflow-worker-0.airflow-worker.data-eng.svc.cluster.local airflow 1 default 2023-06-01T13:11:16.060748+00:00 2 default_pool
success campaign-flow-job_v002 check_cluster_status 2023-06-01T12:00:00+00:00 EmrJobFlowSensor 2023-06-01T13:00:50.461549+00:00 2023-06-01T13:10:52.311851+00:00 0:10:01.850302 389394 airflow-worker-0.airflow-worker.data-eng.svc.cluster.local airflow 3 default 2023-06-01T13:00:48.365551+00:00 2 default_pool
success campaign-flow-job_v002 create_cluster_and_add_emr_steps 2023-06-01T12:00:00+00:00 EmrCreateJobFlowOperator 2023-06-01T13:00:28.411785+00:00 2023-06-01T13:00:29.303754+00:00 0:00:00.891969 389392 airflow-worker-0.airflow-worker.data-eng.svc.cluster.local airflow 4 default 2023-06-01T13:00:26.346140+00:00 2 default_pool
success campaign-flow-job_v002 create_emr_steps 2023-06-01T12:00:00+00:00 PythonOperator 2023-06-01T13:00:08.426615+00:00 2023-06-01T13:00:09.355511+00:00 0:00:00.928896 389390 airflow-worker-0.airflow-worker.data-eng.svc.cluster.local airflow 5 default 2023-06-01T13:00:06.323812+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_campaign-history-job_v002 2023-06-01T11:00:00+00:00 TriggerDagRunOperator 2023-06-01T12:11:11.280641+00:00 2023-06-01T12:11:11.738258+00:00 0:00:00.457617 389382 airflow-worker-1.airflow-worker.data-eng.svc.cluster.local airflow 1 default 2023-06-01T12:11:09.116115+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_booking-processing-job_v002 2023-06-01T11:00:00+00:00 TriggerDagRunOperator 2023-06-01T12:11:11.264809+00:00 2023-06-01T12:11:11.721170+00:00 0:00:00.456361 389381 airflow-worker-0.airflow-worker.data-eng.svc.cluster.local airflow 1 default 2023-06-01T12:11:09.116083+00:00 2 default_pool
success campaign-flow-job_v002 check_cluster_status 2023-06-01T11:00:00+00:00 EmrJobFlowSensor 2023-06-01T12:01:01.365633+00:00 2023-06-01T12:11:03.065893+00:00 0:10:01.700260 389374 airflow-worker-1.airflow-worker.data-eng.svc.cluster.local airflow 3 default 2023-06-01T12:00:59.331886+00:00 2 default_pool
success campaign-flow-job_v002 create_cluster_and_add_emr_steps 2023-06-01T11:00:00+00:00 EmrCreateJobFlowOperator 2023-06-01T12:00:39.547335+00:00 2023-06-01T12:00:40.385237+00:00 0:00:00.837902 389372 airflow-worker-0.airflow-worker.data-eng.svc.cluster.local airflow 4 default 2023-06-01T12:00:37.319025+00:00 2 default_pool
success campaign-flow-job_v002 create_emr_steps 2023-06-01T11:00:00+00:00 PythonOperator 2023-06-01T12:00:19.729248+00:00 2023-06-01T12:00:20.644785+00:00 0:00:00.915537 389370 airflow-worker-1.airflow-worker.data-eng.svc.cluster.local airflow 5 default 2023-06-01T12:00:17.305903+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_booking-processing-job_v002 2023-06-01T10:00:00+00:00 TriggerDagRunOperator 2023-06-01T11:11:02.877183+00:00 2023-06-01T11:11:03.327497+00:00 0:00:00.450314 389360 airflow-worker-0.airflow-worker.data-eng.svc.cluster.local airflow 1 default 2023-06-01T11:11:00.809004+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_campaign-history-job_v002 2023-06-01T10:00:00+00:00 TriggerDagRunOperator 2023-06-01T11:11:02.772413+00:00 2023-06-01T11:11:03.214408+00:00 0:00:00.441995 389359 airflow-worker-1.airflow-worker.data-eng.svc.cluster.local airflow 1 default 2023-06-01T11:11:00.809032+00:00 2 default_pool
success campaign-flow-job_v002 check_cluster_status 2023-06-01T10:00:00+00:00 EmrJobFlowSensor 2023-06-01T11:00:50.365641+00:00 2023-06-01T11:10:52.141568+00:00 0:10:01.775927 389352 airflow-worker-1.airflow-worker.data-eng.svc.cluster.local airflow 3 default 2023-06-01T11:00:48.336668+00:00 2 default_pool