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-08T01:00:00+00:00 EmrJobFlowSensor 2023-02-08T02:00:52.169554+00:00 2023-02-08T02:10:53.940170+00:00 0:10:01.770616 335671 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2023-02-08T02:00:49.831850+00:00 2 default_pool
success campaign-flow-job_v002 create_cluster_and_add_emr_steps 2023-02-08T01:00:00+00:00 EmrCreateJobFlowOperator 2023-02-08T02:00:32.198821+00:00 2023-02-08T02:00:33.109099+00:00 0:00:00.910278 335670 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 4 default 2023-02-08T02:00:29.797278+00:00 2 default_pool
success campaign-flow-job_v002 create_emr_steps 2023-02-08T01:00:00+00:00 PythonOperator 2023-02-08T02:00:10.416949+00:00 2023-02-08T02:00:13.527228+00:00 0:00:03.110279 335668 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 5 default 2023-02-08T02:00:07.770917+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_booking-processing-job_v002 2023-02-08T00:00:00+00:00 TriggerDagRunOperator 2023-02-08T01:10:58.070540+00:00 2023-02-08T01:10:58.725294+00:00 0:00:00.654754 335647 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2023-02-08T01:10:55.146114+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_campaign-history-job_v002 2023-02-08T00:00:00+00:00 TriggerDagRunOperator 2023-02-08T01:10:57.432222+00:00 2023-02-08T01:10:57.912684+00:00 0:00:00.480462 335646 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2023-02-08T01:10:55.146141+00:00 2 default_pool
success campaign-flow-job_v002 check_cluster_status 2023-02-08T00:00:00+00:00 EmrJobFlowSensor 2023-02-08T01:00:52.093435+00:00 2023-02-08T01:10:53.857333+00:00 0:10:01.763898 335639 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2023-02-08T01:00:49.850793+00:00 2 default_pool
success campaign-flow-job_v002 create_cluster_and_add_emr_steps 2023-02-08T00:00:00+00:00 EmrCreateJobFlowOperator 2023-02-08T01:00:32.606184+00:00 2023-02-08T01:00:33.819269+00:00 0:00:01.213085 335637 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 4 default 2023-02-08T01:00:29.833164+00:00 2 default_pool
success campaign-flow-job_v002 create_emr_steps 2023-02-08T00:00:00+00:00 PythonOperator 2023-02-08T01:00:11.432753+00:00 2023-02-08T01:00:16.042746+00:00 0:00:04.609993 335635 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 5 default 2023-02-08T01:00:07.894761+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_campaign-history-job_v002 2023-02-07T23:00:00+00:00 TriggerDagRunOperator 2023-02-08T00:11:45.548767+00:00 2023-02-08T00:11:46.091110+00:00 0:00:00.542343 335623 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2023-02-08T00:11:43.010537+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_booking-processing-job_v002 2023-02-07T23:00:00+00:00 TriggerDagRunOperator 2023-02-08T00:11:45.472222+00:00 2023-02-08T00:11:45.983104+00:00 0:00:00.510882 335622 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2023-02-08T00:11:43.010508+00:00 2 default_pool
success campaign-flow-job_v002 check_cluster_status 2023-02-07T23:00:00+00:00 EmrJobFlowSensor 2023-02-08T00:01:26.318513+00:00 2023-02-08T00:11:28.330364+00:00 0:10:02.011851 335615 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2023-02-08T00:01:23.991450+00:00 2 default_pool
success campaign-flow-job_v002 create_cluster_and_add_emr_steps 2023-02-07T23:00:00+00:00 EmrCreateJobFlowOperator 2023-02-08T00:01:04.401756+00:00 2023-02-08T00:01:05.256757+00:00 0:00:00.855001 335613 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 4 default 2023-02-08T00:01:01.963556+00:00 2 default_pool
success campaign-flow-job_v002 create_emr_steps 2023-02-07T23:00:00+00:00 PythonOperator 2023-02-08T00:00:42.896101+00:00 2023-02-08T00:00:45.800893+00:00 0:00:02.904792 335611 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 5 default 2023-02-08T00:00:39.993103+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_campaign-history-job_v002 2023-02-07T22:00:00+00:00 TriggerDagRunOperator 2023-02-07T23:11:25.895145+00:00 2023-02-07T23:11:26.363564+00:00 0:00:00.468419 335597 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2023-02-07T23:11:23.516211+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_booking-processing-job_v002 2023-02-07T22:00:00+00:00 TriggerDagRunOperator 2023-02-07T23:11:25.848285+00:00 2023-02-07T23:11:26.353695+00:00 0:00:00.505410 335596 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2023-02-07T23:11:23.516182+00:00 2 default_pool
success campaign-flow-job_v002 check_cluster_status 2023-02-07T22:00:00+00:00 EmrJobFlowSensor 2023-02-07T23:01:07.038026+00:00 2023-02-07T23:11:09.141220+00:00 0:10:02.103194 335590 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2023-02-07T23:01:04.523226+00:00 2 default_pool
success campaign-flow-job_v002 create_cluster_and_add_emr_steps 2023-02-07T22:00:00+00:00 EmrCreateJobFlowOperator 2023-02-07T23:00:44.644585+00:00 2023-02-07T23:00:45.631615+00:00 0:00:00.987030 335587 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 4 default 2023-02-07T23:00:42.430512+00:00 2 default_pool
success campaign-flow-job_v002 create_emr_steps 2023-02-07T22:00:00+00:00 PythonOperator 2023-02-07T23:00:24.677013+00:00 2023-02-07T23:00:27.748507+00:00 0:00:03.071494 335584 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 5 default 2023-02-07T23:00:22.416693+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_booking-processing-job_v002 2023-02-07T21:00:00+00:00 TriggerDagRunOperator 2023-02-07T22:11:20.692238+00:00 2023-02-07T22:11:21.391461+00:00 0:00:00.699223 335568 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2023-02-07T22:11:17.890946+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_campaign-history-job_v002 2023-02-07T21:00:00+00:00 TriggerDagRunOperator 2023-02-07T22:11:20.628764+00:00 2023-02-07T22:11:21.310950+00:00 0:00:00.682186 335567 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2023-02-07T22:11:17.891020+00:00 2 default_pool
success campaign-flow-job_v002 check_cluster_status 2023-02-07T21:00:00+00:00 EmrJobFlowSensor 2023-02-07T22:01:04.468289+00:00 2023-02-07T22:11:06.246866+00:00 0:10:01.778577 335561 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2023-02-07T22:01:02.228005+00:00 2 default_pool
success campaign-flow-job_v002 create_cluster_and_add_emr_steps 2023-02-07T21:00:00+00:00 EmrCreateJobFlowOperator 2023-02-07T22:00:44.342856+00:00 2023-02-07T22:00:45.215849+00:00 0:00:00.872993 335559 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 4 default 2023-02-07T22:00:42.150744+00:00 2 default_pool
success campaign-flow-job_v002 create_emr_steps 2023-02-07T21:00:00+00:00 PythonOperator 2023-02-07T22:00:22.327122+00:00 2023-02-07T22:00:25.083468+00:00 0:00:02.756346 335557 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 5 default 2023-02-07T22:00:20.129246+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_campaign-history-job_v002 2023-02-07T20:00:00+00:00 TriggerDagRunOperator 2023-02-07T21:11:21.374620+00:00 2023-02-07T21:11:21.860910+00:00 0:00:00.486290 335542 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2023-02-07T21:11:18.487554+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_booking-processing-job_v002 2023-02-07T20:00:00+00:00 TriggerDagRunOperator 2023-02-07T21:11:21.266344+00:00 2023-02-07T21:11:21.793066+00:00 0:00:00.526722 335541 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2023-02-07T21:11:18.487526+00:00 2 default_pool
success campaign-flow-job_v002 check_cluster_status 2023-02-07T20:00:00+00:00 EmrJobFlowSensor 2023-02-07T21:01:05.318073+00:00 2023-02-07T21:11:07.026026+00:00 0:10:01.707953 335535 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2023-02-07T21:01:03.169632+00:00 2 default_pool
success campaign-flow-job_v002 create_cluster_and_add_emr_steps 2023-02-07T20:00:00+00:00 EmrCreateJobFlowOperator 2023-02-07T21:00:45.507386+00:00 2023-02-07T21:00:46.376031+00:00 0:00:00.868645 335533 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 4 default 2023-02-07T21:00:43.156409+00:00 2 default_pool
success campaign-flow-job_v002 create_emr_steps 2023-02-07T20:00:00+00:00 PythonOperator 2023-02-07T21:00:23.445308+00:00 2023-02-07T21:00:26.533286+00:00 0:00:03.087978 335531 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 5 default 2023-02-07T21:00:21.132056+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_booking-processing-job_v002 2023-02-07T19:00:00+00:00 TriggerDagRunOperator 2023-02-07T20:11:08.035804+00:00 2023-02-07T20:11:08.544529+00:00 0:00:00.508725 335516 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2023-02-07T20:11:04.914725+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_campaign-history-job_v002 2023-02-07T19:00:00+00:00 TriggerDagRunOperator 2023-02-07T20:11:07.796502+00:00 2023-02-07T20:11:08.367133+00:00 0:00:00.570631 335515 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2023-02-07T20:11:04.914769+00:00 2 default_pool
success campaign-flow-job_v002 check_cluster_status 2023-02-07T19:00:00+00:00 EmrJobFlowSensor 2023-02-07T20:00:58.466779+00:00 2023-02-07T20:11:00.321466+00:00 0:10:01.854687 335509 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2023-02-07T20:00:55.912437+00:00 2 default_pool
success campaign-flow-job_v002 create_cluster_and_add_emr_steps 2023-02-07T19:00:00+00:00 EmrCreateJobFlowOperator 2023-02-07T20:00:36.285595+00:00 2023-02-07T20:00:37.134667+00:00 0:00:00.849072 335507 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 4 default 2023-02-07T20:00:33.825639+00:00 2 default_pool
success campaign-flow-job_v002 create_emr_steps 2023-02-07T19:00:00+00:00 PythonOperator 2023-02-07T20:00:16.039218+00:00 2023-02-07T20:00:18.833051+00:00 0:00:02.793833 335505 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 5 default 2023-02-07T20:00:13.790007+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_booking-processing-job_v002 2023-02-07T18:00:00+00:00 TriggerDagRunOperator 2023-02-07T19:11:11.373595+00:00 2023-02-07T19:11:11.921835+00:00 0:00:00.548240 335490 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2023-02-07T19:11:08.901264+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_campaign-history-job_v002 2023-02-07T18:00:00+00:00 TriggerDagRunOperator 2023-02-07T19:11:11.358955+00:00 2023-02-07T19:11:11.860648+00:00 0:00:00.501693 335489 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2023-02-07T19:11:08.901293+00:00 2 default_pool
success campaign-flow-job_v002 check_cluster_status 2023-02-07T18:00:00+00:00 EmrJobFlowSensor 2023-02-07T19:00:56.638365+00:00 2023-02-07T19:10:58.431351+00:00 0:10:01.792986 335483 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2023-02-07T19:00:53.632235+00:00 2 default_pool
success campaign-flow-job_v002 create_cluster_and_add_emr_steps 2023-02-07T18:00:00+00:00 EmrCreateJobFlowOperator 2023-02-07T19:00:33.882087+00:00 2023-02-07T19:00:34.748961+00:00 0:00:00.866874 335481 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 4 default 2023-02-07T19:00:31.520869+00:00 2 default_pool
success campaign-flow-job_v002 create_emr_steps 2023-02-07T18:00:00+00:00 PythonOperator 2023-02-07T19:00:11.740127+00:00 2023-02-07T19:00:15.494249+00:00 0:00:03.754122 335479 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 5 default 2023-02-07T19:00:09.492808+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_campaign-history-job_v002 2023-02-07T17:00:00+00:00 TriggerDagRunOperator 2023-02-07T18:11:22.316680+00:00 2023-02-07T18:11:22.799635+00:00 0:00:00.482955 335464 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2023-02-07T18:11:19.770583+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_booking-processing-job_v002 2023-02-07T17:00:00+00:00 TriggerDagRunOperator 2023-02-07T18:11:22.257543+00:00 2023-02-07T18:11:22.704975+00:00 0:00:00.447432 335463 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2023-02-07T18:11:19.770553+00:00 2 default_pool
success campaign-flow-job_v002 check_cluster_status 2023-02-07T17:00:00+00:00 EmrJobFlowSensor 2023-02-07T18:01:07.151090+00:00 2023-02-07T18:11:08.984812+00:00 0:10:01.833722 335457 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2023-02-07T18:01:04.790983+00:00 2 default_pool
success campaign-flow-job_v002 create_cluster_and_add_emr_steps 2023-02-07T17:00:00+00:00 EmrCreateJobFlowOperator 2023-02-07T18:00:45.338855+00:00 2023-02-07T18:00:46.247169+00:00 0:00:00.908314 335455 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 4 default 2023-02-07T18:00:42.707289+00:00 2 default_pool
success campaign-flow-job_v002 create_emr_steps 2023-02-07T17:00:00+00:00 PythonOperator 2023-02-07T18:00:22.942099+00:00 2023-02-07T18:00:25.852473+00:00 0:00:02.910374 335453 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 5 default 2023-02-07T18:00:20.603129+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_booking-processing-job_v002 2023-02-07T16:00:00+00:00 TriggerDagRunOperator 2023-02-07T17:11:02.132001+00:00 2023-02-07T17:11:02.710221+00:00 0:00:00.578220 335438 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2023-02-07T17:10:59.527686+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_campaign-history-job_v002 2023-02-07T16:00:00+00:00 TriggerDagRunOperator 2023-02-07T17:11:02.108313+00:00 2023-02-07T17:11:02.610735+00:00 0:00:00.502422 335437 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2023-02-07T17:10:59.527723+00:00 2 default_pool
success campaign-flow-job_v002 check_cluster_status 2023-02-07T16:00:00+00:00 EmrJobFlowSensor 2023-02-07T17:00:48.878802+00:00 2023-02-07T17:10:50.681161+00:00 0:10:01.802359 335431 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2023-02-07T17:00:46.603457+00:00 2 default_pool
success campaign-flow-job_v002 create_cluster_and_add_emr_steps 2023-02-07T16:00:00+00:00 EmrCreateJobFlowOperator 2023-02-07T17:00:30.355225+00:00 2023-02-07T17:00:31.609302+00:00 0:00:01.254077 335429 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 4 default 2023-02-07T17:00:26.575966+00:00 2 default_pool
success campaign-flow-job_v002 create_emr_steps 2023-02-07T16:00:00+00:00 PythonOperator 2023-02-07T17:00:06.764217+00:00 2023-02-07T17:00:10.503085+00:00 0:00:03.738868 335427 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 5 default 2023-02-07T17:00:04.557654+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_campaign-history-job_v002 2023-02-07T15:00:00+00:00 TriggerDagRunOperator 2023-02-07T16:17:57.428502+00:00 2023-02-07T16:17:57.908327+00:00 0:00:00.479825 335414 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2023-02-07T16:17:54.644933+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_booking-processing-job_v002 2023-02-07T15:00:00+00:00 TriggerDagRunOperator 2023-02-07T16:17:57.221462+00:00 2023-02-07T16:17:57.711430+00:00 0:00:00.489968 335413 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2023-02-07T16:17:54.644904+00:00 2 default_pool
success campaign-flow-job_v002 check_cluster_status 2023-02-07T15:00:00+00:00 EmrJobFlowSensor 2023-02-07T16:01:06.140404+00:00 2023-02-07T16:11:08.015788+00:00 0:10:01.875384 335406 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2023-02-07T16:01:03.868776+00:00 2 default_pool
success campaign-flow-job_v002 create_cluster_and_add_emr_steps 2023-02-07T15:00:00+00:00 EmrCreateJobFlowOperator 2023-02-07T16:00:44.057133+00:00 2023-02-07T16:00:44.870364+00:00 0:00:00.813231 335404 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 4 default 2023-02-07T16:00:41.851586+00:00 2 default_pool
success campaign-flow-job_v002 create_emr_steps 2023-02-07T15:00:00+00:00 PythonOperator 2023-02-07T16:00:24.494263+00:00 2023-02-07T16:00:27.209751+00:00 0:00:02.715488 335402 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 5 default 2023-02-07T16:00:21.892388+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_campaign-history-job_v002 2023-02-07T14:00:00+00:00 TriggerDagRunOperator 2023-02-07T15:11:57.698182+00:00 2023-02-07T15:11:58.399369+00:00 0:00:00.701187 335390 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2023-02-07T15:11:55.172041+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_booking-processing-job_v002 2023-02-07T14:00:00+00:00 TriggerDagRunOperator 2023-02-07T15:11:57.630067+00:00 2023-02-07T15:11:58.203020+00:00 0:00:00.572953 335389 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2023-02-07T15:11:55.172012+00:00 2 default_pool
success campaign-flow-job_v002 check_cluster_status 2023-02-07T14:00:00+00:00 EmrJobFlowSensor 2023-02-07T15:01:33.587854+00:00 2023-02-07T15:11:35.268507+00:00 0:10:01.680653 335383 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2023-02-07T15:01:31.373947+00:00 2 default_pool
success campaign-flow-job_v002 create_cluster_and_add_emr_steps 2023-02-07T14:00:00+00:00 EmrCreateJobFlowOperator 2023-02-07T15:01:14.759713+00:00 2023-02-07T15:01:15.678213+00:00 0:00:00.918500 335381 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 4 default 2023-02-07T15:01:09.357385+00:00 2 default_pool
success campaign-flow-job_v002 create_emr_steps 2023-02-07T14:00:00+00:00 PythonOperator 2023-02-07T15:00:52.484122+00:00 2023-02-07T15:00:55.452294+00:00 0:00:02.968172 335379 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 5 default 2023-02-07T15:00:49.347519+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_booking-processing-job_v002 2023-02-07T13:00:00+00:00 TriggerDagRunOperator 2023-02-07T14:17:18.388065+00:00 2023-02-07T14:17:19.268539+00:00 0:00:00.880474 335363 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2023-02-07T14:17:15.338559+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_campaign-history-job_v002 2023-02-07T13:00:00+00:00 TriggerDagRunOperator 2023-02-07T14:17:18.266676+00:00 2023-02-07T14:17:18.817888+00:00 0:00:00.551212 335362 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2023-02-07T14:17:15.338598+00:00 2 default_pool
success campaign-flow-job_v002 check_cluster_status 2023-02-07T13:00:00+00:00 EmrJobFlowSensor 2023-02-07T14:00:54.851012+00:00 2023-02-07T14:10:56.586243+00:00 0:10:01.735231 335358 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2023-02-07T14:00:52.710268+00:00 2 default_pool
success campaign-flow-job_v002 create_cluster_and_add_emr_steps 2023-02-07T13:00:00+00:00 EmrCreateJobFlowOperator 2023-02-07T14:00:33.104699+00:00 2023-02-07T14:00:33.950784+00:00 0:00:00.846085 335356 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 4 default 2023-02-07T14:00:30.688427+00:00 2 default_pool
success campaign-flow-job_v002 create_emr_steps 2023-02-07T13:00:00+00:00 PythonOperator 2023-02-07T14:00:13.312397+00:00 2023-02-07T14:00:17.129045+00:00 0:00:03.816648 335354 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 5 default 2023-02-07T14:00:10.671077+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_booking-processing-job_v002 2023-02-07T12:00:00+00:00 TriggerDagRunOperator 2023-02-07T13:31:52.968719+00:00 2023-02-07T13:31:53.537972+00:00 0:00:00.569253 335345 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2023-02-07T13:31:50.128206+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_campaign-history-job_v002 2023-02-07T12:00:00+00:00 TriggerDagRunOperator 2023-02-07T13:31:52.738959+00:00 2023-02-07T13:31:53.260225+00:00 0:00:00.521266 335344 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2023-02-07T13:31:50.128234+00:00 2 default_pool
success campaign-flow-job_v002 check_cluster_status 2023-02-07T12:00:00+00:00 EmrJobFlowSensor 2023-02-07T13:00:51.362981+00:00 2023-02-07T13:10:53.102775+00:00 0:10:01.739794 335338 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2023-02-07T13:00:49.154761+00:00 2 default_pool
success campaign-flow-job_v002 create_cluster_and_add_emr_steps 2023-02-07T12:00:00+00:00 EmrCreateJobFlowOperator 2023-02-07T13:00:29.652174+00:00 2023-02-07T13:00:30.615849+00:00 0:00:00.963675 335336 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 4 default 2023-02-07T13:00:27.104443+00:00 2 default_pool
success campaign-flow-job_v002 create_emr_steps 2023-02-07T12:00:00+00:00 PythonOperator 2023-02-07T13:00:09.686811+00:00 2023-02-07T13:00:12.840963+00:00 0:00:03.154152 335334 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 5 default 2023-02-07T13:00:07.088370+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_booking-processing-job_v002 2023-02-07T11:00:00+00:00 TriggerDagRunOperator 2023-02-07T12:27:47.560059+00:00 2023-02-07T12:27:48.032132+00:00 0:00:00.472073 335323 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2023-02-07T12:27:44.934296+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_campaign-history-job_v002 2023-02-07T11:00:00+00:00 TriggerDagRunOperator 2023-02-07T12:27:47.424321+00:00 2023-02-07T12:27:47.897363+00:00 0:00:00.473042 335322 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2023-02-07T12:27:44.934324+00:00 2 default_pool
success campaign-flow-job_v002 check_cluster_status 2023-02-07T11:00:00+00:00 EmrJobFlowSensor 2023-02-07T12:17:31.789186+00:00 2023-02-07T12:27:33.698204+00:00 0:10:01.909018 335318 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2023-02-07T12:17:29.406144+00:00 2 default_pool
success campaign-flow-job_v002 create_cluster_and_add_emr_steps 2023-02-07T11:00:00+00:00 EmrCreateJobFlowOperator 2023-02-07T12:17:09.756191+00:00 2023-02-07T12:17:10.660843+00:00 0:00:00.904652 335315 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 4 default 2023-02-07T12:17:07.376723+00:00 2 default_pool
success campaign-flow-job_v002 create_emr_steps 2023-02-07T11:00:00+00:00 PythonOperator 2023-02-07T12:16:49.314265+00:00 2023-02-07T12:16:53.199069+00:00 0:00:03.884804 335312 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 5 default 2023-02-07T12:16:45.435565+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_campaign-history-job_v002 2023-02-07T10:00:00+00:00 TriggerDagRunOperator 2023-02-07T11:11:07.726018+00:00 2023-02-07T11:11:08.306261+00:00 0:00:00.580243 335300 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2023-02-07T11:11:05.384516+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_booking-processing-job_v002 2023-02-07T10:00:00+00:00 TriggerDagRunOperator 2023-02-07T11:11:07.658647+00:00 2023-02-07T11:11:08.201815+00:00 0:00:00.543168 335299 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2023-02-07T11:11:05.384480+00:00 2 default_pool
success campaign-flow-job_v002 check_cluster_status 2023-02-07T10:00:00+00:00 EmrJobFlowSensor 2023-02-07T11:00:51.231622+00:00 2023-02-07T11:10:52.977813+00:00 0:10:01.746191 335292 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2023-02-07T11:00:48.963510+00:00 2 default_pool
success campaign-flow-job_v002 create_cluster_and_add_emr_steps 2023-02-07T10:00:00+00:00 EmrCreateJobFlowOperator 2023-02-07T11:00:31.227939+00:00 2023-02-07T11:00:32.022252+00:00 0:00:00.794313 335290 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 4 default 2023-02-07T11:00:28.941713+00:00 2 default_pool
success campaign-flow-job_v002 create_emr_steps 2023-02-07T10:00:00+00:00 PythonOperator 2023-02-07T11:00:09.391648+00:00 2023-02-07T11:00:12.514191+00:00 0:00:03.122543 335288 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 5 default 2023-02-07T11:00:06.906350+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_campaign-history-job_v002 2023-02-07T09:00:00+00:00 TriggerDagRunOperator 2023-02-07T10:10:55.767609+00:00 2023-02-07T10:10:56.240121+00:00 0:00:00.472512 335276 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2023-02-07T10:10:52.829153+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_booking-processing-job_v002 2023-02-07T09:00:00+00:00 TriggerDagRunOperator 2023-02-07T10:10:55.413676+00:00 2023-02-07T10:10:55.935356+00:00 0:00:00.521680 335275 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2023-02-07T10:10:52.829123+00:00 2 default_pool
success campaign-flow-job_v002 check_cluster_status 2023-02-07T09:00:00+00:00 EmrJobFlowSensor 2023-02-07T10:00:49.017697+00:00 2023-02-07T10:10:51.191215+00:00 0:10:02.173518 335267 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2023-02-07T10:00:46.787176+00:00 2 default_pool
success campaign-flow-job_v002 create_cluster_and_add_emr_steps 2023-02-07T09:00:00+00:00 EmrCreateJobFlowOperator 2023-02-07T10:00:27.081549+00:00 2023-02-07T10:00:28.016723+00:00 0:00:00.935174 335265 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 4 default 2023-02-07T10:00:24.769133+00:00 2 default_pool
success campaign-flow-job_v002 create_emr_steps 2023-02-07T09:00:00+00:00 PythonOperator 2023-02-07T10:00:05.320355+00:00 2023-02-07T10:00:08.128432+00:00 0:00:02.808077 335263 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 5 default 2023-02-07T10:00:02.815836+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_booking-processing-job_v002 2023-02-07T08:00:00+00:00 TriggerDagRunOperator 2023-02-07T09:11:12.826004+00:00 2023-02-07T09:11:13.402372+00:00 0:00:00.576368 335250 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2023-02-07T09:11:10.095669+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_campaign-history-job_v002 2023-02-07T08:00:00+00:00 TriggerDagRunOperator 2023-02-07T09:11:12.614802+00:00 2023-02-07T09:11:13.214913+00:00 0:00:00.600111 335249 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2023-02-07T09:11:10.095699+00:00 2 default_pool
success campaign-flow-job_v002 check_cluster_status 2023-02-07T08:00:00+00:00 EmrJobFlowSensor 2023-02-07T09:00:58.672876+00:00 2023-02-07T09:11:00.549300+00:00 0:10:01.876424 335242 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2023-02-07T09:00:56.267637+00:00 2 default_pool
success campaign-flow-job_v002 create_cluster_and_add_emr_steps 2023-02-07T08:00:00+00:00 EmrCreateJobFlowOperator 2023-02-07T09:00:36.865429+00:00 2023-02-07T09:00:37.685224+00:00 0:00:00.819795 335240 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 4 default 2023-02-07T09:00:34.316045+00:00 2 default_pool
success campaign-flow-job_v002 create_emr_steps 2023-02-07T08:00:00+00:00 PythonOperator 2023-02-07T09:00:14.952372+00:00 2023-02-07T09:00:17.913366+00:00 0:00:02.960994 335238 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 5 default 2023-02-07T09:00:12.228428+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_booking-processing-job_v002 2023-02-07T07:00:00+00:00 TriggerDagRunOperator 2023-02-07T08:29:05.787099+00:00 2023-02-07T08:29:06.289917+00:00 0:00:00.502818 335227 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2023-02-07T08:29:03.199226+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_campaign-history-job_v002 2023-02-07T07:00:00+00:00 TriggerDagRunOperator 2023-02-07T08:29:05.618057+00:00 2023-02-07T08:29:06.113220+00:00 0:00:00.495163 335226 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2023-02-07T08:29:03.199254+00:00 2 default_pool
success campaign-flow-job_v002 check_cluster_status 2023-02-07T07:00:00+00:00 EmrJobFlowSensor 2023-02-07T08:04:00.994481+00:00 2023-02-07T08:14:02.952175+00:00 0:10:01.957694 335219 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2023-02-07T08:03:58.603629+00:00 2 default_pool
success campaign-flow-job_v002 create_cluster_and_add_emr_steps 2023-02-07T07:00:00+00:00 EmrCreateJobFlowOperator 2023-02-07T08:03:38.928066+00:00 2023-02-07T08:03:39.777066+00:00 0:00:00.849000 335217 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 4 default 2023-02-07T08:03:36.563653+00:00 2 default_pool
success campaign-flow-job_v002 create_emr_steps 2023-02-07T07:00:00+00:00 PythonOperator 2023-02-07T08:03:19.254332+00:00 2023-02-07T08:03:25.528352+00:00 0:00:06.274020 335215 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 5 default 2023-02-07T08:03:16.545481+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_booking-processing-job_v002 2023-02-07T06:00:00+00:00 TriggerDagRunOperator 2023-02-07T07:15:11.279867+00:00 2023-02-07T07:15:11.806097+00:00 0:00:00.526230 335201 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2023-02-07T07:15:08.257707+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_campaign-history-job_v002 2023-02-07T06:00:00+00:00 TriggerDagRunOperator 2023-02-07T07:15:11.220116+00:00 2023-02-07T07:15:11.726878+00:00 0:00:00.506762 335200 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2023-02-07T07:15:08.257742+00:00 2 default_pool
success campaign-flow-job_v002 check_cluster_status 2023-02-07T06:00:00+00:00 EmrJobFlowSensor 2023-02-07T07:00:58.250685+00:00 2023-02-07T07:10:59.943413+00:00 0:10:01.692728 335197 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2023-02-07T07:00:55.660245+00:00 2 default_pool
success campaign-flow-job_v002 create_cluster_and_add_emr_steps 2023-02-07T06:00:00+00:00 EmrCreateJobFlowOperator 2023-02-07T07:00:37.858019+00:00 2023-02-07T07:00:38.625549+00:00 0:00:00.767530 335195 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 4 default 2023-02-07T07:00:35.633225+00:00 2 default_pool
success campaign-flow-job_v002 create_emr_steps 2023-02-07T06:00:00+00:00 PythonOperator 2023-02-07T07:00:15.739518+00:00 2023-02-07T07:00:19.624136+00:00 0:00:03.884618 335193 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 5 default 2023-02-07T07:00:13.585081+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_booking-processing-job_v002 2023-02-07T05:00:00+00:00 TriggerDagRunOperator 2023-02-07T06:15:25.320392+00:00 2023-02-07T06:15:25.898833+00:00 0:00:00.578441 335181 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2023-02-07T06:15:22.742568+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_campaign-history-job_v002 2023-02-07T05:00:00+00:00 TriggerDagRunOperator 2023-02-07T06:15:25.241505+00:00 2023-02-07T06:15:25.840028+00:00 0:00:00.598523 335180 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2023-02-07T06:15:22.742596+00:00 2 default_pool