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-history-job_v002 create_cluster_and_add_emr_steps 2021-04-01T03:00:00+00:00 EmrCreateJobFlowOperator 2021-04-01T04:12:55.039146+00:00 2021-04-01T04:12:56.745812+00:00 0:00:01.706666 12279 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 2 default 2021-04-01T04:12:52.412664+00:00 2 default_pool
success booking-processing-job_v002 create_emr_steps 2021-04-01T03:00:00+00:00 PythonOperator 2021-04-01T04:12:42.674885+00:00 2021-04-01T04:12:45.581067+00:00 0:00:02.906182 12278 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-04-01T04:12:40.391585+00:00 2 default_pool
success campaign-history-job_v002 create_emr_steps 2021-04-01T03:00:00+00:00 PythonOperator 2021-04-01T04:12:33.018377+00:00 2021-04-01T04:12:35.756072+00:00 0:00:02.737695 12277 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-04-01T04:12:30.385731+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_campaign-history-job_v002 2021-04-01T03:00:00+00:00 TriggerDagRunOperator 2021-04-01T04:12:20.920521+00:00 2021-04-01T04:12:21.332754+00:00 0:00:00.412233 12276 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-01T04:12:18.356273+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_booking-processing-job_v002 2021-04-01T03:00:00+00:00 TriggerDagRunOperator 2021-04-01T04:12:20.727973+00:00 2021-04-01T04:12:21.253699+00:00 0:00:00.525726 12275 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-01T04:12:18.356349+00:00 2 default_pool
success vc-asset-import_v002 check_cluster_status 2021-04-01T03:05:00+00:00 EmrJobFlowSensor 2021-04-01T04:06:10.159976+00:00 2021-04-01T04:15:12.800931+00:00 0:09:02.640955 12274 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-01T04:06:07.846565+00:00 2 default_pool
success vc-asset-import_v002 create_cluster_and_add_emr_steps 2021-04-01T03:05:00+00:00 EmrCreateJobFlowOperator 2021-04-01T04:05:43.911140+00:00 2021-04-01T04:05:45.574095+00:00 0:00:01.662955 12273 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 2 default 2021-04-01T04:05:41.747497+00:00 2 default_pool
success vc-asset-import_v002 create_emr_steps 2021-04-01T03:05:00+00:00 PythonOperator 2021-04-01T04:05:21.880470+00:00 2021-04-01T04:05:24.569499+00:00 0:00:02.689029 12272 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-04-01T04:05:19.727321+00:00 2 default_pool
success campaign-flow-job_v002 check_cluster_status 2021-04-01T03:00:00+00:00 EmrJobFlowSensor 2021-04-01T04:03:07.952201+00:00 2021-04-01T04:12:10.612355+00:00 0:09:02.660154 12271 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-04-01T04:03:05.563828+00:00 2 default_pool
success campaign-flow-job_v002 create_cluster_and_add_emr_steps 2021-04-01T03:00:00+00:00 EmrCreateJobFlowOperator 2021-04-01T04:02:39.728759+00:00 2021-04-01T04:02:41.422565+00:00 0:00:01.693806 12270 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 4 default 2021-04-01T04:02:37.511269+00:00 2 default_pool
success campaign-flow-job_v002 create_emr_steps 2021-04-01T03:00:00+00:00 PythonOperator 2021-04-01T04:02:17.818538+00:00 2021-04-01T04:02:20.574514+00:00 0:00:02.755976 12269 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 5 default 2021-04-01T04:02:15.490681+00:00 2 default_pool
success booking-processing-job_v002 check_cluster_status 2021-04-01T02:00:00+00:00 EmrJobFlowSensor 2021-04-01T03:12:03.905080+00:00 2021-04-01T03:24:06.890037+00:00 0:12:02.984957 12267 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-01T03:12:01.701185+00:00 2 default_pool
success campaign-history-job_v002 check_cluster_status 2021-04-01T02:00:00+00:00 EmrJobFlowSensor 2021-04-01T03:11:50.187198+00:00 2021-04-01T03:21:53.010069+00:00 0:10:02.822871 12266 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-01T03:11:47.749916+00:00 2 default_pool
success booking-processing-job_v002 create_cluster_and_add_emr_steps 2021-04-01T02:00:00+00:00 EmrCreateJobFlowOperator 2021-04-01T03:11:41.923786+00:00 2021-04-01T03:11:43.628613+00:00 0:00:01.704827 12265 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 2 default 2021-04-01T03:11:39.685036+00:00 2 default_pool
success campaign-history-job_v002 create_cluster_and_add_emr_steps 2021-04-01T02:00:00+00:00 EmrCreateJobFlowOperator 2021-04-01T03:11:30.026381+00:00 2021-04-01T03:11:31.918405+00:00 0:00:01.892024 12264 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 2 default 2021-04-01T03:11:27.595702+00:00 2 default_pool
success booking-processing-job_v002 create_emr_steps 2021-04-01T02:00:00+00:00 PythonOperator 2021-04-01T03:11:20.234050+00:00 2021-04-01T03:11:23.162940+00:00 0:00:02.928890 12263 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-04-01T03:11:17.592171+00:00 2 default_pool
success campaign-history-job_v002 create_emr_steps 2021-04-01T02:00:00+00:00 PythonOperator 2021-04-01T03:11:07.914046+00:00 2021-04-01T03:11:10.833645+00:00 0:00:02.919599 12262 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-04-01T03:11:05.556048+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_campaign-history-job_v002 2021-04-01T02:00:00+00:00 TriggerDagRunOperator 2021-04-01T03:11:03.924114+00:00 2021-04-01T03:11:04.361984+00:00 0:00:00.437870 12261 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-01T03:11:01.553883+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_booking-processing-job_v002 2021-04-01T02:00:00+00:00 TriggerDagRunOperator 2021-04-01T03:11:03.902373+00:00 2021-04-01T03:11:04.484108+00:00 0:00:00.581735 12260 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-01T03:11:01.553915+00:00 2 default_pool
success vc-asset-import_v002 check_cluster_status 2021-04-01T02:05:00+00:00 EmrJobFlowSensor 2021-04-01T03:05:59.374138+00:00 2021-04-01T03:15:02.104903+00:00 0:09:02.730765 12259 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-01T03:05:57.114549+00:00 2 default_pool
success vc-asset-import_v002 create_cluster_and_add_emr_steps 2021-04-01T02:05:00+00:00 EmrCreateJobFlowOperator 2021-04-01T03:05:37.504103+00:00 2021-04-01T03:05:39.268044+00:00 0:00:01.763941 12258 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 2 default 2021-04-01T03:05:35.148081+00:00 2 default_pool
success vc-asset-import_v002 create_emr_steps 2021-04-01T02:05:00+00:00 PythonOperator 2021-04-01T03:05:15.505106+00:00 2021-04-01T03:05:18.201533+00:00 0:00:02.696427 12257 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-04-01T03:05:13.055913+00:00 2 default_pool
success campaign-flow-job_v002 check_cluster_status 2021-04-01T02:00:00+00:00 EmrJobFlowSensor 2021-04-01T03:00:54.854891+00:00 2021-04-01T03:10:57.634113+00:00 0:10:02.779222 12256 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-04-01T03:00:52.494237+00:00 2 default_pool
success campaign-flow-job_v002 create_cluster_and_add_emr_steps 2021-04-01T02:00:00+00:00 EmrCreateJobFlowOperator 2021-04-01T03:00:34.674817+00:00 2021-04-01T03:00:36.371078+00:00 0:00:01.696261 12255 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 4 default 2021-04-01T03:00:32.449952+00:00 2 default_pool
success campaign-flow-job_v002 create_emr_steps 2021-04-01T02:00:00+00:00 PythonOperator 2021-04-01T03:00:12.837654+00:00 2021-04-01T03:00:15.568722+00:00 0:00:02.731068 12254 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 5 default 2021-04-01T03:00:10.430746+00:00 2 default_pool
success booking-processing-job_v002 check_cluster_status 2021-04-01T01:00:00+00:00 EmrJobFlowSensor 2021-04-01T02:12:15.900585+00:00 2021-04-01T02:22:18.494892+00:00 0:10:02.594307 12252 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-01T02:12:13.646658+00:00 2 default_pool
success campaign-history-job_v002 check_cluster_status 2021-04-01T01:00:00+00:00 EmrJobFlowSensor 2021-04-01T02:11:56.048973+00:00 2021-04-01T02:20:58.870468+00:00 0:09:02.821495 12251 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-01T02:11:53.625802+00:00 2 default_pool
success booking-processing-job_v002 create_cluster_and_add_emr_steps 2021-04-01T01:00:00+00:00 EmrCreateJobFlowOperator 2021-04-01T02:11:56.011881+00:00 2021-04-01T02:11:57.760840+00:00 0:00:01.748959 12250 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 2 default 2021-04-01T02:11:53.625837+00:00 2 default_pool
success campaign-history-job_v002 create_cluster_and_add_emr_steps 2021-04-01T01:00:00+00:00 EmrCreateJobFlowOperator 2021-04-01T02:11:35.914072+00:00 2021-04-01T02:11:37.582424+00:00 0:00:01.668352 12249 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 2 default 2021-04-01T02:11:33.605206+00:00 2 default_pool
success booking-processing-job_v002 create_emr_steps 2021-04-01T01:00:00+00:00 PythonOperator 2021-04-01T02:11:33.946663+00:00 2021-04-01T02:11:37.058486+00:00 0:00:03.111823 12248 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-04-01T02:11:31.603974+00:00 2 default_pool
success campaign-history-job_v002 create_emr_steps 2021-04-01T01:00:00+00:00 PythonOperator 2021-04-01T02:11:11.930149+00:00 2021-04-01T02:11:14.634330+00:00 0:00:02.704181 12247 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-04-01T02:11:09.649762+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_booking-processing-job_v002 2021-04-01T01:00:00+00:00 TriggerDagRunOperator 2021-04-01T02:11:08.139683+00:00 2021-04-01T02:11:08.705961+00:00 0:00:00.566278 12246 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-01T02:11:05.584696+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_campaign-history-job_v002 2021-04-01T01:00:00+00:00 TriggerDagRunOperator 2021-04-01T02:11:07.970829+00:00 2021-04-01T02:11:08.382326+00:00 0:00:00.411497 12245 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-01T02:11:05.584664+00:00 2 default_pool
success vc-asset-import_v002 check_cluster_status 2021-04-01T01:05:00+00:00 EmrJobFlowSensor 2021-04-01T02:05:53.106418+00:00 2021-04-01T02:14:55.712818+00:00 0:09:02.606400 12244 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-01T02:05:50.912628+00:00 2 default_pool
success vc-asset-import_v002 create_cluster_and_add_emr_steps 2021-04-01T01:05:00+00:00 EmrCreateJobFlowOperator 2021-04-01T02:05:33.194355+00:00 2021-04-01T02:05:34.855327+00:00 0:00:01.660972 12243 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 2 default 2021-04-01T02:05:30.895908+00:00 2 default_pool
success vc-asset-import_v002 create_emr_steps 2021-04-01T01:05:00+00:00 PythonOperator 2021-04-01T02:05:11.095230+00:00 2021-04-01T02:05:13.776778+00:00 0:00:02.681548 12242 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-04-01T02:05:08.858740+00:00 2 default_pool
success campaign-flow-job_v002 check_cluster_status 2021-04-01T01:00:00+00:00 EmrJobFlowSensor 2021-04-01T02:00:50.798903+00:00 2021-04-01T02:10:53.624650+00:00 0:10:02.825747 12241 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-04-01T02:00:48.481740+00:00 2 default_pool
success campaign-flow-job_v002 create_cluster_and_add_emr_steps 2021-04-01T01:00:00+00:00 EmrCreateJobFlowOperator 2021-04-01T02:00:30.973226+00:00 2021-04-01T02:00:32.695345+00:00 0:00:01.722119 12240 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 4 default 2021-04-01T02:00:28.557678+00:00 2 default_pool
success campaign-flow-job_v002 create_emr_steps 2021-04-01T01:00:00+00:00 PythonOperator 2021-04-01T02:00:09.258182+00:00 2021-04-01T02:00:12.136915+00:00 0:00:02.878733 12239 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 5 default 2021-04-01T02:00:06.390566+00:00 2 default_pool
success booking-processing-job_v002 check_cluster_status 2021-04-01T00:00:00+00:00 EmrJobFlowSensor 2021-04-01T01:11:26.113219+00:00 2021-04-01T01:21:28.914356+00:00 0:10:02.801137 12237 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-01T01:11:23.935712+00:00 2 default_pool
success campaign-history-job_v002 check_cluster_status 2021-04-01T00:00:00+00:00 EmrJobFlowSensor 2021-04-01T01:11:16.396670+00:00 2021-04-01T01:20:19.235854+00:00 0:09:02.839184 12236 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-01T01:11:13.929620+00:00 2 default_pool
success booking-processing-job_v002 create_cluster_and_add_emr_steps 2021-04-01T00:00:00+00:00 EmrCreateJobFlowOperator 2021-04-01T01:11:04.390477+00:00 2021-04-01T01:11:06.129088+00:00 0:00:01.738611 12235 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 2 default 2021-04-01T01:11:01.974971+00:00 2 default_pool
success campaign-history-job_v002 create_cluster_and_add_emr_steps 2021-04-01T00:00:00+00:00 EmrCreateJobFlowOperator 2021-04-01T01:10:54.561588+00:00 2021-04-01T01:10:56.250140+00:00 0:00:01.688552 12234 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 2 default 2021-04-01T01:10:51.908666+00:00 2 default_pool
success booking-processing-job_v002 create_emr_steps 2021-04-01T00:00:00+00:00 PythonOperator 2021-04-01T01:10:42.076070+00:00 2021-04-01T01:10:44.943910+00:00 0:00:02.867840 12233 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-04-01T01:10:39.896057+00:00 2 default_pool
success campaign-history-job_v002 create_emr_steps 2021-04-01T00:00:00+00:00 PythonOperator 2021-04-01T01:10:32.773203+00:00 2021-04-01T01:10:35.576488+00:00 0:00:02.803285 12232 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-04-01T01:10:29.960826+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_campaign-history-job_v002 2021-04-01T00:00:00+00:00 TriggerDagRunOperator 2021-04-01T01:10:22.098398+00:00 2021-04-01T01:10:22.498333+00:00 0:00:00.399935 12231 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-01T01:10:19.817178+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_booking-processing-job_v002 2021-04-01T00:00:00+00:00 TriggerDagRunOperator 2021-04-01T01:10:22.115200+00:00 2021-04-01T01:10:22.756828+00:00 0:00:00.641628 12230 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-01T01:10:19.817213+00:00 2 default_pool
success vc-asset-import_v002 check_cluster_status 2021-04-01T00:05:00+00:00 EmrJobFlowSensor 2021-04-01T01:05:57.875896+00:00 2021-04-01T01:15:00.386018+00:00 0:09:02.510122 12229 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-01T01:05:55.563516+00:00 2 default_pool
success vc-asset-import_v002 create_cluster_and_add_emr_steps 2021-04-01T00:05:00+00:00 EmrCreateJobFlowOperator 2021-04-01T01:05:37.686252+00:00 2021-04-01T01:05:39.374906+00:00 0:00:01.688654 12228 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 2 default 2021-04-01T01:05:35.497818+00:00 2 default_pool
success vc-asset-import_v002 create_emr_steps 2021-04-01T00:05:00+00:00 PythonOperator 2021-04-01T01:05:15.702319+00:00 2021-04-01T01:05:18.525097+00:00 0:00:02.822778 12227 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-04-01T01:05:13.447223+00:00 2 default_pool
success campaign-flow-job_v002 check_cluster_status 2021-04-01T00:00:00+00:00 EmrJobFlowSensor 2021-04-01T01:00:55.138507+00:00 2021-04-01T01:09:57.859787+00:00 0:09:02.721280 12226 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-04-01T01:00:52.834103+00:00 2 default_pool
success campaign-flow-job_v002 create_cluster_and_add_emr_steps 2021-04-01T00:00:00+00:00 EmrCreateJobFlowOperator 2021-04-01T01:00:33.123039+00:00 2021-04-01T01:00:34.947292+00:00 0:00:01.824253 12225 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 4 default 2021-04-01T01:00:30.814489+00:00 2 default_pool
success campaign-flow-job_v002 create_emr_steps 2021-04-01T00:00:00+00:00 PythonOperator 2021-04-01T01:00:11.260377+00:00 2021-04-01T01:00:14.037546+00:00 0:00:02.777169 12224 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 5 default 2021-04-01T01:00:08.800565+00:00 2 default_pool
success campaign-history-job_v002 check_cluster_status 2021-03-31T23:00:00+00:00 EmrJobFlowSensor 2021-04-01T00:12:08.633243+00:00 2021-04-01T00:30:12.495665+00:00 0:18:03.862422 12222 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-01T00:12:06.163687+00:00 2 default_pool
success booking-processing-job_v002 check_cluster_status 2021-03-31T23:00:00+00:00 EmrJobFlowSensor 2021-04-01T00:11:54.376581+00:00 2021-04-01T00:21:57.182132+00:00 0:10:02.805551 12221 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-01T00:11:52.090276+00:00 2 default_pool
success campaign-history-job_v002 create_cluster_and_add_emr_steps 2021-03-31T23:00:00+00:00 EmrCreateJobFlowOperator 2021-04-01T00:11:48.535624+00:00 2021-04-01T00:11:50.231053+00:00 0:00:01.695429 12220 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 2 default 2021-04-01T00:11:46.155418+00:00 2 default_pool
success booking-processing-job_v002 create_cluster_and_add_emr_steps 2021-03-31T23:00:00+00:00 EmrCreateJobFlowOperator 2021-04-01T00:11:34.531244+00:00 2021-04-01T00:11:36.343108+00:00 0:00:01.811864 12219 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 2 default 2021-04-01T00:11:32.048544+00:00 2 default_pool
success campaign-history-job_v002 create_emr_steps 2021-03-31T23:00:00+00:00 PythonOperator 2021-04-01T00:11:26.199669+00:00 2021-04-01T00:11:28.895572+00:00 0:00:02.695903 12218 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-04-01T00:11:24.058255+00:00 2 default_pool
success booking-processing-job_v002 create_emr_steps 2021-03-31T23:00:00+00:00 PythonOperator 2021-04-01T00:11:12.270425+00:00 2021-04-01T00:11:15.333006+00:00 0:00:03.062581 12217 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-04-01T00:11:10.036288+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_campaign-history-job_v002 2021-03-31T23:00:00+00:00 TriggerDagRunOperator 2021-04-01T00:11:06.735676+00:00 2021-04-01T00:11:07.234167+00:00 0:00:00.498491 12216 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-01T00:11:04.030959+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_booking-processing-job_v002 2021-03-31T23:00:00+00:00 TriggerDagRunOperator 2021-04-01T00:11:06.223634+00:00 2021-04-01T00:11:06.632401+00:00 0:00:00.408767 12215 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-01T00:11:04.030992+00:00 2 default_pool
success vc-asset-import_v002 check_cluster_status 2021-03-31T23:05:00+00:00 EmrJobFlowSensor 2021-04-01T00:06:02.299061+00:00 2021-04-01T00:15:05.046866+00:00 0:09:02.747805 12214 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-01T00:05:59.840697+00:00 2 default_pool
success vc-asset-import_v002 create_cluster_and_add_emr_steps 2021-03-31T23:05:00+00:00 EmrCreateJobFlowOperator 2021-04-01T00:05:40.065320+00:00 2021-04-01T00:05:41.725124+00:00 0:00:01.659804 12213 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 2 default 2021-04-01T00:05:37.687603+00:00 2 default_pool
success vc-asset-import_v002 create_emr_steps 2021-03-31T23:05:00+00:00 PythonOperator 2021-04-01T00:05:19.978566+00:00 2021-04-01T00:05:22.789336+00:00 0:00:02.810770 12212 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-04-01T00:05:17.621895+00:00 2 default_pool
success campaign-flow-job_v002 check_cluster_status 2021-03-31T23:00:00+00:00 EmrJobFlowSensor 2021-04-01T00:00:57.606862+00:00 2021-04-01T00:11:00.406859+00:00 0:10:02.799997 12211 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-04-01T00:00:55.332367+00:00 2 default_pool
success campaign-flow-job_v002 create_cluster_and_add_emr_steps 2021-03-31T23:00:00+00:00 EmrCreateJobFlowOperator 2021-04-01T00:00:37.637197+00:00 2021-04-01T00:00:39.454693+00:00 0:00:01.817496 12210 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 4 default 2021-04-01T00:00:35.315027+00:00 2 default_pool
success campaign-flow-job_v002 create_emr_steps 2021-03-31T23:00:00+00:00 PythonOperator 2021-04-01T00:00:03.633240+00:00 2021-04-01T00:00:06.477073+00:00 0:00:02.843833 12209 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 5 default 2021-04-01T00:00:01.284056+00:00 2 default_pool
success booking-processing-job_v002 check_cluster_status 2021-03-31T22:00:00+00:00 EmrJobFlowSensor 2021-03-31T23:12:06.614245+00:00 2021-03-31T23:21:09.227682+00:00 0:09:02.613437 12207 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-03-31T23:12:04.260325+00:00 2 default_pool
success campaign-history-job_v002 check_cluster_status 2021-03-31T22:00:00+00:00 EmrJobFlowSensor 2021-03-31T23:11:52.322077+00:00 2021-03-31T23:20:55.029324+00:00 0:09:02.707247 12206 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-03-31T23:11:50.122946+00:00 2 default_pool
success booking-processing-job_v002 create_cluster_and_add_emr_steps 2021-03-31T22:00:00+00:00 EmrCreateJobFlowOperator 2021-03-31T23:11:44.438517+00:00 2021-03-31T23:11:46.261181+00:00 0:00:01.822664 12205 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 2 default 2021-03-31T23:11:42.117596+00:00 2 default_pool
success campaign-history-job_v002 create_cluster_and_add_emr_steps 2021-03-31T22:00:00+00:00 EmrCreateJobFlowOperator 2021-03-31T23:11:30.789364+00:00 2021-03-31T23:11:32.509985+00:00 0:00:01.720621 12204 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 2 default 2021-03-31T23:11:28.109958+00:00 2 default_pool
success booking-processing-job_v002 create_emr_steps 2021-03-31T22:00:00+00:00 PythonOperator 2021-03-31T23:11:22.496732+00:00 2021-03-31T23:11:25.454778+00:00 0:00:02.958046 12203 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-03-31T23:11:20.153261+00:00 2 default_pool
success campaign-history-job_v002 create_emr_steps 2021-03-31T22:00:00+00:00 PythonOperator 2021-03-31T23:11:08.564891+00:00 2021-03-31T23:11:11.427203+00:00 0:00:02.862312 12202 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-03-31T23:11:06.089903+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_booking-processing-job_v002 2021-03-31T22:00:00+00:00 TriggerDagRunOperator 2021-03-31T23:11:02.571136+00:00 2021-03-31T23:11:03.288803+00:00 0:00:00.717667 12201 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-03-31T23:11:00.093962+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_campaign-history-job_v002 2021-03-31T22:00:00+00:00 TriggerDagRunOperator 2021-03-31T23:11:02.377303+00:00 2021-03-31T23:11:02.835053+00:00 0:00:00.457750 12200 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-03-31T23:11:00.093928+00:00 2 default_pool
success vc-asset-import_v002 check_cluster_status 2021-03-31T22:05:00+00:00 EmrJobFlowSensor 2021-03-31T23:05:53.786735+00:00 2021-03-31T23:13:56.346977+00:00 0:08:02.560242 12199 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-03-31T23:05:51.625268+00:00 2 default_pool
success vc-asset-import_v002 create_cluster_and_add_emr_steps 2021-03-31T22:05:00+00:00 EmrCreateJobFlowOperator 2021-03-31T23:05:31.779865+00:00 2021-03-31T23:05:33.572303+00:00 0:00:01.792438 12198 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 2 default 2021-03-31T23:05:29.607329+00:00 2 default_pool
success vc-asset-import_v002 create_emr_steps 2021-03-31T22:05:00+00:00 PythonOperator 2021-03-31T23:05:09.728476+00:00 2021-03-31T23:05:12.410886+00:00 0:00:02.682410 12197 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-03-31T23:05:07.589975+00:00 2 default_pool
success campaign-flow-job_v002 check_cluster_status 2021-03-31T22:00:00+00:00 EmrJobFlowSensor 2021-03-31T23:00:49.411251+00:00 2021-03-31T23:10:52.390451+00:00 0:10:02.979200 12196 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-03-31T23:00:47.030932+00:00 2 default_pool
success campaign-flow-job_v002 create_cluster_and_add_emr_steps 2021-03-31T22:00:00+00:00 EmrCreateJobFlowOperator 2021-03-31T23:00:27.294368+00:00 2021-03-31T23:00:29.107023+00:00 0:00:01.812655 12195 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 4 default 2021-03-31T23:00:25.006361+00:00 2 default_pool
success campaign-flow-job_v002 create_emr_steps 2021-03-31T22:00:00+00:00 PythonOperator 2021-03-31T23:00:07.289510+00:00 2021-03-31T23:00:10.040561+00:00 0:00:02.751051 12194 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 5 default 2021-03-31T23:00:04.987123+00:00 2 default_pool
success booking-processing-job_v002 check_cluster_status 2021-03-31T21:00:00+00:00 EmrJobFlowSensor 2021-03-31T22:12:26.890127+00:00 2021-03-31T22:22:29.728471+00:00 0:10:02.838344 12192 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-03-31T22:12:24.618659+00:00 2 default_pool
success campaign-history-job_v002 check_cluster_status 2021-03-31T21:00:00+00:00 EmrJobFlowSensor 2021-03-31T22:12:18.794057+00:00 2021-03-31T22:20:21.304353+00:00 0:08:02.510296 12191 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-03-31T22:12:16.611004+00:00 2 default_pool
success booking-processing-job_v002 create_cluster_and_add_emr_steps 2021-03-31T21:00:00+00:00 EmrCreateJobFlowOperator 2021-03-31T22:12:05.177284+00:00 2021-03-31T22:12:06.902374+00:00 0:00:01.725090 12190 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 2 default 2021-03-31T22:12:02.672546+00:00 2 default_pool
success campaign-history-job_v002 create_cluster_and_add_emr_steps 2021-03-31T21:00:00+00:00 EmrCreateJobFlowOperator 2021-03-31T22:11:57.097332+00:00 2021-03-31T22:11:58.814923+00:00 0:00:01.717591 12189 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 2 default 2021-03-31T22:11:54.602732+00:00 2 default_pool
success booking-processing-job_v002 create_emr_steps 2021-03-31T21:00:00+00:00 PythonOperator 2021-03-31T22:11:44.970531+00:00 2021-03-31T22:11:48.002864+00:00 0:00:03.032333 12188 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-03-31T22:11:42.591265+00:00 2 default_pool
success campaign-history-job_v002 create_emr_steps 2021-03-31T21:00:00+00:00 PythonOperator 2021-03-31T22:11:36.840795+00:00 2021-03-31T22:11:39.842913+00:00 0:00:03.002118 12187 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-03-31T22:11:34.538797+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_campaign-history-job_v002 2021-03-31T21:00:00+00:00 TriggerDagRunOperator 2021-03-31T22:11:29.025081+00:00 2021-03-31T22:11:29.561027+00:00 0:00:00.535946 12186 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-03-31T22:11:26.544800+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_booking-processing-job_v002 2021-03-31T21:00:00+00:00 TriggerDagRunOperator 2021-03-31T22:11:28.888016+00:00 2021-03-31T22:11:29.300898+00:00 0:00:00.412882 12185 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-03-31T22:11:26.544830+00:00 2 default_pool
success vc-asset-import_v002 check_cluster_status 2021-03-31T21:05:00+00:00 EmrJobFlowSensor 2021-03-31T22:06:02.371712+00:00 2021-03-31T22:15:05.043207+00:00 0:09:02.671495 12184 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-03-31T22:06:00.153099+00:00 2 default_pool
success vc-asset-import_v002 create_cluster_and_add_emr_steps 2021-03-31T21:05:00+00:00 EmrCreateJobFlowOperator 2021-03-31T22:05:40.189423+00:00 2021-03-31T22:05:41.933880+00:00 0:00:01.744457 12183 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 2 default 2021-03-31T22:05:38.006528+00:00 2 default_pool
success vc-asset-import_v002 create_emr_steps 2021-03-31T21:05:00+00:00 PythonOperator 2021-03-31T22:05:20.255398+00:00 2021-03-31T22:05:23.032163+00:00 0:00:02.776765 12182 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-03-31T22:05:17.990346+00:00 2 default_pool
success campaign-flow-job_v002 check_cluster_status 2021-03-31T21:00:00+00:00 EmrJobFlowSensor 2021-03-31T22:00:53.807986+00:00 2021-03-31T22:10:56.640402+00:00 0:10:02.832416 12181 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-03-31T22:00:51.633166+00:00 2 default_pool
success campaign-flow-job_v002 create_cluster_and_add_emr_steps 2021-03-31T21:00:00+00:00 EmrCreateJobFlowOperator 2021-03-31T22:00:32.037765+00:00 2021-03-31T22:00:33.719758+00:00 0:00:01.681993 12180 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 4 default 2021-03-31T22:00:29.668714+00:00 2 default_pool
success campaign-flow-job_v002 create_emr_steps 2021-03-31T21:00:00+00:00 PythonOperator 2021-03-31T22:00:10.102942+00:00 2021-03-31T22:00:12.815788+00:00 0:00:02.712846 12179 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 5 default 2021-03-31T22:00:07.657862+00:00 2 default_pool
success booking-processing-job_v002 check_cluster_status 2021-03-31T20:00:00+00:00 EmrJobFlowSensor 2021-03-31T21:11:19.484060+00:00 2021-03-31T21:21:22.409348+00:00 0:10:02.925288 12177 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-03-31T21:11:16.800631+00:00 2 default_pool
success campaign-history-job_v002 check_cluster_status 2021-03-31T20:00:00+00:00 EmrJobFlowSensor 2021-03-31T21:11:19.125314+00:00 2021-03-31T21:20:21.724783+00:00 0:09:02.599469 12176 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-03-31T21:11:16.800663+00:00 2 default_pool
success campaign-history-job_v002 create_cluster_and_add_emr_steps 2021-03-31T20:00:00+00:00 EmrCreateJobFlowOperator 2021-03-31T21:10:57.355179+00:00 2021-03-31T21:10:59.192042+00:00 0:00:01.836863 12175 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 2 default 2021-03-31T21:10:54.785078+00:00 2 default_pool
success booking-processing-job_v002 create_cluster_and_add_emr_steps 2021-03-31T20:00:00+00:00 EmrCreateJobFlowOperator 2021-03-31T21:10:57.290923+00:00 2021-03-31T21:10:59.016920+00:00 0:00:01.725997 12174 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 2 default 2021-03-31T21:10:54.785050+00:00 2 default_pool
success booking-processing-job_v002 create_emr_steps 2021-03-31T20:00:00+00:00 PythonOperator 2021-03-31T21:10:37.456293+00:00 2021-03-31T21:10:40.389542+00:00 0:00:02.933249 12173 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-03-31T21:10:34.771809+00:00 2 default_pool