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 campaign-flow-job_v002 create_emr_steps 2021-04-11T13:00:00+00:00 PythonOperator 2021-04-11T14:00:17.025625+00:00 2021-04-11T14:00:20.141864+00:00 0:00:03.116239 16021 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 5 default 2021-04-11T14:00:14.684223+00:00 2 default_pool
success booking-processing-job_v002 check_cluster_status 2021-04-11T12:00:00+00:00 EmrJobFlowSensor 2021-04-11T13:11:20.576835+00:00 2021-04-11T13:21:23.608282+00:00 0:10:03.031447 16019 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-11T13:11:17.413456+00:00 2 default_pool
success campaign-history-job_v002 check_cluster_status 2021-04-11T12:00:00+00:00 EmrJobFlowSensor 2021-04-11T13:11:20.505306+00:00 2021-04-11T13:19:23.060998+00:00 0:08:02.555692 16018 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-11T13:11:17.413487+00:00 2 default_pool
success campaign-history-job_v002 create_cluster_and_add_emr_steps 2021-04-11T12:00:00+00:00 EmrCreateJobFlowOperator 2021-04-11T13:10:57.735557+00:00 2021-04-11T13:10:59.556330+00:00 0:00:01.820773 16017 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 2 default 2021-04-11T13:10:55.357855+00:00 2 default_pool
success booking-processing-job_v002 create_cluster_and_add_emr_steps 2021-04-11T12:00:00+00:00 EmrCreateJobFlowOperator 2021-04-11T13:10:57.631531+00:00 2021-04-11T13:10:59.346921+00:00 0:00:01.715390 16016 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 2 default 2021-04-11T13:10:55.357890+00:00 2 default_pool
success booking-processing-job_v002 create_emr_steps 2021-04-11T12:00:00+00:00 PythonOperator 2021-04-11T13:10:37.679837+00:00 2021-04-11T13:10:40.967115+00:00 0:00:03.287278 16015 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-04-11T13:10:35.338721+00:00 2 default_pool
success campaign-history-job_v002 create_emr_steps 2021-04-11T12:00:00+00:00 PythonOperator 2021-04-11T13:10:37.632961+00:00 2021-04-11T13:10:40.649241+00:00 0:00:03.016280 16014 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-04-11T13:10:35.338752+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_booking-processing-job_v002 2021-04-11T12:00:00+00:00 TriggerDagRunOperator 2021-04-11T13:10:12.481459+00:00 2021-04-11T13:10:13.058126+00:00 0:00:00.576667 16013 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-11T13:10:09.365283+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_campaign-history-job_v002 2021-04-11T12:00:00+00:00 TriggerDagRunOperator 2021-04-11T13:10:12.448023+00:00 2021-04-11T13:10:12.918131+00:00 0:00:00.470108 16012 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-11T13:10:09.365232+00:00 2 default_pool
success vc-asset-import_v002 check_cluster_status 2021-04-11T12:05:00+00:00 EmrJobFlowSensor 2021-04-11T13:05:59.031743+00:00 2021-04-11T13:15:01.640018+00:00 0:09:02.608275 16011 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-11T13:05:56.840080+00:00 2 default_pool
success vc-asset-import_v002 create_cluster_and_add_emr_steps 2021-04-11T12:05:00+00:00 EmrCreateJobFlowOperator 2021-04-11T13:05:37.070259+00:00 2021-04-11T13:05:38.711576+00:00 0:00:01.641317 16010 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 2 default 2021-04-11T13:05:34.788271+00:00 2 default_pool
success vc-asset-import_v002 create_emr_steps 2021-04-11T12:05:00+00:00 PythonOperator 2021-04-11T13:05:15.181039+00:00 2021-04-11T13:05:17.895296+00:00 0:00:02.714257 16009 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-04-11T13:05:12.700029+00:00 2 default_pool
success campaign-flow-job_v002 check_cluster_status 2021-04-11T12:00:00+00:00 EmrJobFlowSensor 2021-04-11T13:00:58.503638+00:00 2021-04-11T13:10:01.403434+00:00 0:09:02.899796 16008 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-04-11T13:00:56.304505+00:00 2 default_pool
success campaign-flow-job_v002 create_cluster_and_add_emr_steps 2021-04-11T12:00:00+00:00 EmrCreateJobFlowOperator 2021-04-11T13:00:36.518003+00:00 2021-04-11T13:00:38.253690+00:00 0:00:01.735687 16007 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 4 default 2021-04-11T13:00:34.283134+00:00 2 default_pool
success campaign-flow-job_v002 create_emr_steps 2021-04-11T12:00:00+00:00 PythonOperator 2021-04-11T13:00:16.796178+00:00 2021-04-11T13:00:19.536885+00:00 0:00:02.740707 16006 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 5 default 2021-04-11T13:00:14.232103+00:00 2 default_pool
success campaign-history-job_v002 check_cluster_status 2021-04-11T11:00:00+00:00 EmrJobFlowSensor 2021-04-11T12:11:23.996618+00:00 2021-04-11T12:20:26.752587+00:00 0:09:02.755969 16004 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-11T12:11:21.687218+00:00 2 default_pool
success booking-processing-job_v002 check_cluster_status 2021-04-11T11:00:00+00:00 EmrJobFlowSensor 2021-04-11T12:11:22.165534+00:00 2021-04-11T12:20:24.919793+00:00 0:09:02.754259 16003 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-11T12:11:19.753980+00:00 2 default_pool
success campaign-history-job_v002 create_cluster_and_add_emr_steps 2021-04-11T11:00:00+00:00 EmrCreateJobFlowOperator 2021-04-11T12:11:02.031339+00:00 2021-04-11T12:11:03.724598+00:00 0:00:01.693259 16002 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 2 default 2021-04-11T12:10:59.740804+00:00 2 default_pool
success booking-processing-job_v002 create_cluster_and_add_emr_steps 2021-04-11T11:00:00+00:00 EmrCreateJobFlowOperator 2021-04-11T12:11:00.277367+00:00 2021-04-11T12:11:02.202026+00:00 0:00:01.924659 16001 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 2 default 2021-04-11T12:10:57.647034+00:00 2 default_pool
success campaign-history-job_v002 create_emr_steps 2021-04-11T11:00:00+00:00 PythonOperator 2021-04-11T12:10:40.081937+00:00 2021-04-11T12:10:42.969392+00:00 0:00:02.887455 16000 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-04-11T12:10:37.612171+00:00 2 default_pool
success booking-processing-job_v002 create_emr_steps 2021-04-11T11:00:00+00:00 PythonOperator 2021-04-11T12:10:38.036946+00:00 2021-04-11T12:10:40.962265+00:00 0:00:02.925319 15999 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-04-11T12:10:35.672282+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_campaign-history-job_v002 2021-04-11T11:00:00+00:00 TriggerDagRunOperator 2021-04-11T12:10:34.429665+00:00 2021-04-11T12:10:34.879080+00:00 0:00:00.449415 15998 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-11T12:10:31.664045+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_booking-processing-job_v002 2021-04-11T11:00:00+00:00 TriggerDagRunOperator 2021-04-11T12:10:34.277231+00:00 2021-04-11T12:10:34.847052+00:00 0:00:00.569821 15997 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-11T12:10:31.664075+00:00 2 default_pool
success vc-asset-import_v002 check_cluster_status 2021-04-11T11:05:00+00:00 EmrJobFlowSensor 2021-04-11T12:05:49.425498+00:00 2021-04-11T12:14:52.053239+00:00 0:09:02.627741 15996 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-11T12:05:47.124790+00:00 2 default_pool
success vc-asset-import_v002 create_cluster_and_add_emr_steps 2021-04-11T11:05:00+00:00 EmrCreateJobFlowOperator 2021-04-11T12:05:27.796916+00:00 2021-04-11T12:05:29.471797+00:00 0:00:01.674881 15995 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 2 default 2021-04-11T12:05:25.167847+00:00 2 default_pool
success vc-asset-import_v002 create_emr_steps 2021-04-11T11:05:00+00:00 PythonOperator 2021-04-11T12:05:07.396065+00:00 2021-04-11T12:05:10.110654+00:00 0:00:02.714589 15994 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-04-11T12:05:05.152944+00:00 2 default_pool
success campaign-flow-job_v002 check_cluster_status 2021-04-11T11:00:00+00:00 EmrJobFlowSensor 2021-04-11T12:01:12.799798+00:00 2021-04-11T12:10:15.459931+00:00 0:09:02.660133 15993 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-04-11T12:01:10.616993+00:00 2 default_pool
success campaign-flow-job_v002 create_cluster_and_add_emr_steps 2021-04-11T11:00:00+00:00 EmrCreateJobFlowOperator 2021-04-11T12:00:42.867765+00:00 2021-04-11T12:00:44.668526+00:00 0:00:01.800761 15992 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 4 default 2021-04-11T12:00:40.591062+00:00 2 default_pool
success campaign-flow-job_v002 create_emr_steps 2021-04-11T11:00:00+00:00 PythonOperator 2021-04-11T12:00:12.915972+00:00 2021-04-11T12:00:15.629005+00:00 0:00:02.713033 15991 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 5 default 2021-04-11T12:00:10.523795+00:00 2 default_pool
success booking-processing-job_v002 check_cluster_status 2021-04-11T10:00:00+00:00 EmrJobFlowSensor 2021-04-11T11:18:42.601507+00:00 2021-04-11T11:28:45.283992+00:00 0:10:02.682485 15989 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-11T11:18:40.390626+00:00 2 default_pool
success booking-processing-job_v002 create_cluster_and_add_emr_steps 2021-04-11T10:00:00+00:00 EmrCreateJobFlowOperator 2021-04-11T11:18:20.760434+00:00 2021-04-11T11:18:23.173314+00:00 0:00:02.412880 15988 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 2 default 2021-04-11T11:18:18.354067+00:00 2 default_pool
success campaign-history-job_v002 check_cluster_status 2021-04-11T10:00:00+00:00 EmrJobFlowSensor 2021-04-11T11:18:14.407728+00:00 2021-04-11T11:28:17.038575+00:00 0:10:02.630847 15987 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-11T11:18:12.234863+00:00 2 default_pool
success booking-processing-job_v002 create_emr_steps 2021-04-11T10:00:00+00:00 PythonOperator 2021-04-11T11:18:00.838214+00:00 2021-04-11T11:18:03.915260+00:00 0:00:03.077046 15986 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-04-11T11:17:58.269632+00:00 2 default_pool
success campaign-history-job_v002 create_cluster_and_add_emr_steps 2021-04-11T10:00:00+00:00 EmrCreateJobFlowOperator 2021-04-11T11:17:54.453046+00:00 2021-04-11T11:17:56.154238+00:00 0:00:01.701192 15985 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 2 default 2021-04-11T11:17:52.045434+00:00 2 default_pool
success campaign-history-job_v002 create_emr_steps 2021-04-11T10:00:00+00:00 PythonOperator 2021-04-11T11:17:32.747246+00:00 2021-04-11T11:17:35.788967+00:00 0:00:03.041721 15984 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-04-11T11:17:30.036139+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_booking-processing-job_v002 2021-04-11T10:00:00+00:00 TriggerDagRunOperator 2021-04-11T11:17:22.278684+00:00 2021-04-11T11:17:22.877366+00:00 0:00:00.598682 15983 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-11T11:17:20.025984+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_campaign-history-job_v002 2021-04-11T10:00:00+00:00 TriggerDagRunOperator 2021-04-11T11:17:22.195435+00:00 2021-04-11T11:17:22.683169+00:00 0:00:00.487734 15982 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-11T11:17:20.025953+00:00 2 default_pool
success vc-asset-import_v002 check_cluster_status 2021-04-11T10:05:00+00:00 EmrJobFlowSensor 2021-04-11T11:06:17.021306+00:00 2021-04-11T11:14:19.507438+00:00 0:08:02.486132 15981 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-11T11:06:14.774219+00:00 2 default_pool
success vc-asset-import_v002 create_cluster_and_add_emr_steps 2021-04-11T10:05:00+00:00 EmrCreateJobFlowOperator 2021-04-11T11:05:45.170534+00:00 2021-04-11T11:05:47.546841+00:00 0:00:02.376307 15980 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 2 default 2021-04-11T11:05:42.751395+00:00 2 default_pool
success vc-asset-import_v002 create_emr_steps 2021-04-11T10:05:00+00:00 PythonOperator 2021-04-11T11:05:22.930696+00:00 2021-04-11T11:05:25.599915+00:00 0:00:02.669219 15979 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-04-11T11:05:20.688184+00:00 2 default_pool
success campaign-flow-job_v002 check_cluster_status 2021-04-11T10:00:00+00:00 EmrJobFlowSensor 2021-04-11T11:01:04.554297+00:00 2021-04-11T11:17:08.573043+00:00 0:16:04.018746 15978 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-04-11T11:01:02.097528+00:00 2 default_pool
success campaign-flow-job_v002 create_cluster_and_add_emr_steps 2021-04-11T10:00:00+00:00 EmrCreateJobFlowOperator 2021-04-11T11:00:40.573090+00:00 2021-04-11T11:00:42.384576+00:00 0:00:01.811486 15977 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 4 default 2021-04-11T11:00:38.152813+00:00 2 default_pool
success campaign-flow-job_v002 create_emr_steps 2021-04-11T10:00:00+00:00 PythonOperator 2021-04-11T11:00:18.276790+00:00 2021-04-11T11:00:21.022651+00:00 0:00:02.745861 15976 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 5 default 2021-04-11T11:00:15.991974+00:00 2 default_pool
success booking-processing-job_v002 check_cluster_status 2021-04-11T09:00:00+00:00 EmrJobFlowSensor 2021-04-11T10:11:26.362891+00:00 2021-04-11T10:20:29.102445+00:00 0:09:02.739554 15974 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-11T10:11:24.026934+00:00 2 default_pool
success campaign-history-job_v002 check_cluster_status 2021-04-11T09:00:00+00:00 EmrJobFlowSensor 2021-04-11T10:11:26.232799+00:00 2021-04-11T10:20:28.851859+00:00 0:09:02.619060 15973 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-11T10:11:24.026968+00:00 2 default_pool
success booking-processing-job_v002 create_cluster_and_add_emr_steps 2021-04-11T09:00:00+00:00 EmrCreateJobFlowOperator 2021-04-11T10:11:04.458434+00:00 2021-04-11T10:11:06.280359+00:00 0:00:01.821925 15972 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 2 default 2021-04-11T10:11:01.959845+00:00 2 default_pool
success campaign-history-job_v002 create_cluster_and_add_emr_steps 2021-04-11T09:00:00+00:00 EmrCreateJobFlowOperator 2021-04-11T10:11:04.236188+00:00 2021-04-11T10:11:05.963943+00:00 0:00:01.727755 15971 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 2 default 2021-04-11T10:11:01.959875+00:00 2 default_pool
success booking-processing-job_v002 create_emr_steps 2021-04-11T09:00:00+00:00 PythonOperator 2021-04-11T10:10:44.821915+00:00 2021-04-11T10:10:47.840910+00:00 0:00:03.018995 15970 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-04-11T10:10:41.956520+00:00 2 default_pool
success campaign-history-job_v002 create_emr_steps 2021-04-11T09:00:00+00:00 PythonOperator 2021-04-11T10:10:44.813938+00:00 2021-04-11T10:10:47.739217+00:00 0:00:02.925279 15969 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-04-11T10:10:41.956487+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_campaign-history-job_v002 2021-04-11T09:00:00+00:00 TriggerDagRunOperator 2021-04-11T10:10:32.382485+00:00 2021-04-11T10:10:32.954589+00:00 0:00:00.572104 15968 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-11T10:10:29.893148+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_booking-processing-job_v002 2021-04-11T09:00:00+00:00 TriggerDagRunOperator 2021-04-11T10:10:32.269450+00:00 2021-04-11T10:10:32.677331+00:00 0:00:00.407881 15967 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-11T10:10:29.893195+00:00 2 default_pool
success vc-asset-import_v002 check_cluster_status 2021-04-11T09:05:00+00:00 EmrJobFlowSensor 2021-04-11T10:06:03.922281+00:00 2021-04-11T10:14:06.469998+00:00 0:08:02.547717 15966 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-11T10:06:01.468533+00:00 2 default_pool
success vc-asset-import_v002 create_cluster_and_add_emr_steps 2021-04-11T09:05:00+00:00 EmrCreateJobFlowOperator 2021-04-11T10:05:41.592766+00:00 2021-04-11T10:05:43.233996+00:00 0:00:01.641230 15965 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 2 default 2021-04-11T10:05:39.382097+00:00 2 default_pool
success vc-asset-import_v002 create_emr_steps 2021-04-11T09:05:00+00:00 PythonOperator 2021-04-11T10:05:19.584680+00:00 2021-04-11T10:05:22.373417+00:00 0:00:02.788737 15964 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-04-11T10:05:17.321203+00:00 2 default_pool
success campaign-flow-job_v002 check_cluster_status 2021-04-11T09:00:00+00:00 EmrJobFlowSensor 2021-04-11T10:01:13.332532+00:00 2021-04-11T10:10:15.993887+00:00 0:09:02.661355 15963 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-04-11T10:01:10.984715+00:00 2 default_pool
success campaign-flow-job_v002 create_cluster_and_add_emr_steps 2021-04-11T09:00:00+00:00 EmrCreateJobFlowOperator 2021-04-11T10:00:51.209726+00:00 2021-04-11T10:00:52.928543+00:00 0:00:01.718817 15962 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 4 default 2021-04-11T10:00:48.961335+00:00 2 default_pool
success campaign-flow-job_v002 create_emr_steps 2021-04-11T09:00:00+00:00 PythonOperator 2021-04-11T10:00:23.424758+00:00 2021-04-11T10:00:26.451578+00:00 0:00:03.026820 15961 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 5 default 2021-04-11T10:00:20.945152+00:00 2 default_pool
success campaign-history-job_v002 check_cluster_status 2021-04-11T08:00:00+00:00 EmrJobFlowSensor 2021-04-11T09:11:03.099183+00:00 2021-04-11T09:20:05.798411+00:00 0:09:02.699228 15959 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-11T09:11:00.852353+00:00 2 default_pool
success booking-processing-job_v002 check_cluster_status 2021-04-11T08:00:00+00:00 EmrJobFlowSensor 2021-04-11T09:10:56.891070+00:00 2021-04-11T09:20:59.691582+00:00 0:10:02.800512 15958 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-11T09:10:54.730402+00:00 2 default_pool
success campaign-history-job_v002 create_cluster_and_add_emr_steps 2021-04-11T08:00:00+00:00 EmrCreateJobFlowOperator 2021-04-11T09:10:40.908211+00:00 2021-04-11T09:10:42.691477+00:00 0:00:01.783266 15957 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 2 default 2021-04-11T09:10:38.717697+00:00 2 default_pool
success booking-processing-job_v002 create_cluster_and_add_emr_steps 2021-04-11T08:00:00+00:00 EmrCreateJobFlowOperator 2021-04-11T09:10:35.078630+00:00 2021-04-11T09:10:36.762338+00:00 0:00:01.683708 15956 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 2 default 2021-04-11T09:10:32.713419+00:00 2 default_pool
success campaign-history-job_v002 create_emr_steps 2021-04-11T08:00:00+00:00 PythonOperator 2021-04-11T09:10:20.973379+00:00 2021-04-11T09:10:23.704941+00:00 0:00:02.731562 15955 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-04-11T09:10:18.706667+00:00 2 default_pool
success booking-processing-job_v002 create_emr_steps 2021-04-11T08:00:00+00:00 PythonOperator 2021-04-11T09:10:13.439186+00:00 2021-04-11T09:10:16.499921+00:00 0:00:03.060735 15954 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-04-11T09:10:10.695525+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_booking-processing-job_v002 2021-04-11T08:00:00+00:00 TriggerDagRunOperator 2021-04-11T09:10:05.581900+00:00 2021-04-11T09:10:05.967062+00:00 0:00:00.385162 15953 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-11T09:10:02.764668+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_campaign-history-job_v002 2021-04-11T08:00:00+00:00 TriggerDagRunOperator 2021-04-11T09:10:05.247533+00:00 2021-04-11T09:10:05.776746+00:00 0:00:00.529213 15952 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-11T09:10:02.764634+00:00 2 default_pool
success vc-asset-import_v002 check_cluster_status 2021-04-11T08:05:00+00:00 EmrJobFlowSensor 2021-04-11T09:06:00.746423+00:00 2021-04-11T09:14:03.333131+00:00 0:08:02.586708 15951 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-11T09:05:58.257500+00:00 2 default_pool
success vc-asset-import_v002 create_cluster_and_add_emr_steps 2021-04-11T08:05:00+00:00 EmrCreateJobFlowOperator 2021-04-11T09:05:38.549946+00:00 2021-04-11T09:05:40.223843+00:00 0:00:01.673897 15950 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 2 default 2021-04-11T09:05:36.088447+00:00 2 default_pool
success vc-asset-import_v002 create_emr_steps 2021-04-11T08:05:00+00:00 PythonOperator 2021-04-11T09:05:18.236507+00:00 2021-04-11T09:05:20.908727+00:00 0:00:02.672220 15949 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-04-11T09:05:16.065463+00:00 2 default_pool
success campaign-flow-job_v002 check_cluster_status 2021-04-11T08:00:00+00:00 EmrJobFlowSensor 2021-04-11T09:00:53.803943+00:00 2021-04-11T09:09:56.429828+00:00 0:09:02.625885 15948 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-04-11T09:00:51.646549+00:00 2 default_pool
success campaign-flow-job_v002 create_cluster_and_add_emr_steps 2021-04-11T08:00:00+00:00 EmrCreateJobFlowOperator 2021-04-11T09:00:34.427552+00:00 2021-04-11T09:00:36.117819+00:00 0:00:01.690267 15947 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 4 default 2021-04-11T09:00:31.631611+00:00 2 default_pool
success campaign-flow-job_v002 create_emr_steps 2021-04-11T08:00:00+00:00 PythonOperator 2021-04-11T09:00:12.325445+00:00 2021-04-11T09:00:15.053697+00:00 0:00:02.728252 15946 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 5 default 2021-04-11T09:00:09.617004+00:00 2 default_pool
success campaign-history-job_v002 check_cluster_status 2021-04-11T07:00:00+00:00 EmrJobFlowSensor 2021-04-11T08:11:28.141098+00:00 2021-04-11T08:20:30.620624+00:00 0:09:02.479526 15944 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-11T08:11:25.941881+00:00 2 default_pool
success booking-processing-job_v002 check_cluster_status 2021-04-11T07:00:00+00:00 EmrJobFlowSensor 2021-04-11T08:11:20.401109+00:00 2021-04-11T08:21:23.211456+00:00 0:10:02.810347 15943 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-11T08:11:17.970788+00:00 2 default_pool
success campaign-history-job_v002 create_cluster_and_add_emr_steps 2021-04-11T07:00:00+00:00 EmrCreateJobFlowOperator 2021-04-11T08:11:06.132580+00:00 2021-04-11T08:11:07.848165+00:00 0:00:01.715585 15942 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 2 default 2021-04-11T08:11:03.937434+00:00 2 default_pool
success booking-processing-job_v002 create_cluster_and_add_emr_steps 2021-04-11T07:00:00+00:00 EmrCreateJobFlowOperator 2021-04-11T08:11:00.640974+00:00 2021-04-11T08:11:02.427230+00:00 0:00:01.786256 15941 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 2 default 2021-04-11T08:10:58.062650+00:00 2 default_pool
success campaign-history-job_v002 create_emr_steps 2021-04-11T07:00:00+00:00 PythonOperator 2021-04-11T08:10:44.225661+00:00 2021-04-11T08:10:47.047039+00:00 0:00:02.821378 15940 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-04-11T08:10:41.892331+00:00 2 default_pool
success booking-processing-job_v002 create_emr_steps 2021-04-11T07:00:00+00:00 PythonOperator 2021-04-11T08:10:38.133838+00:00 2021-04-11T08:10:41.055422+00:00 0:00:02.921584 15939 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-04-11T08:10:35.887007+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_campaign-history-job_v002 2021-04-11T07:00:00+00:00 TriggerDagRunOperator 2021-04-11T08:10:30.460203+00:00 2021-04-11T08:10:30.894709+00:00 0:00:00.434506 15938 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-11T08:10:27.954163+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_booking-processing-job_v002 2021-04-11T07:00:00+00:00 TriggerDagRunOperator 2021-04-11T08:10:30.417277+00:00 2021-04-11T08:10:31.014381+00:00 0:00:00.597104 15937 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-11T08:10:27.954199+00:00 2 default_pool
success vc-asset-import_v002 check_cluster_status 2021-04-11T07:05:00+00:00 EmrJobFlowSensor 2021-04-11T08:06:05.684629+00:00 2021-04-11T08:14:08.185458+00:00 0:08:02.500829 15936 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-11T08:06:03.542887+00:00 2 default_pool
success vc-asset-import_v002 create_cluster_and_add_emr_steps 2021-04-11T07:05:00+00:00 EmrCreateJobFlowOperator 2021-04-11T08:05:37.936848+00:00 2021-04-11T08:05:39.709013+00:00 0:00:01.772165 15935 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 2 default 2021-04-11T08:05:35.576287+00:00 2 default_pool
success vc-asset-import_v002 create_emr_steps 2021-04-11T07:05:00+00:00 PythonOperator 2021-04-11T08:05:15.769965+00:00 2021-04-11T08:05:18.479367+00:00 0:00:02.709402 15934 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-04-11T08:05:13.502989+00:00 2 default_pool
success campaign-flow-job_v002 check_cluster_status 2021-04-11T07:00:00+00:00 EmrJobFlowSensor 2021-04-11T08:01:09.655120+00:00 2021-04-11T08:10:12.416856+00:00 0:09:02.761736 15933 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-04-11T08:01:07.123129+00:00 2 default_pool
success campaign-flow-job_v002 create_cluster_and_add_emr_steps 2021-04-11T07:00:00+00:00 EmrCreateJobFlowOperator 2021-04-11T08:00:39.653621+00:00 2021-04-11T08:00:41.397531+00:00 0:00:01.743910 15932 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 4 default 2021-04-11T08:00:37.096943+00:00 2 default_pool
success campaign-flow-job_v002 create_emr_steps 2021-04-11T07:00:00+00:00 PythonOperator 2021-04-11T08:00:19.663431+00:00 2021-04-11T08:00:23.034553+00:00 0:00:03.371122 15931 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 5 default 2021-04-11T08:00:17.083593+00:00 2 default_pool
success campaign-history-job_v002 check_cluster_status 2021-04-11T06:00:00+00:00 EmrJobFlowSensor 2021-04-11T07:11:29.870843+00:00 2021-04-11T07:20:32.574128+00:00 0:09:02.703285 15929 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-11T07:11:27.425109+00:00 2 default_pool
success booking-processing-job_v002 check_cluster_status 2021-04-11T06:00:00+00:00 EmrJobFlowSensor 2021-04-11T07:11:17.627221+00:00 2021-04-11T07:21:20.383901+00:00 0:10:02.756680 15928 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-11T07:11:15.411219+00:00 2 default_pool
success campaign-history-job_v002 create_cluster_and_add_emr_steps 2021-04-11T06:00:00+00:00 EmrCreateJobFlowOperator 2021-04-11T07:11:08.326877+00:00 2021-04-11T07:11:10.074665+00:00 0:00:01.747788 15927 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 2 default 2021-04-11T07:11:05.468532+00:00 2 default_pool
success booking-processing-job_v002 create_cluster_and_add_emr_steps 2021-04-11T06:00:00+00:00 EmrCreateJobFlowOperator 2021-04-11T07:10:56.478464+00:00 2021-04-11T07:10:58.328045+00:00 0:00:01.849581 15926 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 2 default 2021-04-11T07:10:53.397837+00:00 2 default_pool
success campaign-history-job_v002 create_emr_steps 2021-04-11T06:00:00+00:00 PythonOperator 2021-04-11T07:10:47.800505+00:00 2021-04-11T07:10:50.674599+00:00 0:00:02.874094 15925 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-04-11T07:10:45.443574+00:00 2 default_pool
success booking-processing-job_v002 create_emr_steps 2021-04-11T06:00:00+00:00 PythonOperator 2021-04-11T07:10:35.724097+00:00 2021-04-11T07:10:38.783241+00:00 0:00:03.059144 15924 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-04-11T07:10:33.337211+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_booking-processing-job_v002 2021-04-11T06:00:00+00:00 TriggerDagRunOperator 2021-04-11T07:10:29.840475+00:00 2021-04-11T07:10:30.373003+00:00 0:00:00.532528 15923 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-11T07:10:27.333196+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_campaign-history-job_v002 2021-04-11T06:00:00+00:00 TriggerDagRunOperator 2021-04-11T07:10:29.620711+00:00 2021-04-11T07:10:30.061784+00:00 0:00:00.441073 15922 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-11T07:10:27.333154+00:00 2 default_pool
success vc-asset-import_v002 check_cluster_status 2021-04-11T06:05:00+00:00 EmrJobFlowSensor 2021-04-11T07:05:51.798700+00:00 2021-04-11T07:14:54.359947+00:00 0:09:02.561247 15921 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-11T07:05:48.995803+00:00 2 default_pool
success vc-asset-import_v002 create_cluster_and_add_emr_steps 2021-04-11T06:05:00+00:00 EmrCreateJobFlowOperator 2021-04-11T07:05:31.403042+00:00 2021-04-11T07:05:33.077921+00:00 0:00:01.674879 15920 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 2 default 2021-04-11T07:05:29.043594+00:00 2 default_pool
success vc-asset-import_v002 create_emr_steps 2021-04-11T06:05:00+00:00 PythonOperator 2021-04-11T07:05:09.170610+00:00 2021-04-11T07:05:11.842844+00:00 0:00:02.672234 15919 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-04-11T07:05:06.919672+00:00 2 default_pool
success campaign-flow-job_v002 check_cluster_status 2021-04-11T06:00:00+00:00 EmrJobFlowSensor 2021-04-11T07:01:04.887310+00:00 2021-04-11T07:10:07.531856+00:00 0:09:02.644546 15918 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-04-11T07:01:02.487065+00:00 2 default_pool
success campaign-flow-job_v002 create_cluster_and_add_emr_steps 2021-04-11T06:00:00+00:00 EmrCreateJobFlowOperator 2021-04-11T07:00:42.985194+00:00 2021-04-11T07:00:44.792911+00:00 0:00:01.807717 15917 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 4 default 2021-04-11T07:00:40.446894+00:00 2 default_pool
success campaign-flow-job_v002 create_emr_steps 2021-04-11T06:00:00+00:00 PythonOperator 2021-04-11T07:00:21.329711+00:00 2021-04-11T07:00:24.277388+00:00 0:00:02.947677 15916 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 5 default 2021-04-11T07:00:18.468375+00:00 2 default_pool
success booking-processing-job_v002 check_cluster_status 2021-04-11T05:00:00+00:00 EmrJobFlowSensor 2021-04-11T06:10:24.310175+00:00 2021-04-11T06:20:27.104853+00:00 0:10:02.794678 15914 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-11T06:10:21.873277+00:00 2 default_pool