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 trigger_dagrun_booking-processing-job_v002 2023-04-07T03:00:00+00:00 TriggerDagRunOperator 2023-04-07T04:34:39.996982+00:00 2023-04-07T04:34:40.449271+00:00 0:00:00.452289 365244 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2023-04-07T04:34:37.582982+00:00 2 default_pool
success campaign-flow-job_v002 check_cluster_status 2023-04-07T03:00:00+00:00 EmrJobFlowSensor 2023-04-07T04:15:38.148101+00:00 2023-04-07T04:25:40.067802+00:00 0:10:01.919701 365240 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2023-04-07T04:15:35.425746+00:00 2 default_pool
success campaign-flow-job_v002 create_cluster_and_add_emr_steps 2023-04-07T03:00:00+00:00 EmrCreateJobFlowOperator 2023-04-07T04:15:15.541581+00:00 2023-04-07T04:15:16.562042+00:00 0:00:01.020461 365237 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 4 default 2023-04-07T04:15:13.375085+00:00 2 default_pool
success campaign-flow-job_v002 create_emr_steps 2023-04-07T03:00:00+00:00 PythonOperator 2023-04-07T04:00:18.730182+00:00 2023-04-07T04:00:22.664308+00:00 0:00:03.934126 365233 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 5 default 2023-04-07T04:00:15.267448+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_campaign-history-job_v002 2023-04-07T02:00:00+00:00 TriggerDagRunOperator 2023-04-07T03:13:44.920422+00:00 2023-04-07T03:13:45.531247+00:00 0:00:00.610825 365223 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2023-04-07T03:13:41.803550+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_booking-processing-job_v002 2023-04-07T02:00:00+00:00 TriggerDagRunOperator 2023-04-07T03:13:44.901838+00:00 2023-04-07T03:13:45.552281+00:00 0:00:00.650443 365222 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2023-04-07T03:13:41.803506+00:00 2 default_pool
success campaign-flow-job_v002 check_cluster_status 2023-04-07T02:00:00+00:00 EmrJobFlowSensor 2023-04-07T03:03:35.222483+00:00 2023-04-07T03:13:37.021347+00:00 0:10:01.798864 365215 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2023-04-07T03:03:32.925311+00:00 2 default_pool
success campaign-flow-job_v002 create_cluster_and_add_emr_steps 2023-04-07T02:00:00+00:00 EmrCreateJobFlowOperator 2023-04-07T03:03:13.331468+00:00 2023-04-07T03:03:14.227851+00:00 0:00:00.896383 365213 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 4 default 2023-04-07T03:03:10.854721+00:00 2 default_pool
success campaign-flow-job_v002 create_emr_steps 2023-04-07T02:00:00+00:00 PythonOperator 2023-04-07T03:02:53.739412+00:00 2023-04-07T03:02:57.308964+00:00 0:00:03.569552 365211 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 5 default 2023-04-07T03:02:50.914301+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_campaign-history-job_v002 2023-04-07T01:00:00+00:00 TriggerDagRunOperator 2023-04-07T02:12:31.649689+00:00 2023-04-07T02:12:32.124399+00:00 0:00:00.474710 365199 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2023-04-07T02:12:28.657099+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_booking-processing-job_v002 2023-04-07T01:00:00+00:00 TriggerDagRunOperator 2023-04-07T02:12:31.520430+00:00 2023-04-07T02:12:31.969161+00:00 0:00:00.448731 365198 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2023-04-07T02:12:28.657066+00:00 2 default_pool
success campaign-flow-job_v002 check_cluster_status 2023-04-07T01:00:00+00:00 EmrJobFlowSensor 2023-04-07T02:00:49.146032+00:00 2023-04-07T02:10:50.945041+00:00 0:10:01.799009 365193 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2023-04-07T02:00:46.724167+00:00 2 default_pool
success campaign-flow-job_v002 create_cluster_and_add_emr_steps 2023-04-07T01:00:00+00:00 EmrCreateJobFlowOperator 2023-04-07T02:00:29.151104+00:00 2023-04-07T02:00:29.967382+00:00 0:00:00.816278 365191 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 4 default 2023-04-07T02:00:26.712214+00:00 2 default_pool
success campaign-flow-job_v002 create_emr_steps 2023-04-07T01:00:00+00:00 PythonOperator 2023-04-07T02:00:07.240775+00:00 2023-04-07T02:00:10.450812+00:00 0:00:03.210037 365189 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 5 default 2023-04-07T02:00:04.691325+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_booking-processing-job_v002 2023-04-07T00:00:00+00:00 TriggerDagRunOperator 2023-04-07T01:33:03.506525+00:00 2023-04-07T01:33:04.060108+00:00 0:00:00.553583 365178 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2023-04-07T01:32:58.217309+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_campaign-history-job_v002 2023-04-07T00:00:00+00:00 TriggerDagRunOperator 2023-04-07T01:33:01.656084+00:00 2023-04-07T01:33:02.143496+00:00 0:00:00.487412 365176 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2023-04-07T01:32:58.217333+00:00 2 default_pool
success campaign-flow-job_v002 check_cluster_status 2023-04-07T00:00:00+00:00 EmrJobFlowSensor 2023-04-07T01:08:23.036179+00:00 2023-04-07T01:18:24.698729+00:00 0:10:01.662550 365172 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2023-04-07T01:08:20.830566+00:00 2 default_pool
success campaign-flow-job_v002 create_cluster_and_add_emr_steps 2023-04-07T00:00:00+00:00 EmrCreateJobFlowOperator 2023-04-07T01:08:03.000922+00:00 2023-04-07T01:08:03.856836+00:00 0:00:00.855914 365169 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 4 default 2023-04-07T01:08:00.790263+00:00 2 default_pool
success campaign-flow-job_v002 create_emr_steps 2023-04-07T00:00:00+00:00 PythonOperator 2023-04-07T01:07:44.552158+00:00 2023-04-07T01:07:48.857100+00:00 0:00:04.304942 365166 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 5 default 2023-04-07T01:07:38.767920+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_booking-processing-job_v002 2023-04-06T23:00:00+00:00 TriggerDagRunOperator 2023-04-07T00:19:19.977316+00:00 2023-04-07T00:19:20.477227+00:00 0:00:00.499911 365158 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2023-04-07T00:19:17.445653+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_campaign-history-job_v002 2023-04-06T23:00:00+00:00 TriggerDagRunOperator 2023-04-07T00:19:19.798470+00:00 2023-04-07T00:19:20.265776+00:00 0:00:00.467306 365157 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2023-04-07T00:19:17.445681+00:00 2 default_pool
success campaign-flow-job_v002 check_cluster_status 2023-04-06T23:00:00+00:00 EmrJobFlowSensor 2023-04-07T00:09:08.460740+00:00 2023-04-07T00:19:10.328111+00:00 0:10:01.867371 365154 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2023-04-07T00:09:05.750677+00:00 2 default_pool
success campaign-flow-job_v002 create_cluster_and_add_emr_steps 2023-04-06T23:00:00+00:00 EmrCreateJobFlowOperator 2023-04-07T00:08:46.064830+00:00 2023-04-07T00:08:46.871330+00:00 0:00:00.806500 365150 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 4 default 2023-04-07T00:08:43.739272+00:00 2 default_pool
success campaign-flow-job_v002 create_emr_steps 2023-04-06T23:00:00+00:00 PythonOperator 2023-04-07T00:08:26.764847+00:00 2023-04-07T00:08:30.194424+00:00 0:00:03.429577 365148 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 5 default 2023-04-07T00:08:23.713881+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_campaign-history-job_v002 2023-04-06T22:00:00+00:00 TriggerDagRunOperator 2023-04-06T23:18:09.511380+00:00 2023-04-06T23:18:09.992719+00:00 0:00:00.481339 365138 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2023-04-06T23:18:06.833147+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_booking-processing-job_v002 2023-04-06T22:00:00+00:00 TriggerDagRunOperator 2023-04-06T23:18:09.303983+00:00 2023-04-06T23:18:09.758050+00:00 0:00:00.454067 365137 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2023-04-06T23:18:06.833119+00:00 2 default_pool
success campaign-flow-job_v002 check_cluster_status 2023-04-06T22:00:00+00:00 EmrJobFlowSensor 2023-04-06T23:07:49.196150+00:00 2023-04-06T23:17:50.918228+00:00 0:10:01.722078 365131 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2023-04-06T23:07:46.929002+00:00 2 default_pool
success campaign-flow-job_v002 create_cluster_and_add_emr_steps 2023-04-06T22:00:00+00:00 EmrCreateJobFlowOperator 2023-04-06T23:07:27.307744+00:00 2023-04-06T23:07:28.155501+00:00 0:00:00.847757 365127 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 4 default 2023-04-06T23:07:24.865166+00:00 2 default_pool
success campaign-flow-job_v002 create_emr_steps 2023-04-06T22:00:00+00:00 PythonOperator 2023-04-06T23:07:08.114363+00:00 2023-04-06T23:07:16.516958+00:00 0:00:08.402595 365123 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 5 default 2023-04-06T23:07:04.849793+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_campaign-history-job_v002 2023-04-06T21:00:00+00:00 TriggerDagRunOperator 2023-04-06T22:11:57.069262+00:00 2023-04-06T22:11:57.567322+00:00 0:00:00.498060 365113 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2023-04-06T22:11:54.651734+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_booking-processing-job_v002 2023-04-06T21:00:00+00:00 TriggerDagRunOperator 2023-04-06T22:11:57.034206+00:00 2023-04-06T22:11:57.501650+00:00 0:00:00.467444 365112 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2023-04-06T22:11:54.651704+00:00 2 default_pool
success campaign-flow-job_v002 check_cluster_status 2023-04-06T21:00:00+00:00 EmrJobFlowSensor 2023-04-06T22:01:36.756424+00:00 2023-04-06T22:11:38.513748+00:00 0:10:01.757324 365106 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2023-04-06T22:01:34.605069+00:00 2 default_pool
success campaign-flow-job_v002 create_cluster_and_add_emr_steps 2023-04-06T21:00:00+00:00 EmrCreateJobFlowOperator 2023-04-06T22:01:15.547689+00:00 2023-04-06T22:01:16.449802+00:00 0:00:00.902113 365104 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 4 default 2023-04-06T22:01:12.559305+00:00 2 default_pool
success campaign-flow-job_v002 create_emr_steps 2023-04-06T21:00:00+00:00 PythonOperator 2023-04-06T22:00:22.596689+00:00 2023-04-06T22:00:26.604480+00:00 0:00:04.007791 365101 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 5 default 2023-04-06T22:00:20.124622+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_campaign-history-job_v002 2023-04-06T20:00:00+00:00 TriggerDagRunOperator 2023-04-06T21:14:59.188979+00:00 2023-04-06T21:14:59.730986+00:00 0:00:00.542007 365090 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2023-04-06T21:14:54.349738+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_booking-processing-job_v002 2023-04-06T20:00:00+00:00 TriggerDagRunOperator 2023-04-06T21:14:58.955374+00:00 2023-04-06T21:14:59.664310+00:00 0:00:00.708936 365089 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2023-04-06T21:14:54.349694+00:00 2 default_pool
success campaign-flow-job_v002 check_cluster_status 2023-04-06T20:00:00+00:00 EmrJobFlowSensor 2023-04-06T21:14:35.135793+00:00 2023-04-06T21:14:35.701605+00:00 0:00:00.565812 365086 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2023-04-06T21:14:32.069039+00:00 2 default_pool
success campaign-flow-job_v002 create_cluster_and_add_emr_steps 2023-04-06T20:00:00+00:00 EmrCreateJobFlowOperator 2023-04-06T21:00:32.232743+00:00 2023-04-06T21:00:33.140994+00:00 0:00:00.908251 365083 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 4 default 2023-04-06T21:00:29.708325+00:00 2 default_pool
success campaign-flow-job_v002 create_emr_steps 2023-04-06T20:00:00+00:00 PythonOperator 2023-04-06T21:00:12.035891+00:00 2023-04-06T21:00:15.599920+00:00 0:00:03.564029 365081 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 5 default 2023-04-06T21:00:09.608108+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_campaign-history-job_v002 2023-04-06T19:00:00+00:00 TriggerDagRunOperator 2023-04-06T20:10:17.944946+00:00 2023-04-06T20:10:18.435145+00:00 0:00:00.490199 365072 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2023-04-06T20:10:15.527262+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_booking-processing-job_v002 2023-04-06T19:00:00+00:00 TriggerDagRunOperator 2023-04-06T20:10:17.936326+00:00 2023-04-06T20:10:18.486295+00:00 0:00:00.549969 365071 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2023-04-06T20:10:15.527234+00:00 2 default_pool
success campaign-flow-job_v002 check_cluster_status 2023-04-06T19:00:00+00:00 EmrJobFlowSensor 2023-04-06T20:01:04.266622+00:00 2023-04-06T20:10:05.986866+00:00 0:09:01.720244 365064 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2023-04-06T20:01:01.807125+00:00 2 default_pool
success campaign-flow-job_v002 create_cluster_and_add_emr_steps 2023-04-06T19:00:00+00:00 EmrCreateJobFlowOperator 2023-04-06T20:00:43.937507+00:00 2023-04-06T20:00:45.199493+00:00 0:00:01.261986 365062 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 4 default 2023-04-06T20:00:39.685613+00:00 2 default_pool
success campaign-flow-job_v002 create_emr_steps 2023-04-06T19:00:00+00:00 PythonOperator 2023-04-06T20:00:18.485038+00:00 2023-04-06T20:00:21.919075+00:00 0:00:03.434037 365060 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 5 default 2023-04-06T20:00:15.495746+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_campaign-history-job_v002 2023-04-06T18:00:00+00:00 TriggerDagRunOperator 2023-04-06T19:12:00.470339+00:00 2023-04-06T19:12:00.972260+00:00 0:00:00.501921 365048 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2023-04-06T19:11:57.755004+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_booking-processing-job_v002 2023-04-06T18:00:00+00:00 TriggerDagRunOperator 2023-04-06T19:12:00.320342+00:00 2023-04-06T19:12:00.796207+00:00 0:00:00.475865 365047 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2023-04-06T19:11:57.754975+00:00 2 default_pool
success campaign-flow-job_v002 check_cluster_status 2023-04-06T18:00:00+00:00 EmrJobFlowSensor 2023-04-06T19:01:07.925277+00:00 2023-04-06T19:11:09.658689+00:00 0:10:01.733412 365043 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2023-04-06T19:01:05.649117+00:00 2 default_pool
success campaign-flow-job_v002 create_cluster_and_add_emr_steps 2023-04-06T18:00:00+00:00 EmrCreateJobFlowOperator 2023-04-06T19:00:45.844557+00:00 2023-04-06T19:00:46.751042+00:00 0:00:00.906485 365041 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 4 default 2023-04-06T19:00:43.631658+00:00 2 default_pool
success campaign-flow-job_v002 create_emr_steps 2023-04-06T18:00:00+00:00 PythonOperator 2023-04-06T19:00:23.700102+00:00 2023-04-06T19:00:27.252813+00:00 0:00:03.552711 365039 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 5 default 2023-04-06T19:00:21.531509+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_booking-processing-job_v002 2023-04-06T17:00:00+00:00 TriggerDagRunOperator 2023-04-06T18:17:15.255733+00:00 2023-04-06T18:17:15.748244+00:00 0:00:00.492511 365030 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2023-04-06T18:17:12.851199+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_campaign-history-job_v002 2023-04-06T17:00:00+00:00 TriggerDagRunOperator 2023-04-06T18:17:15.242100+00:00 2023-04-06T18:17:15.700013+00:00 0:00:00.457913 365029 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2023-04-06T18:17:12.851227+00:00 2 default_pool
success campaign-flow-job_v002 check_cluster_status 2023-04-06T17:00:00+00:00 EmrJobFlowSensor 2023-04-06T18:01:04.044631+00:00 2023-04-06T18:11:05.678003+00:00 0:10:01.633372 365022 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2023-04-06T18:01:01.726176+00:00 2 default_pool
success campaign-flow-job_v002 create_cluster_and_add_emr_steps 2023-04-06T17:00:00+00:00 EmrCreateJobFlowOperator 2023-04-06T18:00:45.807102+00:00 2023-04-06T18:00:47.054335+00:00 0:00:01.247233 365020 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 4 default 2023-04-06T18:00:41.693980+00:00 2 default_pool
success campaign-flow-job_v002 create_emr_steps 2023-04-06T17:00:00+00:00 PythonOperator 2023-04-06T18:00:22.097382+00:00 2023-04-06T18:00:25.277197+00:00 0:00:03.179815 365018 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 5 default 2023-04-06T18:00:19.582524+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_booking-processing-job_v002 2023-04-06T16:00:00+00:00 TriggerDagRunOperator 2023-04-06T17:15:27.825364+00:00 2023-04-06T17:15:28.300432+00:00 0:00:00.475068 365009 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2023-04-06T17:15:24.853872+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_campaign-history-job_v002 2023-04-06T16:00:00+00:00 TriggerDagRunOperator 2023-04-06T17:15:27.585296+00:00 2023-04-06T17:15:28.045533+00:00 0:00:00.460237 365008 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2023-04-06T17:15:24.853904+00:00 2 default_pool
success campaign-flow-job_v002 check_cluster_status 2023-04-06T16:00:00+00:00 EmrJobFlowSensor 2023-04-06T17:02:43.844771+00:00 2023-04-06T17:12:45.606538+00:00 0:10:01.761767 365001 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2023-04-06T17:02:41.431590+00:00 2 default_pool
success campaign-flow-job_v002 create_cluster_and_add_emr_steps 2023-04-06T16:00:00+00:00 EmrCreateJobFlowOperator 2023-04-06T17:02:21.528466+00:00 2023-04-06T17:02:22.332670+00:00 0:00:00.804204 364999 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 4 default 2023-04-06T17:02:19.383666+00:00 2 default_pool
success campaign-flow-job_v002 create_emr_steps 2023-04-06T16:00:00+00:00 PythonOperator 2023-04-06T17:02:02.196267+00:00 2023-04-06T17:02:05.868681+00:00 0:00:03.672414 364998 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 5 default 2023-04-06T17:01:59.366256+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_campaign-history-job_v002 2023-04-06T15:00:00+00:00 TriggerDagRunOperator 2023-04-06T16:22:15.345321+00:00 2023-04-06T16:22:15.988084+00:00 0:00:00.642763 364988 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2023-04-06T16:22:09.386467+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_booking-processing-job_v002 2023-04-06T15:00:00+00:00 TriggerDagRunOperator 2023-04-06T16:22:12.287114+00:00 2023-04-06T16:22:12.711960+00:00 0:00:00.424846 364986 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2023-04-06T16:22:09.386437+00:00 2 default_pool
success campaign-flow-job_v002 check_cluster_status 2023-04-06T15:00:00+00:00 EmrJobFlowSensor 2023-04-06T16:00:52.477065+00:00 2023-04-06T16:10:54.340258+00:00 0:10:01.863193 364982 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2023-04-06T16:00:50.290216+00:00 2 default_pool
success campaign-flow-job_v002 create_cluster_and_add_emr_steps 2023-04-06T15:00:00+00:00 EmrCreateJobFlowOperator 2023-04-06T16:00:28.807425+00:00 2023-04-06T16:00:30.120658+00:00 0:00:01.313233 364980 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 4 default 2023-04-06T16:00:26.323686+00:00 2 default_pool
success campaign-flow-job_v002 create_emr_steps 2023-04-06T15:00:00+00:00 PythonOperator 2023-04-06T16:00:07.000701+00:00 2023-04-06T16:00:10.399145+00:00 0:00:03.398444 364978 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 5 default 2023-04-06T16:00:04.309347+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_campaign-history-job_v002 2023-04-06T14:00:00+00:00 TriggerDagRunOperator 2023-04-06T15:29:58.570068+00:00 2023-04-06T15:29:59.331776+00:00 0:00:00.761708 364972 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2023-04-06T15:29:55.377648+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_booking-processing-job_v002 2023-04-06T14:00:00+00:00 TriggerDagRunOperator 2023-04-06T15:29:58.161380+00:00 2023-04-06T15:29:58.995836+00:00 0:00:00.834456 364971 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2023-04-06T15:29:55.377619+00:00 2 default_pool
success campaign-flow-job_v002 check_cluster_status 2023-04-06T14:00:00+00:00 EmrJobFlowSensor 2023-04-06T15:12:49.260313+00:00 2023-04-06T15:22:51.086478+00:00 0:10:01.826165 364967 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2023-04-06T15:12:46.750097+00:00 2 default_pool
success campaign-flow-job_v002 create_cluster_and_add_emr_steps 2023-04-06T14:00:00+00:00 EmrCreateJobFlowOperator 2023-04-06T15:12:27.177914+00:00 2023-04-06T15:12:28.103574+00:00 0:00:00.925660 364965 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 4 default 2023-04-06T15:12:24.703884+00:00 2 default_pool
success campaign-flow-job_v002 create_emr_steps 2023-04-06T14:00:00+00:00 PythonOperator 2023-04-06T15:12:07.423838+00:00 2023-04-06T15:12:12.281272+00:00 0:00:04.857434 364962 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 5 default 2023-04-06T15:12:02.692425+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_campaign-history-job_v002 2023-04-06T13:00:00+00:00 TriggerDagRunOperator 2023-04-06T14:14:58.543905+00:00 2023-04-06T14:14:59.335356+00:00 0:00:00.791451 364953 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2023-04-06T14:14:55.650865+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_booking-processing-job_v002 2023-04-06T13:00:00+00:00 TriggerDagRunOperator 2023-04-06T14:14:58.571588+00:00 2023-04-06T14:14:59.351115+00:00 0:00:00.779527 364952 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2023-04-06T14:14:55.650833+00:00 2 default_pool
success campaign-flow-job_v002 check_cluster_status 2023-04-06T13:00:00+00:00 EmrJobFlowSensor 2023-04-06T14:04:46.292708+00:00 2023-04-06T14:14:48.048576+00:00 0:10:01.755868 364946 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2023-04-06T14:04:44.053340+00:00 2 default_pool
success campaign-flow-job_v002 create_cluster_and_add_emr_steps 2023-04-06T13:00:00+00:00 EmrCreateJobFlowOperator 2023-04-06T14:04:24.255539+00:00 2023-04-06T14:04:25.158002+00:00 0:00:00.902463 364944 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 4 default 2023-04-06T14:04:22.035291+00:00 2 default_pool
success campaign-flow-job_v002 create_emr_steps 2023-04-06T13:00:00+00:00 PythonOperator 2023-04-06T14:04:02.168623+00:00 2023-04-06T14:04:05.663837+00:00 0:00:03.495214 364942 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 5 default 2023-04-06T14:03:59.982533+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_campaign-history-job_v002 2023-04-06T12:00:00+00:00 TriggerDagRunOperator 2023-04-06T13:11:03.530104+00:00 2023-04-06T13:11:04.056400+00:00 0:00:00.526296 364932 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2023-04-06T13:11:00.795293+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_booking-processing-job_v002 2023-04-06T12:00:00+00:00 TriggerDagRunOperator 2023-04-06T13:11:03.312788+00:00 2023-04-06T13:11:03.755566+00:00 0:00:00.442778 364931 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2023-04-06T13:11:00.795262+00:00 2 default_pool
success campaign-flow-job_v002 check_cluster_status 2023-04-06T12:00:00+00:00 EmrJobFlowSensor 2023-04-06T13:00:47.857173+00:00 2023-04-06T13:10:49.636735+00:00 0:10:01.779562 364924 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2023-04-06T13:00:45.564842+00:00 2 default_pool
success campaign-flow-job_v002 create_cluster_and_add_emr_steps 2023-04-06T12:00:00+00:00 EmrCreateJobFlowOperator 2023-04-06T13:00:25.986132+00:00 2023-04-06T13:00:27.001447+00:00 0:00:01.015315 364922 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 4 default 2023-04-06T13:00:23.543843+00:00 2 default_pool
success campaign-flow-job_v002 create_emr_steps 2023-04-06T12:00:00+00:00 PythonOperator 2023-04-06T13:00:06.183654+00:00 2023-04-06T13:00:10.381541+00:00 0:00:04.197887 364921 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 5 default 2023-04-06T13:00:03.532454+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_booking-processing-job_v002 2023-04-06T11:00:00+00:00 TriggerDagRunOperator 2023-04-06T12:13:08.462875+00:00 2023-04-06T12:13:09.002844+00:00 0:00:00.539969 364908 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2023-04-06T12:13:05.495123+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_campaign-history-job_v002 2023-04-06T11:00:00+00:00 TriggerDagRunOperator 2023-04-06T12:13:08.348308+00:00 2023-04-06T12:13:08.814220+00:00 0:00:00.465912 364907 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2023-04-06T12:13:05.495163+00:00 2 default_pool
success campaign-flow-job_v002 check_cluster_status 2023-04-06T11:00:00+00:00 EmrJobFlowSensor 2023-04-06T12:01:22.091563+00:00 2023-04-06T12:12:24.105704+00:00 0:11:02.014141 364903 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2023-04-06T12:01:19.755822+00:00 2 default_pool
success campaign-flow-job_v002 create_cluster_and_add_emr_steps 2023-04-06T11:00:00+00:00 EmrCreateJobFlowOperator 2023-04-06T12:01:00.171622+00:00 2023-04-06T12:01:01.308609+00:00 0:00:01.136987 364901 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 4 default 2023-04-06T12:00:57.728155+00:00 2 default_pool
success campaign-flow-job_v002 create_emr_steps 2023-04-06T11:00:00+00:00 PythonOperator 2023-04-06T12:00:40.084291+00:00 2023-04-06T12:00:45.011688+00:00 0:00:04.927397 364899 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 5 default 2023-04-06T12:00:37.669131+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_booking-processing-job_v002 2023-04-06T10:00:00+00:00 TriggerDagRunOperator 2023-04-06T11:11:05.297606+00:00 2023-04-06T11:11:05.760362+00:00 0:00:00.462756 364892 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2023-04-06T11:11:02.607754+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_campaign-history-job_v002 2023-04-06T10:00:00+00:00 TriggerDagRunOperator 2023-04-06T11:11:05.059253+00:00 2023-04-06T11:11:05.506228+00:00 0:00:00.446975 364891 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2023-04-06T11:11:02.607786+00:00 2 default_pool
success campaign-flow-job_v002 check_cluster_status 2023-04-06T10:00:00+00:00 EmrJobFlowSensor 2023-04-06T11:00:48.257560+00:00 2023-04-06T11:10:50.034586+00:00 0:10:01.777026 364884 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2023-04-06T11:00:46.032234+00:00 2 default_pool
success campaign-flow-job_v002 create_cluster_and_add_emr_steps 2023-04-06T10:00:00+00:00 EmrCreateJobFlowOperator 2023-04-06T11:00:26.212203+00:00 2023-04-06T11:00:27.091937+00:00 0:00:00.879734 364882 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 4 default 2023-04-06T11:00:23.998152+00:00 2 default_pool
success campaign-flow-job_v002 create_emr_steps 2023-04-06T10:00:00+00:00 PythonOperator 2023-04-06T11:00:06.403962+00:00 2023-04-06T11:00:09.621359+00:00 0:00:03.217397 364880 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 5 default 2023-04-06T11:00:03.929252+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_booking-processing-job_v002 2023-04-06T09:00:00+00:00 TriggerDagRunOperator 2023-04-06T10:20:38.641548+00:00 2023-04-06T10:20:39.105625+00:00 0:00:00.464077 364872 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2023-04-06T10:20:36.209335+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_campaign-history-job_v002 2023-04-06T09:00:00+00:00 TriggerDagRunOperator 2023-04-06T10:20:38.624032+00:00 2023-04-06T10:20:39.120616+00:00 0:00:00.496584 364871 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2023-04-06T10:20:36.209364+00:00 2 default_pool
success campaign-flow-job_v002 check_cluster_status 2023-04-06T09:00:00+00:00 EmrJobFlowSensor 2023-04-06T10:09:28.648595+00:00 2023-04-06T10:20:30.500198+00:00 0:11:01.851603 364866 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2023-04-06T10:09:26.487076+00:00 2 default_pool
success campaign-flow-job_v002 create_cluster_and_add_emr_steps 2023-04-06T09:00:00+00:00 EmrCreateJobFlowOperator 2023-04-06T10:09:06.663109+00:00 2023-04-06T10:09:07.613602+00:00 0:00:00.950493 364863 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 4 default 2023-04-06T10:09:04.463501+00:00 2 default_pool
success campaign-flow-job_v002 create_emr_steps 2023-04-06T09:00:00+00:00 PythonOperator 2023-04-06T10:08:47.425069+00:00 2023-04-06T10:08:50.826799+00:00 0:00:03.401730 364860 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 5 default 2023-04-06T10:08:44.503283+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_campaign-history-job_v002 2023-04-06T08:00:00+00:00 TriggerDagRunOperator 2023-04-06T09:15:02.456499+00:00 2023-04-06T09:15:02.991640+00:00 0:00:00.535141 364849 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2023-04-06T09:14:59.371153+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_booking-processing-job_v002 2023-04-06T08:00:00+00:00 TriggerDagRunOperator 2023-04-06T09:15:02.158586+00:00 2023-04-06T09:15:02.630225+00:00 0:00:00.471639 364848 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2023-04-06T09:14:59.371111+00:00 2 default_pool
success campaign-flow-job_v002 check_cluster_status 2023-04-06T08:00:00+00:00 EmrJobFlowSensor 2023-04-06T09:01:06.256511+00:00 2023-04-06T09:11:08.083893+00:00 0:10:01.827382 364845 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2023-04-06T09:01:04.053928+00:00 2 default_pool
success campaign-flow-job_v002 create_cluster_and_add_emr_steps 2023-04-06T08:00:00+00:00 EmrCreateJobFlowOperator 2023-04-06T09:00:44.376519+00:00 2023-04-06T09:00:45.280819+00:00 0:00:00.904300 364843 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 4 default 2023-04-06T09:00:42.035685+00:00 2 default_pool
success campaign-flow-job_v002 create_emr_steps 2023-04-06T08:00:00+00:00 PythonOperator 2023-04-06T09:00:22.314186+00:00 2023-04-06T09:00:26.834458+00:00 0:00:04.520272 364841 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 5 default 2023-04-06T09:00:19.954450+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_campaign-history-job_v002 2023-04-06T07:00:00+00:00 TriggerDagRunOperator 2023-04-06T08:48:45.495647+00:00 2023-04-06T08:48:46.036883+00:00 0:00:00.541236 364835 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2023-04-06T08:48:42.251547+00:00 2 default_pool