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-12T05:00:00+00:00 EmrJobFlowSensor 2023-02-12T06:01:03.454154+00:00 2023-02-12T06:11:05.293740+00:00 0:10:01.839586 338212 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2023-02-12T06:01:00.691007+00:00 2 default_pool
success campaign-flow-job_v002 create_cluster_and_add_emr_steps 2023-02-12T05:00:00+00:00 EmrCreateJobFlowOperator 2023-02-12T06:00:40.960121+00:00 2023-02-12T06:00:41.755602+00:00 0:00:00.795481 338210 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 4 default 2023-02-12T06:00:38.564319+00:00 2 default_pool
success campaign-flow-job_v002 create_emr_steps 2023-02-12T05:00:00+00:00 PythonOperator 2023-02-12T06:00:20.755088+00:00 2023-02-12T06:00:24.575555+00:00 0:00:03.820467 338208 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 5 default 2023-02-12T06:00:18.540802+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_booking-processing-job_v002 2023-02-12T04:00:00+00:00 TriggerDagRunOperator 2023-02-12T05:11:32.657463+00:00 2023-02-12T05:11:33.230403+00:00 0:00:00.572940 338193 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2023-02-12T05:11:29.612227+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_campaign-history-job_v002 2023-02-12T04:00:00+00:00 TriggerDagRunOperator 2023-02-12T05:11:32.577187+00:00 2023-02-12T05:11:33.203404+00:00 0:00:00.626217 338192 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2023-02-12T05:11:29.612269+00:00 2 default_pool
success campaign-flow-job_v002 check_cluster_status 2023-02-12T04:00:00+00:00 EmrJobFlowSensor 2023-02-12T05:01:18.646538+00:00 2023-02-12T05:11:20.685534+00:00 0:10:02.038996 338185 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2023-02-12T05:01:16.340577+00:00 2 default_pool
success campaign-flow-job_v002 create_cluster_and_add_emr_steps 2023-02-12T04:00:00+00:00 EmrCreateJobFlowOperator 2023-02-12T05:00:58.660201+00:00 2023-02-12T05:00:59.533870+00:00 0:00:00.873669 338183 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 4 default 2023-02-12T05:00:56.295177+00:00 2 default_pool
success campaign-flow-job_v002 create_emr_steps 2023-02-12T04:00:00+00:00 PythonOperator 2023-02-12T05:00:36.953177+00:00 2023-02-12T05:00:40.018779+00:00 0:00:03.065602 338181 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 5 default 2023-02-12T05:00:34.275714+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_campaign-history-job_v002 2023-02-12T03:00:00+00:00 TriggerDagRunOperator 2023-02-12T04:11:16.293519+00:00 2023-02-12T04:11:16.760026+00:00 0:00:00.466507 338167 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2023-02-12T04:11:13.120681+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_booking-processing-job_v002 2023-02-12T03:00:00+00:00 TriggerDagRunOperator 2023-02-12T04:11:15.891287+00:00 2023-02-12T04:11:16.505223+00:00 0:00:00.613936 338166 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2023-02-12T04:11:13.120651+00:00 2 default_pool
success campaign-flow-job_v002 check_cluster_status 2023-02-12T03:00:00+00:00 EmrJobFlowSensor 2023-02-12T04:01:02.862423+00:00 2023-02-12T04:11:04.897018+00:00 0:10:02.034595 338159 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2023-02-12T04:01:00.637245+00:00 2 default_pool
success campaign-flow-job_v002 create_cluster_and_add_emr_steps 2023-02-12T03:00:00+00:00 EmrCreateJobFlowOperator 2023-02-12T04:00:40.918897+00:00 2023-02-12T04:00:41.787422+00:00 0:00:00.868525 338157 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 4 default 2023-02-12T04:00:38.549637+00:00 2 default_pool
success campaign-flow-job_v002 create_emr_steps 2023-02-12T03:00:00+00:00 PythonOperator 2023-02-12T04:00:21.048367+00:00 2023-02-12T04:00:24.178117+00:00 0:00:03.129750 338155 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 5 default 2023-02-12T04:00:18.529370+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_booking-processing-job_v002 2023-02-12T02:00:00+00:00 TriggerDagRunOperator 2023-02-12T03:11:21.526898+00:00 2023-02-12T03:11:22.153668+00:00 0:00:00.626770 338141 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2023-02-12T03:11:18.604589+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_campaign-history-job_v002 2023-02-12T02:00:00+00:00 TriggerDagRunOperator 2023-02-12T03:11:21.422343+00:00 2023-02-12T03:11:22.017764+00:00 0:00:00.595421 338140 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2023-02-12T03:11:18.604617+00:00 2 default_pool
success campaign-flow-job_v002 check_cluster_status 2023-02-12T02:00:00+00:00 EmrJobFlowSensor 2023-02-12T03:00:54.912317+00:00 2023-02-12T03:10:56.929445+00:00 0:10:02.017128 338133 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2023-02-12T03:00:52.495543+00:00 2 default_pool
success campaign-flow-job_v002 create_cluster_and_add_emr_steps 2023-02-12T02:00:00+00:00 EmrCreateJobFlowOperator 2023-02-12T03:00:32.661255+00:00 2023-02-12T03:00:33.553881+00:00 0:00:00.892626 338131 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 4 default 2023-02-12T03:00:30.414839+00:00 2 default_pool
success campaign-flow-job_v002 create_emr_steps 2023-02-12T02:00:00+00:00 PythonOperator 2023-02-12T03:00:12.904144+00:00 2023-02-12T03:00:15.930371+00:00 0:00:03.026227 338129 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 5 default 2023-02-12T03:00:10.392029+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_booking-processing-job_v002 2023-02-12T01:00:00+00:00 TriggerDagRunOperator 2023-02-12T02:11:07.517305+00:00 2023-02-12T02:11:08.006445+00:00 0:00:00.489140 338115 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2023-02-12T02:11:05.063841+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_campaign-history-job_v002 2023-02-12T01:00:00+00:00 TriggerDagRunOperator 2023-02-12T02:11:07.436173+00:00 2023-02-12T02:11:07.920642+00:00 0:00:00.484469 338114 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2023-02-12T02:11:05.063869+00:00 2 default_pool
success campaign-flow-job_v002 check_cluster_status 2023-02-12T01:00:00+00:00 EmrJobFlowSensor 2023-02-12T02:00:51.036528+00:00 2023-02-12T02:10:52.969252+00:00 0:10:01.932724 338108 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2023-02-12T02:00:48.845888+00:00 2 default_pool
success campaign-flow-job_v002 create_cluster_and_add_emr_steps 2023-02-12T01:00:00+00:00 EmrCreateJobFlowOperator 2023-02-12T02:00:29.086363+00:00 2023-02-12T02:00:30.000770+00:00 0:00:00.914407 338105 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 4 default 2023-02-12T02:00:26.826861+00:00 2 default_pool
success campaign-flow-job_v002 create_emr_steps 2023-02-12T01:00:00+00:00 PythonOperator 2023-02-12T02:00:09.843076+00:00 2023-02-12T02:00:14.221563+00:00 0:00:04.378487 338104 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 5 default 2023-02-12T02:00:06.774173+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_booking-processing-job_v002 2023-02-12T00:00:00+00:00 TriggerDagRunOperator 2023-02-12T01:12:10.437373+00:00 2023-02-12T01:12:10.932747+00:00 0:00:00.495374 338083 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2023-02-12T01:12:07.767931+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_campaign-history-job_v002 2023-02-12T00:00:00+00:00 TriggerDagRunOperator 2023-02-12T01:12:10.344064+00:00 2023-02-12T01:12:10.823539+00:00 0:00:00.479475 338082 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2023-02-12T01:12:07.767902+00:00 2 default_pool
success campaign-flow-job_v002 check_cluster_status 2023-02-12T00:00:00+00:00 EmrJobFlowSensor 2023-02-12T01:00:54.753961+00:00 2023-02-12T01:11:56.723217+00:00 0:11:01.969256 338075 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2023-02-12T01:00:52.492285+00:00 2 default_pool
success campaign-flow-job_v002 create_cluster_and_add_emr_steps 2023-02-12T00:00:00+00:00 EmrCreateJobFlowOperator 2023-02-12T01:00:33.009754+00:00 2023-02-12T01:00:33.948835+00:00 0:00:00.939081 338073 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 4 default 2023-02-12T01:00:30.408636+00:00 2 default_pool
success campaign-flow-job_v002 create_emr_steps 2023-02-12T00:00:00+00:00 PythonOperator 2023-02-12T01:00:12.897602+00:00 2023-02-12T01:00:15.688177+00:00 0:00:02.790575 338071 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 5 default 2023-02-12T01:00:10.325999+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_booking-processing-job_v002 2023-02-11T23:00:00+00:00 TriggerDagRunOperator 2023-02-12T00:10:56.858142+00:00 2023-02-12T00:10:57.348254+00:00 0:00:00.490112 338057 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2023-02-12T00:10:54.233955+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_campaign-history-job_v002 2023-02-11T23:00:00+00:00 TriggerDagRunOperator 2023-02-12T00:10:56.720198+00:00 2023-02-12T00:10:57.223174+00:00 0:00:00.502976 338056 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2023-02-12T00:10:54.233985+00:00 2 default_pool
success campaign-flow-job_v002 check_cluster_status 2023-02-11T23:00:00+00:00 EmrJobFlowSensor 2023-02-12T00:00:48.462817+00:00 2023-02-12T00:10:50.308102+00:00 0:10:01.845285 338049 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2023-02-12T00:00:43.900475+00:00 2 default_pool
success campaign-flow-job_v002 create_cluster_and_add_emr_steps 2023-02-11T23:00:00+00:00 EmrCreateJobFlowOperator 2023-02-12T00:00:26.296852+00:00 2023-02-12T00:00:27.367733+00:00 0:00:01.070881 338047 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 4 default 2023-02-12T00:00:23.852764+00:00 2 default_pool
success campaign-flow-job_v002 create_emr_steps 2023-02-11T23:00:00+00:00 PythonOperator 2023-02-12T00:00:04.355435+00:00 2023-02-12T00:00:07.104636+00:00 0:00:02.749201 338045 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 5 default 2023-02-12T00:00:01.831815+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_campaign-history-job_v002 2023-02-11T22:00:00+00:00 TriggerDagRunOperator 2023-02-11T23:11:09.737497+00:00 2023-02-11T23:11:10.384101+00:00 0:00:00.646604 338030 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2023-02-11T23:11:07.129885+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_booking-processing-job_v002 2023-02-11T22:00:00+00:00 TriggerDagRunOperator 2023-02-11T23:11:09.383744+00:00 2023-02-11T23:11:09.852839+00:00 0:00:00.469095 338029 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2023-02-11T23:11:07.129854+00:00 2 default_pool
success campaign-flow-job_v002 check_cluster_status 2023-02-11T22:00:00+00:00 EmrJobFlowSensor 2023-02-11T23:00:53.186818+00:00 2023-02-11T23:10:54.927270+00:00 0:10:01.740452 338021 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2023-02-11T23:00:50.963263+00:00 2 default_pool
success campaign-flow-job_v002 create_cluster_and_add_emr_steps 2023-02-11T22:00:00+00:00 EmrCreateJobFlowOperator 2023-02-11T23:00:31.293803+00:00 2023-02-11T23:00:32.152201+00:00 0:00:00.858398 338018 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 4 default 2023-02-11T23:00:28.936310+00:00 2 default_pool
success campaign-flow-job_v002 create_emr_steps 2023-02-11T22:00:00+00:00 PythonOperator 2023-02-11T23:00:11.334865+00:00 2023-02-11T23:00:14.446066+00:00 0:00:03.111201 338015 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 5 default 2023-02-11T23:00:08.883059+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_booking-processing-job_v002 2023-02-11T21:00:00+00:00 TriggerDagRunOperator 2023-02-11T22:11:12.502379+00:00 2023-02-11T22:11:12.977226+00:00 0:00:00.474847 338001 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2023-02-11T22:11:09.680394+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_campaign-history-job_v002 2023-02-11T21:00:00+00:00 TriggerDagRunOperator 2023-02-11T22:11:12.301137+00:00 2023-02-11T22:11:12.775628+00:00 0:00:00.474491 338000 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2023-02-11T22:11:09.680366+00:00 2 default_pool
success campaign-flow-job_v002 check_cluster_status 2023-02-11T21:00:00+00:00 EmrJobFlowSensor 2023-02-11T22:01:03.153951+00:00 2023-02-11T22:11:04.922217+00:00 0:10:01.768266 337994 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2023-02-11T22:01:00.727798+00:00 2 default_pool
success campaign-flow-job_v002 create_cluster_and_add_emr_steps 2023-02-11T21:00:00+00:00 EmrCreateJobFlowOperator 2023-02-11T22:00:41.249079+00:00 2023-02-11T22:00:42.112300+00:00 0:00:00.863221 337992 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 4 default 2023-02-11T22:00:38.724000+00:00 2 default_pool
success campaign-flow-job_v002 create_emr_steps 2023-02-11T21:00:00+00:00 PythonOperator 2023-02-11T22:00:20.859316+00:00 2023-02-11T22:00:24.602977+00:00 0:00:03.743661 337990 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 5 default 2023-02-11T22:00:18.653041+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_booking-processing-job_v002 2023-02-11T20:00:00+00:00 TriggerDagRunOperator 2023-02-11T21:11:19.192864+00:00 2023-02-11T21:11:19.960647+00:00 0:00:00.767783 337975 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2023-02-11T21:11:16.166024+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_campaign-history-job_v002 2023-02-11T20:00:00+00:00 TriggerDagRunOperator 2023-02-11T21:11:19.122045+00:00 2023-02-11T21:11:19.799082+00:00 0:00:00.677037 337974 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2023-02-11T21:11:16.166051+00:00 2 default_pool
success campaign-flow-job_v002 check_cluster_status 2023-02-11T20:00:00+00:00 EmrJobFlowSensor 2023-02-11T21:00:52.777501+00:00 2023-02-11T21:10:54.581963+00:00 0:10:01.804462 337968 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2023-02-11T21:00:50.323357+00:00 2 default_pool
success campaign-flow-job_v002 create_cluster_and_add_emr_steps 2023-02-11T20:00:00+00:00 EmrCreateJobFlowOperator 2023-02-11T21:00:32.716781+00:00 2023-02-11T21:00:33.866808+00:00 0:00:01.150027 337966 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 4 default 2023-02-11T21:00:28.250594+00:00 2 default_pool
success campaign-flow-job_v002 create_emr_steps 2023-02-11T20:00:00+00:00 PythonOperator 2023-02-11T21:00:08.561774+00:00 2023-02-11T21:00:13.212979+00:00 0:00:04.651205 337964 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 5 default 2023-02-11T21:00:06.292302+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_booking-processing-job_v002 2023-02-11T19:00:00+00:00 TriggerDagRunOperator 2023-02-11T20:11:01.253711+00:00 2023-02-11T20:11:01.804141+00:00 0:00:00.550430 337949 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2023-02-11T20:10:58.395267+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_campaign-history-job_v002 2023-02-11T19:00:00+00:00 TriggerDagRunOperator 2023-02-11T20:11:01.249786+00:00 2023-02-11T20:11:01.757649+00:00 0:00:00.507863 337948 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2023-02-11T20:10:58.395296+00:00 2 default_pool
success campaign-flow-job_v002 check_cluster_status 2023-02-11T19:00:00+00:00 EmrJobFlowSensor 2023-02-11T20:00:53.385333+00:00 2023-02-11T20:10:55.159564+00:00 0:10:01.774231 337941 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2023-02-11T20:00:50.880386+00:00 2 default_pool
success campaign-flow-job_v002 create_cluster_and_add_emr_steps 2023-02-11T19:00:00+00:00 EmrCreateJobFlowOperator 2023-02-11T20:00:31.172239+00:00 2023-02-11T20:00:32.037285+00:00 0:00:00.865046 337939 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 4 default 2023-02-11T20:00:28.853313+00:00 2 default_pool
success campaign-flow-job_v002 create_emr_steps 2023-02-11T19:00:00+00:00 PythonOperator 2023-02-11T20:00:11.324143+00:00 2023-02-11T20:00:14.330448+00:00 0:00:03.006305 337937 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 5 default 2023-02-11T20:00:08.834165+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_booking-processing-job_v002 2023-02-11T18:00:00+00:00 TriggerDagRunOperator 2023-02-11T19:11:28.619982+00:00 2023-02-11T19:11:29.129551+00:00 0:00:00.509569 337923 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2023-02-11T19:11:25.872486+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_campaign-history-job_v002 2023-02-11T18:00:00+00:00 TriggerDagRunOperator 2023-02-11T19:11:28.557306+00:00 2023-02-11T19:11:29.018329+00:00 0:00:00.461023 337922 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2023-02-11T19:11:25.872514+00:00 2 default_pool
success campaign-flow-job_v002 check_cluster_status 2023-02-11T18:00:00+00:00 EmrJobFlowSensor 2023-02-11T19:01:00.936171+00:00 2023-02-11T19:11:02.813812+00:00 0:10:01.877641 337916 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2023-02-11T19:00:58.690372+00:00 2 default_pool
success campaign-flow-job_v002 create_cluster_and_add_emr_steps 2023-02-11T18:00:00+00:00 EmrCreateJobFlowOperator 2023-02-11T19:00:40.740688+00:00 2023-02-11T19:00:41.581389+00:00 0:00:00.840701 337914 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 4 default 2023-02-11T19:00:38.560523+00:00 2 default_pool
success campaign-flow-job_v002 create_emr_steps 2023-02-11T18:00:00+00:00 PythonOperator 2023-02-11T19:00:18.762074+00:00 2023-02-11T19:00:22.880422+00:00 0:00:04.118348 337912 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 5 default 2023-02-11T19:00:16.542603+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_booking-processing-job_v002 2023-02-11T17:00:00+00:00 TriggerDagRunOperator 2023-02-11T18:11:59.667807+00:00 2023-02-11T18:12:00.256908+00:00 0:00:00.589101 337898 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2023-02-11T18:11:57.094894+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_campaign-history-job_v002 2023-02-11T17:00:00+00:00 TriggerDagRunOperator 2023-02-11T18:11:59.509526+00:00 2023-02-11T18:11:59.989079+00:00 0:00:00.479553 337897 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2023-02-11T18:11:57.094924+00:00 2 default_pool
success campaign-flow-job_v002 check_cluster_status 2023-02-11T17:00:00+00:00 EmrJobFlowSensor 2023-02-11T18:01:37.511561+00:00 2023-02-11T18:11:39.310186+00:00 0:10:01.798625 337890 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2023-02-11T18:01:35.224525+00:00 2 default_pool
success campaign-flow-job_v002 create_cluster_and_add_emr_steps 2023-02-11T17:00:00+00:00 EmrCreateJobFlowOperator 2023-02-11T18:01:16.009237+00:00 2023-02-11T18:01:16.938837+00:00 0:00:00.929600 337888 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 4 default 2023-02-11T18:01:13.254763+00:00 2 default_pool
success campaign-flow-job_v002 create_emr_steps 2023-02-11T17:00:00+00:00 PythonOperator 2023-02-11T18:00:12.527020+00:00 2023-02-11T18:00:16.254383+00:00 0:00:03.727363 337885 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 5 default 2023-02-11T18:00:10.223758+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_campaign-history-job_v002 2023-02-11T16:00:00+00:00 TriggerDagRunOperator 2023-02-11T17:12:14.867530+00:00 2023-02-11T17:12:15.415741+00:00 0:00:00.548211 337872 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2023-02-11T17:12:12.213165+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_booking-processing-job_v002 2023-02-11T16:00:00+00:00 TriggerDagRunOperator 2023-02-11T17:12:14.612092+00:00 2023-02-11T17:12:15.195517+00:00 0:00:00.583425 337871 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2023-02-11T17:12:12.213123+00:00 2 default_pool
success campaign-flow-job_v002 check_cluster_status 2023-02-11T16:00:00+00:00 EmrJobFlowSensor 2023-02-11T17:02:01.156711+00:00 2023-02-11T17:12:03.065325+00:00 0:10:01.908614 337865 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2023-02-11T17:01:58.828470+00:00 2 default_pool
success campaign-flow-job_v002 create_cluster_and_add_emr_steps 2023-02-11T16:00:00+00:00 EmrCreateJobFlowOperator 2023-02-11T17:01:41.406444+00:00 2023-02-11T17:01:42.242144+00:00 0:00:00.835700 337863 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 4 default 2023-02-11T17:01:38.813549+00:00 2 default_pool
success campaign-flow-job_v002 create_emr_steps 2023-02-11T16:00:00+00:00 PythonOperator 2023-02-11T17:00:13.935803+00:00 2023-02-11T17:00:18.188409+00:00 0:00:04.252606 337860 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 5 default 2023-02-11T17:00:11.512702+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_booking-processing-job_v002 2023-02-11T15:00:00+00:00 TriggerDagRunOperator 2023-02-11T16:11:07.430028+00:00 2023-02-11T16:11:07.916018+00:00 0:00:00.485990 337846 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2023-02-11T16:11:04.802897+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_campaign-history-job_v002 2023-02-11T15:00:00+00:00 TriggerDagRunOperator 2023-02-11T16:11:07.240769+00:00 2023-02-11T16:11:07.738583+00:00 0:00:00.497814 337845 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2023-02-11T16:11:04.802943+00:00 2 default_pool
success campaign-flow-job_v002 check_cluster_status 2023-02-11T15:00:00+00:00 EmrJobFlowSensor 2023-02-11T16:00:49.412791+00:00 2023-02-11T16:10:51.323834+00:00 0:10:01.911043 337838 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2023-02-11T16:00:46.999211+00:00 2 default_pool
success campaign-flow-job_v002 create_cluster_and_add_emr_steps 2023-02-11T15:00:00+00:00 EmrCreateJobFlowOperator 2023-02-11T16:00:27.305405+00:00 2023-02-11T16:00:28.144089+00:00 0:00:00.838684 337836 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 4 default 2023-02-11T16:00:24.973030+00:00 2 default_pool
success campaign-flow-job_v002 create_emr_steps 2023-02-11T15:00:00+00:00 PythonOperator 2023-02-11T16:00:05.413869+00:00 2023-02-11T16:00:08.550760+00:00 0:00:03.136891 337834 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 5 default 2023-02-11T16:00:02.963628+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_booking-processing-job_v002 2023-02-11T14:00:00+00:00 TriggerDagRunOperator 2023-02-11T15:11:11.430052+00:00 2023-02-11T15:11:11.921345+00:00 0:00:00.491293 337822 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2023-02-11T15:11:08.711329+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_campaign-history-job_v002 2023-02-11T14:00:00+00:00 TriggerDagRunOperator 2023-02-11T15:11:11.246670+00:00 2023-02-11T15:11:11.731947+00:00 0:00:00.485277 337821 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2023-02-11T15:11:08.711375+00:00 2 default_pool
success campaign-flow-job_v002 check_cluster_status 2023-02-11T14:00:00+00:00 EmrJobFlowSensor 2023-02-11T15:00:56.832354+00:00 2023-02-11T15:10:58.651159+00:00 0:10:01.818805 337815 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2023-02-11T15:00:54.447803+00:00 2 default_pool
success campaign-flow-job_v002 create_cluster_and_add_emr_steps 2023-02-11T14:00:00+00:00 EmrCreateJobFlowOperator 2023-02-11T15:00:36.858683+00:00 2023-02-11T15:00:37.730860+00:00 0:00:00.872177 337813 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 4 default 2023-02-11T15:00:34.393529+00:00 2 default_pool
success campaign-flow-job_v002 create_emr_steps 2023-02-11T14:00:00+00:00 PythonOperator 2023-02-11T15:00:14.754189+00:00 2023-02-11T15:00:17.784612+00:00 0:00:03.030423 337811 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 5 default 2023-02-11T15:00:12.304823+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_campaign-history-job_v002 2023-02-11T13:00:00+00:00 TriggerDagRunOperator 2023-02-11T14:16:14.751104+00:00 2023-02-11T14:16:15.288744+00:00 0:00:00.537640 337798 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2023-02-11T14:16:11.944680+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_booking-processing-job_v002 2023-02-11T13:00:00+00:00 TriggerDagRunOperator 2023-02-11T14:16:14.439432+00:00 2023-02-11T14:16:14.915283+00:00 0:00:00.475851 337797 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2023-02-11T14:16:11.944635+00:00 2 default_pool
success campaign-flow-job_v002 check_cluster_status 2023-02-11T13:00:00+00:00 EmrJobFlowSensor 2023-02-11T14:03:30.996481+00:00 2023-02-11T14:13:33.280806+00:00 0:10:02.284325 337790 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2023-02-11T14:03:28.335680+00:00 2 default_pool
success campaign-flow-job_v002 create_cluster_and_add_emr_steps 2023-02-11T13:00:00+00:00 EmrCreateJobFlowOperator 2023-02-11T14:03:10.687693+00:00 2023-02-11T14:03:11.725805+00:00 0:00:01.038112 337789 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 4 default 2023-02-11T14:03:08.279794+00:00 2 default_pool
success campaign-flow-job_v002 create_emr_steps 2023-02-11T13:00:00+00:00 PythonOperator 2023-02-11T14:02:48.651511+00:00 2023-02-11T14:02:52.586165+00:00 0:00:03.934654 337786 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 5 default 2023-02-11T14:02:46.258798+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_booking-processing-job_v002 2023-02-11T12:00:00+00:00 TriggerDagRunOperator 2023-02-11T13:17:37.034626+00:00 2023-02-11T13:17:37.548399+00:00 0:00:00.513773 337775 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2023-02-11T13:17:34.333497+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_campaign-history-job_v002 2023-02-11T12:00:00+00:00 TriggerDagRunOperator 2023-02-11T13:17:36.916444+00:00 2023-02-11T13:17:37.369339+00:00 0:00:00.452895 337774 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2023-02-11T13:17:34.333531+00:00 2 default_pool
success campaign-flow-job_v002 check_cluster_status 2023-02-11T12:00:00+00:00 EmrJobFlowSensor 2023-02-11T13:07:26.282904+00:00 2023-02-11T13:17:28.178709+00:00 0:10:01.895805 337771 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2023-02-11T13:07:23.852280+00:00 2 default_pool
success campaign-flow-job_v002 create_cluster_and_add_emr_steps 2023-02-11T12:00:00+00:00 EmrCreateJobFlowOperator 2023-02-11T13:07:04.223518+00:00 2023-02-11T13:07:05.110307+00:00 0:00:00.886789 337768 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 4 default 2023-02-11T13:07:01.830372+00:00 2 default_pool
success campaign-flow-job_v002 create_emr_steps 2023-02-11T12:00:00+00:00 PythonOperator 2023-02-11T13:06:42.041758+00:00 2023-02-11T13:06:45.880920+00:00 0:00:03.839162 337765 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 5 default 2023-02-11T13:06:39.773043+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_booking-processing-job_v002 2023-02-11T11:00:00+00:00 TriggerDagRunOperator 2023-02-11T12:12:39.055558+00:00 2023-02-11T12:12:39.541240+00:00 0:00:00.485682 337753 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2023-02-11T12:12:36.661969+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_campaign-history-job_v002 2023-02-11T11:00:00+00:00 TriggerDagRunOperator 2023-02-11T12:12:39.059406+00:00 2023-02-11T12:12:39.551409+00:00 0:00:00.492003 337752 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2023-02-11T12:12:36.661997+00:00 2 default_pool
success campaign-flow-job_v002 check_cluster_status 2023-02-11T11:00:00+00:00 EmrJobFlowSensor 2023-02-11T12:00:57.087058+00:00 2023-02-11T12:10:58.950366+00:00 0:10:01.863308 337744 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2023-02-11T12:00:54.733299+00:00 2 default_pool
success campaign-flow-job_v002 create_cluster_and_add_emr_steps 2023-02-11T11:00:00+00:00 EmrCreateJobFlowOperator 2023-02-11T12:00:36.957608+00:00 2023-02-11T12:00:37.959118+00:00 0:00:01.001510 337742 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 4 default 2023-02-11T12:00:34.697094+00:00 2 default_pool
success campaign-flow-job_v002 create_emr_steps 2023-02-11T11:00:00+00:00 PythonOperator 2023-02-11T12:00:15.221006+00:00 2023-02-11T12:00:18.244425+00:00 0:00:03.023419 337740 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 5 default 2023-02-11T12:00:12.633994+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_campaign-history-job_v002 2023-02-11T10:00:00+00:00 TriggerDagRunOperator 2023-02-11T11:11:38.497241+00:00 2023-02-11T11:11:38.975050+00:00 0:00:00.477809 337727 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2023-02-11T11:11:35.440841+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_booking-processing-job_v002 2023-02-11T10:00:00+00:00 TriggerDagRunOperator 2023-02-11T11:11:38.345252+00:00 2023-02-11T11:11:38.824367+00:00 0:00:00.479115 337726 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2023-02-11T11:11:35.440805+00:00 2 default_pool
success campaign-flow-job_v002 check_cluster_status 2023-02-11T10:00:00+00:00 EmrJobFlowSensor 2023-02-11T11:01:05.624107+00:00 2023-02-11T11:11:07.439899+00:00 0:10:01.815792 337719 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2023-02-11T11:01:03.291752+00:00 2 default_pool
success campaign-flow-job_v002 create_cluster_and_add_emr_steps 2023-02-11T10:00:00+00:00 EmrCreateJobFlowOperator 2023-02-11T11:00:47.617055+00:00 2023-02-11T11:00:48.715853+00:00 0:00:01.098798 337717 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 4 default 2023-02-11T11:00:43.211682+00:00 2 default_pool
success campaign-flow-job_v002 create_emr_steps 2023-02-11T10:00:00+00:00 PythonOperator 2023-02-11T11:00:23.454036+00:00 2023-02-11T11:00:27.074025+00:00 0:00:03.619989 337715 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 5 default 2023-02-11T11:00:21.212845+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_campaign-history-job_v002 2023-02-11T09:00:00+00:00 TriggerDagRunOperator 2023-02-11T10:11:02.321759+00:00 2023-02-11T10:11:02.860984+00:00 0:00:00.539225 337700 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2023-02-11T10:10:59.859523+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_booking-processing-job_v002 2023-02-11T09:00:00+00:00 TriggerDagRunOperator 2023-02-11T10:11:02.040671+00:00 2023-02-11T10:11:02.608454+00:00 0:00:00.567783 337699 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2023-02-11T10:10:59.859486+00:00 2 default_pool