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 booking-processing-job_v002 check_cluster_status 2021-07-10T05:00:00+00:00 EmrJobFlowSensor 2021-07-10T06:12:31.297034+00:00 2021-07-10T06:22:34.503569+00:00 0:10:03.206535 52138 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-07-10T06:12:28.877534+00:00 2 default_pool
success campaign-history-job_v002 create_cluster_and_add_emr_steps 2021-07-10T05:00:00+00:00 EmrCreateJobFlowOperator 2021-07-10T06:12:11.833844+00:00 2021-07-10T06:12:13.616939+00:00 0:00:01.783095 52137 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 2 default 2021-07-10T06:12:08.867933+00:00 2 default_pool
success booking-processing-job_v002 create_cluster_and_add_emr_steps 2021-07-10T05:00:00+00:00 EmrCreateJobFlowOperator 2021-07-10T06:12:09.650526+00:00 2021-07-10T06:12:11.711862+00:00 0:00:02.061336 52136 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 2 default 2021-07-10T06:12:06.858964+00:00 2 default_pool
success campaign-history-job_v002 create_emr_steps 2021-07-10T05:00:00+00:00 PythonOperator 2021-07-10T06:11:48.962870+00:00 2021-07-10T06:11:52.690019+00:00 0:00:03.727149 52135 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-07-10T06:11:46.787969+00:00 2 default_pool
success booking-processing-job_v002 create_emr_steps 2021-07-10T05:00:00+00:00 PythonOperator 2021-07-10T06:11:47.302997+00:00 2021-07-10T06:11:51.066967+00:00 0:00:03.763970 52134 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-07-10T06:11:44.844693+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_campaign-history-job_v002 2021-07-10T05:00:00+00:00 TriggerDagRunOperator 2021-07-10T06:11:23.534339+00:00 2021-07-10T06:11:24.143418+00:00 0:00:00.609079 52133 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-07-10T06:11:20.727471+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_booking-processing-job_v002 2021-07-10T05:00:00+00:00 TriggerDagRunOperator 2021-07-10T06:11:23.432030+00:00 2021-07-10T06:11:23.863543+00:00 0:00:00.431513 52132 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-07-10T06:11:20.727498+00:00 2 default_pool
success vc-asset-import_v002 check_cluster_status 2021-07-10T05:05:00+00:00 EmrJobFlowSensor 2021-07-10T06:05:58.176683+00:00 2021-07-10T06:15:01.083108+00:00 0:09:02.906425 52130 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-07-10T06:05:55.854213+00:00 2 default_pool
success vc-asset-import_v002 create_cluster_and_add_emr_steps 2021-07-10T05:05:00+00:00 EmrCreateJobFlowOperator 2021-07-10T06:05:35.963288+00:00 2021-07-10T06:05:37.567605+00:00 0:00:01.604317 52129 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 2 default 2021-07-10T06:05:33.763534+00:00 2 default_pool
success vc-asset-import_v002 create_emr_steps 2021-07-10T05:05:00+00:00 PythonOperator 2021-07-10T06:05:14.124412+00:00 2021-07-10T06:05:17.499373+00:00 0:00:03.374961 52128 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-07-10T06:05:11.658090+00:00 2 default_pool
success campaign-flow-job_v002 check_cluster_status 2021-07-10T05:00:00+00:00 EmrJobFlowSensor 2021-07-10T06:01:15.795497+00:00 2021-07-10T06:10:18.794413+00:00 0:09:02.998916 52127 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-07-10T06:01:13.345415+00:00 2 default_pool
success campaign-flow-job_v002 create_cluster_and_add_emr_steps 2021-07-10T05:00:00+00:00 EmrCreateJobFlowOperator 2021-07-10T06:00:55.517127+00:00 2021-07-10T06:00:57.331405+00:00 0:00:01.814278 52126 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 4 default 2021-07-10T06:00:53.203341+00:00 2 default_pool
success campaign-flow-job_v002 create_emr_steps 2021-07-10T05:00:00+00:00 PythonOperator 2021-07-10T06:00:33.374966+00:00 2021-07-10T06:00:37.121193+00:00 0:00:03.746227 52125 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 5 default 2021-07-10T06:00:31.182078+00:00 2 default_pool
success campaign-history-job_v002 check_cluster_status 2021-07-10T04:00:00+00:00 EmrJobFlowSensor 2021-07-10T05:11:30.340120+00:00 2021-07-10T05:19:33.033132+00:00 0:08:02.693012 52124 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-07-10T05:11:27.894614+00:00 2 default_pool
success booking-processing-job_v002 check_cluster_status 2021-07-10T04:00:00+00:00 EmrJobFlowSensor 2021-07-10T05:11:30.254875+00:00 2021-07-10T05:21:33.080734+00:00 0:10:02.825859 52123 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-07-10T05:11:27.894586+00:00 2 default_pool
success booking-processing-job_v002 create_cluster_and_add_emr_steps 2021-07-10T04:00:00+00:00 EmrCreateJobFlowOperator 2021-07-10T05:11:08.425339+00:00 2021-07-10T05:11:10.338950+00:00 0:00:01.913611 52122 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 2 default 2021-07-10T05:11:05.870718+00:00 2 default_pool
success campaign-history-job_v002 create_cluster_and_add_emr_steps 2021-07-10T04:00:00+00:00 EmrCreateJobFlowOperator 2021-07-10T05:11:08.203287+00:00 2021-07-10T05:11:09.918578+00:00 0:00:01.715291 52121 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 2 default 2021-07-10T05:11:05.870746+00:00 2 default_pool
success campaign-history-job_v002 create_emr_steps 2021-07-10T04:00:00+00:00 PythonOperator 2021-07-10T05:10:46.347994+00:00 2021-07-10T05:10:49.794208+00:00 0:00:03.446214 52120 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-07-10T05:10:43.825965+00:00 2 default_pool
success booking-processing-job_v002 create_emr_steps 2021-07-10T04:00:00+00:00 PythonOperator 2021-07-10T05:10:46.187502+00:00 2021-07-10T05:10:50.198496+00:00 0:00:04.010994 52119 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-07-10T05:10:43.825932+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_booking-processing-job_v002 2021-07-10T04:00:00+00:00 TriggerDagRunOperator 2021-07-10T05:10:34.625423+00:00 2021-07-10T05:10:35.057566+00:00 0:00:00.432143 52118 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-07-10T05:10:31.680476+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_campaign-history-job_v002 2021-07-10T04:00:00+00:00 TriggerDagRunOperator 2021-07-10T05:10:34.650578+00:00 2021-07-10T05:10:35.159308+00:00 0:00:00.508730 52117 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-07-10T05:10:31.680440+00:00 2 default_pool
success vc-asset-import_v002 check_cluster_status 2021-07-10T04:05:00+00:00 EmrJobFlowSensor 2021-07-10T05:06:09.783403+00:00 2021-07-10T05:14:12.338736+00:00 0:08:02.555333 52115 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-07-10T05:06:07.516565+00:00 2 default_pool
success vc-asset-import_v002 create_cluster_and_add_emr_steps 2021-07-10T04:05:00+00:00 EmrCreateJobFlowOperator 2021-07-10T05:05:45.948435+00:00 2021-07-10T05:05:47.632449+00:00 0:00:01.684014 52114 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 2 default 2021-07-10T05:05:43.562469+00:00 2 default_pool
success vc-asset-import_v002 create_emr_steps 2021-07-10T04:05:00+00:00 PythonOperator 2021-07-10T05:05:23.670037+00:00 2021-07-10T05:05:27.591103+00:00 0:00:03.921066 52113 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-07-10T05:05:21.456209+00:00 2 default_pool
success campaign-flow-job_v002 check_cluster_status 2021-07-10T04:00:00+00:00 EmrJobFlowSensor 2021-07-10T05:01:07.255554+00:00 2021-07-10T05:10:10.185785+00:00 0:09:02.930231 52112 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-07-10T05:01:04.951811+00:00 2 default_pool
success campaign-flow-job_v002 create_cluster_and_add_emr_steps 2021-07-10T04:00:00+00:00 EmrCreateJobFlowOperator 2021-07-10T05:00:45.370749+00:00 2021-07-10T05:00:47.171051+00:00 0:00:01.800302 52111 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 4 default 2021-07-10T05:00:42.818184+00:00 2 default_pool
success campaign-flow-job_v002 create_emr_steps 2021-07-10T04:00:00+00:00 PythonOperator 2021-07-10T05:00:23.233392+00:00 2021-07-10T05:00:26.968816+00:00 0:00:03.735424 52110 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 5 default 2021-07-10T05:00:20.840796+00:00 2 default_pool
success booking-processing-job_v002 check_cluster_status 2021-07-10T03:00:00+00:00 EmrJobFlowSensor 2021-07-10T04:12:46.108779+00:00 2021-07-10T04:21:48.925813+00:00 0:09:02.817034 52109 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-07-10T04:12:43.653592+00:00 2 default_pool
success campaign-history-job_v002 check_cluster_status 2021-07-10T03:00:00+00:00 EmrJobFlowSensor 2021-07-10T04:12:19.777977+00:00 2021-07-10T04:21:22.614046+00:00 0:09:02.836069 52108 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-07-10T04:12:17.545451+00:00 2 default_pool
success booking-processing-job_v002 create_cluster_and_add_emr_steps 2021-07-10T03:00:00+00:00 EmrCreateJobFlowOperator 2021-07-10T04:12:13.684407+00:00 2021-07-10T04:12:15.433805+00:00 0:00:01.749398 52107 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 2 default 2021-07-10T04:12:11.536519+00:00 2 default_pool
success campaign-history-job_v002 create_cluster_and_add_emr_steps 2021-07-10T03:00:00+00:00 EmrCreateJobFlowOperator 2021-07-10T04:11:52.190613+00:00 2021-07-10T04:11:53.892148+00:00 0:00:01.701535 52106 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 2 default 2021-07-10T04:11:49.517160+00:00 2 default_pool
success booking-processing-job_v002 create_emr_steps 2021-07-10T03:00:00+00:00 PythonOperator 2021-07-10T04:11:43.918661+00:00 2021-07-10T04:11:47.942331+00:00 0:00:04.023670 52105 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-07-10T04:11:41.572332+00:00 2 default_pool
success campaign-history-job_v002 create_emr_steps 2021-07-10T03:00:00+00:00 PythonOperator 2021-07-10T04:11:30.202553+00:00 2021-07-10T04:11:33.959915+00:00 0:00:03.757362 52104 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-07-10T04:11:27.741831+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_campaign-history-job_v002 2021-07-10T03:00:00+00:00 TriggerDagRunOperator 2021-07-10T04:11:20.298284+00:00 2021-07-10T04:11:20.793195+00:00 0:00:00.494911 52103 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-07-10T04:11:17.260556+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_booking-processing-job_v002 2021-07-10T03:00:00+00:00 TriggerDagRunOperator 2021-07-10T04:11:20.169396+00:00 2021-07-10T04:11:20.559875+00:00 0:00:00.390479 52102 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-07-10T04:11:17.260584+00:00 2 default_pool
success vc-asset-import_v002 check_cluster_status 2021-07-10T03:05:00+00:00 EmrJobFlowSensor 2021-07-10T04:06:07.967540+00:00 2021-07-10T04:15:10.648003+00:00 0:09:02.680463 52100 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-07-10T04:06:05.440924+00:00 2 default_pool
success vc-asset-import_v002 create_cluster_and_add_emr_steps 2021-07-10T03:05:00+00:00 EmrCreateJobFlowOperator 2021-07-10T04:05:45.660233+00:00 2021-07-10T04:05:47.289085+00:00 0:00:01.628852 52099 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 2 default 2021-07-10T04:05:43.418804+00:00 2 default_pool
success vc-asset-import_v002 create_emr_steps 2021-07-10T03:05:00+00:00 PythonOperator 2021-07-10T04:05:25.564224+00:00 2021-07-10T04:05:29.286195+00:00 0:00:03.721971 52098 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-07-10T04:05:23.406163+00:00 2 default_pool
success campaign-flow-job_v002 check_cluster_status 2021-07-10T03:00:00+00:00 EmrJobFlowSensor 2021-07-10T04:01:06.906993+00:00 2021-07-10T04:11:09.952788+00:00 0:10:03.045795 52097 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-07-10T04:01:04.685751+00:00 2 default_pool
success campaign-flow-job_v002 create_cluster_and_add_emr_steps 2021-07-10T03:00:00+00:00 EmrCreateJobFlowOperator 2021-07-10T04:00:46.874889+00:00 2021-07-10T04:00:48.744608+00:00 0:00:01.869719 52096 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 4 default 2021-07-10T04:00:44.619362+00:00 2 default_pool
success campaign-flow-job_v002 create_emr_steps 2021-07-10T03:00:00+00:00 PythonOperator 2021-07-10T04:00:24.779589+00:00 2021-07-10T04:00:28.537831+00:00 0:00:03.758242 52095 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 5 default 2021-07-10T04:00:22.600597+00:00 2 default_pool
success booking-processing-job_v002 check_cluster_status 2021-07-10T02:00:00+00:00 EmrJobFlowSensor 2021-07-10T03:12:13.216722+00:00 2021-07-10T03:22:16.026594+00:00 0:10:02.809872 52094 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-07-10T03:12:10.864163+00:00 2 default_pool
success campaign-history-job_v002 check_cluster_status 2021-07-10T02:00:00+00:00 EmrJobFlowSensor 2021-07-10T03:12:07.297895+00:00 2021-07-10T03:21:10.059759+00:00 0:09:02.761864 52093 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-07-10T03:12:04.868439+00:00 2 default_pool
success booking-processing-job_v002 create_cluster_and_add_emr_steps 2021-07-10T02:00:00+00:00 EmrCreateJobFlowOperator 2021-07-10T03:11:53.197552+00:00 2021-07-10T03:11:54.906935+00:00 0:00:01.709383 52092 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 2 default 2021-07-10T03:11:50.860825+00:00 2 default_pool
success campaign-history-job_v002 create_cluster_and_add_emr_steps 2021-07-10T02:00:00+00:00 EmrCreateJobFlowOperator 2021-07-10T03:11:45.362373+00:00 2021-07-10T03:11:47.165738+00:00 0:00:01.803365 52091 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 2 default 2021-07-10T03:11:42.844361+00:00 2 default_pool
success booking-processing-job_v002 create_emr_steps 2021-07-10T02:00:00+00:00 PythonOperator 2021-07-10T03:11:30.923097+00:00 2021-07-10T03:11:35.052466+00:00 0:00:04.129369 52090 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-07-10T03:11:28.655920+00:00 2 default_pool
success campaign-history-job_v002 create_emr_steps 2021-07-10T02:00:00+00:00 PythonOperator 2021-07-10T03:11:25.423866+00:00 2021-07-10T03:11:28.958807+00:00 0:00:03.534941 52089 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-07-10T03:11:22.606036+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_campaign-history-job_v002 2021-07-10T02:00:00+00:00 TriggerDagRunOperator 2021-07-10T03:11:16.870316+00:00 2021-07-10T03:11:17.370934+00:00 0:00:00.500618 52088 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-07-10T03:11:14.601973+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_booking-processing-job_v002 2021-07-10T02:00:00+00:00 TriggerDagRunOperator 2021-07-10T03:11:16.801140+00:00 2021-07-10T03:11:17.231389+00:00 0:00:00.430249 52087 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-07-10T03:11:14.602008+00:00 2 default_pool
success vc-asset-import_v002 check_cluster_status 2021-07-10T02:05:00+00:00 EmrJobFlowSensor 2021-07-10T03:07:12.406587+00:00 2021-07-10T03:15:15.020769+00:00 0:08:02.614182 52086 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-07-10T03:07:10.216783+00:00 2 default_pool
success vc-asset-import_v002 create_cluster_and_add_emr_steps 2021-07-10T02:05:00+00:00 EmrCreateJobFlowOperator 2021-07-10T03:06:52.414517+00:00 2021-07-10T03:06:54.178872+00:00 0:00:01.764355 52085 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 2 default 2021-07-10T03:06:50.194802+00:00 2 default_pool
success vc-asset-import_v002 create_emr_steps 2021-07-10T02:05:00+00:00 PythonOperator 2021-07-10T03:06:30.929799+00:00 2021-07-10T03:06:34.356260+00:00 0:00:03.426461 52084 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-07-10T03:06:28.233184+00:00 2 default_pool
success campaign-flow-job_v002 check_cluster_status 2021-07-10T02:00:00+00:00 EmrJobFlowSensor 2021-07-10T03:01:06.358712+00:00 2021-07-10T03:11:09.296584+00:00 0:10:02.937872 52082 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-07-10T03:01:03.962705+00:00 2 default_pool
success campaign-flow-job_v002 create_cluster_and_add_emr_steps 2021-07-10T02:00:00+00:00 EmrCreateJobFlowOperator 2021-07-10T03:00:44.294267+00:00 2021-07-10T03:00:46.127232+00:00 0:00:01.832965 52081 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 4 default 2021-07-10T03:00:41.832184+00:00 2 default_pool
success campaign-flow-job_v002 create_emr_steps 2021-07-10T02:00:00+00:00 PythonOperator 2021-07-10T03:00:22.044028+00:00 2021-07-10T03:00:25.747377+00:00 0:00:03.703349 52080 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 5 default 2021-07-10T03:00:19.773756+00:00 2 default_pool
success vc-asset-import_v002 check_cluster_status 2021-07-10T01:05:00+00:00 EmrJobFlowSensor 2021-07-10T02:18:33.395541+00:00 2021-07-10T02:18:34.825425+00:00 0:00:01.429884 52079 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-07-10T02:18:31.157698+00:00 3 default_pool
success booking-processing-job_v002 check_cluster_status 2021-07-10T01:00:00+00:00 EmrJobFlowSensor 2021-07-10T02:15:46.908250+00:00 2021-07-10T02:25:49.916328+00:00 0:10:03.008078 52078 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-07-10T02:15:44.620015+00:00 2 default_pool
success campaign-history-job_v002 check_cluster_status 2021-07-10T01:00:00+00:00 EmrJobFlowSensor 2021-07-10T02:15:36.849683+00:00 2021-07-10T02:24:39.584852+00:00 0:09:02.735169 52077 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-07-10T02:15:34.612450+00:00 2 default_pool
success booking-processing-job_v002 create_cluster_and_add_emr_steps 2021-07-10T01:00:00+00:00 EmrCreateJobFlowOperator 2021-07-10T02:15:25.013351+00:00 2021-07-10T02:15:26.697894+00:00 0:00:01.684543 52076 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 2 default 2021-07-10T02:15:22.660891+00:00 2 default_pool
success campaign-history-job_v002 create_cluster_and_add_emr_steps 2021-07-10T01:00:00+00:00 EmrCreateJobFlowOperator 2021-07-10T02:15:13.071790+00:00 2021-07-10T02:15:14.801523+00:00 0:00:01.729733 52075 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 2 default 2021-07-10T02:15:10.661949+00:00 2 default_pool
success booking-processing-job_v002 create_emr_steps 2021-07-10T01:00:00+00:00 PythonOperator 2021-07-10T02:15:05.091806+00:00 2021-07-10T02:15:08.820083+00:00 0:00:03.728277 52074 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-07-10T02:15:02.589237+00:00 2 default_pool
success campaign-history-job_v002 create_emr_steps 2021-07-10T01:00:00+00:00 PythonOperator 2021-07-10T02:14:50.790823+00:00 2021-07-10T02:14:54.646889+00:00 0:00:03.856066 52073 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-07-10T02:14:48.517165+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_campaign-history-job_v002 2021-07-10T01:00:00+00:00 TriggerDagRunOperator 2021-07-10T02:14:40.753602+00:00 2021-07-10T02:14:41.161791+00:00 0:00:00.408189 52072 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-07-10T02:14:38.505768+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_booking-processing-job_v002 2021-07-10T01:00:00+00:00 TriggerDagRunOperator 2021-07-10T02:14:40.772033+00:00 2021-07-10T02:14:41.277807+00:00 0:00:00.505774 52071 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-07-10T02:14:38.505795+00:00 2 default_pool
success vc-asset-import_v002 create_cluster_and_add_emr_steps 2021-07-10T01:05:00+00:00 EmrCreateJobFlowOperator 2021-07-10T02:05:27.974370+00:00 2021-07-10T02:05:29.736725+00:00 0:00:01.762355 52069 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 2 default 2021-07-10T02:05:25.551866+00:00 2 default_pool
success campaign-flow-job_v002 check_cluster_status 2021-07-10T01:00:00+00:00 EmrJobFlowSensor 2021-07-10T02:05:11.679712+00:00 2021-07-10T02:14:14.521189+00:00 0:09:02.841477 52068 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-07-10T02:05:09.404205+00:00 2 default_pool
success vc-asset-import_v002 create_emr_steps 2021-07-10T01:05:00+00:00 PythonOperator 2021-07-10T02:05:07.695337+00:00 2021-07-10T02:05:11.433518+00:00 0:00:03.738181 52067 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-07-10T02:05:05.455426+00:00 2 default_pool
success campaign-flow-job_v002 create_cluster_and_add_emr_steps 2021-07-10T01:00:00+00:00 EmrCreateJobFlowOperator 2021-07-10T02:04:49.862908+00:00 2021-07-10T02:04:51.659331+00:00 0:00:01.796423 52066 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 4 default 2021-07-10T02:04:47.383924+00:00 2 default_pool
success campaign-flow-job_v002 create_emr_steps 2021-07-10T01:00:00+00:00 PythonOperator 2021-07-10T02:04:29.834574+00:00 2021-07-10T02:04:33.382815+00:00 0:00:03.548241 52065 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 5 default 2021-07-10T02:04:27.344434+00:00 2 default_pool
success booking-processing-job_v002 check_cluster_status 2021-07-10T00:00:00+00:00 EmrJobFlowSensor 2021-07-10T01:13:25.392876+00:00 2021-07-10T01:24:28.552195+00:00 0:11:03.159319 52063 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-07-10T01:13:22.969833+00:00 2 default_pool
success campaign-history-job_v002 check_cluster_status 2021-07-10T00:00:00+00:00 EmrJobFlowSensor 2021-07-10T01:13:09.104120+00:00 2021-07-10T01:23:12.065943+00:00 0:10:02.961823 52062 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-07-10T01:13:06.885637+00:00 2 default_pool
success booking-processing-job_v002 create_cluster_and_add_emr_steps 2021-07-10T00:00:00+00:00 EmrCreateJobFlowOperator 2021-07-10T01:13:05.018728+00:00 2021-07-10T01:13:06.737434+00:00 0:00:01.718706 52061 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 2 default 2021-07-10T01:13:02.877397+00:00 2 default_pool
success campaign-history-job_v002 create_cluster_and_add_emr_steps 2021-07-10T00:00:00+00:00 EmrCreateJobFlowOperator 2021-07-10T01:12:48.408094+00:00 2021-07-10T01:12:50.089622+00:00 0:00:01.681528 52060 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 2 default 2021-07-10T01:12:44.809057+00:00 2 default_pool
success booking-processing-job_v002 create_emr_steps 2021-07-10T00:00:00+00:00 PythonOperator 2021-07-10T01:12:42.997468+00:00 2021-07-10T01:12:48.358649+00:00 0:00:05.361181 52059 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-07-10T01:12:40.805469+00:00 2 default_pool
success campaign-history-job_v002 create_emr_steps 2021-07-10T00:00:00+00:00 PythonOperator 2021-07-10T01:12:25.403041+00:00 2021-07-10T01:12:29.336744+00:00 0:00:03.933703 52058 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-07-10T01:12:22.853522+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_booking-processing-job_v002 2021-07-10T00:00:00+00:00 TriggerDagRunOperator 2021-07-10T01:12:19.423569+00:00 2021-07-10T01:12:19.934146+00:00 0:00:00.510577 52057 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-07-10T01:12:16.788853+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_campaign-history-job_v002 2021-07-10T00:00:00+00:00 TriggerDagRunOperator 2021-07-10T01:12:19.307430+00:00 2021-07-10T01:12:19.693820+00:00 0:00:00.386390 52056 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-07-10T01:12:16.788807+00:00 2 default_pool
success vc-asset-import_v002 check_cluster_status 2021-07-10T00:05:00+00:00 EmrJobFlowSensor 2021-07-10T01:06:44.437537+00:00 2021-07-10T01:14:47.002764+00:00 0:08:02.565227 52055 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-07-10T01:06:42.149146+00:00 2 default_pool
success vc-asset-import_v002 create_cluster_and_add_emr_steps 2021-07-10T00:05:00+00:00 EmrCreateJobFlowOperator 2021-07-10T01:06:02.231217+00:00 2021-07-10T01:06:03.955299+00:00 0:00:01.724082 52054 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 2 default 2021-07-10T01:06:00.017529+00:00 2 default_pool
success vc-asset-import_v002 create_emr_steps 2021-07-10T00:05:00+00:00 PythonOperator 2021-07-10T01:05:24.315537+00:00 2021-07-10T01:05:27.731801+00:00 0:00:03.416264 52053 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-07-10T01:05:21.967149+00:00 2 default_pool
success campaign-flow-job_v002 check_cluster_status 2021-07-10T00:00:00+00:00 EmrJobFlowSensor 2021-07-10T01:01:52.000922+00:00 2021-07-10T01:11:55.214465+00:00 0:10:03.213543 52052 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-07-10T01:01:49.708025+00:00 2 default_pool
success campaign-flow-job_v002 create_cluster_and_add_emr_steps 2021-07-10T00:00:00+00:00 EmrCreateJobFlowOperator 2021-07-10T01:01:29.988887+00:00 2021-07-10T01:01:31.721932+00:00 0:00:01.733045 52051 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 4 default 2021-07-10T01:01:27.688426+00:00 2 default_pool
success campaign-flow-job_v002 create_emr_steps 2021-07-10T00:00:00+00:00 PythonOperator 2021-07-10T01:00:14.508856+00:00 2021-07-10T01:00:18.043470+00:00 0:00:03.534614 52050 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 5 default 2021-07-10T01:00:11.671336+00:00 2 default_pool
success booking-processing-job_v002 check_cluster_status 2021-07-09T23:00:00+00:00 EmrJobFlowSensor 2021-07-10T00:10:21.747918+00:00 2021-07-10T00:20:24.528711+00:00 0:10:02.780793 52048 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-07-10T00:10:19.006008+00:00 2 default_pool
success campaign-history-job_v002 check_cluster_status 2021-07-09T23:00:00+00:00 EmrJobFlowSensor 2021-07-10T00:10:19.532641+00:00 2021-07-10T00:20:22.852002+00:00 0:10:03.319361 52047 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-07-10T00:10:17.057007+00:00 2 default_pool
success campaign-history-job_v002 create_cluster_and_add_emr_steps 2021-07-09T23:00:00+00:00 EmrCreateJobFlowOperator 2021-07-10T00:09:59.512927+00:00 2021-07-10T00:10:01.338129+00:00 0:00:01.825202 52046 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 2 default 2021-07-10T00:09:56.970272+00:00 2 default_pool
success booking-processing-job_v002 create_cluster_and_add_emr_steps 2021-07-09T23:00:00+00:00 EmrCreateJobFlowOperator 2021-07-10T00:09:59.408230+00:00 2021-07-10T00:10:01.120726+00:00 0:00:01.712496 52045 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 2 default 2021-07-10T00:09:56.970241+00:00 2 default_pool
success booking-processing-job_v002 create_emr_steps 2021-07-09T23:00:00+00:00 PythonOperator 2021-07-10T00:09:39.204586+00:00 2021-07-10T00:09:42.848146+00:00 0:00:03.643560 52044 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-07-10T00:09:36.914654+00:00 2 default_pool
success campaign-history-job_v002 create_emr_steps 2021-07-09T23:00:00+00:00 PythonOperator 2021-07-10T00:09:37.118098+00:00 2021-07-10T00:09:40.828032+00:00 0:00:03.709934 52043 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-07-10T00:09:34.927036+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_campaign-history-job_v002 2021-07-09T23:00:00+00:00 TriggerDagRunOperator 2021-07-10T00:09:11.139960+00:00 2021-07-10T00:09:11.652967+00:00 0:00:00.513007 52042 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-07-10T00:09:08.893360+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_booking-processing-job_v002 2021-07-09T23:00:00+00:00 TriggerDagRunOperator 2021-07-10T00:09:11.096465+00:00 2021-07-10T00:09:11.495223+00:00 0:00:00.398758 52041 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-07-10T00:09:08.893391+00:00 2 default_pool
success vc-asset-import_v002 check_cluster_status 2021-07-09T23:05:00+00:00 EmrJobFlowSensor 2021-07-10T00:05:48.941848+00:00 2021-07-10T00:14:51.684762+00:00 0:09:02.742914 52040 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-07-10T00:05:46.655823+00:00 2 default_pool
success vc-asset-import_v002 create_cluster_and_add_emr_steps 2021-07-09T23:05:00+00:00 EmrCreateJobFlowOperator 2021-07-10T00:05:27.121330+00:00 2021-07-10T00:05:28.799106+00:00 0:00:01.677776 52039 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 2 default 2021-07-10T00:05:24.557857+00:00 2 default_pool
success vc-asset-import_v002 create_emr_steps 2021-07-09T23:05:00+00:00 PythonOperator 2021-07-10T00:05:06.685718+00:00 2021-07-10T00:05:10.359581+00:00 0:00:03.673863 52038 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-07-10T00:05:04.492424+00:00 2 default_pool
success campaign-flow-job_v002 check_cluster_status 2021-07-09T23:00:00+00:00 EmrJobFlowSensor 2021-07-10T00:00:56.556464+00:00 2021-07-10T00:08:59.339695+00:00 0:08:02.783231 52037 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-07-10T00:00:54.170502+00:00 2 default_pool
success campaign-flow-job_v002 create_cluster_and_add_emr_steps 2021-07-09T23:00:00+00:00 EmrCreateJobFlowOperator 2021-07-10T00:00:36.290325+00:00 2021-07-10T00:00:37.940966+00:00 0:00:01.650641 52036 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 4 default 2021-07-10T00:00:34.112104+00:00 2 default_pool
success campaign-flow-job_v002 create_emr_steps 2021-07-09T23:00:00+00:00 PythonOperator 2021-07-10T00:00:12.400590+00:00 2021-07-10T00:00:16.160911+00:00 0:00:03.760321 52035 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 5 default 2021-07-10T00:00:10.090286+00:00 2 default_pool
success booking-processing-job_v002 check_cluster_status 2021-07-09T22:00:00+00:00 EmrJobFlowSensor 2021-07-09T23:12:19.413947+00:00 2021-07-09T23:22:22.418993+00:00 0:10:03.005046 52033 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-07-09T23:12:17.059553+00:00 2 default_pool
success campaign-history-job_v002 check_cluster_status 2021-07-09T22:00:00+00:00 EmrJobFlowSensor 2021-07-09T23:12:09.659810+00:00 2021-07-09T23:22:12.542077+00:00 0:10:02.882267 52032 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-07-09T23:12:07.042244+00:00 2 default_pool
success booking-processing-job_v002 create_cluster_and_add_emr_steps 2021-07-09T22:00:00+00:00 EmrCreateJobFlowOperator 2021-07-09T23:11:57.404183+00:00 2021-07-09T23:11:59.119996+00:00 0:00:01.715813 52031 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 2 default 2021-07-09T23:11:55.058024+00:00 2 default_pool