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-10T07:00:00+00:00 EmrCreateJobFlowOperator 2021-04-10T08:12:23.813298+00:00 2021-04-10T08:12:25.706758+00:00 0:00:01.893460 15581 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 2 default 2021-04-10T08:12:21.252423+00:00 2 default_pool
success booking-processing-job_v002 create_cluster_and_add_emr_steps 2021-04-10T07:00:00+00:00 EmrCreateJobFlowOperator 2021-04-10T08:12:05.781065+00:00 2021-04-10T08:12:07.572906+00:00 0:00:01.791841 15580 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 2 default 2021-04-10T08:12:03.098256+00:00 2 default_pool
success campaign-history-job_v002 create_emr_steps 2021-04-10T07:00:00+00:00 PythonOperator 2021-04-10T08:12:03.533967+00:00 2021-04-10T08:12:06.552207+00:00 0:00:03.018240 15579 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-04-10T08:12:01.143800+00:00 2 default_pool
success booking-processing-job_v002 create_emr_steps 2021-04-10T07:00:00+00:00 PythonOperator 2021-04-10T08:11:39.661837+00:00 2021-04-10T08:11:42.701390+00:00 0:00:03.039553 15578 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-04-10T08:11:37.013556+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_campaign-history-job_v002 2021-04-10T07:00:00+00:00 TriggerDagRunOperator 2021-04-10T08:11:33.369591+00:00 2021-04-10T08:11:33.964777+00:00 0:00:00.595186 15577 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-10T08:11:31.011511+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_booking-processing-job_v002 2021-04-10T07:00:00+00:00 TriggerDagRunOperator 2021-04-10T08:11:33.263617+00:00 2021-04-10T08:11:33.685596+00:00 0:00:00.421979 15576 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-10T08:11:31.011542+00:00 2 default_pool
success vc-asset-import_v002 check_cluster_status 2021-04-10T07:05:00+00:00 EmrJobFlowSensor 2021-04-10T08:06:03.013119+00:00 2021-04-10T08:14:05.567045+00:00 0:08:02.553926 15575 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-10T08:06:00.454433+00:00 2 default_pool
success vc-asset-import_v002 create_cluster_and_add_emr_steps 2021-04-10T07:05:00+00:00 EmrCreateJobFlowOperator 2021-04-10T08:05:40.778075+00:00 2021-04-10T08:05:42.511452+00:00 0:00:01.733377 15574 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 2 default 2021-04-10T08:05:38.440825+00:00 2 default_pool
success vc-asset-import_v002 create_emr_steps 2021-04-10T07:05:00+00:00 PythonOperator 2021-04-10T08:05:20.460562+00:00 2021-04-10T08:05:23.207956+00:00 0:00:02.747394 15573 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-04-10T08:05:18.300076+00:00 2 default_pool
success campaign-flow-job_v002 check_cluster_status 2021-04-10T07:00:00+00:00 EmrJobFlowSensor 2021-04-10T08:01:06.411954+00:00 2021-04-10T08:11:09.381907+00:00 0:10:02.969953 15572 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-04-10T08:01:04.010216+00:00 2 default_pool
success campaign-flow-job_v002 create_cluster_and_add_emr_steps 2021-04-10T07:00:00+00:00 EmrCreateJobFlowOperator 2021-04-10T08:00:44.225267+00:00 2021-04-10T08:00:45.933569+00:00 0:00:01.708302 15571 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 4 default 2021-04-10T08:00:41.942558+00:00 2 default_pool
success campaign-flow-job_v002 create_emr_steps 2021-04-10T07:00:00+00:00 PythonOperator 2021-04-10T08:00:20.709938+00:00 2021-04-10T08:00:23.423850+00:00 0:00:02.713912 15570 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 5 default 2021-04-10T08:00:17.984418+00:00 2 default_pool
success campaign-history-job_v002 check_cluster_status 2021-04-10T06:00:00+00:00 EmrJobFlowSensor 2021-04-10T07:10:08.470953+00:00 2021-04-10T07:19:11.144993+00:00 0:09:02.674040 15568 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-10T07:10:06.188043+00:00 2 default_pool
success booking-processing-job_v002 check_cluster_status 2021-04-10T06:00:00+00:00 EmrJobFlowSensor 2021-04-10T07:09:54.439057+00:00 2021-04-10T07:19:57.107726+00:00 0:10:02.668669 15567 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-10T07:09:52.123590+00:00 2 default_pool
success campaign-history-job_v002 create_cluster_and_add_emr_steps 2021-04-10T06:00:00+00:00 EmrCreateJobFlowOperator 2021-04-10T07:09:46.482744+00:00 2021-04-10T07:09:48.559287+00:00 0:00:02.076543 15566 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 2 default 2021-04-10T07:09:44.111481+00:00 2 default_pool
success booking-processing-job_v002 create_cluster_and_add_emr_steps 2021-04-10T06:00:00+00:00 EmrCreateJobFlowOperator 2021-04-10T07:09:34.334915+00:00 2021-04-10T07:09:36.313461+00:00 0:00:01.978546 15565 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 2 default 2021-04-10T07:09:32.099237+00:00 2 default_pool
success campaign-history-job_v002 create_emr_steps 2021-04-10T06:00:00+00:00 PythonOperator 2021-04-10T07:09:24.628867+00:00 2021-04-10T07:09:27.470686+00:00 0:00:02.841819 15564 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-04-10T07:09:22.155244+00:00 2 default_pool
success booking-processing-job_v002 create_emr_steps 2021-04-10T06:00:00+00:00 PythonOperator 2021-04-10T07:09:10.552240+00:00 2021-04-10T07:09:13.911356+00:00 0:00:03.359116 15563 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-04-10T07:09:08.052884+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_booking-processing-job_v002 2021-04-10T06:00:00+00:00 TriggerDagRunOperator 2021-04-10T07:09:00.857496+00:00 2021-04-10T07:09:01.476865+00:00 0:00:00.619369 15562 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-10T07:08:58.066045+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_campaign-history-job_v002 2021-04-10T06:00:00+00:00 TriggerDagRunOperator 2021-04-10T07:09:00.646272+00:00 2021-04-10T07:09:01.067880+00:00 0:00:00.421608 15561 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-10T07:08:58.065999+00:00 2 default_pool
success vc-asset-import_v002 check_cluster_status 2021-04-10T06:05:00+00:00 EmrJobFlowSensor 2021-04-10T07:06:02.018988+00:00 2021-04-10T07:14:04.579136+00:00 0:08:02.560148 15560 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-10T07:05:59.783208+00:00 2 default_pool
success vc-asset-import_v002 create_cluster_and_add_emr_steps 2021-04-10T06:05:00+00:00 EmrCreateJobFlowOperator 2021-04-10T07:05:40.142587+00:00 2021-04-10T07:05:41.879762+00:00 0:00:01.737175 15559 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 2 default 2021-04-10T07:05:37.725393+00:00 2 default_pool
success vc-asset-import_v002 create_emr_steps 2021-04-10T06:05:00+00:00 PythonOperator 2021-04-10T07:05:19.744070+00:00 2021-04-10T07:05:22.427945+00:00 0:00:02.683875 15558 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-04-10T07:05:17.627017+00:00 2 default_pool
success campaign-flow-job_v002 check_cluster_status 2021-04-10T06:00:00+00:00 EmrJobFlowSensor 2021-04-10T07:00:51.401953+00:00 2021-04-10T07:08:54.060017+00:00 0:08:02.658064 15557 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-04-10T07:00:49.206219+00:00 2 default_pool
success campaign-flow-job_v002 create_cluster_and_add_emr_steps 2021-04-10T06:00:00+00:00 EmrCreateJobFlowOperator 2021-04-10T07:00:29.423465+00:00 2021-04-10T07:00:31.147311+00:00 0:00:01.723846 15556 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 4 default 2021-04-10T07:00:27.157082+00:00 2 default_pool
success campaign-flow-job_v002 create_emr_steps 2021-04-10T06:00:00+00:00 PythonOperator 2021-04-10T07:00:09.775057+00:00 2021-04-10T07:00:12.624379+00:00 0:00:02.849322 15555 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 5 default 2021-04-10T07:00:07.133706+00:00 2 default_pool
success booking-processing-job_v002 check_cluster_status 2021-04-10T05:00:00+00:00 EmrJobFlowSensor 2021-04-10T06:10:57.390602+00:00 2021-04-10T06:19:59.975038+00:00 0:09:02.584436 15553 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-10T06:10:55.158410+00:00 2 default_pool
success campaign-history-job_v002 check_cluster_status 2021-04-10T05:00:00+00:00 EmrJobFlowSensor 2021-04-10T06:10:49.453537+00:00 2021-04-10T06:19:52.026528+00:00 0:09:02.572991 15552 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-10T06:10:47.154378+00:00 2 default_pool
success booking-processing-job_v002 create_cluster_and_add_emr_steps 2021-04-10T05:00:00+00:00 EmrCreateJobFlowOperator 2021-04-10T06:10:35.520509+00:00 2021-04-10T06:10:37.281003+00:00 0:00:01.760494 15551 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 2 default 2021-04-10T06:10:33.159206+00:00 2 default_pool
success campaign-history-job_v002 create_cluster_and_add_emr_steps 2021-04-10T05:00:00+00:00 EmrCreateJobFlowOperator 2021-04-10T06:10:27.391432+00:00 2021-04-10T06:10:29.203208+00:00 0:00:01.811776 15550 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 2 default 2021-04-10T06:10:25.111210+00:00 2 default_pool
success booking-processing-job_v002 create_emr_steps 2021-04-10T05:00:00+00:00 PythonOperator 2021-04-10T06:10:13.520577+00:00 2021-04-10T06:10:16.447639+00:00 0:00:02.927062 15549 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-04-10T06:10:11.100283+00:00 2 default_pool
success campaign-history-job_v002 create_emr_steps 2021-04-10T05:00:00+00:00 PythonOperator 2021-04-10T06:10:07.401336+00:00 2021-04-10T06:10:10.143906+00:00 0:00:02.742570 15548 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-04-10T06:10:05.096158+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_booking-processing-job_v002 2021-04-10T05:00:00+00:00 TriggerDagRunOperator 2021-04-10T06:09:59.830981+00:00 2021-04-10T06:10:00.362335+00:00 0:00:00.531354 15547 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-10T06:09:57.163089+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_campaign-history-job_v002 2021-04-10T05:00:00+00:00 TriggerDagRunOperator 2021-04-10T06:09:59.524187+00:00 2021-04-10T06:09:59.940236+00:00 0:00:00.416049 15546 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-10T06:09:57.163048+00:00 2 default_pool
success vc-asset-import_v002 check_cluster_status 2021-04-10T05:05:00+00:00 EmrJobFlowSensor 2021-04-10T06:05:57.010308+00:00 2021-04-10T06:14:59.579596+00:00 0:09:02.569288 15545 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-10T06:05:54.697953+00:00 2 default_pool
success vc-asset-import_v002 create_cluster_and_add_emr_steps 2021-04-10T05:05:00+00:00 EmrCreateJobFlowOperator 2021-04-10T06:05:35.276721+00:00 2021-04-10T06:05:36.973253+00:00 0:00:01.696532 15544 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 2 default 2021-04-10T06:05:32.675657+00:00 2 default_pool
success vc-asset-import_v002 create_emr_steps 2021-04-10T05:05:00+00:00 PythonOperator 2021-04-10T06:05:12.759695+00:00 2021-04-10T06:05:15.417468+00:00 0:00:02.657773 15543 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-04-10T06:05:10.617192+00:00 2 default_pool
success campaign-flow-job_v002 check_cluster_status 2021-04-10T05:00:00+00:00 EmrJobFlowSensor 2021-04-10T06:00:52.321989+00:00 2021-04-10T06:09:55.135472+00:00 0:09:02.813483 15542 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-04-10T06:00:50.081321+00:00 2 default_pool
success campaign-flow-job_v002 create_cluster_and_add_emr_steps 2021-04-10T05:00:00+00:00 EmrCreateJobFlowOperator 2021-04-10T06:00:30.305038+00:00 2021-04-10T06:00:32.118912+00:00 0:00:01.813874 15541 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 4 default 2021-04-10T06:00:28.045303+00:00 2 default_pool
success campaign-flow-job_v002 create_emr_steps 2021-04-10T05:00:00+00:00 PythonOperator 2021-04-10T06:00:10.487772+00:00 2021-04-10T06:00:13.369265+00:00 0:00:02.881493 15540 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 5 default 2021-04-10T06:00:08.013583+00:00 2 default_pool
success booking-processing-job_v002 check_cluster_status 2021-04-10T04:00:00+00:00 EmrJobFlowSensor 2021-04-10T05:10:58.869529+00:00 2021-04-10T05:21:01.700964+00:00 0:10:02.831435 15538 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-10T05:10:56.236441+00:00 2 default_pool
success campaign-history-job_v002 check_cluster_status 2021-04-10T04:00:00+00:00 EmrJobFlowSensor 2021-04-10T05:10:56.416364+00:00 2021-04-10T05:20:59.591210+00:00 0:10:03.174846 15537 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-10T05:10:54.236533+00:00 2 default_pool
success booking-processing-job_v002 create_cluster_and_add_emr_steps 2021-04-10T04:00:00+00:00 EmrCreateJobFlowOperator 2021-04-10T05:10:36.977857+00:00 2021-04-10T05:10:38.635480+00:00 0:00:01.657623 15536 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 2 default 2021-04-10T05:10:34.274303+00:00 2 default_pool
success campaign-history-job_v002 create_cluster_and_add_emr_steps 2021-04-10T04:00:00+00:00 EmrCreateJobFlowOperator 2021-04-10T05:10:34.608655+00:00 2021-04-10T05:10:36.602607+00:00 0:00:01.993952 15535 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 2 default 2021-04-10T05:10:32.018543+00:00 2 default_pool
success booking-processing-job_v002 create_emr_steps 2021-04-10T04:00:00+00:00 PythonOperator 2021-04-10T05:10:14.856758+00:00 2021-04-10T05:10:17.781120+00:00 0:00:02.924362 15534 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-04-10T05:10:12.068246+00:00 2 default_pool
success campaign-history-job_v002 create_emr_steps 2021-04-10T04:00:00+00:00 PythonOperator 2021-04-10T05:10:12.282112+00:00 2021-04-10T05:10:15.495126+00:00 0:00:03.213014 15533 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-04-10T05:10:09.999121+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_booking-processing-job_v002 2021-04-10T04:00:00+00:00 TriggerDagRunOperator 2021-04-10T05:10:04.877547+00:00 2021-04-10T05:10:05.403497+00:00 0:00:00.525950 15532 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-10T05:10:01.813948+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_campaign-history-job_v002 2021-04-10T04:00:00+00:00 TriggerDagRunOperator 2021-04-10T05:10:04.619132+00:00 2021-04-10T05:10:05.046593+00:00 0:00:00.427461 15531 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-10T05:10:01.813901+00:00 2 default_pool
success vc-asset-import_v002 check_cluster_status 2021-04-10T04:05:00+00:00 EmrJobFlowSensor 2021-04-10T05:05:59.849609+00:00 2021-04-10T05:15:02.694818+00:00 0:09:02.845209 15530 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-10T05:05:57.388350+00:00 2 default_pool
success vc-asset-import_v002 create_cluster_and_add_emr_steps 2021-04-10T04:05:00+00:00 EmrCreateJobFlowOperator 2021-04-10T05:05:37.555492+00:00 2021-04-10T05:05:39.194749+00:00 0:00:01.639257 15529 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 2 default 2021-04-10T05:05:35.337725+00:00 2 default_pool
success vc-asset-import_v002 create_emr_steps 2021-04-10T04:05:00+00:00 PythonOperator 2021-04-10T05:05:17.623206+00:00 2021-04-10T05:05:20.427025+00:00 0:00:02.803819 15528 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-04-10T05:05:15.262253+00:00 2 default_pool
success campaign-flow-job_v002 check_cluster_status 2021-04-10T04:00:00+00:00 EmrJobFlowSensor 2021-04-10T05:00:56.823186+00:00 2021-04-10T05:09:59.361153+00:00 0:09:02.537967 15527 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-04-10T05:00:54.696059+00:00 2 default_pool
success campaign-flow-job_v002 create_cluster_and_add_emr_steps 2021-04-10T04:00:00+00:00 EmrCreateJobFlowOperator 2021-04-10T05:00:36.884667+00:00 2021-04-10T05:00:38.582393+00:00 0:00:01.697726 15526 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 4 default 2021-04-10T05:00:34.683375+00:00 2 default_pool
success campaign-flow-job_v002 create_emr_steps 2021-04-10T04:00:00+00:00 PythonOperator 2021-04-10T05:00:13.007419+00:00 2021-04-10T05:00:15.877605+00:00 0:00:02.870186 15525 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 5 default 2021-04-10T05:00:10.617372+00:00 2 default_pool
success booking-processing-job_v002 check_cluster_status 2021-04-10T03:00:00+00:00 EmrJobFlowSensor 2021-04-10T04:12:28.874904+00:00 2021-04-10T04:23:31.808371+00:00 0:11:02.933467 15523 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-10T04:12:26.607257+00:00 2 default_pool
success campaign-history-job_v002 check_cluster_status 2021-04-10T03:00:00+00:00 EmrJobFlowSensor 2021-04-10T04:12:25.007225+00:00 2021-04-10T04:21:27.674797+00:00 0:09:02.667572 15522 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-10T04:12:22.611000+00:00 2 default_pool
success booking-processing-job_v002 create_cluster_and_add_emr_steps 2021-04-10T03:00:00+00:00 EmrCreateJobFlowOperator 2021-04-10T04:12:06.772208+00:00 2021-04-10T04:12:08.502047+00:00 0:00:01.729839 15521 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 2 default 2021-04-10T04:12:04.588058+00:00 2 default_pool
success campaign-history-job_v002 create_cluster_and_add_emr_steps 2021-04-10T03:00:00+00:00 EmrCreateJobFlowOperator 2021-04-10T04:12:03.130053+00:00 2021-04-10T04:12:04.859225+00:00 0:00:01.729172 15520 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 2 default 2021-04-10T04:12:00.655804+00:00 2 default_pool
success booking-processing-job_v002 create_emr_steps 2021-04-10T03:00:00+00:00 PythonOperator 2021-04-10T04:11:44.993789+00:00 2021-04-10T04:11:48.224066+00:00 0:00:03.230277 15519 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-04-10T04:11:42.572332+00:00 2 default_pool
success campaign-history-job_v002 create_emr_steps 2021-04-10T03:00:00+00:00 PythonOperator 2021-04-10T04:11:40.907313+00:00 2021-04-10T04:11:43.767637+00:00 0:00:02.860324 15518 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-04-10T04:11:38.489625+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_booking-processing-job_v002 2021-04-10T03:00:00+00:00 TriggerDagRunOperator 2021-04-10T04:11:25.519765+00:00 2021-04-10T04:11:26.024661+00:00 0:00:00.504896 15517 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-10T04:11:22.486160+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_campaign-history-job_v002 2021-04-10T03:00:00+00:00 TriggerDagRunOperator 2021-04-10T04:11:25.278936+00:00 2021-04-10T04:11:25.700097+00:00 0:00:00.421161 15516 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-10T04:11:22.486133+00:00 2 default_pool
success vc-asset-import_v002 check_cluster_status 2021-04-10T03:05:00+00:00 EmrJobFlowSensor 2021-04-10T04:05:56.281468+00:00 2021-04-10T04:14:58.733897+00:00 0:09:02.452429 15515 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-10T04:05:53.972858+00:00 2 default_pool
success vc-asset-import_v002 create_cluster_and_add_emr_steps 2021-04-10T03:05:00+00:00 EmrCreateJobFlowOperator 2021-04-10T04:05:34.213122+00:00 2021-04-10T04:05:36.032413+00:00 0:00:01.819291 15514 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 2 default 2021-04-10T04:05:31.884603+00:00 2 default_pool
success vc-asset-import_v002 create_emr_steps 2021-04-10T03:05:00+00:00 PythonOperator 2021-04-10T04:05:14.315667+00:00 2021-04-10T04:05:17.059837+00:00 0:00:02.744170 15513 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-04-10T04:05:11.850561+00:00 2 default_pool
success campaign-flow-job_v002 check_cluster_status 2021-04-10T03:00:00+00:00 EmrJobFlowSensor 2021-04-10T04:01:01.752430+00:00 2021-04-10T04:11:04.513606+00:00 0:10:02.761176 15512 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-04-10T04:00:59.511282+00:00 2 default_pool
success campaign-flow-job_v002 create_cluster_and_add_emr_steps 2021-04-10T03:00:00+00:00 EmrCreateJobFlowOperator 2021-04-10T04:00:37.744702+00:00 2021-04-10T04:00:39.566996+00:00 0:00:01.822294 15511 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 4 default 2021-04-10T04:00:35.494713+00:00 2 default_pool
success campaign-flow-job_v002 create_emr_steps 2021-04-10T03:00:00+00:00 PythonOperator 2021-04-10T04:00:15.919052+00:00 2021-04-10T04:00:18.761409+00:00 0:00:02.842357 15510 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 5 default 2021-04-10T04:00:13.478051+00:00 2 default_pool
success booking-processing-job_v002 check_cluster_status 2021-04-10T02:00:00+00:00 EmrJobFlowSensor 2021-04-10T03:11:05.904982+00:00 2021-04-10T03:21:08.818144+00:00 0:10:02.913162 15508 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-10T03:11:03.529708+00:00 2 default_pool
success campaign-history-job_v002 check_cluster_status 2021-04-10T02:00:00+00:00 EmrJobFlowSensor 2021-04-10T03:10:57.992010+00:00 2021-04-10T03:19:00.474210+00:00 0:08:02.482200 15507 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-10T03:10:55.524219+00:00 2 default_pool
success booking-processing-job_v002 create_cluster_and_add_emr_steps 2021-04-10T02:00:00+00:00 EmrCreateJobFlowOperator 2021-04-10T03:10:45.809221+00:00 2021-04-10T03:10:47.512033+00:00 0:00:01.702812 15506 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 2 default 2021-04-10T03:10:43.514913+00:00 2 default_pool
success campaign-history-job_v002 create_cluster_and_add_emr_steps 2021-04-10T02:00:00+00:00 EmrCreateJobFlowOperator 2021-04-10T03:10:35.899706+00:00 2021-04-10T03:10:37.697293+00:00 0:00:01.797587 15505 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 2 default 2021-04-10T03:10:33.508065+00:00 2 default_pool
success booking-processing-job_v002 create_emr_steps 2021-04-10T02:00:00+00:00 PythonOperator 2021-04-10T03:10:24.212814+00:00 2021-04-10T03:10:27.393146+00:00 0:00:03.180332 15504 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-04-10T03:10:21.568146+00:00 2 default_pool
success campaign-history-job_v002 create_emr_steps 2021-04-10T02:00:00+00:00 PythonOperator 2021-04-10T03:10:15.686467+00:00 2021-04-10T03:10:18.392687+00:00 0:00:02.706220 15503 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-04-10T03:10:13.495272+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_booking-processing-job_v002 2021-04-10T02:00:00+00:00 TriggerDagRunOperator 2021-04-10T03:10:02.142363+00:00 2021-04-10T03:10:02.774395+00:00 0:00:00.632032 15502 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-10T03:09:59.456246+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_campaign-history-job_v002 2021-04-10T02:00:00+00:00 TriggerDagRunOperator 2021-04-10T03:10:02.131194+00:00 2021-04-10T03:10:02.574626+00:00 0:00:00.443432 15501 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-10T03:09:59.456197+00:00 2 default_pool
success vc-asset-import_v002 check_cluster_status 2021-04-10T02:05:00+00:00 EmrJobFlowSensor 2021-04-10T03:05:49.005514+00:00 2021-04-10T03:13:51.437176+00:00 0:08:02.431662 15500 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-10T03:05:46.857589+00:00 2 default_pool
success vc-asset-import_v002 create_cluster_and_add_emr_steps 2021-04-10T02:05:00+00:00 EmrCreateJobFlowOperator 2021-04-10T03:05:26.985990+00:00 2021-04-10T03:05:28.661787+00:00 0:00:01.675797 15499 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 2 default 2021-04-10T03:05:24.846325+00:00 2 default_pool
success vc-asset-import_v002 create_emr_steps 2021-04-10T02:05:00+00:00 PythonOperator 2021-04-10T03:05:05.121666+00:00 2021-04-10T03:05:08.165244+00:00 0:00:03.043578 15498 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-04-10T03:05:02.803415+00:00 2 default_pool
success campaign-flow-job_v002 check_cluster_status 2021-04-10T02:00:00+00:00 EmrJobFlowSensor 2021-04-10T03:00:54.675244+00:00 2021-04-10T03:09:57.335673+00:00 0:09:02.660429 15497 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-04-10T03:00:52.301482+00:00 2 default_pool
success campaign-flow-job_v002 create_cluster_and_add_emr_steps 2021-04-10T02:00:00+00:00 EmrCreateJobFlowOperator 2021-04-10T03:00:32.674202+00:00 2021-04-10T03:00:34.410324+00:00 0:00:01.736122 15496 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 4 default 2021-04-10T03:00:30.344993+00:00 2 default_pool
success campaign-flow-job_v002 create_emr_steps 2021-04-10T02:00:00+00:00 PythonOperator 2021-04-10T03:00:10.539293+00:00 2021-04-10T03:00:13.227382+00:00 0:00:02.688089 15495 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 5 default 2021-04-10T03:00:08.232021+00:00 2 default_pool
success campaign-history-job_v002 check_cluster_status 2021-04-10T01:00:00+00:00 EmrJobFlowSensor 2021-04-10T02:11:58.705355+00:00 2021-04-10T02:30:02.641022+00:00 0:18:03.935667 15493 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-10T02:11:56.420087+00:00 2 default_pool
success campaign-history-job_v002 create_cluster_and_add_emr_steps 2021-04-10T01:00:00+00:00 EmrCreateJobFlowOperator 2021-04-10T02:11:36.800475+00:00 2021-04-10T02:11:38.514914+00:00 0:00:01.714439 15492 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 2 default 2021-04-10T02:11:34.459375+00:00 2 default_pool
success booking-processing-job_v002 check_cluster_status 2021-04-10T01:00:00+00:00 EmrJobFlowSensor 2021-04-10T02:11:18.985881+00:00 2021-04-10T02:20:21.680457+00:00 0:09:02.694576 15491 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-10T02:11:16.455076+00:00 2 default_pool
success booking-processing-job_v002 create_cluster_and_add_emr_steps 2021-04-10T01:00:00+00:00 EmrCreateJobFlowOperator 2021-04-10T02:10:46.665826+00:00 2021-04-10T02:10:48.482705+00:00 0:00:01.816879 15490 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 2 default 2021-04-10T02:10:44.348051+00:00 2 default_pool
success booking-processing-job_v002 create_emr_steps 2021-04-10T01:00:00+00:00 PythonOperator 2021-04-10T02:10:22.813768+00:00 2021-04-10T02:10:25.743628+00:00 0:00:02.929860 15489 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-04-10T02:10:20.327283+00:00 2 default_pool
success campaign-history-job_v002 create_emr_steps 2021-04-10T01:00:00+00:00 PythonOperator 2021-04-10T02:10:18.484227+00:00 2021-04-10T02:10:21.422804+00:00 0:00:02.938577 15488 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-04-10T02:10:16.321823+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_campaign-history-job_v002 2021-04-10T01:00:00+00:00 TriggerDagRunOperator 2021-04-10T02:09:56.856916+00:00 2021-04-10T02:09:57.407887+00:00 0:00:00.550971 15487 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-10T02:09:54.371970+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_booking-processing-job_v002 2021-04-10T01:00:00+00:00 TriggerDagRunOperator 2021-04-10T02:09:56.609878+00:00 2021-04-10T02:09:57.033792+00:00 0:00:00.423914 15486 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-10T02:09:54.372016+00:00 2 default_pool
success vc-asset-import_v002 check_cluster_status 2021-04-10T01:05:00+00:00 EmrJobFlowSensor 2021-04-10T02:06:18.415724+00:00 2021-04-10T02:15:21.217240+00:00 0:09:02.801516 15485 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-10T02:06:16.048479+00:00 2 default_pool
success vc-asset-import_v002 create_cluster_and_add_emr_steps 2021-04-10T01:05:00+00:00 EmrCreateJobFlowOperator 2021-04-10T02:05:46.453606+00:00 2021-04-10T02:05:48.262629+00:00 0:00:01.809023 15484 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 2 default 2021-04-10T02:05:44.053039+00:00 2 default_pool
success vc-asset-import_v002 create_emr_steps 2021-04-10T01:05:00+00:00 PythonOperator 2021-04-10T02:05:22.300932+00:00 2021-04-10T02:05:24.977613+00:00 0:00:02.676681 15483 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-04-10T02:05:20.011971+00:00 2 default_pool
success campaign-flow-job_v002 check_cluster_status 2021-04-10T01:00:00+00:00 EmrJobFlowSensor 2021-04-10T02:00:47.785930+00:00 2021-04-10T02:09:50.607227+00:00 0:09:02.821297 15482 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-04-10T02:00:45.461912+00:00 2 default_pool
success campaign-flow-job_v002 create_cluster_and_add_emr_steps 2021-04-10T01:00:00+00:00 EmrCreateJobFlowOperator 2021-04-10T02:00:25.706916+00:00 2021-04-10T02:00:27.591223+00:00 0:00:01.884307 15481 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 4 default 2021-04-10T02:00:23.389284+00:00 2 default_pool
success campaign-flow-job_v002 create_emr_steps 2021-04-10T01:00:00+00:00 PythonOperator 2021-04-10T02:00:04.232363+00:00 2021-04-10T02:00:06.950717+00:00 0:00:02.718354 15480 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 5 default 2021-04-10T02:00:01.370390+00:00 2 default_pool
success campaign-history-job_v002 check_cluster_status 2021-04-10T00:00:00+00:00 EmrJobFlowSensor 2021-04-10T01:11:16.708623+00:00 2021-04-10T01:20:19.394693+00:00 0:09:02.686070 15478 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-10T01:11:14.501682+00:00 2 default_pool
success booking-processing-job_v002 check_cluster_status 2021-04-10T00:00:00+00:00 EmrJobFlowSensor 2021-04-10T01:10:56.630346+00:00 2021-04-10T01:19:59.233308+00:00 0:09:02.602962 15477 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-10T01:10:54.458743+00:00 2 default_pool
success campaign-history-job_v002 create_cluster_and_add_emr_steps 2021-04-10T00:00:00+00:00 EmrCreateJobFlowOperator 2021-04-10T01:10:54.830501+00:00 2021-04-10T01:10:56.668492+00:00 0:00:01.837991 15476 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 2 default 2021-04-10T01:10:52.432700+00:00 2 default_pool
success booking-processing-job_v002 create_cluster_and_add_emr_steps 2021-04-10T00:00:00+00:00 EmrCreateJobFlowOperator 2021-04-10T01:10:36.658973+00:00 2021-04-10T01:10:38.460854+00:00 0:00:01.801881 15475 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 2 default 2021-04-10T01:10:34.406501+00:00 2 default_pool