Task Instances

Reset Filters
  State Dag Id Task Id Execution Date Operator Start Date End Date Duration Job Id Hostname Unixname Priority Weight Queue Queued Dttm Try Number Pool Log Url
success campaign-flow-job_v002 create_emr_steps 2021-05-07T05:00:00+00:00 PythonOperator 2021-05-07T06:00:04.822809+00:00 2021-05-07T06:00:07.941189+00:00 0:00:03.118380 25359 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 5 default 2021-05-07T06:00:02.607341+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_booking-processing-job_v002 2021-05-07T04:00:00+00:00 TriggerDagRunOperator 2021-05-07T05:11:27.012111+00:00 2021-05-07T05:11:27.523150+00:00 0:00:00.511039 25351 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-05-07T05:11:24.339160+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_campaign-history-job_v002 2021-05-07T04:00:00+00:00 TriggerDagRunOperator 2021-05-07T05:11:26.759392+00:00 2021-05-07T05:11:27.180772+00:00 0:00:00.421380 25350 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-05-07T05:11:24.339130+00:00 2 default_pool
success campaign-flow-job_v002 check_cluster_status 2021-05-07T04:00:00+00:00 EmrJobFlowSensor 2021-05-07T05:00:59.393348+00:00 2021-05-07T05:11:02.313360+00:00 0:10:02.920012 25346 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-05-07T05:00:56.961134+00:00 2 default_pool
success campaign-flow-job_v002 create_cluster_and_add_emr_steps 2021-05-07T04:00:00+00:00 EmrCreateJobFlowOperator 2021-05-07T05:00:39.265709+00:00 2021-05-07T05:00:40.914060+00:00 0:00:01.648351 25345 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 4 default 2021-05-07T05:00:36.963648+00:00 2 default_pool
success campaign-flow-job_v002 create_emr_steps 2021-05-07T04:00:00+00:00 PythonOperator 2021-05-07T05:00:17.026915+00:00 2021-05-07T05:00:20.154244+00:00 0:00:03.127329 25344 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 5 default 2021-05-07T05:00:14.837603+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_booking-processing-job_v002 2021-05-07T03:00:00+00:00 TriggerDagRunOperator 2021-05-07T04:11:13.937430+00:00 2021-05-07T04:11:14.497234+00:00 0:00:00.559804 25334 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-05-07T04:11:11.345227+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_campaign-history-job_v002 2021-05-07T03:00:00+00:00 TriggerDagRunOperator 2021-05-07T04:11:13.806010+00:00 2021-05-07T04:11:14.321919+00:00 0:00:00.515909 25333 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-05-07T04:11:11.345194+00:00 2 default_pool
success campaign-flow-job_v002 check_cluster_status 2021-05-07T03:00:00+00:00 EmrJobFlowSensor 2021-05-07T04:00:46.147926+00:00 2021-05-07T04:10:49.158819+00:00 0:10:03.010893 25329 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-05-07T04:00:43.881917+00:00 2 default_pool
success campaign-flow-job_v002 create_cluster_and_add_emr_steps 2021-05-07T03:00:00+00:00 EmrCreateJobFlowOperator 2021-05-07T04:00:26.125169+00:00 2021-05-07T04:00:27.955789+00:00 0:00:01.830620 25328 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 4 default 2021-05-07T04:00:23.847428+00:00 2 default_pool
success campaign-flow-job_v002 create_emr_steps 2021-05-07T03:00:00+00:00 PythonOperator 2021-05-07T04:00:04.484715+00:00 2021-05-07T04:00:07.545168+00:00 0:00:03.060453 25327 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 5 default 2021-05-07T04:00:01.810792+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_campaign-history-job_v002 2021-05-07T02:00:00+00:00 TriggerDagRunOperator 2021-05-07T03:11:03.829552+00:00 2021-05-07T03:11:04.347639+00:00 0:00:00.518087 25319 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-05-07T03:11:01.187317+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_booking-processing-job_v002 2021-05-07T02:00:00+00:00 TriggerDagRunOperator 2021-05-07T03:11:03.725992+00:00 2021-05-07T03:11:04.135619+00:00 0:00:00.409627 25318 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-05-07T03:11:01.187349+00:00 2 default_pool
success campaign-flow-job_v002 check_cluster_status 2021-05-07T02:00:00+00:00 EmrJobFlowSensor 2021-05-07T03:00:48.552064+00:00 2021-05-07T03:10:51.515806+00:00 0:10:02.963742 25314 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-05-07T03:00:46.027837+00:00 2 default_pool
success campaign-flow-job_v002 create_cluster_and_add_emr_steps 2021-05-07T02:00:00+00:00 EmrCreateJobFlowOperator 2021-05-07T03:00:26.374933+00:00 2021-05-07T03:00:28.145154+00:00 0:00:01.770221 25313 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 4 default 2021-05-07T03:00:24.077616+00:00 2 default_pool
success campaign-flow-job_v002 create_emr_steps 2021-05-07T02:00:00+00:00 PythonOperator 2021-05-07T03:00:06.763984+00:00 2021-05-07T03:00:09.832872+00:00 0:00:03.068888 25312 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 5 default 2021-05-07T03:00:04.044405+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_booking-processing-job_v002 2021-05-07T01:00:00+00:00 TriggerDagRunOperator 2021-05-07T02:10:46.000975+00:00 2021-05-07T02:10:46.560726+00:00 0:00:00.559751 25304 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-05-07T02:10:43.605637+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_campaign-history-job_v002 2021-05-07T01:00:00+00:00 TriggerDagRunOperator 2021-05-07T02:10:45.958512+00:00 2021-05-07T02:10:46.399890+00:00 0:00:00.441378 25303 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-05-07T02:10:43.605607+00:00 2 default_pool
success campaign-flow-job_v002 check_cluster_status 2021-05-07T01:00:00+00:00 EmrJobFlowSensor 2021-05-07T02:01:12.760957+00:00 2021-05-07T02:10:15.509364+00:00 0:09:02.748407 25299 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-05-07T02:01:10.436481+00:00 2 default_pool
success campaign-flow-job_v002 create_cluster_and_add_emr_steps 2021-05-07T01:00:00+00:00 EmrCreateJobFlowOperator 2021-05-07T02:00:46.684807+00:00 2021-05-07T02:00:48.514293+00:00 0:00:01.829486 25298 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 4 default 2021-05-07T02:00:44.412634+00:00 2 default_pool
success campaign-flow-job_v002 create_emr_steps 2021-05-07T01:00:00+00:00 PythonOperator 2021-05-07T02:00:16.588683+00:00 2021-05-07T02:00:19.654419+00:00 0:00:03.065736 25297 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 5 default 2021-05-07T02:00:14.402966+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_campaign-history-job_v002 2021-05-07T00:00:00+00:00 TriggerDagRunOperator 2021-05-07T01:10:04.604211+00:00 2021-05-07T01:10:05.090769+00:00 0:00:00.486558 25289 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-05-07T01:10:02.208436+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_booking-processing-job_v002 2021-05-07T00:00:00+00:00 TriggerDagRunOperator 2021-05-07T01:10:04.322540+00:00 2021-05-07T01:10:04.730207+00:00 0:00:00.407667 25288 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-05-07T01:10:02.208466+00:00 2 default_pool
success campaign-flow-job_v002 check_cluster_status 2021-05-07T00:00:00+00:00 EmrJobFlowSensor 2021-05-07T01:00:57.939105+00:00 2021-05-07T01:10:00.674452+00:00 0:09:02.735347 25284 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-05-07T01:00:55.650948+00:00 2 default_pool
success campaign-flow-job_v002 create_cluster_and_add_emr_steps 2021-05-07T00:00:00+00:00 EmrCreateJobFlowOperator 2021-05-07T01:00:37.773234+00:00 2021-05-07T01:00:39.476935+00:00 0:00:01.703701 25283 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 4 default 2021-05-07T01:00:35.542625+00:00 2 default_pool
success campaign-flow-job_v002 create_emr_steps 2021-05-07T00:00:00+00:00 PythonOperator 2021-05-07T01:00:15.801814+00:00 2021-05-07T01:00:18.890803+00:00 0:00:03.088989 25282 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 5 default 2021-05-07T01:00:13.522972+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_booking-processing-job_v002 2021-05-06T23:00:00+00:00 TriggerDagRunOperator 2021-05-07T00:10:21.133368+00:00 2021-05-07T00:10:21.655646+00:00 0:00:00.522278 25274 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-05-07T00:10:18.900566+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_campaign-history-job_v002 2021-05-06T23:00:00+00:00 TriggerDagRunOperator 2021-05-07T00:10:20.990580+00:00 2021-05-07T00:10:21.444943+00:00 0:00:00.454363 25273 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-05-07T00:10:18.900529+00:00 2 default_pool
success campaign-flow-job_v002 check_cluster_status 2021-05-06T23:00:00+00:00 EmrJobFlowSensor 2021-05-07T00:01:04.403298+00:00 2021-05-07T00:10:07.129011+00:00 0:09:02.725713 25269 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-05-07T00:01:02.229241+00:00 2 default_pool
success campaign-flow-job_v002 create_cluster_and_add_emr_steps 2021-05-06T23:00:00+00:00 EmrCreateJobFlowOperator 2021-05-07T00:00:42.450461+00:00 2021-05-07T00:00:44.320463+00:00 0:00:01.870002 25268 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 4 default 2021-05-07T00:00:40.207698+00:00 2 default_pool
success campaign-flow-job_v002 create_emr_steps 2021-05-06T23:00:00+00:00 PythonOperator 2021-05-07T00:00:20.724369+00:00 2021-05-07T00:00:23.875370+00:00 0:00:03.151001 25267 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 5 default 2021-05-07T00:00:18.187445+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_booking-processing-job_v002 2021-05-06T22:00:00+00:00 TriggerDagRunOperator 2021-05-06T23:10:28.175139+00:00 2021-05-06T23:10:28.786368+00:00 0:00:00.611229 25258 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-05-06T23:10:25.725928+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_campaign-history-job_v002 2021-05-06T22:00:00+00:00 TriggerDagRunOperator 2021-05-06T23:10:27.956640+00:00 2021-05-06T23:10:28.412291+00:00 0:00:00.455651 25257 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-05-06T23:10:25.725882+00:00 2 default_pool
success campaign-flow-job_v002 check_cluster_status 2021-05-06T22:00:00+00:00 EmrJobFlowSensor 2021-05-06T23:01:01.186199+00:00 2021-05-06T23:10:04.092791+00:00 0:09:02.906592 25252 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-05-06T23:00:58.667620+00:00 2 default_pool
success campaign-flow-job_v002 create_cluster_and_add_emr_steps 2021-05-06T22:00:00+00:00 EmrCreateJobFlowOperator 2021-05-06T23:00:38.775880+00:00 2021-05-06T23:00:40.474148+00:00 0:00:01.698268 25250 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 4 default 2021-05-06T23:00:36.571342+00:00 2 default_pool
success campaign-flow-job_v002 create_emr_steps 2021-05-06T22:00:00+00:00 PythonOperator 2021-05-06T23:00:17.082039+00:00 2021-05-06T23:00:20.163242+00:00 0:00:03.081203 25248 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 5 default 2021-05-06T23:00:14.544110+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_booking-processing-job_v002 2021-05-06T21:00:00+00:00 TriggerDagRunOperator 2021-05-06T22:10:15.016027+00:00 2021-05-06T22:10:15.543373+00:00 0:00:00.527346 25240 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-05-06T22:10:12.481798+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_campaign-history-job_v002 2021-05-06T21:00:00+00:00 TriggerDagRunOperator 2021-05-06T22:10:14.674020+00:00 2021-05-06T22:10:15.095508+00:00 0:00:00.421488 25239 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-05-06T22:10:12.481733+00:00 2 default_pool
success campaign-flow-job_v002 check_cluster_status 2021-05-06T21:00:00+00:00 EmrJobFlowSensor 2021-05-06T22:00:49.599440+00:00 2021-05-06T22:09:52.402222+00:00 0:09:02.802782 25235 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-05-06T22:00:47.416561+00:00 2 default_pool
success campaign-flow-job_v002 create_cluster_and_add_emr_steps 2021-05-06T21:00:00+00:00 EmrCreateJobFlowOperator 2021-05-06T22:00:27.582379+00:00 2021-05-06T22:00:29.299702+00:00 0:00:01.717323 25234 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 4 default 2021-05-06T22:00:25.400494+00:00 2 default_pool
success campaign-flow-job_v002 create_emr_steps 2021-05-06T21:00:00+00:00 PythonOperator 2021-05-06T22:00:05.895374+00:00 2021-05-06T22:00:08.985402+00:00 0:00:03.090028 25233 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 5 default 2021-05-06T22:00:03.444481+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_booking-processing-job_v002 2021-05-06T20:00:00+00:00 TriggerDagRunOperator 2021-05-06T21:10:17.314726+00:00 2021-05-06T21:10:17.742583+00:00 0:00:00.427857 25225 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-05-06T21:10:14.923952+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_campaign-history-job_v002 2021-05-06T20:00:00+00:00 TriggerDagRunOperator 2021-05-06T21:10:17.176407+00:00 2021-05-06T21:10:17.734310+00:00 0:00:00.557903 25224 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-05-06T21:10:14.923914+00:00 2 default_pool
success campaign-flow-job_v002 check_cluster_status 2021-05-06T20:00:00+00:00 EmrJobFlowSensor 2021-05-06T21:00:58.111182+00:00 2021-05-06T21:10:00.770880+00:00 0:09:02.659698 25220 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-05-06T21:00:56.008452+00:00 2 default_pool
success campaign-flow-job_v002 create_cluster_and_add_emr_steps 2021-05-06T20:00:00+00:00 EmrCreateJobFlowOperator 2021-05-06T21:00:36.276560+00:00 2021-05-06T21:00:38.060265+00:00 0:00:01.783705 25219 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 4 default 2021-05-06T21:00:33.991884+00:00 2 default_pool
success campaign-flow-job_v002 create_emr_steps 2021-05-06T20:00:00+00:00 PythonOperator 2021-05-06T21:00:16.212137+00:00 2021-05-06T21:00:19.279012+00:00 0:00:03.066875 25218 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 5 default 2021-05-06T21:00:13.982074+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_campaign-history-job_v002 2021-05-06T19:00:00+00:00 TriggerDagRunOperator 2021-05-06T20:11:27.047207+00:00 2021-05-06T20:11:27.547322+00:00 0:00:00.500115 25209 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-05-06T20:11:24.792211+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_booking-processing-job_v002 2021-05-06T19:00:00+00:00 TriggerDagRunOperator 2021-05-06T20:11:26.883260+00:00 2021-05-06T20:11:27.349489+00:00 0:00:00.466229 25208 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-05-06T20:11:24.792247+00:00 2 default_pool
success campaign-flow-job_v002 check_cluster_status 2021-05-06T19:00:00+00:00 EmrJobFlowSensor 2021-05-06T20:01:03.903347+00:00 2021-05-06T20:11:06.742154+00:00 0:10:02.838807 25204 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-05-06T20:01:01.802294+00:00 2 default_pool
success campaign-flow-job_v002 create_cluster_and_add_emr_steps 2021-05-06T19:00:00+00:00 EmrCreateJobFlowOperator 2021-05-06T20:00:42.020320+00:00 2021-05-06T20:00:43.827350+00:00 0:00:01.807030 25203 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 4 default 2021-05-06T20:00:39.792834+00:00 2 default_pool
success campaign-flow-job_v002 create_emr_steps 2021-05-06T19:00:00+00:00 PythonOperator 2021-05-06T20:00:22.029947+00:00 2021-05-06T20:00:25.272958+00:00 0:00:03.243011 25202 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 5 default 2021-05-06T20:00:19.686500+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_campaign-history-job_v002 2021-05-06T18:00:00+00:00 TriggerDagRunOperator 2021-05-06T19:10:12.151464+00:00 2021-05-06T19:10:12.741262+00:00 0:00:00.589798 25194 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-05-06T19:10:09.790198+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_booking-processing-job_v002 2021-05-06T18:00:00+00:00 TriggerDagRunOperator 2021-05-06T19:10:11.979684+00:00 2021-05-06T19:10:12.406034+00:00 0:00:00.426350 25193 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-05-06T19:10:09.790232+00:00 2 default_pool
success campaign-flow-job_v002 check_cluster_status 2021-05-06T18:00:00+00:00 EmrJobFlowSensor 2021-05-06T19:01:03.194832+00:00 2021-05-06T19:10:06.040755+00:00 0:09:02.845923 25189 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-05-06T19:01:00.908244+00:00 2 default_pool
success campaign-flow-job_v002 create_cluster_and_add_emr_steps 2021-05-06T18:00:00+00:00 EmrCreateJobFlowOperator 2021-05-06T19:00:40.998654+00:00 2021-05-06T19:00:42.737940+00:00 0:00:01.739286 25188 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 4 default 2021-05-06T19:00:38.890073+00:00 2 default_pool
success campaign-flow-job_v002 create_emr_steps 2021-05-06T18:00:00+00:00 PythonOperator 2021-05-06T19:00:19.856992+00:00 2021-05-06T19:00:22.960090+00:00 0:00:03.103098 25187 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 5 default 2021-05-06T19:00:16.859582+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_campaign-history-job_v002 2021-05-06T17:00:00+00:00 TriggerDagRunOperator 2021-05-06T18:10:31.000777+00:00 2021-05-06T18:10:31.554734+00:00 0:00:00.553957 25179 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-05-06T18:10:28.558675+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_booking-processing-job_v002 2021-05-06T17:00:00+00:00 TriggerDagRunOperator 2021-05-06T18:10:30.861128+00:00 2021-05-06T18:10:31.308978+00:00 0:00:00.447850 25178 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-05-06T18:10:28.558725+00:00 2 default_pool
success campaign-flow-job_v002 check_cluster_status 2021-05-06T17:00:00+00:00 EmrJobFlowSensor 2021-05-06T18:01:03.782285+00:00 2021-05-06T18:10:06.526139+00:00 0:09:02.743854 25174 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-05-06T18:01:01.684509+00:00 2 default_pool
success campaign-flow-job_v002 create_cluster_and_add_emr_steps 2021-05-06T17:00:00+00:00 EmrCreateJobFlowOperator 2021-05-06T18:00:41.794519+00:00 2021-05-06T18:00:43.471589+00:00 0:00:01.677070 25173 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 4 default 2021-05-06T18:00:39.644286+00:00 2 default_pool
success campaign-flow-job_v002 create_emr_steps 2021-05-06T17:00:00+00:00 PythonOperator 2021-05-06T18:00:19.969897+00:00 2021-05-06T18:00:23.130190+00:00 0:00:03.160293 25172 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 5 default 2021-05-06T18:00:17.596857+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_booking-processing-job_v002 2021-05-06T16:00:00+00:00 TriggerDagRunOperator 2021-05-06T17:10:06.364151+00:00 2021-05-06T17:10:06.872777+00:00 0:00:00.508626 25164 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-05-06T17:10:03.993611+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_campaign-history-job_v002 2021-05-06T16:00:00+00:00 TriggerDagRunOperator 2021-05-06T17:10:06.174611+00:00 2021-05-06T17:10:06.591734+00:00 0:00:00.417123 25163 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-05-06T17:10:03.993577+00:00 2 default_pool
success campaign-flow-job_v002 check_cluster_status 2021-05-06T16:00:00+00:00 EmrJobFlowSensor 2021-05-06T17:00:49.406597+00:00 2021-05-06T17:09:52.084166+00:00 0:09:02.677569 25159 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-05-06T17:00:47.152576+00:00 2 default_pool
success campaign-flow-job_v002 create_cluster_and_add_emr_steps 2021-05-06T16:00:00+00:00 EmrCreateJobFlowOperator 2021-05-06T17:00:27.421635+00:00 2021-05-06T17:00:29.247688+00:00 0:00:01.826053 25158 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 4 default 2021-05-06T17:00:25.076347+00:00 2 default_pool
success campaign-flow-job_v002 create_emr_steps 2021-05-06T16:00:00+00:00 PythonOperator 2021-05-06T17:00:07.204501+00:00 2021-05-06T17:00:10.347496+00:00 0:00:03.142995 25157 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 5 default 2021-05-06T17:00:05.024184+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_campaign-history-job_v002 2021-05-06T15:00:00+00:00 TriggerDagRunOperator 2021-05-06T16:13:22.953156+00:00 2021-05-06T16:13:23.474651+00:00 0:00:00.521495 25148 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-05-06T16:13:20.300307+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_booking-processing-job_v002 2021-05-06T15:00:00+00:00 TriggerDagRunOperator 2021-05-06T16:13:22.459353+00:00 2021-05-06T16:13:22.828008+00:00 0:00:00.368655 25147 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-05-06T16:13:20.300339+00:00 2 default_pool
success campaign-flow-job_v002 check_cluster_status 2021-05-06T15:00:00+00:00 EmrJobFlowSensor 2021-05-06T16:00:51.947618+00:00 2021-05-06T16:10:54.793059+00:00 0:10:02.845441 25144 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-05-06T16:00:49.598219+00:00 2 default_pool
success campaign-flow-job_v002 create_cluster_and_add_emr_steps 2021-05-06T15:00:00+00:00 EmrCreateJobFlowOperator 2021-05-06T16:00:32.044518+00:00 2021-05-06T16:00:33.748512+00:00 0:00:01.703994 25143 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 4 default 2021-05-06T16:00:29.747162+00:00 2 default_pool
success campaign-flow-job_v002 create_emr_steps 2021-05-06T15:00:00+00:00 PythonOperator 2021-05-06T16:00:09.925834+00:00 2021-05-06T16:00:12.977914+00:00 0:00:03.052080 25142 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 5 default 2021-05-06T16:00:07.529762+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_campaign-history-job_v002 2021-05-06T14:00:00+00:00 TriggerDagRunOperator 2021-05-06T15:14:16.738642+00:00 2021-05-06T15:14:17.265599+00:00 0:00:00.526957 25135 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-05-06T15:14:14.446721+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_booking-processing-job_v002 2021-05-06T14:00:00+00:00 TriggerDagRunOperator 2021-05-06T15:14:16.573365+00:00 2021-05-06T15:14:16.994531+00:00 0:00:00.421166 25134 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-05-06T15:14:14.446753+00:00 2 default_pool
success campaign-flow-job_v002 check_cluster_status 2021-05-06T14:00:00+00:00 EmrJobFlowSensor 2021-05-06T15:03:56.153774+00:00 2021-05-06T15:13:59.138336+00:00 0:10:02.984562 25130 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-05-06T15:03:53.574023+00:00 2 default_pool
success campaign-flow-job_v002 create_cluster_and_add_emr_steps 2021-05-06T14:00:00+00:00 EmrCreateJobFlowOperator 2021-05-06T15:03:17.634933+00:00 2021-05-06T15:03:19.374483+00:00 0:00:01.739550 25129 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 4 default 2021-05-06T15:03:15.480475+00:00 2 default_pool
success campaign-flow-job_v002 create_emr_steps 2021-05-06T14:00:00+00:00 PythonOperator 2021-05-06T15:02:56.010246+00:00 2021-05-06T15:02:59.284869+00:00 0:00:03.274623 25128 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 5 default 2021-05-06T15:02:53.461589+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_booking-processing-job_v002 2021-05-06T13:00:00+00:00 TriggerDagRunOperator 2021-05-06T14:10:36.238150+00:00 2021-05-06T14:10:36.773093+00:00 0:00:00.534943 25120 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-05-06T14:10:33.989128+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_campaign-history-job_v002 2021-05-06T13:00:00+00:00 TriggerDagRunOperator 2021-05-06T14:10:36.185647+00:00 2021-05-06T14:10:36.603288+00:00 0:00:00.417641 25119 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-05-06T14:10:33.989093+00:00 2 default_pool
success campaign-flow-job_v002 check_cluster_status 2021-05-06T13:00:00+00:00 EmrJobFlowSensor 2021-05-06T14:01:08.921094+00:00 2021-05-06T14:10:11.702768+00:00 0:09:02.781674 25115 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-05-06T14:01:06.788722+00:00 2 default_pool
success campaign-flow-job_v002 create_cluster_and_add_emr_steps 2021-05-06T13:00:00+00:00 EmrCreateJobFlowOperator 2021-05-06T14:00:46.836155+00:00 2021-05-06T14:00:48.531238+00:00 0:00:01.695083 25114 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 4 default 2021-05-06T14:00:44.748549+00:00 2 default_pool
success campaign-flow-job_v002 create_emr_steps 2021-05-06T13:00:00+00:00 PythonOperator 2021-05-06T14:00:25.186778+00:00 2021-05-06T14:00:28.268707+00:00 0:00:03.081929 25113 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 5 default 2021-05-06T14:00:22.757790+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_booking-processing-job_v002 2021-05-06T12:00:00+00:00 TriggerDagRunOperator 2021-05-06T13:11:09.182192+00:00 2021-05-06T13:11:09.611094+00:00 0:00:00.428902 25105 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-05-06T13:11:06.690982+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_campaign-history-job_v002 2021-05-06T12:00:00+00:00 TriggerDagRunOperator 2021-05-06T13:11:09.183219+00:00 2021-05-06T13:11:09.743766+00:00 0:00:00.560547 25104 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-05-06T13:11:06.690948+00:00 2 default_pool
success campaign-flow-job_v002 check_cluster_status 2021-05-06T12:00:00+00:00 EmrJobFlowSensor 2021-05-06T13:00:45.893347+00:00 2021-05-06T13:10:48.779346+00:00 0:10:02.885999 25100 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-05-06T13:00:43.725339+00:00 2 default_pool
success campaign-flow-job_v002 create_cluster_and_add_emr_steps 2021-05-06T12:00:00+00:00 EmrCreateJobFlowOperator 2021-05-06T13:00:25.893673+00:00 2021-05-06T13:00:27.628736+00:00 0:00:01.735063 25099 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 4 default 2021-05-06T13:00:23.706750+00:00 2 default_pool
success campaign-flow-job_v002 create_emr_steps 2021-05-06T12:00:00+00:00 PythonOperator 2021-05-06T13:00:03.976683+00:00 2021-05-06T13:00:07.185399+00:00 0:00:03.208716 25098 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 5 default 2021-05-06T13:00:01.697227+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_booking-processing-job_v002 2021-05-06T11:00:00+00:00 TriggerDagRunOperator 2021-05-06T12:26:36.916531+00:00 2021-05-06T12:26:37.505321+00:00 0:00:00.588790 25088 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-05-06T12:26:34.271721+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_campaign-history-job_v002 2021-05-06T11:00:00+00:00 TriggerDagRunOperator 2021-05-06T12:26:36.774119+00:00 2021-05-06T12:26:37.175620+00:00 0:00:00.401501 25087 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-05-06T12:26:34.271693+00:00 2 default_pool
success campaign-flow-job_v002 check_cluster_status 2021-05-06T11:00:00+00:00 EmrJobFlowSensor 2021-05-06T12:00:56.104985+00:00 2021-05-06T12:10:59.011858+00:00 0:10:02.906873 25085 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-05-06T12:00:53.781083+00:00 2 default_pool
success campaign-flow-job_v002 create_cluster_and_add_emr_steps 2021-05-06T11:00:00+00:00 EmrCreateJobFlowOperator 2021-05-06T12:00:34.059749+00:00 2021-05-06T12:00:35.993604+00:00 0:00:01.933855 25084 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 4 default 2021-05-06T12:00:31.696695+00:00 2 default_pool
success campaign-flow-job_v002 create_emr_steps 2021-05-06T11:00:00+00:00 PythonOperator 2021-05-06T12:00:11.682856+00:00 2021-05-06T12:00:14.755247+00:00 0:00:03.072391 25083 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 5 default 2021-05-06T12:00:09.571320+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_campaign-history-job_v002 2021-05-06T10:00:00+00:00 TriggerDagRunOperator 2021-05-06T11:12:51.036345+00:00 2021-05-06T11:12:51.564295+00:00 0:00:00.527950 25076 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-05-06T11:12:48.556352+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_booking-processing-job_v002 2021-05-06T10:00:00+00:00 TriggerDagRunOperator 2021-05-06T11:12:50.874038+00:00 2021-05-06T11:12:51.296089+00:00 0:00:00.422051 25075 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-05-06T11:12:48.556400+00:00 2 default_pool
success campaign-flow-job_v002 check_cluster_status 2021-05-06T10:00:00+00:00 EmrJobFlowSensor 2021-05-06T11:03:25.923521+00:00 2021-05-06T11:12:28.886662+00:00 0:09:02.963141 25071 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-05-06T11:03:23.586672+00:00 2 default_pool
success campaign-flow-job_v002 create_cluster_and_add_emr_steps 2021-05-06T10:00:00+00:00 EmrCreateJobFlowOperator 2021-05-06T11:03:05.732142+00:00 2021-05-06T11:03:07.426461+00:00 0:00:01.694319 25070 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 4 default 2021-05-06T11:03:03.549580+00:00 2 default_pool
success campaign-flow-job_v002 create_emr_steps 2021-05-06T10:00:00+00:00 PythonOperator 2021-05-06T11:02:44.200570+00:00 2021-05-06T11:02:47.285550+00:00 0:00:03.084980 25069 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 5 default 2021-05-06T11:02:41.531367+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_booking-processing-job_v002 2021-05-06T09:00:00+00:00 TriggerDagRunOperator 2021-05-06T10:09:09.383916+00:00 2021-05-06T10:09:09.921034+00:00 0:00:00.537118 25061 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-05-06T10:09:07.029526+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_campaign-history-job_v002 2021-05-06T09:00:00+00:00 TriggerDagRunOperator 2021-05-06T10:09:09.315816+00:00 2021-05-06T10:09:09.752782+00:00 0:00:00.436966 25060 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-05-06T10:09:07.029493+00:00 2 default_pool
success campaign-flow-job_v002 check_cluster_status 2021-05-06T09:00:00+00:00 EmrJobFlowSensor 2021-05-06T10:00:50.686465+00:00 2021-05-06T10:08:53.351207+00:00 0:08:02.664742 25056 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-05-06T10:00:48.173271+00:00 2 default_pool
success campaign-flow-job_v002 create_cluster_and_add_emr_steps 2021-05-06T09:00:00+00:00 EmrCreateJobFlowOperator 2021-05-06T10:00:28.525909+00:00 2021-05-06T10:00:30.348978+00:00 0:00:01.823069 25055 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 4 default 2021-05-06T10:00:26.168076+00:00 2 default_pool