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-03-21T18:00:00+00:00 PythonOperator 2021-03-21T19:00:19.594289+00:00 2021-03-21T19:00:22.447039+00:00 0:00:02.852750 10350 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 5 default 2021-03-21T19:00:16.964395+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_campaign-history-job_v002 2021-03-21T17:00:00+00:00 TriggerDagRunOperator 2021-03-21T18:10:20.863618+00:00 2021-03-21T18:10:21.384354+00:00 0:00:00.520736 10345 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-03-21T18:10:18.115421+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_booking-processing-job_v002 2021-03-21T17:00:00+00:00 TriggerDagRunOperator 2021-03-21T18:10:20.677651+00:00 2021-03-21T18:10:21.069222+00:00 0:00:00.391571 10344 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-03-21T18:10:18.115473+00:00 2 default_pool
success campaign-flow-job_v002 check_cluster_status 2021-03-21T17:00:00+00:00 EmrJobFlowSensor 2021-03-21T18:01:01.304005+00:00 2021-03-21T18:10:04.082510+00:00 0:09:02.778505 10343 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-03-21T18:00:58.960826+00:00 2 default_pool
success campaign-flow-job_v002 create_cluster_and_add_emr_steps 2021-03-21T17:00:00+00:00 EmrCreateJobFlowOperator 2021-03-21T18:00:45.488247+00:00 2021-03-21T18:00:47.368143+00:00 0:00:01.879896 10342 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 4 default 2021-03-21T18:00:43.018156+00:00 2 default_pool
success campaign-flow-job_v002 create_emr_steps 2021-03-21T17:00:00+00:00 PythonOperator 2021-03-21T18:00:11.119895+00:00 2021-03-21T18:00:13.840051+00:00 0:00:02.720156 10341 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 5 default 2021-03-21T18:00:08.873077+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_booking-processing-job_v002 2021-03-21T16:00:00+00:00 TriggerDagRunOperator 2021-03-21T17:10:55.966467+00:00 2021-03-21T17:10:56.502286+00:00 0:00:00.535819 10336 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-03-21T17:10:53.664628+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_campaign-history-job_v002 2021-03-21T16:00:00+00:00 TriggerDagRunOperator 2021-03-21T17:10:55.916543+00:00 2021-03-21T17:10:56.304927+00:00 0:00:00.388384 10335 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-03-21T17:10:53.664590+00:00 2 default_pool
success campaign-flow-job_v002 check_cluster_status 2021-03-21T16:00:00+00:00 EmrJobFlowSensor 2021-03-21T17:00:38.511955+00:00 2021-03-21T17:10:41.336074+00:00 0:10:02.824119 10334 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-03-21T17:00:36.286574+00:00 2 default_pool
success campaign-flow-job_v002 create_cluster_and_add_emr_steps 2021-03-21T16:00:00+00:00 EmrCreateJobFlowOperator 2021-03-21T17:00:22.551766+00:00 2021-03-21T17:00:24.410174+00:00 0:00:01.858408 10333 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 4 default 2021-03-21T17:00:20.255256+00:00 2 default_pool
success campaign-flow-job_v002 create_emr_steps 2021-03-21T16:00:00+00:00 PythonOperator 2021-03-21T17:00:06.603333+00:00 2021-03-21T17:00:09.487092+00:00 0:00:02.883759 10332 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 5 default 2021-03-21T17:00:04.185606+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_booking-processing-job_v002 2021-03-21T15:00:00+00:00 TriggerDagRunOperator 2021-03-21T16:09:56.872104+00:00 2021-03-21T16:09:57.262436+00:00 0:00:00.390332 10327 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-03-21T16:09:54.189628+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_campaign-history-job_v002 2021-03-21T15:00:00+00:00 TriggerDagRunOperator 2021-03-21T16:09:56.605921+00:00 2021-03-21T16:09:57.157489+00:00 0:00:00.551568 10326 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-03-21T16:09:54.189587+00:00 2 default_pool
success campaign-flow-job_v002 check_cluster_status 2021-03-21T15:00:00+00:00 EmrJobFlowSensor 2021-03-21T16:00:41.711728+00:00 2021-03-21T16:09:44.250223+00:00 0:09:02.538495 10325 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-03-21T16:00:39.520868+00:00 2 default_pool
success campaign-flow-job_v002 create_cluster_and_add_emr_steps 2021-03-21T15:00:00+00:00 EmrCreateJobFlowOperator 2021-03-21T16:00:25.606583+00:00 2021-03-21T16:00:27.308846+00:00 0:00:01.702263 10324 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 4 default 2021-03-21T16:00:23.257518+00:00 2 default_pool
success campaign-flow-job_v002 create_emr_steps 2021-03-21T15:00:00+00:00 PythonOperator 2021-03-21T16:00:07.626029+00:00 2021-03-21T16:00:10.319609+00:00 0:00:02.693580 10323 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 5 default 2021-03-21T16:00:05.167080+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_booking-processing-job_v002 2021-03-21T14:00:00+00:00 TriggerDagRunOperator 2021-03-21T15:10:54.614595+00:00 2021-03-21T15:10:55.145649+00:00 0:00:00.531054 10318 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-03-21T15:10:52.108727+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_campaign-history-job_v002 2021-03-21T14:00:00+00:00 TriggerDagRunOperator 2021-03-21T15:10:54.339691+00:00 2021-03-21T15:10:54.745245+00:00 0:00:00.405554 10317 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-03-21T15:10:52.108699+00:00 2 default_pool
success campaign-flow-job_v002 check_cluster_status 2021-03-21T14:00:00+00:00 EmrJobFlowSensor 2021-03-21T15:00:39.251478+00:00 2021-03-21T15:10:41.913987+00:00 0:10:02.662509 10316 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-03-21T15:00:37.080744+00:00 2 default_pool
success campaign-flow-job_v002 create_cluster_and_add_emr_steps 2021-03-21T14:00:00+00:00 EmrCreateJobFlowOperator 2021-03-21T15:00:23.765167+00:00 2021-03-21T15:00:25.731280+00:00 0:00:01.966113 10315 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 4 default 2021-03-21T15:00:21.135759+00:00 2 default_pool
success campaign-flow-job_v002 create_emr_steps 2021-03-21T14:00:00+00:00 PythonOperator 2021-03-21T15:00:05.555149+00:00 2021-03-21T15:00:08.440558+00:00 0:00:02.885409 10314 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 5 default 2021-03-21T15:00:03.058540+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_booking-processing-job_v002 2021-03-21T13:00:00+00:00 TriggerDagRunOperator 2021-03-21T14:10:36.173679+00:00 2021-03-21T14:10:36.722503+00:00 0:00:00.548824 10309 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-03-21T14:10:33.700324+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_campaign-history-job_v002 2021-03-21T13:00:00+00:00 TriggerDagRunOperator 2021-03-21T14:10:36.035741+00:00 2021-03-21T14:10:36.423394+00:00 0:00:00.387653 10308 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-03-21T14:10:33.700288+00:00 2 default_pool
success campaign-flow-job_v002 check_cluster_status 2021-03-21T13:00:00+00:00 EmrJobFlowSensor 2021-03-21T14:01:21.310056+00:00 2021-03-21T14:10:24.065067+00:00 0:09:02.755011 10307 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-03-21T14:01:18.835326+00:00 2 default_pool
success campaign-flow-job_v002 create_cluster_and_add_emr_steps 2021-03-21T13:00:00+00:00 EmrCreateJobFlowOperator 2021-03-21T14:01:05.012171+00:00 2021-03-21T14:01:06.694109+00:00 0:00:01.681938 10306 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 4 default 2021-03-21T14:01:02.720963+00:00 2 default_pool
success campaign-flow-job_v002 create_emr_steps 2021-03-21T13:00:00+00:00 PythonOperator 2021-03-21T14:00:43.065181+00:00 2021-03-21T14:00:45.767974+00:00 0:00:02.702793 10305 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 5 default 2021-03-21T14:00:40.673102+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_booking-processing-job_v002 2021-03-21T12:00:00+00:00 TriggerDagRunOperator 2021-03-21T13:15:14.915063+00:00 2021-03-21T13:15:15.478336+00:00 0:00:00.563273 10301 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-03-21T13:15:11.932216+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_campaign-history-job_v002 2021-03-21T12:00:00+00:00 TriggerDagRunOperator 2021-03-21T13:15:14.824467+00:00 2021-03-21T13:15:15.233899+00:00 0:00:00.409432 10300 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-03-21T13:15:11.932164+00:00 2 default_pool
success campaign-flow-job_v002 check_cluster_status 2021-03-21T12:00:00+00:00 EmrJobFlowSensor 2021-03-21T13:00:52.939264+00:00 2021-03-21T13:09:55.696579+00:00 0:09:02.757315 10298 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-03-21T13:00:50.535613+00:00 2 default_pool
success campaign-flow-job_v002 create_cluster_and_add_emr_steps 2021-03-21T12:00:00+00:00 EmrCreateJobFlowOperator 2021-03-21T13:00:36.746203+00:00 2021-03-21T13:00:38.474956+00:00 0:00:01.728753 10297 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 4 default 2021-03-21T13:00:34.469811+00:00 2 default_pool
success campaign-flow-job_v002 create_emr_steps 2021-03-21T12:00:00+00:00 PythonOperator 2021-03-21T13:00:21.073332+00:00 2021-03-21T13:00:23.999105+00:00 0:00:02.925773 10296 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 5 default 2021-03-21T13:00:18.538488+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_campaign-history-job_v002 2021-03-21T11:00:00+00:00 TriggerDagRunOperator 2021-03-21T12:10:59.712027+00:00 2021-03-21T12:11:00.263401+00:00 0:00:00.551374 10292 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-03-21T12:10:57.102344+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_booking-processing-job_v002 2021-03-21T11:00:00+00:00 TriggerDagRunOperator 2021-03-21T12:10:59.552299+00:00 2021-03-21T12:10:59.974339+00:00 0:00:00.422040 10291 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-03-21T12:10:57.102372+00:00 2 default_pool
success campaign-flow-job_v002 check_cluster_status 2021-03-21T11:00:00+00:00 EmrJobFlowSensor 2021-03-21T12:00:42.621409+00:00 2021-03-21T12:10:45.610804+00:00 0:10:02.989395 10289 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-03-21T12:00:40.047360+00:00 2 default_pool
success campaign-flow-job_v002 create_cluster_and_add_emr_steps 2021-03-21T11:00:00+00:00 EmrCreateJobFlowOperator 2021-03-21T12:00:26.446066+00:00 2021-03-21T12:00:28.134636+00:00 0:00:01.688570 10288 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 4 default 2021-03-21T12:00:24.043944+00:00 2 default_pool
success campaign-flow-job_v002 create_emr_steps 2021-03-21T11:00:00+00:00 PythonOperator 2021-03-21T12:00:08.125997+00:00 2021-03-21T12:00:10.849703+00:00 0:00:02.723706 10287 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 5 default 2021-03-21T12:00:05.890245+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_booking-processing-job_v002 2021-03-21T10:00:00+00:00 TriggerDagRunOperator 2021-03-21T11:11:05.392145+00:00 2021-03-21T11:11:05.955621+00:00 0:00:00.563476 10283 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-03-21T11:11:02.119111+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_campaign-history-job_v002 2021-03-21T10:00:00+00:00 TriggerDagRunOperator 2021-03-21T11:11:04.945916+00:00 2021-03-21T11:11:05.342525+00:00 0:00:00.396609 10282 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-03-21T11:11:02.119063+00:00 2 default_pool
success campaign-flow-job_v002 check_cluster_status 2021-03-21T10:00:00+00:00 EmrJobFlowSensor 2021-03-21T11:00:41.461619+00:00 2021-03-21T11:10:44.341663+00:00 0:10:02.880044 10280 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-03-21T11:00:39.176980+00:00 2 default_pool
success campaign-flow-job_v002 create_cluster_and_add_emr_steps 2021-03-21T10:00:00+00:00 EmrCreateJobFlowOperator 2021-03-21T11:00:25.372029+00:00 2021-03-21T11:00:27.036824+00:00 0:00:01.664795 10279 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 4 default 2021-03-21T11:00:23.155488+00:00 2 default_pool
success campaign-flow-job_v002 create_emr_steps 2021-03-21T10:00:00+00:00 PythonOperator 2021-03-21T11:00:07.585845+00:00 2021-03-21T11:00:10.488353+00:00 0:00:02.902508 10278 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 5 default 2021-03-21T11:00:05.077486+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_booking-processing-job_v002 2021-03-21T09:00:00+00:00 TriggerDagRunOperator 2021-03-21T10:10:21.840474+00:00 2021-03-21T10:10:22.367007+00:00 0:00:00.526533 10274 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-03-21T10:10:19.383916+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_campaign-history-job_v002 2021-03-21T09:00:00+00:00 TriggerDagRunOperator 2021-03-21T10:10:21.685658+00:00 2021-03-21T10:10:22.106869+00:00 0:00:00.421211 10273 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-03-21T10:10:19.383888+00:00 2 default_pool
success campaign-flow-job_v002 check_cluster_status 2021-03-21T09:00:00+00:00 EmrJobFlowSensor 2021-03-21T10:00:56.236861+00:00 2021-03-21T10:09:58.984524+00:00 0:09:02.747663 10271 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-03-21T10:00:54.025741+00:00 2 default_pool
success campaign-flow-job_v002 create_cluster_and_add_emr_steps 2021-03-21T09:00:00+00:00 EmrCreateJobFlowOperator 2021-03-21T10:00:28.117636+00:00 2021-03-21T10:00:29.810376+00:00 0:00:01.692740 10270 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 4 default 2021-03-21T10:00:25.914893+00:00 2 default_pool
success campaign-flow-job_v002 create_emr_steps 2021-03-21T09:00:00+00:00 PythonOperator 2021-03-21T10:00:06.195417+00:00 2021-03-21T10:00:09.077299+00:00 0:00:02.881882 10269 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 5 default 2021-03-21T10:00:03.871304+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_campaign-history-job_v002 2021-03-21T08:00:00+00:00 TriggerDagRunOperator 2021-03-21T09:15:29.636095+00:00 2021-03-21T09:15:30.171232+00:00 0:00:00.535137 10265 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-03-21T09:15:26.852016+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_booking-processing-job_v002 2021-03-21T08:00:00+00:00 TriggerDagRunOperator 2021-03-21T09:15:29.430420+00:00 2021-03-21T09:15:29.885591+00:00 0:00:00.455171 10264 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-03-21T09:15:26.852070+00:00 2 default_pool
success campaign-flow-job_v002 check_cluster_status 2021-03-21T08:00:00+00:00 EmrJobFlowSensor 2021-03-21T09:05:14.479759+00:00 2021-03-21T09:15:17.247790+00:00 0:10:02.768031 10263 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-03-21T09:05:11.922941+00:00 2 default_pool
success campaign-flow-job_v002 create_cluster_and_add_emr_steps 2021-03-21T08:00:00+00:00 EmrCreateJobFlowOperator 2021-03-21T09:04:58.137031+00:00 2021-03-21T09:05:00.043190+00:00 0:00:01.906159 10262 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 4 default 2021-03-21T09:04:55.839475+00:00 2 default_pool
success campaign-flow-job_v002 create_emr_steps 2021-03-21T08:00:00+00:00 PythonOperator 2021-03-21T09:04:42.697643+00:00 2021-03-21T09:04:45.563334+00:00 0:00:02.865691 10261 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 5 default 2021-03-21T09:04:39.829244+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_booking-processing-job_v002 2021-03-21T07:00:00+00:00 TriggerDagRunOperator 2021-03-21T08:11:00.564739+00:00 2021-03-21T08:11:01.100697+00:00 0:00:00.535958 10256 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-03-21T08:10:58.115991+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_campaign-history-job_v002 2021-03-21T07:00:00+00:00 TriggerDagRunOperator 2021-03-21T08:11:00.426340+00:00 2021-03-21T08:11:00.934760+00:00 0:00:00.508420 10255 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-03-21T08:10:58.115962+00:00 2 default_pool
success campaign-flow-job_v002 check_cluster_status 2021-03-21T07:00:00+00:00 EmrJobFlowSensor 2021-03-21T08:00:41.280833+00:00 2021-03-21T08:10:44.124063+00:00 0:10:02.843230 10254 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-03-21T08:00:38.945546+00:00 2 default_pool
success campaign-flow-job_v002 create_cluster_and_add_emr_steps 2021-03-21T07:00:00+00:00 EmrCreateJobFlowOperator 2021-03-21T08:00:25.126113+00:00 2021-03-21T08:00:26.837898+00:00 0:00:01.711785 10253 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 4 default 2021-03-21T08:00:22.871868+00:00 2 default_pool
success campaign-flow-job_v002 create_emr_steps 2021-03-21T07:00:00+00:00 PythonOperator 2021-03-21T08:00:07.640261+00:00 2021-03-21T08:00:10.327941+00:00 0:00:02.687680 10252 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 5 default 2021-03-21T08:00:04.926237+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_campaign-history-job_v002 2021-03-21T06:00:00+00:00 TriggerDagRunOperator 2021-03-21T07:10:55.001160+00:00 2021-03-21T07:10:55.456747+00:00 0:00:00.455587 10244 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-03-21T07:10:52.576239+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_booking-processing-job_v002 2021-03-21T06:00:00+00:00 TriggerDagRunOperator 2021-03-21T07:10:54.927294+00:00 2021-03-21T07:10:55.550429+00:00 0:00:00.623135 10243 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-03-21T07:10:52.576267+00:00 2 default_pool
success campaign-flow-job_v002 check_cluster_status 2021-03-21T06:00:00+00:00 EmrJobFlowSensor 2021-03-21T07:00:41.778465+00:00 2021-03-21T07:10:44.754013+00:00 0:10:02.975548 10242 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-03-21T07:00:39.474277+00:00 2 default_pool
success campaign-flow-job_v002 create_cluster_and_add_emr_steps 2021-03-21T06:00:00+00:00 EmrCreateJobFlowOperator 2021-03-21T07:00:25.777635+00:00 2021-03-21T07:00:27.466683+00:00 0:00:01.689048 10241 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 4 default 2021-03-21T07:00:23.486975+00:00 2 default_pool
success campaign-flow-job_v002 create_emr_steps 2021-03-21T06:00:00+00:00 PythonOperator 2021-03-21T07:00:10.054749+00:00 2021-03-21T07:00:12.925388+00:00 0:00:02.870639 10240 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 5 default 2021-03-21T07:00:07.394065+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_campaign-history-job_v002 2021-03-21T05:00:00+00:00 TriggerDagRunOperator 2021-03-21T06:10:02.019554+00:00 2021-03-21T06:10:02.576775+00:00 0:00:00.557221 10235 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-03-21T06:09:59.194194+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_booking-processing-job_v002 2021-03-21T05:00:00+00:00 TriggerDagRunOperator 2021-03-21T06:10:01.904409+00:00 2021-03-21T06:10:02.375347+00:00 0:00:00.470938 10234 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-03-21T06:09:59.194231+00:00 2 default_pool
success campaign-flow-job_v002 check_cluster_status 2021-03-21T05:00:00+00:00 EmrJobFlowSensor 2021-03-21T06:00:44.321013+00:00 2021-03-21T06:09:46.915346+00:00 0:09:02.594333 10233 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-03-21T06:00:41.945946+00:00 2 default_pool
success campaign-flow-job_v002 create_cluster_and_add_emr_steps 2021-03-21T05:00:00+00:00 EmrCreateJobFlowOperator 2021-03-21T06:00:28.222220+00:00 2021-03-21T06:00:30.155734+00:00 0:00:01.933514 10232 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 4 default 2021-03-21T06:00:25.879087+00:00 2 default_pool
success campaign-flow-job_v002 create_emr_steps 2021-03-21T05:00:00+00:00 PythonOperator 2021-03-21T06:00:12.336074+00:00 2021-03-21T06:00:15.232575+00:00 0:00:02.896501 10231 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 5 default 2021-03-21T06:00:09.868396+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_booking-processing-job_v002 2021-03-21T04:00:00+00:00 TriggerDagRunOperator 2021-03-21T05:10:51.314516+00:00 2021-03-21T05:10:51.725257+00:00 0:00:00.410741 10226 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-03-21T05:10:49.022796+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_campaign-history-job_v002 2021-03-21T04:00:00+00:00 TriggerDagRunOperator 2021-03-21T05:10:51.349659+00:00 2021-03-21T05:10:51.886955+00:00 0:00:00.537296 10225 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-03-21T05:10:49.022757+00:00 2 default_pool
success campaign-flow-job_v002 check_cluster_status 2021-03-21T04:00:00+00:00 EmrJobFlowSensor 2021-03-21T05:00:44.456028+00:00 2021-03-21T05:10:47.167199+00:00 0:10:02.711171 10224 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-03-21T05:00:42.032286+00:00 2 default_pool
success campaign-flow-job_v002 create_cluster_and_add_emr_steps 2021-03-21T04:00:00+00:00 EmrCreateJobFlowOperator 2021-03-21T05:00:28.351301+00:00 2021-03-21T05:00:30.082230+00:00 0:00:01.730929 10223 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 4 default 2021-03-21T05:00:25.961374+00:00 2 default_pool
success campaign-flow-job_v002 create_emr_steps 2021-03-21T04:00:00+00:00 PythonOperator 2021-03-21T05:00:12.214838+00:00 2021-03-21T05:00:14.920214+00:00 0:00:02.705376 10222 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 5 default 2021-03-21T05:00:09.902335+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_booking-processing-job_v002 2021-03-21T03:00:00+00:00 TriggerDagRunOperator 2021-03-21T04:10:25.704761+00:00 2021-03-21T04:10:26.239732+00:00 0:00:00.534971 10217 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-03-21T04:10:23.384100+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_campaign-history-job_v002 2021-03-21T03:00:00+00:00 TriggerDagRunOperator 2021-03-21T04:10:25.613288+00:00 2021-03-21T04:10:25.999910+00:00 0:00:00.386622 10216 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-03-21T04:10:23.384074+00:00 2 default_pool
success campaign-flow-job_v002 check_cluster_status 2021-03-21T03:00:00+00:00 EmrJobFlowSensor 2021-03-21T04:01:06.303930+00:00 2021-03-21T04:10:08.946042+00:00 0:09:02.642112 10215 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-03-21T04:01:04.166705+00:00 2 default_pool
success campaign-flow-job_v002 create_cluster_and_add_emr_steps 2021-03-21T03:00:00+00:00 EmrCreateJobFlowOperator 2021-03-21T04:00:50.880137+00:00 2021-03-21T04:00:52.753357+00:00 0:00:01.873220 10214 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 4 default 2021-03-21T04:00:48.320942+00:00 2 default_pool
success campaign-flow-job_v002 create_emr_steps 2021-03-21T03:00:00+00:00 PythonOperator 2021-03-21T04:00:34.548937+00:00 2021-03-21T04:00:37.286452+00:00 0:00:02.737515 10213 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 5 default 2021-03-21T04:00:32.088727+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_campaign-history-job_v002 2021-03-21T02:00:00+00:00 TriggerDagRunOperator 2021-03-21T03:09:11.663469+00:00 2021-03-21T03:09:12.166354+00:00 0:00:00.502885 10208 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-03-21T03:09:09.234231+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_booking-processing-job_v002 2021-03-21T02:00:00+00:00 TriggerDagRunOperator 2021-03-21T03:09:11.523419+00:00 2021-03-21T03:09:11.906264+00:00 0:00:00.382845 10207 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-03-21T03:09:09.234280+00:00 2 default_pool
success campaign-flow-job_v002 check_cluster_status 2021-03-21T02:00:00+00:00 EmrJobFlowSensor 2021-03-21T03:01:04.764729+00:00 2021-03-21T03:09:07.507404+00:00 0:08:02.742675 10206 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-03-21T03:01:02.346121+00:00 2 default_pool
success campaign-flow-job_v002 create_cluster_and_add_emr_steps 2021-03-21T02:00:00+00:00 EmrCreateJobFlowOperator 2021-03-21T03:00:30.606582+00:00 2021-03-21T03:00:32.470381+00:00 0:00:01.863799 10205 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 4 default 2021-03-21T03:00:28.265479+00:00 2 default_pool
success campaign-flow-job_v002 create_emr_steps 2021-03-21T02:00:00+00:00 PythonOperator 2021-03-21T03:00:12.484573+00:00 2021-03-21T03:00:15.199442+00:00 0:00:02.714869 10204 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 5 default 2021-03-21T03:00:10.203155+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_booking-processing-job_v002 2021-03-21T01:00:00+00:00 TriggerDagRunOperator 2021-03-21T02:09:22.550150+00:00 2021-03-21T02:09:23.080593+00:00 0:00:00.530443 10199 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-03-21T02:09:20.075218+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_campaign-history-job_v002 2021-03-21T01:00:00+00:00 TriggerDagRunOperator 2021-03-21T02:09:22.391005+00:00 2021-03-21T02:09:22.793577+00:00 0:00:00.402572 10198 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-03-21T02:09:20.075184+00:00 2 default_pool
success campaign-flow-job_v002 check_cluster_status 2021-03-21T01:00:00+00:00 EmrJobFlowSensor 2021-03-21T02:01:03.272595+00:00 2021-03-21T02:09:05.965912+00:00 0:08:02.693317 10197 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-03-21T02:01:00.831994+00:00 2 default_pool
success campaign-flow-job_v002 create_cluster_and_add_emr_steps 2021-03-21T01:00:00+00:00 EmrCreateJobFlowOperator 2021-03-21T02:00:37.109405+00:00 2021-03-21T02:00:38.955173+00:00 0:00:01.845768 10196 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 4 default 2021-03-21T02:00:34.808293+00:00 2 default_pool
success campaign-flow-job_v002 create_emr_steps 2021-03-21T01:00:00+00:00 PythonOperator 2021-03-21T02:00:19.254639+00:00 2021-03-21T02:00:21.968782+00:00 0:00:02.714143 10195 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 5 default 2021-03-21T02:00:16.828271+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_booking-processing-job_v002 2021-03-21T00:00:00+00:00 TriggerDagRunOperator 2021-03-21T01:09:58.697436+00:00 2021-03-21T01:09:59.234850+00:00 0:00:00.537414 10190 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-03-21T01:09:56.295870+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_campaign-history-job_v002 2021-03-21T00:00:00+00:00 TriggerDagRunOperator 2021-03-21T01:09:58.631153+00:00 2021-03-21T01:09:59.055856+00:00 0:00:00.424703 10189 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-03-21T01:09:56.295842+00:00 2 default_pool
success campaign-flow-job_v002 check_cluster_status 2021-03-21T00:00:00+00:00 EmrJobFlowSensor 2021-03-21T01:00:39.685869+00:00 2021-03-21T01:09:42.314482+00:00 0:09:02.628613 10188 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-03-21T01:00:37.391482+00:00 2 default_pool
success campaign-flow-job_v002 create_cluster_and_add_emr_steps 2021-03-21T00:00:00+00:00 EmrCreateJobFlowOperator 2021-03-21T01:00:23.772570+00:00 2021-03-21T01:00:25.601385+00:00 0:00:01.828815 10187 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 4 default 2021-03-21T01:00:21.377354+00:00 2 default_pool
success campaign-flow-job_v002 create_emr_steps 2021-03-21T00:00:00+00:00 PythonOperator 2021-03-21T01:00:06.144403+00:00 2021-03-21T01:00:09.111738+00:00 0:00:02.967335 10186 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 5 default 2021-03-21T01:00:03.428781+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_campaign-history-job_v002 2021-03-20T23:00:00+00:00 TriggerDagRunOperator 2021-03-21T00:10:56.079950+00:00 2021-03-21T00:10:56.454426+00:00 0:00:00.374476 10181 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-03-21T00:10:53.167023+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_booking-processing-job_v002 2021-03-20T23:00:00+00:00 TriggerDagRunOperator 2021-03-21T00:10:55.738464+00:00 2021-03-21T00:10:56.266660+00:00 0:00:00.528196 10180 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-03-21T00:10:53.167052+00:00 2 default_pool
success campaign-flow-job_v002 check_cluster_status 2021-03-20T23:00:00+00:00 EmrJobFlowSensor 2021-03-21T00:00:46.279969+00:00 2021-03-21T00:10:49.035013+00:00 0:10:02.755044 10179 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-03-21T00:00:44.038805+00:00 2 default_pool
success campaign-flow-job_v002 create_cluster_and_add_emr_steps 2021-03-20T23:00:00+00:00 EmrCreateJobFlowOperator 2021-03-21T00:00:28.669119+00:00 2021-03-21T00:00:30.372871+00:00 0:00:01.703752 10178 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 4 default 2021-03-21T00:00:26.034722+00:00 2 default_pool
success campaign-flow-job_v002 create_emr_steps 2021-03-20T23:00:00+00:00 PythonOperator 2021-03-21T00:00:12.303290+00:00 2021-03-21T00:00:15.066379+00:00 0:00:02.763089 10177 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 5 default 2021-03-21T00:00:10.025113+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_booking-processing-job_v002 2021-03-20T22:00:00+00:00 TriggerDagRunOperator 2021-03-20T23:10:59.736310+00:00 2021-03-20T23:11:00.262995+00:00 0:00:00.526685 10172 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-03-20T23:10:57.020095+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_campaign-history-job_v002 2021-03-20T22:00:00+00:00 TriggerDagRunOperator 2021-03-20T23:10:59.369861+00:00 2021-03-20T23:10:59.775785+00:00 0:00:00.405924 10171 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-03-20T23:10:57.020054+00:00 2 default_pool
success campaign-flow-job_v002 check_cluster_status 2021-03-20T22:00:00+00:00 EmrJobFlowSensor 2021-03-20T23:00:48.101934+00:00 2021-03-20T23:10:50.830284+00:00 0:10:02.728350 10170 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-03-20T23:00:45.882868+00:00 2 default_pool
success campaign-flow-job_v002 create_cluster_and_add_emr_steps 2021-03-20T22:00:00+00:00 EmrCreateJobFlowOperator 2021-03-20T23:00:30.364949+00:00 2021-03-20T23:00:32.261643+00:00 0:00:01.896694 10169 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 4 default 2021-03-20T23:00:27.918222+00:00 2 default_pool