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 vc-asset-import_v002 create_cluster_and_add_emr_steps 2021-05-02T09:05:00+00:00 EmrCreateJobFlowOperator 2021-05-02T10:05:27.599603+00:00 2021-05-02T10:05:29.256892+00:00 0:00:01.657289 23606 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 2 default 2021-05-02T10:05:25.446037+00:00 2 default_pool
success vc-asset-import_v002 create_emr_steps 2021-05-02T09:05:00+00:00 PythonOperator 2021-05-02T10:05:03.584451+00:00 2021-05-02T10:05:06.652853+00:00 0:00:03.068402 23605 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-05-02T10:05:01.400867+00:00 2 default_pool
success campaign-flow-job_v002 check_cluster_status 2021-05-02T09:00:00+00:00 EmrJobFlowSensor 2021-05-02T10:01:01.527082+00:00 2021-05-02T10:11:04.501588+00:00 0:10:02.974506 23604 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-05-02T10:00:59.154507+00:00 2 default_pool
success campaign-flow-job_v002 create_cluster_and_add_emr_steps 2021-05-02T09:00:00+00:00 EmrCreateJobFlowOperator 2021-05-02T10:00:37.515466+00:00 2021-05-02T10:00:39.259187+00:00 0:00:01.743721 23603 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 4 default 2021-05-02T10:00:35.140702+00:00 2 default_pool
success campaign-flow-job_v002 create_emr_steps 2021-05-02T09:00:00+00:00 PythonOperator 2021-05-02T10:00:15.224736+00:00 2021-05-02T10:00:18.266200+00:00 0:00:03.041464 23602 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 5 default 2021-05-02T10:00:12.996537+00:00 2 default_pool
success campaign-history-job_v002 check_cluster_status 2021-05-02T08:00:00+00:00 EmrJobFlowSensor 2021-05-02T09:13:02.626883+00:00 2021-05-02T09:21:05.262211+00:00 0:08:02.635328 23601 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-05-02T09:13:00.384005+00:00 2 default_pool
success booking-processing-job_v002 check_cluster_status 2021-05-02T08:00:00+00:00 EmrJobFlowSensor 2021-05-02T09:12:56.736133+00:00 2021-05-02T09:22:59.636222+00:00 0:10:02.900089 23600 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-05-02T09:12:54.380614+00:00 2 default_pool
success booking-processing-job_v002 create_cluster_and_add_emr_steps 2021-05-02T08:00:00+00:00 EmrCreateJobFlowOperator 2021-05-02T09:12:19.772471+00:00 2021-05-02T09:12:21.504058+00:00 0:00:01.731587 23598 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 2 default 2021-05-02T09:12:17.269348+00:00 2 default_pool
success campaign-history-job_v002 create_cluster_and_add_emr_steps 2021-05-02T08:00:00+00:00 EmrCreateJobFlowOperator 2021-05-02T09:12:13.472893+00:00 2021-05-02T09:12:15.264051+00:00 0:00:01.791158 23597 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 2 default 2021-05-02T09:12:11.185024+00:00 2 default_pool
success booking-processing-job_v002 create_emr_steps 2021-05-02T08:00:00+00:00 PythonOperator 2021-05-02T09:11:57.793334+00:00 2021-05-02T09:12:01.259268+00:00 0:00:03.465934 23596 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-05-02T09:11:55.156153+00:00 2 default_pool
success campaign-history-job_v002 create_emr_steps 2021-05-02T08:00:00+00:00 PythonOperator 2021-05-02T09:11:53.499896+00:00 2021-05-02T09:11:57.076646+00:00 0:00:03.576750 23595 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-05-02T09:11:51.131975+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_booking-processing-job_v002 2021-05-02T08:00:00+00:00 TriggerDagRunOperator 2021-05-02T09:11:33.634000+00:00 2021-05-02T09:11:34.123490+00:00 0:00:00.489490 23594 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-05-02T09:11:31.112418+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_campaign-history-job_v002 2021-05-02T08:00:00+00:00 TriggerDagRunOperator 2021-05-02T09:11:33.579447+00:00 2021-05-02T09:11:34.177497+00:00 0:00:00.598050 23593 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-05-02T09:11:31.112384+00:00 2 default_pool
success vc-asset-import_v002 check_cluster_status 2021-05-02T08:05:00+00:00 EmrJobFlowSensor 2021-05-02T09:05:48.833271+00:00 2021-05-02T09:14:51.405661+00:00 0:09:02.572390 23592 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-05-02T09:05:46.433509+00:00 2 default_pool
success vc-asset-import_v002 create_cluster_and_add_emr_steps 2021-05-02T08:05:00+00:00 EmrCreateJobFlowOperator 2021-05-02T09:05:27.049915+00:00 2021-05-02T09:05:28.696976+00:00 0:00:01.647061 23591 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 2 default 2021-05-02T09:05:24.462797+00:00 2 default_pool
success vc-asset-import_v002 create_emr_steps 2021-05-02T08:05:00+00:00 PythonOperator 2021-05-02T09:05:04.802552+00:00 2021-05-02T09:05:07.860086+00:00 0:00:03.057534 23590 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-05-02T09:05:02.384277+00:00 2 default_pool
success campaign-flow-job_v002 check_cluster_status 2021-05-02T08:00:00+00:00 EmrJobFlowSensor 2021-05-02T09:01:08.681005+00:00 2021-05-02T09:11:11.624657+00:00 0:10:02.943652 23589 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-05-02T09:01:06.120120+00:00 2 default_pool
success campaign-flow-job_v002 create_cluster_and_add_emr_steps 2021-05-02T08:00:00+00:00 EmrCreateJobFlowOperator 2021-05-02T09:00:42.280315+00:00 2021-05-02T09:00:44.028156+00:00 0:00:01.747841 23588 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 4 default 2021-05-02T09:00:40.091663+00:00 2 default_pool
success campaign-flow-job_v002 create_emr_steps 2021-05-02T08:00:00+00:00 PythonOperator 2021-05-02T09:00:20.346890+00:00 2021-05-02T09:00:23.463112+00:00 0:00:03.116222 23587 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 5 default 2021-05-02T09:00:18.045882+00:00 2 default_pool
success campaign-history-job_v002 check_cluster_status 2021-05-02T07:00:00+00:00 EmrJobFlowSensor 2021-05-02T08:14:41.286882+00:00 2021-05-02T08:22:43.912749+00:00 0:08:02.625867 23586 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-05-02T08:14:39.090514+00:00 2 default_pool
success campaign-history-job_v002 create_cluster_and_add_emr_steps 2021-05-02T07:00:00+00:00 EmrCreateJobFlowOperator 2021-05-02T08:14:19.402794+00:00 2021-05-02T08:14:21.095425+00:00 0:00:01.692631 23585 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 2 default 2021-05-02T08:14:17.070744+00:00 2 default_pool
success campaign-history-job_v002 create_emr_steps 2021-05-02T07:00:00+00:00 PythonOperator 2021-05-02T08:13:59.360921+00:00 2021-05-02T08:14:02.437686+00:00 0:00:03.076765 23584 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-05-02T08:13:57.068383+00:00 2 default_pool
success booking-processing-job_v002 check_cluster_status 2021-05-02T07:00:00+00:00 EmrJobFlowSensor 2021-05-02T08:13:45.457487+00:00 2021-05-02T08:22:48.244990+00:00 0:09:02.787503 23583 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-05-02T08:13:43.054336+00:00 2 default_pool
success booking-processing-job_v002 create_cluster_and_add_emr_steps 2021-05-02T07:00:00+00:00 EmrCreateJobFlowOperator 2021-05-02T08:13:19.241720+00:00 2021-05-02T08:13:20.940480+00:00 0:00:01.698760 23582 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 2 default 2021-05-02T08:13:17.017410+00:00 2 default_pool
success booking-processing-job_v002 create_emr_steps 2021-05-02T07:00:00+00:00 PythonOperator 2021-05-02T08:12:57.155993+00:00 2021-05-02T08:13:00.412948+00:00 0:00:03.256955 23581 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-05-02T08:12:54.992492+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_booking-processing-job_v002 2021-05-02T07:00:00+00:00 TriggerDagRunOperator 2021-05-02T08:12:43.587504+00:00 2021-05-02T08:12:44.158459+00:00 0:00:00.570955 23580 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-05-02T08:12:40.983038+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_campaign-history-job_v002 2021-05-02T07:00:00+00:00 TriggerDagRunOperator 2021-05-02T08:12:43.506999+00:00 2021-05-02T08:12:43.961185+00:00 0:00:00.454186 23579 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-05-02T08:12:40.982994+00:00 2 default_pool
success vc-asset-import_v002 check_cluster_status 2021-05-02T07:05:00+00:00 EmrJobFlowSensor 2021-05-02T08:05:55.093406+00:00 2021-05-02T08:14:57.705522+00:00 0:09:02.612116 23577 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-05-02T08:05:52.478700+00:00 2 default_pool
success vc-asset-import_v002 create_cluster_and_add_emr_steps 2021-05-02T07:05:00+00:00 EmrCreateJobFlowOperator 2021-05-02T08:05:34.816327+00:00 2021-05-02T08:05:36.568696+00:00 0:00:01.752369 23576 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 2 default 2021-05-02T08:05:32.460891+00:00 2 default_pool
success vc-asset-import_v002 create_emr_steps 2021-05-02T07:05:00+00:00 PythonOperator 2021-05-02T08:05:12.610487+00:00 2021-05-02T08:05:15.627654+00:00 0:00:03.017167 23575 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-05-02T08:05:10.293736+00:00 2 default_pool
success campaign-flow-job_v002 check_cluster_status 2021-05-02T07:00:00+00:00 EmrJobFlowSensor 2021-05-02T08:00:58.130095+00:00 2021-05-02T08:09:00.650466+00:00 0:08:02.520371 23574 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-05-02T08:00:55.782094+00:00 2 default_pool
success campaign-flow-job_v002 create_cluster_and_add_emr_steps 2021-05-02T07:00:00+00:00 EmrCreateJobFlowOperator 2021-05-02T08:00:38.006551+00:00 2021-05-02T08:00:39.768126+00:00 0:00:01.761575 23573 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 4 default 2021-05-02T08:00:35.768030+00:00 2 default_pool
success campaign-flow-job_v002 create_emr_steps 2021-05-02T07:00:00+00:00 PythonOperator 2021-05-02T08:00:15.917973+00:00 2021-05-02T08:00:19.008205+00:00 0:00:03.090232 23572 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 5 default 2021-05-02T08:00:13.697731+00:00 2 default_pool
success campaign-history-job_v002 check_cluster_status 2021-05-02T06:00:00+00:00 EmrJobFlowSensor 2021-05-02T07:12:33.413619+00:00 2021-05-02T07:20:35.992484+00:00 0:08:02.578865 23571 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-05-02T07:12:31.022541+00:00 2 default_pool
success booking-processing-job_v002 check_cluster_status 2021-05-02T06:00:00+00:00 EmrJobFlowSensor 2021-05-02T07:12:33.376723+00:00 2021-05-02T07:22:36.087502+00:00 0:10:02.710779 23570 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-05-02T07:12:31.022575+00:00 2 default_pool
success campaign-history-job_v002 create_cluster_and_add_emr_steps 2021-05-02T06:00:00+00:00 EmrCreateJobFlowOperator 2021-05-02T07:12:11.411664+00:00 2021-05-02T07:12:13.205781+00:00 0:00:01.794117 23569 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 2 default 2021-05-02T07:12:09.004813+00:00 2 default_pool
success booking-processing-job_v002 create_cluster_and_add_emr_steps 2021-05-02T06:00:00+00:00 EmrCreateJobFlowOperator 2021-05-02T07:12:11.328430+00:00 2021-05-02T07:12:13.218961+00:00 0:00:01.890531 23568 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 2 default 2021-05-02T07:12:09.004860+00:00 2 default_pool
success campaign-history-job_v002 create_emr_steps 2021-05-02T06:00:00+00:00 PythonOperator 2021-05-02T07:11:51.256633+00:00 2021-05-02T07:11:54.382566+00:00 0:00:03.125933 23567 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-05-02T07:11:48.992196+00:00 2 default_pool
success booking-processing-job_v002 create_emr_steps 2021-05-02T06:00:00+00:00 PythonOperator 2021-05-02T07:11:49.433049+00:00 2021-05-02T07:11:52.694458+00:00 0:00:03.261409 23566 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-05-02T07:11:47.046454+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_booking-processing-job_v002 2021-05-02T06:00:00+00:00 TriggerDagRunOperator 2021-05-02T07:11:25.924040+00:00 2021-05-02T07:11:26.450865+00:00 0:00:00.526825 23565 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-05-02T07:11:22.944614+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_campaign-history-job_v002 2021-05-02T06:00:00+00:00 TriggerDagRunOperator 2021-05-02T07:11:25.750907+00:00 2021-05-02T07:11:26.169256+00:00 0:00:00.418349 23564 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-05-02T07:11:22.944569+00:00 2 default_pool
success vc-asset-import_v002 check_cluster_status 2021-05-02T06:05:00+00:00 EmrJobFlowSensor 2021-05-02T07:06:06.944179+00:00 2021-05-02T07:14:09.507808+00:00 0:08:02.563629 23562 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-05-02T07:06:04.739218+00:00 2 default_pool
success vc-asset-import_v002 create_cluster_and_add_emr_steps 2021-05-02T06:05:00+00:00 EmrCreateJobFlowOperator 2021-05-02T07:05:38.899187+00:00 2021-05-02T07:05:40.507566+00:00 0:00:01.608379 23561 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 2 default 2021-05-02T07:05:36.691762+00:00 2 default_pool
success vc-asset-import_v002 create_emr_steps 2021-05-02T06:05:00+00:00 PythonOperator 2021-05-02T07:05:16.957203+00:00 2021-05-02T07:05:19.977293+00:00 0:00:03.020090 23560 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-05-02T07:05:14.745795+00:00 2 default_pool
success campaign-flow-job_v002 check_cluster_status 2021-05-02T06:00:00+00:00 EmrJobFlowSensor 2021-05-02T07:01:06.406789+00:00 2021-05-02T07:11:09.299399+00:00 0:10:02.892610 23559 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-05-02T07:01:04.157724+00:00 2 default_pool
success campaign-flow-job_v002 create_cluster_and_add_emr_steps 2021-05-02T06:00:00+00:00 EmrCreateJobFlowOperator 2021-05-02T07:00:42.417987+00:00 2021-05-02T07:00:44.251039+00:00 0:00:01.833052 23558 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 4 default 2021-05-02T07:00:40.155090+00:00 2 default_pool
success campaign-flow-job_v002 create_emr_steps 2021-05-02T06:00:00+00:00 PythonOperator 2021-05-02T07:00:22.338835+00:00 2021-05-02T07:00:25.488815+00:00 0:00:03.149980 23557 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 5 default 2021-05-02T07:00:20.069637+00:00 2 default_pool
success booking-processing-job_v002 check_cluster_status 2021-05-02T05:00:00+00:00 EmrJobFlowSensor 2021-05-02T06:12:17.251358+00:00 2021-05-02T06:22:20.077336+00:00 0:10:02.825978 23556 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-05-02T06:12:14.982943+00:00 2 default_pool
success campaign-history-job_v002 check_cluster_status 2021-05-02T05:00:00+00:00 EmrJobFlowSensor 2021-05-02T06:12:11.229917+00:00 2021-05-02T06:21:13.998933+00:00 0:09:02.769016 23555 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-05-02T06:12:08.967351+00:00 2 default_pool
success booking-processing-job_v002 create_cluster_and_add_emr_steps 2021-05-02T05:00:00+00:00 EmrCreateJobFlowOperator 2021-05-02T06:11:55.314771+00:00 2021-05-02T06:11:57.018028+00:00 0:00:01.703257 23554 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 2 default 2021-05-02T06:11:52.922454+00:00 2 default_pool
success campaign-history-job_v002 create_cluster_and_add_emr_steps 2021-05-02T05:00:00+00:00 EmrCreateJobFlowOperator 2021-05-02T06:11:51.185569+00:00 2021-05-02T06:11:52.851644+00:00 0:00:01.666075 23553 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 2 default 2021-05-02T06:11:48.921781+00:00 2 default_pool
success booking-processing-job_v002 create_emr_steps 2021-05-02T05:00:00+00:00 PythonOperator 2021-05-02T06:11:33.387105+00:00 2021-05-02T06:11:36.715157+00:00 0:00:03.328052 23552 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-05-02T06:11:30.974324+00:00 2 default_pool
success campaign-history-job_v002 create_emr_steps 2021-05-02T05:00:00+00:00 PythonOperator 2021-05-02T06:11:29.324210+00:00 2021-05-02T06:11:32.358716+00:00 0:00:03.034506 23551 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-05-02T06:11:26.958793+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_campaign-history-job_v002 2021-05-02T05:00:00+00:00 TriggerDagRunOperator 2021-05-02T06:11:19.453896+00:00 2021-05-02T06:11:19.969370+00:00 0:00:00.515474 23550 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-05-02T06:11:16.892992+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_booking-processing-job_v002 2021-05-02T05:00:00+00:00 TriggerDagRunOperator 2021-05-02T06:11:19.308172+00:00 2021-05-02T06:11:19.728740+00:00 0:00:00.420568 23549 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-05-02T06:11:16.893022+00:00 2 default_pool
success vc-asset-import_v002 check_cluster_status 2021-05-02T05:05:00+00:00 EmrJobFlowSensor 2021-05-02T06:05:49.083588+00:00 2021-05-02T06:13:51.443807+00:00 0:08:02.360219 23547 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-05-02T06:05:46.826761+00:00 2 default_pool
success vc-asset-import_v002 create_cluster_and_add_emr_steps 2021-05-02T05:05:00+00:00 EmrCreateJobFlowOperator 2021-05-02T06:05:27.240073+00:00 2021-05-02T06:05:28.897951+00:00 0:00:01.657878 23546 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 2 default 2021-05-02T06:05:24.869650+00:00 2 default_pool
success vc-asset-import_v002 create_emr_steps 2021-05-02T05:05:00+00:00 PythonOperator 2021-05-02T06:05:05.027432+00:00 2021-05-02T06:05:08.122244+00:00 0:00:03.094812 23545 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-05-02T06:05:02.785268+00:00 2 default_pool
success campaign-flow-job_v002 check_cluster_status 2021-05-02T05:00:00+00:00 EmrJobFlowSensor 2021-05-02T06:01:08.910012+00:00 2021-05-02T06:11:11.856051+00:00 0:10:02.946039 23544 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-05-02T06:01:06.552483+00:00 2 default_pool
success campaign-flow-job_v002 create_cluster_and_add_emr_steps 2021-05-02T05:00:00+00:00 EmrCreateJobFlowOperator 2021-05-02T06:00:46.643736+00:00 2021-05-02T06:00:48.351518+00:00 0:00:01.707782 23543 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 4 default 2021-05-02T06:00:44.460526+00:00 2 default_pool
success campaign-flow-job_v002 create_emr_steps 2021-05-02T05:00:00+00:00 PythonOperator 2021-05-02T06:00:20.755661+00:00 2021-05-02T06:00:23.793053+00:00 0:00:03.037392 23542 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 5 default 2021-05-02T06:00:18.427981+00:00 2 default_pool
success campaign-history-job_v002 check_cluster_status 2021-05-02T04:00:00+00:00 EmrJobFlowSensor 2021-05-02T05:12:25.503641+00:00 2021-05-02T05:22:28.252753+00:00 0:10:02.749112 23541 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-05-02T05:12:23.173180+00:00 2 default_pool
success booking-processing-job_v002 check_cluster_status 2021-05-02T04:00:00+00:00 EmrJobFlowSensor 2021-05-02T05:12:21.520851+00:00 2021-05-02T05:22:24.463232+00:00 0:10:02.942381 23540 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-05-02T05:12:19.156200+00:00 2 default_pool
success campaign-history-job_v002 create_cluster_and_add_emr_steps 2021-05-02T04:00:00+00:00 EmrCreateJobFlowOperator 2021-05-02T05:12:05.438783+00:00 2021-05-02T05:12:07.157348+00:00 0:00:01.718565 23539 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 2 default 2021-05-02T05:12:03.148173+00:00 2 default_pool
success booking-processing-job_v002 create_cluster_and_add_emr_steps 2021-05-02T04:00:00+00:00 EmrCreateJobFlowOperator 2021-05-02T05:12:01.391887+00:00 2021-05-02T05:12:03.223962+00:00 0:00:01.832075 23538 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 2 default 2021-05-02T05:11:59.080568+00:00 2 default_pool
success campaign-history-job_v002 create_emr_steps 2021-05-02T04:00:00+00:00 PythonOperator 2021-05-02T05:11:33.897292+00:00 2021-05-02T05:11:37.220332+00:00 0:00:03.323040 23537 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-05-02T05:11:31.009531+00:00 2 default_pool
success booking-processing-job_v002 create_emr_steps 2021-05-02T04:00:00+00:00 PythonOperator 2021-05-02T05:11:29.304790+00:00 2021-05-02T05:11:33.237450+00:00 0:00:03.932660 23536 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-05-02T05:11:27.027014+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_booking-processing-job_v002 2021-05-02T04:00:00+00:00 TriggerDagRunOperator 2021-05-02T05:11:19.832275+00:00 2021-05-02T05:11:20.332011+00:00 0:00:00.499736 23535 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-05-02T05:11:16.861946+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_campaign-history-job_v002 2021-05-02T04:00:00+00:00 TriggerDagRunOperator 2021-05-02T05:11:19.692849+00:00 2021-05-02T05:11:20.117141+00:00 0:00:00.424292 23534 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-05-02T05:11:16.861915+00:00 2 default_pool
success vc-asset-import_v002 check_cluster_status 2021-05-02T04:05:00+00:00 EmrJobFlowSensor 2021-05-02T05:05:56.199967+00:00 2021-05-02T05:13:58.655007+00:00 0:08:02.455040 23532 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-05-02T05:05:53.986373+00:00 2 default_pool
success vc-asset-import_v002 create_cluster_and_add_emr_steps 2021-05-02T04:05:00+00:00 EmrCreateJobFlowOperator 2021-05-02T05:05:34.191441+00:00 2021-05-02T05:05:35.909571+00:00 0:00:01.718130 23531 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 2 default 2021-05-02T05:05:31.943963+00:00 2 default_pool
success vc-asset-import_v002 create_emr_steps 2021-05-02T04:05:00+00:00 PythonOperator 2021-05-02T05:05:12.287556+00:00 2021-05-02T05:05:15.298557+00:00 0:00:03.011001 23530 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-05-02T05:05:10.044269+00:00 2 default_pool
success campaign-flow-job_v002 check_cluster_status 2021-05-02T04:00:00+00:00 EmrJobFlowSensor 2021-05-02T05:00:55.728243+00:00 2021-05-02T05:10:58.584902+00:00 0:10:02.856659 23529 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-05-02T05:00:53.503274+00:00 2 default_pool
success campaign-flow-job_v002 create_cluster_and_add_emr_steps 2021-05-02T04:00:00+00:00 EmrCreateJobFlowOperator 2021-05-02T05:00:34.010220+00:00 2021-05-02T05:00:35.710595+00:00 0:00:01.700375 23528 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 4 default 2021-05-02T05:00:31.490413+00:00 2 default_pool
success campaign-flow-job_v002 create_emr_steps 2021-05-02T04:00:00+00:00 PythonOperator 2021-05-02T05:00:11.654346+00:00 2021-05-02T05:00:14.685179+00:00 0:00:03.030833 23527 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 5 default 2021-05-02T05:00:09.445910+00:00 2 default_pool
success booking-processing-job_v002 check_cluster_status 2021-05-02T03:00:00+00:00 EmrJobFlowSensor 2021-05-02T04:11:21.136114+00:00 2021-05-02T04:21:23.950743+00:00 0:10:02.814629 23526 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-05-02T04:11:18.653232+00:00 2 default_pool
success campaign-history-job_v002 check_cluster_status 2021-05-02T03:00:00+00:00 EmrJobFlowSensor 2021-05-02T04:11:12.750536+00:00 2021-05-02T04:21:15.473479+00:00 0:10:02.722943 23525 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-05-02T04:11:10.516139+00:00 2 default_pool
success booking-processing-job_v002 create_cluster_and_add_emr_steps 2021-05-02T03:00:00+00:00 EmrCreateJobFlowOperator 2021-05-02T04:10:58.950369+00:00 2021-05-02T04:11:00.711076+00:00 0:00:01.760707 23524 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 2 default 2021-05-02T04:10:56.552854+00:00 2 default_pool
success campaign-history-job_v002 create_cluster_and_add_emr_steps 2021-05-02T03:00:00+00:00 EmrCreateJobFlowOperator 2021-05-02T04:10:52.879140+00:00 2021-05-02T04:10:54.613385+00:00 0:00:01.734245 23523 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 2 default 2021-05-02T04:10:50.511417+00:00 2 default_pool
success booking-processing-job_v002 create_emr_steps 2021-05-02T03:00:00+00:00 PythonOperator 2021-05-02T04:10:36.808323+00:00 2021-05-02T04:10:40.040492+00:00 0:00:03.232169 23522 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-05-02T04:10:34.556072+00:00 2 default_pool
success campaign-history-job_v002 create_emr_steps 2021-05-02T03:00:00+00:00 PythonOperator 2021-05-02T04:10:30.950684+00:00 2021-05-02T04:10:34.151430+00:00 0:00:03.200746 23521 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-05-02T04:10:28.547770+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_booking-processing-job_v002 2021-05-02T03:00:00+00:00 TriggerDagRunOperator 2021-05-02T04:10:25.098949+00:00 2021-05-02T04:10:25.646549+00:00 0:00:00.547600 23520 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-05-02T04:10:22.492917+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_campaign-history-job_v002 2021-05-02T03:00:00+00:00 TriggerDagRunOperator 2021-05-02T04:10:25.035605+00:00 2021-05-02T04:10:25.447782+00:00 0:00:00.412177 23519 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-05-02T04:10:22.492866+00:00 2 default_pool
success vc-asset-import_v002 check_cluster_status 2021-05-02T03:05:00+00:00 EmrJobFlowSensor 2021-05-02T04:08:32.744927+00:00 2021-05-02T04:17:35.276546+00:00 0:09:02.531619 23518 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-05-02T04:08:30.343852+00:00 2 default_pool
success vc-asset-import_v002 create_cluster_and_add_emr_steps 2021-05-02T03:05:00+00:00 EmrCreateJobFlowOperator 2021-05-02T04:08:10.592221+00:00 2021-05-02T04:08:12.297628+00:00 0:00:01.705407 23517 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 2 default 2021-05-02T04:08:08.257807+00:00 2 default_pool
success vc-asset-import_v002 create_emr_steps 2021-05-02T03:05:00+00:00 PythonOperator 2021-05-02T04:07:50.605862+00:00 2021-05-02T04:07:53.600986+00:00 0:00:02.995124 23516 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-05-02T04:07:48.237815+00:00 2 default_pool
success campaign-flow-job_v002 check_cluster_status 2021-05-02T03:00:00+00:00 EmrJobFlowSensor 2021-05-02T04:01:06.205546+00:00 2021-05-02T04:10:09.004793+00:00 0:09:02.799247 23514 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-05-02T04:01:04.000934+00:00 2 default_pool
success campaign-flow-job_v002 create_cluster_and_add_emr_steps 2021-05-02T03:00:00+00:00 EmrCreateJobFlowOperator 2021-05-02T04:00:44.181790+00:00 2021-05-02T04:00:45.882990+00:00 0:00:01.701200 23513 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 4 default 2021-05-02T04:00:41.983661+00:00 2 default_pool
success campaign-flow-job_v002 create_emr_steps 2021-05-02T03:00:00+00:00 PythonOperator 2021-05-02T04:00:24.435202+00:00 2021-05-02T04:00:27.466815+00:00 0:00:03.031613 23512 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 5 default 2021-05-02T04:00:21.967683+00:00 2 default_pool
success campaign-history-job_v002 check_cluster_status 2021-05-02T02:00:00+00:00 EmrJobFlowSensor 2021-05-02T03:11:15.867602+00:00 2021-05-02T03:20:18.507530+00:00 0:09:02.639928 23511 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-05-02T03:11:12.898830+00:00 2 default_pool
success booking-processing-job_v002 check_cluster_status 2021-05-02T02:00:00+00:00 EmrJobFlowSensor 2021-05-02T03:11:13.448956+00:00 2021-05-02T03:20:16.589974+00:00 0:09:03.141018 23510 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-05-02T03:11:10.890757+00:00 2 default_pool
success campaign-history-job_v002 create_cluster_and_add_emr_steps 2021-05-02T02:00:00+00:00 EmrCreateJobFlowOperator 2021-05-02T03:10:55.573730+00:00 2021-05-02T03:10:57.340228+00:00 0:00:01.766498 23509 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 2 default 2021-05-02T03:10:52.791200+00:00 2 default_pool
success booking-processing-job_v002 create_cluster_and_add_emr_steps 2021-05-02T02:00:00+00:00 EmrCreateJobFlowOperator 2021-05-02T03:10:53.333381+00:00 2021-05-02T03:10:55.393496+00:00 0:00:02.060115 23508 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 2 default 2021-05-02T03:10:50.799039+00:00 2 default_pool
success campaign-history-job_v002 create_emr_steps 2021-05-02T02:00:00+00:00 PythonOperator 2021-05-02T03:10:33.986324+00:00 2021-05-02T03:10:37.261063+00:00 0:00:03.274739 23507 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-05-02T03:10:30.733254+00:00 2 default_pool
success booking-processing-job_v002 create_emr_steps 2021-05-02T02:00:00+00:00 PythonOperator 2021-05-02T03:10:31.937816+00:00 2021-05-02T03:10:35.694381+00:00 0:00:03.756565 23506 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-05-02T03:10:28.750870+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_campaign-history-job_v002 2021-05-02T02:00:00+00:00 TriggerDagRunOperator 2021-05-02T03:10:23.125588+00:00 2021-05-02T03:10:23.540325+00:00 0:00:00.414737 23505 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-05-02T03:10:20.724805+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_booking-processing-job_v002 2021-05-02T02:00:00+00:00 TriggerDagRunOperator 2021-05-02T03:10:23.117681+00:00 2021-05-02T03:10:23.664464+00:00 0:00:00.546783 23504 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-05-02T03:10:20.724836+00:00 2 default_pool
success vc-asset-import_v002 check_cluster_status 2021-05-02T02:05:00+00:00 EmrJobFlowSensor 2021-05-02T03:06:08.488583+00:00 2021-05-02T03:14:10.967968+00:00 0:08:02.479385 23503 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-05-02T03:06:06.341831+00:00 2 default_pool
success vc-asset-import_v002 create_cluster_and_add_emr_steps 2021-05-02T02:05:00+00:00 EmrCreateJobFlowOperator 2021-05-02T03:05:46.715591+00:00 2021-05-02T03:05:48.457333+00:00 0:00:01.741742 23502 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 2 default 2021-05-02T03:05:44.445281+00:00 2 default_pool
success vc-asset-import_v002 create_emr_steps 2021-05-02T02:05:00+00:00 PythonOperator 2021-05-02T03:05:26.749204+00:00 2021-05-02T03:05:29.784937+00:00 0:00:03.035733 23501 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-05-02T03:05:24.359884+00:00 2 default_pool