Task Instances

  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 livepop-shuffle-job_v002 create_emr_steps 2021-07-05T22:00:00+00:00 PythonOperator 2021-07-05T23:00:14.473585+00:00 2021-07-05T23:00:18.180940+00:00 0:00:03.707355 50322 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-07-05T23:00:12.196555+00:00 2 default_pool
success campaign-delta-past-delete-job_v002 create_emr_steps 2021-07-04T23:00:00+00:00 PythonOperator 2021-07-05T23:00:12.666889+00:00 2021-07-05T23:00:16.200712+00:00 0:00:03.533823 50321 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-07-05T23:00:10.185900+00:00 2 default_pool
success campaign-history-job_v002 check_cluster_status 2021-07-05T21:00:00+00:00 EmrJobFlowSensor 2021-07-05T22:12:21.614828+00:00 2021-07-05T22:21:24.321123+00:00 0:09:02.706295 50319 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-07-05T22:12:19.494711+00:00 2 default_pool
success booking-processing-job_v002 check_cluster_status 2021-07-05T21:00:00+00:00 EmrJobFlowSensor 2021-07-05T22:12:05.722158+00:00 2021-07-05T22:22:08.813145+00:00 0:10:03.090987 50318 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-07-05T22:12:03.439852+00:00 2 default_pool
success campaign-history-job_v002 create_cluster_and_add_emr_steps 2021-07-05T21:00:00+00:00 EmrCreateJobFlowOperator 2021-07-05T22:11:59.731962+00:00 2021-07-05T22:12:01.468102+00:00 0:00:01.736140 50317 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 2 default 2021-07-05T22:11:57.449579+00:00 2 default_pool
success booking-processing-job_v002 create_cluster_and_add_emr_steps 2021-07-05T21:00:00+00:00 EmrCreateJobFlowOperator 2021-07-05T22:11:43.985395+00:00 2021-07-05T22:11:45.656065+00:00 0:00:01.670670 50316 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 2 default 2021-07-05T22:11:41.477761+00:00 2 default_pool
success campaign-history-job_v002 create_emr_steps 2021-07-05T21:00:00+00:00 PythonOperator 2021-07-05T22:11:37.682764+00:00 2021-07-05T22:11:41.410342+00:00 0:00:03.727578 50315 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-07-05T22:11:35.396232+00:00 2 default_pool
success booking-processing-job_v002 create_emr_steps 2021-07-05T21:00:00+00:00 PythonOperator 2021-07-05T22:11:21.834144+00:00 2021-07-05T22:11:25.519943+00:00 0:00:03.685799 50314 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-07-05T22:11:19.346079+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_campaign-history-job_v002 2021-07-05T21:00:00+00:00 TriggerDagRunOperator 2021-07-05T22:11:14.177752+00:00 2021-07-05T22:11:14.665675+00:00 0:00:00.487923 50313 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-07-05T22:11:11.357912+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_booking-processing-job_v002 2021-07-05T21:00:00+00:00 TriggerDagRunOperator 2021-07-05T22:11:13.613080+00:00 2021-07-05T22:11:14.133460+00:00 0:00:00.520380 50312 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-07-05T22:11:11.357947+00:00 2 default_pool
success vc-asset-import_v002 check_cluster_status 2021-07-05T21:05:00+00:00 EmrJobFlowSensor 2021-07-05T22:06:06.979647+00:00 2021-07-05T22:15:09.585950+00:00 0:09:02.606303 50311 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-07-05T22:06:04.824708+00:00 2 default_pool
success vc-asset-import_v002 create_cluster_and_add_emr_steps 2021-07-05T21:05:00+00:00 EmrCreateJobFlowOperator 2021-07-05T22:05:45.125280+00:00 2021-07-05T22:05:46.870324+00:00 0:00:01.745044 50310 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 2 default 2021-07-05T22:05:42.699872+00:00 2 default_pool
success vc-asset-import_v002 create_emr_steps 2021-07-05T21:05:00+00:00 PythonOperator 2021-07-05T22:05:22.737693+00:00 2021-07-05T22:05:26.338411+00:00 0:00:03.600718 50309 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-07-05T22:05:20.629816+00:00 2 default_pool
success campaign-flow-job_v002 check_cluster_status 2021-07-05T21:00:00+00:00 EmrJobFlowSensor 2021-07-05T22:01:06.848942+00:00 2021-07-05T22:11:09.821664+00:00 0:10:02.972722 50308 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-07-05T22:01:04.443297+00:00 2 default_pool
success livepop-shuffle-job_v002 check_cluster_status 2021-07-05T21:00:00+00:00 EmrJobFlowSensor 2021-07-05T22:00:56.724871+00:00 2021-07-05T22:13:00.099635+00:00 0:12:03.374764 50307 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-07-05T22:00:54.359194+00:00 2 default_pool
success campaign-flow-job_v002 create_cluster_and_add_emr_steps 2021-07-05T21:00:00+00:00 EmrCreateJobFlowOperator 2021-07-05T22:00:44.636069+00:00 2021-07-05T22:00:46.376361+00:00 0:00:01.740292 50306 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 4 default 2021-07-05T22:00:42.359268+00:00 2 default_pool
success livepop-shuffle-job_v002 create_cluster_and_add_emr_steps 2021-07-05T21:00:00+00:00 EmrCreateJobFlowOperator 2021-07-05T22:00:34.461181+00:00 2021-07-05T22:00:36.177592+00:00 0:00:01.716411 50305 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 2 default 2021-07-05T22:00:32.300174+00:00 2 default_pool
success campaign-flow-job_v002 create_emr_steps 2021-07-05T21:00:00+00:00 PythonOperator 2021-07-05T22:00:22.520488+00:00 2021-07-05T22:00:25.894434+00:00 0:00:03.373946 50304 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 5 default 2021-07-05T22:00:20.290365+00:00 2 default_pool
success livepop-shuffle-job_v002 create_emr_steps 2021-07-05T21:00:00+00:00 PythonOperator 2021-07-05T22:00:12.540776+00:00 2021-07-05T22:00:16.208609+00:00 0:00:03.667833 50303 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-07-05T22:00:10.282960+00:00 2 default_pool
success booking-processing-job_v002 check_cluster_status 2021-07-05T20:00:00+00:00 EmrJobFlowSensor 2021-07-05T21:23:02.413867+00:00 2021-07-05T21:23:04.000066+00:00 0:00:01.586199 50301 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-07-05T21:23:00.211950+00:00 3 default_pool
success campaign-history-job_v002 check_cluster_status 2021-07-05T20:00:00+00:00 EmrJobFlowSensor 2021-07-05T21:22:58.389780+00:00 2021-07-05T21:22:59.883729+00:00 0:00:01.493949 50300 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-07-05T21:22:56.211783+00:00 3 default_pool
success campaign-history-job_v002 create_cluster_and_add_emr_steps 2021-07-05T20:00:00+00:00 EmrCreateJobFlowOperator 2021-07-05T21:10:55.898391+00:00 2021-07-05T21:10:57.606182+00:00 0:00:01.707791 50297 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 2 default 2021-07-05T21:10:52.843881+00:00 2 default_pool
success booking-processing-job_v002 create_cluster_and_add_emr_steps 2021-07-05T20:00:00+00:00 EmrCreateJobFlowOperator 2021-07-05T21:10:53.500033+00:00 2021-07-05T21:10:55.629461+00:00 0:00:02.129428 50296 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 2 default 2021-07-05T21:10:50.864627+00:00 2 default_pool
success campaign-history-job_v002 create_emr_steps 2021-07-05T20:00:00+00:00 PythonOperator 2021-07-05T21:10:34.149546+00:00 2021-07-05T21:10:37.819508+00:00 0:00:03.669962 50295 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-07-05T21:10:30.783110+00:00 2 default_pool
success booking-processing-job_v002 create_emr_steps 2021-07-05T20:00:00+00:00 PythonOperator 2021-07-05T21:10:32.325930+00:00 2021-07-05T21:10:36.705104+00:00 0:00:04.379174 50294 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-07-05T21:10:28.873221+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_campaign-history-job_v002 2021-07-05T20:00:00+00:00 TriggerDagRunOperator 2021-07-05T21:10:23.211204+00:00 2021-07-05T21:10:23.696943+00:00 0:00:00.485739 50293 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-07-05T21:10:20.750784+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_booking-processing-job_v002 2021-07-05T20:00:00+00:00 TriggerDagRunOperator 2021-07-05T21:10:23.047074+00:00 2021-07-05T21:10:23.427861+00:00 0:00:00.380787 50292 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-07-05T21:10:20.750814+00:00 2 default_pool
success vc-asset-import_v002 check_cluster_status 2021-07-05T20:05:00+00:00 EmrJobFlowSensor 2021-07-05T21:07:50.708722+00:00 2021-07-05T21:14:53.049903+00:00 0:07:02.341181 50291 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-07-05T21:07:48.573927+00:00 3 default_pool
success vc-asset-import_v002 create_cluster_and_add_emr_steps 2021-07-05T20:05:00+00:00 EmrCreateJobFlowOperator 2021-07-05T21:05:41.033312+00:00 2021-07-05T21:05:42.707752+00:00 0:00:01.674440 50289 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 2 default 2021-07-05T21:05:38.261474+00:00 2 default_pool
success vc-asset-import_v002 create_emr_steps 2021-07-05T20:05:00+00:00 PythonOperator 2021-07-05T21:05:18.374624+00:00 2021-07-05T21:05:21.991470+00:00 0:00:03.616846 50288 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-07-05T21:05:16.122072+00:00 2 default_pool
success campaign-flow-job_v002 check_cluster_status 2021-07-05T20:00:00+00:00 EmrJobFlowSensor 2021-07-05T21:01:08.080899+00:00 2021-07-05T21:10:10.930873+00:00 0:09:02.849974 50287 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-07-05T21:01:05.754240+00:00 2 default_pool
success livepop-shuffle-job_v002 check_cluster_status 2021-07-05T20:00:00+00:00 EmrJobFlowSensor 2021-07-05T21:00:47.844190+00:00 2021-07-05T21:10:50.803230+00:00 0:10:02.959040 50286 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-07-05T21:00:45.725523+00:00 2 default_pool
success campaign-flow-job_v002 create_cluster_and_add_emr_steps 2021-07-05T20:00:00+00:00 EmrCreateJobFlowOperator 2021-07-05T21:00:46.068380+00:00 2021-07-05T21:00:47.946109+00:00 0:00:01.877729 50285 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 4 default 2021-07-05T21:00:43.723832+00:00 2 default_pool
success livepop-shuffle-job_v002 create_cluster_and_add_emr_steps 2021-07-05T20:00:00+00:00 EmrCreateJobFlowOperator 2021-07-05T21:00:26.418925+00:00 2021-07-05T21:00:28.173880+00:00 0:00:01.754955 50284 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 2 default 2021-07-05T21:00:23.711412+00:00 2 default_pool
success campaign-flow-job_v002 create_emr_steps 2021-07-05T20:00:00+00:00 PythonOperator 2021-07-05T21:00:24.117841+00:00 2021-07-05T21:00:28.132081+00:00 0:00:04.014240 50283 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 5 default 2021-07-05T21:00:21.763167+00:00 2 default_pool
success livepop-shuffle-job_v002 create_emr_steps 2021-07-05T20:00:00+00:00 PythonOperator 2021-07-05T21:00:04.224370+00:00 2021-07-05T21:00:07.884327+00:00 0:00:03.659957 50282 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-07-05T21:00:01.746982+00:00 2 default_pool
success booking-processing-job_v002 check_cluster_status 2021-07-05T19:00:00+00:00 EmrJobFlowSensor 2021-07-05T20:11:16.015382+00:00 2021-07-05T20:21:19.127766+00:00 0:10:03.112384 50280 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-07-05T20:11:13.705784+00:00 2 default_pool
success campaign-history-job_v002 check_cluster_status 2021-07-05T19:00:00+00:00 EmrJobFlowSensor 2021-07-05T20:11:10.198766+00:00 2021-07-05T20:20:12.876365+00:00 0:09:02.677599 50279 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-07-05T20:11:07.767567+00:00 2 default_pool
success booking-processing-job_v002 create_cluster_and_add_emr_steps 2021-07-05T19:00:00+00:00 EmrCreateJobFlowOperator 2021-07-05T20:10:54.476829+00:00 2021-07-05T20:10:56.159177+00:00 0:00:01.682348 50278 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 2 default 2021-07-05T20:10:51.768032+00:00 2 default_pool
success campaign-history-job_v002 create_cluster_and_add_emr_steps 2021-07-05T19:00:00+00:00 EmrCreateJobFlowOperator 2021-07-05T20:10:48.007620+00:00 2021-07-05T20:10:49.687220+00:00 0:00:01.679600 50277 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 2 default 2021-07-05T20:10:45.744027+00:00 2 default_pool
success booking-processing-job_v002 create_emr_steps 2021-07-05T19:00:00+00:00 PythonOperator 2021-07-05T20:10:25.971844+00:00 2021-07-05T20:10:29.752881+00:00 0:00:03.781037 50276 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-07-05T20:10:23.536990+00:00 2 default_pool
success campaign-history-job_v002 create_emr_steps 2021-07-05T19:00:00+00:00 PythonOperator 2021-07-05T20:10:20.152878+00:00 2021-07-05T20:10:23.859658+00:00 0:00:03.706780 50275 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-07-05T20:10:17.547148+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_booking-processing-job_v002 2021-07-05T19:00:00+00:00 TriggerDagRunOperator 2021-07-05T20:10:11.843787+00:00 2021-07-05T20:10:12.489216+00:00 0:00:00.645429 50274 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-07-05T20:10:09.525777+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_campaign-history-job_v002 2021-07-05T19:00:00+00:00 TriggerDagRunOperator 2021-07-05T20:10:11.783729+00:00 2021-07-05T20:10:12.311388+00:00 0:00:00.527659 50273 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-07-05T20:10:09.525745+00:00 2 default_pool
success vc-asset-import_v002 check_cluster_status 2021-07-05T19:05:00+00:00 EmrJobFlowSensor 2021-07-05T20:06:07.377120+00:00 2021-07-05T20:15:10.031101+00:00 0:09:02.653981 50272 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-07-05T20:06:05.091017+00:00 2 default_pool
success vc-asset-import_v002 create_cluster_and_add_emr_steps 2021-07-05T19:05:00+00:00 EmrCreateJobFlowOperator 2021-07-05T20:05:45.463254+00:00 2021-07-05T20:05:47.159351+00:00 0:00:01.696097 50271 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 2 default 2021-07-05T20:05:43.066769+00:00 2 default_pool
success vc-asset-import_v002 create_emr_steps 2021-07-05T19:05:00+00:00 PythonOperator 2021-07-05T20:05:23.690777+00:00 2021-07-05T20:05:27.324164+00:00 0:00:03.633387 50270 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-07-05T20:05:21.046354+00:00 2 default_pool
success livepop-shuffle-job_v002 check_cluster_status 2021-07-05T19:00:00+00:00 EmrJobFlowSensor 2021-07-05T20:01:08.674394+00:00 2021-07-05T20:11:11.646120+00:00 0:10:02.971726 50269 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-07-05T20:01:06.518254+00:00 2 default_pool
success campaign-flow-job_v002 check_cluster_status 2021-07-05T19:00:00+00:00 EmrJobFlowSensor 2021-07-05T20:00:59.051411+00:00 2021-07-05T20:10:01.934088+00:00 0:09:02.882677 50268 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-07-05T20:00:56.565991+00:00 2 default_pool
success livepop-shuffle-job_v002 create_cluster_and_add_emr_steps 2021-07-05T19:00:00+00:00 EmrCreateJobFlowOperator 2021-07-05T20:00:44.960826+00:00 2021-07-05T20:00:46.794908+00:00 0:00:01.834082 50267 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 2 default 2021-07-05T20:00:42.501606+00:00 2 default_pool
success campaign-flow-job_v002 create_cluster_and_add_emr_steps 2021-07-05T19:00:00+00:00 EmrCreateJobFlowOperator 2021-07-05T20:00:38.701273+00:00 2021-07-05T20:00:40.400468+00:00 0:00:01.699195 50266 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 4 default 2021-07-05T20:00:36.493872+00:00 2 default_pool
success livepop-shuffle-job_v002 create_emr_steps 2021-07-05T19:00:00+00:00 PythonOperator 2021-07-05T20:00:22.931647+00:00 2021-07-05T20:00:26.654654+00:00 0:00:03.723007 50265 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-07-05T20:00:20.432850+00:00 2 default_pool
success campaign-flow-job_v002 create_emr_steps 2021-07-05T19:00:00+00:00 PythonOperator 2021-07-05T20:00:17.073987+00:00 2021-07-05T20:00:20.937676+00:00 0:00:03.863689 50264 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 5 default 2021-07-05T20:00:14.433080+00:00 2 default_pool
success booking-processing-job_v002 check_cluster_status 2021-07-05T18:00:00+00:00 EmrJobFlowSensor 2021-07-05T19:11:19.622988+00:00 2021-07-05T19:20:22.447454+00:00 0:09:02.824466 50262 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-07-05T19:11:17.325373+00:00 2 default_pool
success campaign-history-job_v002 check_cluster_status 2021-07-05T18:00:00+00:00 EmrJobFlowSensor 2021-07-05T19:11:15.785138+00:00 2021-07-05T19:20:18.528625+00:00 0:09:02.743487 50261 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-07-05T19:11:13.321553+00:00 2 default_pool
success booking-processing-job_v002 create_cluster_and_add_emr_steps 2021-07-05T18:00:00+00:00 EmrCreateJobFlowOperator 2021-07-05T19:10:56.086123+00:00 2021-07-05T19:10:57.962223+00:00 0:00:01.876100 50260 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 2 default 2021-07-05T19:10:53.304796+00:00 2 default_pool
success campaign-history-job_v002 create_cluster_and_add_emr_steps 2021-07-05T18:00:00+00:00 EmrCreateJobFlowOperator 2021-07-05T19:10:47.516493+00:00 2021-07-05T19:10:49.371585+00:00 0:00:01.855092 50259 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 2 default 2021-07-05T19:10:45.298143+00:00 2 default_pool
success booking-processing-job_v002 create_emr_steps 2021-07-05T18:00:00+00:00 PythonOperator 2021-07-05T19:10:27.581086+00:00 2021-07-05T19:10:31.541528+00:00 0:00:03.960442 50258 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-07-05T19:10:25.287022+00:00 2 default_pool
success campaign-history-job_v002 create_emr_steps 2021-07-05T18:00:00+00:00 PythonOperator 2021-07-05T19:10:21.799122+00:00 2021-07-05T19:10:25.526295+00:00 0:00:03.727173 50257 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-07-05T19:10:19.264495+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_booking-processing-job_v002 2021-07-05T18:00:00+00:00 TriggerDagRunOperator 2021-07-05T19:10:13.551990+00:00 2021-07-05T19:10:14.140816+00:00 0:00:00.588826 50256 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-07-05T19:10:11.258322+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_campaign-history-job_v002 2021-07-05T18:00:00+00:00 TriggerDagRunOperator 2021-07-05T19:10:13.493203+00:00 2021-07-05T19:10:13.928025+00:00 0:00:00.434822 50255 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-07-05T19:10:11.258288+00:00 2 default_pool
success vc-asset-import_v002 check_cluster_status 2021-07-05T18:05:00+00:00 EmrJobFlowSensor 2021-07-05T19:06:05.011303+00:00 2021-07-05T19:15:07.568778+00:00 0:09:02.557475 50254 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-07-05T19:06:02.889322+00:00 2 default_pool
success vc-asset-import_v002 create_cluster_and_add_emr_steps 2021-07-05T18:05:00+00:00 EmrCreateJobFlowOperator 2021-07-05T19:05:43.036318+00:00 2021-07-05T19:05:44.810153+00:00 0:00:01.773835 50253 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 2 default 2021-07-05T19:05:40.812729+00:00 2 default_pool
success vc-asset-import_v002 create_emr_steps 2021-07-05T18:05:00+00:00 PythonOperator 2021-07-05T19:05:20.966258+00:00 2021-07-05T19:05:24.658821+00:00 0:00:03.692563 50252 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-07-05T19:05:18.799925+00:00 2 default_pool
success livepop-shuffle-job_v002 check_cluster_status 2021-07-05T18:00:00+00:00 EmrJobFlowSensor 2021-07-05T19:00:54.412608+00:00 2021-07-05T19:10:57.423209+00:00 0:10:03.010601 50251 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-07-05T19:00:52.202350+00:00 2 default_pool
success campaign-flow-job_v002 check_cluster_status 2021-07-05T18:00:00+00:00 EmrJobFlowSensor 2021-07-05T19:00:48.382274+00:00 2021-07-05T19:09:51.071678+00:00 0:09:02.689404 50250 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-07-05T19:00:46.192888+00:00 2 default_pool
success livepop-shuffle-job_v002 create_cluster_and_add_emr_steps 2021-07-05T18:00:00+00:00 EmrCreateJobFlowOperator 2021-07-05T19:00:32.902503+00:00 2021-07-05T19:00:34.589781+00:00 0:00:01.687278 50249 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 2 default 2021-07-05T19:00:30.187690+00:00 2 default_pool
success campaign-flow-job_v002 create_cluster_and_add_emr_steps 2021-07-05T18:00:00+00:00 EmrCreateJobFlowOperator 2021-07-05T19:00:28.384323+00:00 2021-07-05T19:00:30.152514+00:00 0:00:01.768191 50248 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 4 default 2021-07-05T19:00:26.123252+00:00 2 default_pool
success livepop-shuffle-job_v002 create_emr_steps 2021-07-05T18:00:00+00:00 PythonOperator 2021-07-05T19:00:10.675109+00:00 2021-07-05T19:00:14.162433+00:00 0:00:03.487324 50247 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-07-05T19:00:08.157424+00:00 2 default_pool
success campaign-flow-job_v002 create_emr_steps 2021-07-05T18:00:00+00:00 PythonOperator 2021-07-05T19:00:06.880916+00:00 2021-07-05T19:00:10.513359+00:00 0:00:03.632443 50246 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 5 default 2021-07-05T19:00:04.163602+00:00 2 default_pool
success booking-processing-job_v002 check_cluster_status 2021-07-05T17:00:00+00:00 EmrJobFlowSensor 2021-07-05T18:11:27.022980+00:00 2021-07-05T18:21:30.032831+00:00 0:10:03.009851 50244 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-07-05T18:11:24.885522+00:00 2 default_pool
success campaign-history-job_v002 check_cluster_status 2021-07-05T17:00:00+00:00 EmrJobFlowSensor 2021-07-05T18:11:25.101064+00:00 2021-07-05T18:19:27.720762+00:00 0:08:02.619698 50243 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-07-05T18:11:22.884488+00:00 2 default_pool
success booking-processing-job_v002 create_cluster_and_add_emr_steps 2021-07-05T17:00:00+00:00 EmrCreateJobFlowOperator 2021-07-05T18:11:07.576739+00:00 2021-07-05T18:11:09.321732+00:00 0:00:01.744993 50242 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 2 default 2021-07-05T18:11:04.865666+00:00 2 default_pool
success campaign-history-job_v002 create_cluster_and_add_emr_steps 2021-07-05T17:00:00+00:00 EmrCreateJobFlowOperator 2021-07-05T18:11:05.524945+00:00 2021-07-05T18:11:07.496003+00:00 0:00:01.971058 50241 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 2 default 2021-07-05T18:11:02.864888+00:00 2 default_pool
success booking-processing-job_v002 create_emr_steps 2021-07-05T17:00:00+00:00 PythonOperator 2021-07-05T18:10:43.077766+00:00 2021-07-05T18:10:46.900874+00:00 0:00:03.823108 50240 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-07-05T18:10:40.795954+00:00 2 default_pool
success campaign-history-job_v002 create_emr_steps 2021-07-05T17:00:00+00:00 PythonOperator 2021-07-05T18:10:41.170031+00:00 2021-07-05T18:10:44.651836+00:00 0:00:03.481805 50239 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-07-05T18:10:38.796318+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_campaign-history-job_v002 2021-07-05T17:00:00+00:00 TriggerDagRunOperator 2021-07-05T18:10:19.256496+00:00 2021-07-05T18:10:19.748004+00:00 0:00:00.491508 50238 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-07-05T18:10:16.761393+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_booking-processing-job_v002 2021-07-05T17:00:00+00:00 TriggerDagRunOperator 2021-07-05T18:10:19.108960+00:00 2021-07-05T18:10:19.491144+00:00 0:00:00.382184 50237 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-07-05T18:10:16.761442+00:00 2 default_pool
success vc-asset-import_v002 check_cluster_status 2021-07-05T17:05:00+00:00 EmrJobFlowSensor 2021-07-05T18:05:52.537091+00:00 2021-07-05T18:14:55.267792+00:00 0:09:02.730701 50236 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-07-05T18:05:50.337354+00:00 2 default_pool
success vc-asset-import_v002 create_cluster_and_add_emr_steps 2021-07-05T17:05:00+00:00 EmrCreateJobFlowOperator 2021-07-05T18:05:31.029199+00:00 2021-07-05T18:05:32.768032+00:00 0:00:01.738833 50235 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 2 default 2021-07-05T18:05:28.462481+00:00 2 default_pool
success vc-asset-import_v002 create_emr_steps 2021-07-05T17:05:00+00:00 PythonOperator 2021-07-05T18:05:08.660173+00:00 2021-07-05T18:05:12.353025+00:00 0:00:03.692852 50234 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-07-05T18:05:06.364010+00:00 2 default_pool
success campaign-flow-job_v002 check_cluster_status 2021-07-05T17:00:00+00:00 EmrJobFlowSensor 2021-07-05T18:01:06.199966+00:00 2021-07-05T18:10:09.057117+00:00 0:09:02.857151 50233 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-07-05T18:01:03.989989+00:00 2 default_pool
success livepop-shuffle-job_v002 check_cluster_status 2021-07-05T17:00:00+00:00 EmrJobFlowSensor 2021-07-05T18:01:04.193891+00:00 2021-07-05T18:13:07.312058+00:00 0:12:03.118167 50232 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-07-05T18:01:01.984914+00:00 2 default_pool
success campaign-flow-job_v002 create_cluster_and_add_emr_steps 2021-07-05T17:00:00+00:00 EmrCreateJobFlowOperator 2021-07-05T18:00:46.258902+00:00 2021-07-05T18:00:48.122294+00:00 0:00:01.863392 50231 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 4 default 2021-07-05T18:00:43.916564+00:00 2 default_pool
success livepop-shuffle-job_v002 create_cluster_and_add_emr_steps 2021-07-05T17:00:00+00:00 EmrCreateJobFlowOperator 2021-07-05T18:00:40.380840+00:00 2021-07-05T18:00:42.221157+00:00 0:00:01.840317 50230 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 2 default 2021-07-05T18:00:37.911040+00:00 2 default_pool
success campaign-flow-job_v002 create_emr_steps 2021-07-05T17:00:00+00:00 PythonOperator 2021-07-05T18:00:25.400176+00:00 2021-07-05T18:00:29.121111+00:00 0:00:03.720935 50229 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 5 default 2021-07-05T18:00:21.963672+00:00 2 default_pool
success livepop-shuffle-job_v002 create_emr_steps 2021-07-05T17:00:00+00:00 PythonOperator 2021-07-05T18:00:20.444854+00:00 2021-07-05T18:00:25.336859+00:00 0:00:04.892005 50228 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-07-05T18:00:17.898940+00:00 2 default_pool
success booking-processing-job_v002 check_cluster_status 2021-07-05T16:00:00+00:00 EmrJobFlowSensor 2021-07-05T17:11:49.606985+00:00 2021-07-05T17:21:52.499828+00:00 0:10:02.892843 50226 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-07-05T17:11:47.326655+00:00 2 default_pool
success campaign-history-job_v002 check_cluster_status 2021-07-05T16:00:00+00:00 EmrJobFlowSensor 2021-07-05T17:11:45.603680+00:00 2021-07-05T17:21:48.593987+00:00 0:10:02.990307 50225 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-07-05T17:11:43.319455+00:00 2 default_pool
success booking-processing-job_v002 create_cluster_and_add_emr_steps 2021-07-05T16:00:00+00:00 EmrCreateJobFlowOperator 2021-07-05T17:11:27.430994+00:00 2021-07-05T17:11:29.147325+00:00 0:00:01.716331 50224 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 2 default 2021-07-05T17:11:25.303912+00:00 2 default_pool
success campaign-history-job_v002 create_cluster_and_add_emr_steps 2021-07-05T16:00:00+00:00 EmrCreateJobFlowOperator 2021-07-05T17:11:23.528108+00:00 2021-07-05T17:11:25.396750+00:00 0:00:01.868642 50223 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 2 default 2021-07-05T17:11:21.301088+00:00 2 default_pool
success booking-processing-job_v002 create_emr_steps 2021-07-05T16:00:00+00:00 PythonOperator 2021-07-05T17:10:59.581753+00:00 2021-07-05T17:11:03.232121+00:00 0:00:03.650368 50222 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-07-05T17:10:57.268004+00:00 2 default_pool
success campaign-history-job_v002 create_emr_steps 2021-07-05T16:00:00+00:00 PythonOperator 2021-07-05T17:10:47.389156+00:00 2021-07-05T17:10:51.051846+00:00 0:00:03.662690 50221 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-07-05T17:10:45.256753+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_campaign-history-job_v002 2021-07-05T16:00:00+00:00 TriggerDagRunOperator 2021-07-05T17:10:27.485522+00:00 2021-07-05T17:10:27.999132+00:00 0:00:00.513610 50220 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-07-05T17:10:25.201965+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_booking-processing-job_v002 2021-07-05T16:00:00+00:00 TriggerDagRunOperator 2021-07-05T17:10:27.381074+00:00 2021-07-05T17:10:27.853693+00:00 0:00:00.472619 50219 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-07-05T17:10:25.201999+00:00 2 default_pool
success vc-asset-import_v002 check_cluster_status 2021-07-05T16:05:00+00:00 EmrJobFlowSensor 2021-07-05T17:06:15.103267+00:00 2021-07-05T17:15:17.827148+00:00 0:09:02.723881 50218 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-07-05T17:06:12.698940+00:00 2 default_pool
success vc-asset-import_v002 create_cluster_and_add_emr_steps 2021-07-05T16:05:00+00:00 EmrCreateJobFlowOperator 2021-07-05T17:05:50.755981+00:00 2021-07-05T17:05:52.444570+00:00 0:00:01.688589 50217 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 2 default 2021-07-05T17:05:48.654854+00:00 2 default_pool
success vc-asset-import_v002 create_emr_steps 2021-07-05T16:05:00+00:00 PythonOperator 2021-07-05T17:05:24.747897+00:00 2021-07-05T17:05:28.363917+00:00 0:00:03.616020 50216 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-07-05T17:05:22.530686+00:00 2 default_pool
success campaign-flow-job_v002 check_cluster_status 2021-07-05T16:00:00+00:00 EmrJobFlowSensor 2021-07-05T17:01:00.819070+00:00 2021-07-05T17:10:03.684900+00:00 0:09:02.865830 50215 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-07-05T17:00:58.167455+00:00 2 default_pool
success livepop-shuffle-job_v002 check_cluster_status 2021-07-05T16:00:00+00:00 EmrJobFlowSensor 2021-07-05T17:00:50.512345+00:00 2021-07-05T17:11:53.637536+00:00 0:11:03.125191 50214 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-07-05T17:00:48.010808+00:00 2 default_pool