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 check_cluster_status 2021-05-11T11:00:00+00:00 EmrJobFlowSensor 2021-05-11T12:15:36.836886+00:00 2021-05-11T12:25:39.765196+00:00 0:10:02.928310 26913 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-05-11T12:15:34.454174+00:00 2 default_pool
success booking-processing-job_v002 check_cluster_status 2021-05-11T11:00:00+00:00 EmrJobFlowSensor 2021-05-11T12:15:22.741297+00:00 2021-05-11T12:27:25.991823+00:00 0:12:03.250526 26912 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-05-11T12:15:20.340868+00:00 2 default_pool
success campaign-history-job_v002 create_cluster_and_add_emr_steps 2021-05-11T11:00:00+00:00 EmrCreateJobFlowOperator 2021-05-11T12:15:04.507556+00:00 2021-05-11T12:15:06.185814+00:00 0:00:01.678258 26911 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 2 default 2021-05-11T12:15:02.321725+00:00 2 default_pool
success booking-processing-job_v002 create_cluster_and_add_emr_steps 2021-05-11T11:00:00+00:00 EmrCreateJobFlowOperator 2021-05-11T12:14:56.642641+00:00 2021-05-11T12:14:58.521900+00:00 0:00:01.879259 26910 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 2 default 2021-05-11T12:14:54.309259+00:00 2 default_pool
success campaign-history-job_v002 create_emr_steps 2021-05-11T11:00:00+00:00 PythonOperator 2021-05-11T12:14:39.376050+00:00 2021-05-11T12:14:42.550814+00:00 0:00:03.174764 26909 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-05-11T12:14:36.298973+00:00 2 default_pool
success booking-processing-job_v002 create_emr_steps 2021-05-11T11:00:00+00:00 PythonOperator 2021-05-11T12:14:34.515002+00:00 2021-05-11T12:14:38.936166+00:00 0:00:04.421164 26908 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-05-11T12:14:32.288197+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_campaign-history-job_v002 2021-05-11T11:00:00+00:00 TriggerDagRunOperator 2021-05-11T12:14:28.774335+00:00 2021-05-11T12:14:29.307351+00:00 0:00:00.533016 26907 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-05-11T12:14:26.290814+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_booking-processing-job_v002 2021-05-11T11:00:00+00:00 TriggerDagRunOperator 2021-05-11T12:14:28.479854+00:00 2021-05-11T12:14:28.896991+00:00 0:00:00.417137 26906 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-05-11T12:14:26.290845+00:00 2 default_pool
success vc-asset-import_v002 check_cluster_status 2021-05-11T11:05:00+00:00 EmrJobFlowSensor 2021-05-11T12:06:05.558011+00:00 2021-05-11T12:16:08.322013+00:00 0:10:02.764002 26905 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-05-11T12:06:03.409784+00:00 2 default_pool
success vc-asset-import_v002 create_cluster_and_add_emr_steps 2021-05-11T11:05:00+00:00 EmrCreateJobFlowOperator 2021-05-11T12:05:43.579877+00:00 2021-05-11T12:05:45.327168+00:00 0:00:01.747291 26904 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 2 default 2021-05-11T12:05:41.390960+00:00 2 default_pool
success vc-asset-import_v002 create_emr_steps 2021-05-11T11:05:00+00:00 PythonOperator 2021-05-11T12:05:21.523636+00:00 2021-05-11T12:05:24.662651+00:00 0:00:03.139015 26903 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-05-11T12:05:19.347854+00:00 2 default_pool
success campaign-flow-job_v002 check_cluster_status 2021-05-11T11:00:00+00:00 EmrJobFlowSensor 2021-05-11T12:01:10.922476+00:00 2021-05-11T12:14:14.613480+00:00 0:13:03.691004 26902 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-05-11T12:01:08.719053+00:00 2 default_pool
success campaign-flow-job_v002 create_cluster_and_add_emr_steps 2021-05-11T11:00:00+00:00 EmrCreateJobFlowOperator 2021-05-11T12:00:43.093848+00:00 2021-05-11T12:00:44.901690+00:00 0:00:01.807842 26901 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 4 default 2021-05-11T12:00:40.697699+00:00 2 default_pool
success campaign-flow-job_v002 create_emr_steps 2021-05-11T11:00:00+00:00 PythonOperator 2021-05-11T12:00:17.083999+00:00 2021-05-11T12:00:20.201122+00:00 0:00:03.117123 26900 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 5 default 2021-05-11T12:00:14.653121+00:00 2 default_pool
success campaign-history-job_v002 check_cluster_status 2021-05-11T11:30:27.816525+00:00 EmrJobFlowSensor 2021-05-11T11:31:29.161533+00:00 2021-05-11T11:41:37.212089+00:00 0:10:08.050556 26898 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-05-11T11:31:26.665871+00:00 2 default_pool
success campaign-history-job_v002 create_cluster_and_add_emr_steps 2021-05-11T11:30:27.816525+00:00 EmrCreateJobFlowOperator 2021-05-11T11:31:08.729237+00:00 2021-05-11T11:31:10.555810+00:00 0:00:01.826573 26897 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 2 default 2021-05-11T11:31:06.588121+00:00 2 default_pool
success campaign-history-job_v002 create_emr_steps 2021-05-11T11:30:27.816525+00:00 PythonOperator 2021-05-11T11:30:46.578391+00:00 2021-05-11T11:30:49.712990+00:00 0:00:03.134599 26896 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-05-11T11:30:44.508709+00:00 2 default_pool
success booking-processing-job_v002 check_cluster_status 2021-05-11T10:00:00+00:00 EmrJobFlowSensor 2021-05-11T11:13:21.119956+00:00 2021-05-11T11:25:29.406764+00:00 0:12:08.286808 26895 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-05-11T11:13:18.886874+00:00 2 default_pool
success campaign-history-job_v002 check_cluster_status 2021-05-11T10:00:00+00:00 EmrJobFlowSensor 2021-05-11T11:13:06.895664+00:00 2021-05-11T11:22:09.466927+00:00 0:09:02.571263 26894 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-05-11T11:13:04.813643+00:00 2 default_pool
success booking-processing-job_v002 create_cluster_and_add_emr_steps 2021-05-11T10:00:00+00:00 EmrCreateJobFlowOperator 2021-05-11T11:13:01.133345+00:00 2021-05-11T11:13:03.017545+00:00 0:00:01.884200 26893 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 2 default 2021-05-11T11:12:58.840784+00:00 2 default_pool
success campaign-history-job_v002 create_cluster_and_add_emr_steps 2021-05-11T10:00:00+00:00 EmrCreateJobFlowOperator 2021-05-11T11:12:44.978431+00:00 2021-05-11T11:12:46.715471+00:00 0:00:01.737040 26892 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 2 default 2021-05-11T11:12:42.793994+00:00 2 default_pool
success booking-processing-job_v002 create_emr_steps 2021-05-11T10:00:00+00:00 PythonOperator 2021-05-11T11:12:39.333039+00:00 2021-05-11T11:12:42.694325+00:00 0:00:03.361286 26891 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-05-11T11:12:36.788278+00:00 2 default_pool
success campaign-history-job_v002 create_emr_steps 2021-05-11T10:00:00+00:00 PythonOperator 2021-05-11T11:12:25.512824+00:00 2021-05-11T11:12:28.771633+00:00 0:00:03.258809 26890 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-05-11T11:12:22.732096+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_campaign-history-job_v002 2021-05-11T10:00:00+00:00 TriggerDagRunOperator 2021-05-11T11:12:16.935644+00:00 2021-05-11T11:12:17.467770+00:00 0:00:00.532126 26889 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-05-11T11:12:14.724454+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_booking-processing-job_v002 2021-05-11T10:00:00+00:00 TriggerDagRunOperator 2021-05-11T11:12:16.785231+00:00 2021-05-11T11:12:17.180243+00:00 0:00:00.395012 26888 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-05-11T11:12:14.724488+00:00 2 default_pool
success vc-asset-import_v002 check_cluster_status 2021-05-11T10:05:00+00:00 EmrJobFlowSensor 2021-05-11T11:06:02.358566+00:00 2021-05-11T11:15:05.565634+00:00 0:09:03.207068 26887 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-05-11T11:06:00.163482+00:00 2 default_pool
success vc-asset-import_v002 create_cluster_and_add_emr_steps 2021-05-11T10:05:00+00:00 EmrCreateJobFlowOperator 2021-05-11T11:05:40.205499+00:00 2021-05-11T11:05:41.860644+00:00 0:00:01.655145 26886 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 2 default 2021-05-11T11:05:38.092466+00:00 2 default_pool
success vc-asset-import_v002 create_emr_steps 2021-05-11T10:05:00+00:00 PythonOperator 2021-05-11T11:05:20.158562+00:00 2021-05-11T11:05:23.294490+00:00 0:00:03.135928 26885 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-05-11T11:05:18.027370+00:00 2 default_pool
success campaign-flow-job_v002 check_cluster_status 2021-05-11T10:00:00+00:00 EmrJobFlowSensor 2021-05-11T11:01:04.021806+00:00 2021-05-11T11:12:06.877516+00:00 0:11:02.855710 26884 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-05-11T11:01:01.738468+00:00 2 default_pool
success campaign-flow-job_v002 create_cluster_and_add_emr_steps 2021-05-11T10:00:00+00:00 EmrCreateJobFlowOperator 2021-05-11T11:00:42.007099+00:00 2021-05-11T11:00:43.799916+00:00 0:00:01.792817 26883 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 4 default 2021-05-11T11:00:39.709041+00:00 2 default_pool
success campaign-flow-job_v002 create_emr_steps 2021-05-11T10:00:00+00:00 PythonOperator 2021-05-11T11:00:18.009872+00:00 2021-05-11T11:00:21.156635+00:00 0:00:03.146763 26882 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 5 default 2021-05-11T11:00:15.690492+00:00 2 default_pool
success booking-processing-job_v002 check_cluster_status 2021-05-11T09:00:00+00:00 EmrJobFlowSensor 2021-05-11T10:11:08.045602+00:00 2021-05-11T10:20:10.646243+00:00 0:09:02.600641 26880 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-05-11T10:11:05.765455+00:00 2 default_pool
success campaign-history-job_v002 check_cluster_status 2021-05-11T09:00:00+00:00 EmrJobFlowSensor 2021-05-11T10:10:56.608569+00:00 2021-05-11T10:20:59.567604+00:00 0:10:02.959035 26879 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-05-11T10:10:53.694316+00:00 2 default_pool
success booking-processing-job_v002 create_cluster_and_add_emr_steps 2021-05-11T09:00:00+00:00 EmrCreateJobFlowOperator 2021-05-11T10:10:48.060371+00:00 2021-05-11T10:10:49.926389+00:00 0:00:01.866018 26878 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 2 default 2021-05-11T10:10:45.757330+00:00 2 default_pool
success campaign-history-job_v002 create_cluster_and_add_emr_steps 2021-05-11T09:00:00+00:00 EmrCreateJobFlowOperator 2021-05-11T10:10:35.905042+00:00 2021-05-11T10:10:37.724790+00:00 0:00:01.819748 26877 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 2 default 2021-05-11T10:10:33.655123+00:00 2 default_pool
success booking-processing-job_v002 create_emr_steps 2021-05-11T09:00:00+00:00 PythonOperator 2021-05-11T10:10:25.821895+00:00 2021-05-11T10:10:29.245518+00:00 0:00:03.423623 26876 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-05-11T10:10:23.644615+00:00 2 default_pool
success campaign-history-job_v002 create_emr_steps 2021-05-11T09:00:00+00:00 PythonOperator 2021-05-11T10:10:14.002932+00:00 2021-05-11T10:10:17.157717+00:00 0:00:03.154785 26875 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-05-11T10:10:11.639861+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_campaign-history-job_v002 2021-05-11T09:00:00+00:00 TriggerDagRunOperator 2021-05-11T10:10:08.203642+00:00 2021-05-11T10:10:08.798819+00:00 0:00:00.595177 26874 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-05-11T10:10:05.667095+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_booking-processing-job_v002 2021-05-11T09:00:00+00:00 TriggerDagRunOperator 2021-05-11T10:10:08.168640+00:00 2021-05-11T10:10:08.620314+00:00 0:00:00.451674 26873 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-05-11T10:10:05.667123+00:00 2 default_pool
success vc-asset-import_v002 check_cluster_status 2021-05-11T09:05:00+00:00 EmrJobFlowSensor 2021-05-11T10:06:05.513323+00:00 2021-05-11T10:14:08.047591+00:00 0:08:02.534268 26872 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-05-11T10:06:03.280745+00:00 2 default_pool
success vc-asset-import_v002 create_cluster_and_add_emr_steps 2021-05-11T09:05:00+00:00 EmrCreateJobFlowOperator 2021-05-11T10:05:37.467973+00:00 2021-05-11T10:05:39.247690+00:00 0:00:01.779717 26871 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 2 default 2021-05-11T10:05:35.259339+00:00 2 default_pool
success vc-asset-import_v002 create_emr_steps 2021-05-11T09:05:00+00:00 PythonOperator 2021-05-11T10:05:15.646701+00:00 2021-05-11T10:05:18.722097+00:00 0:00:03.075396 26870 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-05-11T10:05:13.282864+00:00 2 default_pool
success campaign-flow-job_v002 check_cluster_status 2021-05-11T09:00:00+00:00 EmrJobFlowSensor 2021-05-11T10:01:01.107660+00:00 2021-05-11T10:10:03.927005+00:00 0:09:02.819345 26869 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-05-11T10:00:58.844125+00:00 2 default_pool
success campaign-flow-job_v002 create_cluster_and_add_emr_steps 2021-05-11T09:00:00+00:00 EmrCreateJobFlowOperator 2021-05-11T10:00:39.013165+00:00 2021-05-11T10:00:40.688154+00:00 0:00:01.674989 26868 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 4 default 2021-05-11T10:00:36.753883+00:00 2 default_pool
success campaign-flow-job_v002 create_emr_steps 2021-05-11T09:00:00+00:00 PythonOperator 2021-05-11T10:00:18.998947+00:00 2021-05-11T10:00:22.155489+00:00 0:00:03.156542 26867 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 5 default 2021-05-11T10:00:16.688253+00:00 2 default_pool
success booking-processing-job_v002 check_cluster_status 2021-05-11T08:00:00+00:00 EmrJobFlowSensor 2021-05-11T09:11:14.413704+00:00 2021-05-11T09:21:17.212986+00:00 0:10:02.799282 26865 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-05-11T09:11:12.094677+00:00 2 default_pool
success campaign-history-job_v002 check_cluster_status 2021-05-11T08:00:00+00:00 EmrJobFlowSensor 2021-05-11T09:11:06.400369+00:00 2021-05-11T09:19:08.919003+00:00 0:08:02.518634 26864 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-05-11T09:11:04.159720+00:00 2 default_pool
success booking-processing-job_v002 create_cluster_and_add_emr_steps 2021-05-11T08:00:00+00:00 EmrCreateJobFlowOperator 2021-05-11T09:10:54.487117+00:00 2021-05-11T09:10:56.175287+00:00 0:00:01.688170 26863 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 2 default 2021-05-11T09:10:52.152671+00:00 2 default_pool
success campaign-history-job_v002 create_cluster_and_add_emr_steps 2021-05-11T08:00:00+00:00 EmrCreateJobFlowOperator 2021-05-11T09:10:44.478273+00:00 2021-05-11T09:10:46.151046+00:00 0:00:01.672773 26862 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 2 default 2021-05-11T09:10:42.075184+00:00 2 default_pool
success booking-processing-job_v002 create_emr_steps 2021-05-11T08:00:00+00:00 PythonOperator 2021-05-11T09:10:32.396566+00:00 2021-05-11T09:10:35.654733+00:00 0:00:03.258167 26861 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-05-11T09:10:30.071131+00:00 2 default_pool
success campaign-history-job_v002 create_emr_steps 2021-05-11T08:00:00+00:00 PythonOperator 2021-05-11T09:10:24.217584+00:00 2021-05-11T09:10:27.292865+00:00 0:00:03.075281 26860 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-05-11T09:10:22.006076+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_booking-processing-job_v002 2021-05-11T08:00:00+00:00 TriggerDagRunOperator 2021-05-11T09:10:14.662518+00:00 2021-05-11T09:10:15.167827+00:00 0:00:00.505309 26859 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-05-11T09:10:11.912240+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_campaign-history-job_v002 2021-05-11T08:00:00+00:00 TriggerDagRunOperator 2021-05-11T09:10:14.510919+00:00 2021-05-11T09:10:14.912181+00:00 0:00:00.401262 26858 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-05-11T09:10:11.912210+00:00 2 default_pool
success vc-asset-import_v002 check_cluster_status 2021-05-11T08:05:00+00:00 EmrJobFlowSensor 2021-05-11T09:05:59.742776+00:00 2021-05-11T09:14:02.367211+00:00 0:08:02.624435 26857 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-05-11T09:05:57.640797+00:00 2 default_pool
success vc-asset-import_v002 create_cluster_and_add_emr_steps 2021-05-11T08:05:00+00:00 EmrCreateJobFlowOperator 2021-05-11T09:05:37.612067+00:00 2021-05-11T09:05:39.240732+00:00 0:00:01.628665 26856 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 2 default 2021-05-11T09:05:35.568820+00:00 2 default_pool
success vc-asset-import_v002 create_emr_steps 2021-05-11T08:05:00+00:00 PythonOperator 2021-05-11T09:05:15.929691+00:00 2021-05-11T09:05:19.070882+00:00 0:00:03.141191 26855 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-05-11T09:05:13.577618+00:00 2 default_pool
success campaign-flow-job_v002 check_cluster_status 2021-05-11T08:00:00+00:00 EmrJobFlowSensor 2021-05-11T09:00:59.771816+00:00 2021-05-11T09:10:02.655333+00:00 0:09:02.883517 26854 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-05-11T09:00:57.166598+00:00 2 default_pool
success campaign-flow-job_v002 create_cluster_and_add_emr_steps 2021-05-11T08:00:00+00:00 EmrCreateJobFlowOperator 2021-05-11T09:00:37.347242+00:00 2021-05-11T09:00:39.069758+00:00 0:00:01.722516 26853 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 4 default 2021-05-11T09:00:35.087988+00:00 2 default_pool
success campaign-flow-job_v002 create_emr_steps 2021-05-11T08:00:00+00:00 PythonOperator 2021-05-11T09:00:17.476525+00:00 2021-05-11T09:00:20.610046+00:00 0:00:03.133521 26852 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 5 default 2021-05-11T09:00:15.072132+00:00 2 default_pool
success booking-processing-job_v002 check_cluster_status 2021-05-11T07:00:00+00:00 EmrJobFlowSensor 2021-05-11T08:11:06.311176+00:00 2021-05-11T08:20:08.952630+00:00 0:09:02.641454 26850 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-05-11T08:11:03.971422+00:00 2 default_pool
success campaign-history-job_v002 check_cluster_status 2021-05-11T07:00:00+00:00 EmrJobFlowSensor 2021-05-11T08:10:58.180595+00:00 2021-05-11T08:21:00.947582+00:00 0:10:02.766987 26849 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-05-11T08:10:55.982065+00:00 2 default_pool
success booking-processing-job_v002 create_cluster_and_add_emr_steps 2021-05-11T07:00:00+00:00 EmrCreateJobFlowOperator 2021-05-11T08:10:44.454767+00:00 2021-05-11T08:10:46.204564+00:00 0:00:01.749797 26848 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 2 default 2021-05-11T08:10:41.955776+00:00 2 default_pool
success campaign-history-job_v002 create_cluster_and_add_emr_steps 2021-05-11T07:00:00+00:00 EmrCreateJobFlowOperator 2021-05-11T08:10:37.992252+00:00 2021-05-11T08:10:39.705518+00:00 0:00:01.713266 26847 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 2 default 2021-05-11T08:10:35.882690+00:00 2 default_pool
success booking-processing-job_v002 create_emr_steps 2021-05-11T07:00:00+00:00 PythonOperator 2021-05-11T08:10:22.094059+00:00 2021-05-11T08:10:25.723908+00:00 0:00:03.629849 26846 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-05-11T08:10:19.820888+00:00 2 default_pool
success campaign-history-job_v002 create_emr_steps 2021-05-11T07:00:00+00:00 PythonOperator 2021-05-11T08:10:16.207364+00:00 2021-05-11T08:10:19.270817+00:00 0:00:03.063453 26845 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-05-11T08:10:13.816922+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_booking-processing-job_v002 2021-05-11T07:00:00+00:00 TriggerDagRunOperator 2021-05-11T08:10:06.439274+00:00 2021-05-11T08:10:06.941558+00:00 0:00:00.502284 26844 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-05-11T08:10:03.807682+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_campaign-history-job_v002 2021-05-11T07:00:00+00:00 TriggerDagRunOperator 2021-05-11T08:10:06.022783+00:00 2021-05-11T08:10:06.440483+00:00 0:00:00.417700 26843 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-05-11T08:10:03.807650+00:00 2 default_pool
success vc-asset-import_v002 check_cluster_status 2021-05-11T07:05:00+00:00 EmrJobFlowSensor 2021-05-11T08:05:53.922790+00:00 2021-05-11T08:14:56.676488+00:00 0:09:02.753698 26842 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-05-11T08:05:51.440656+00:00 2 default_pool
success vc-asset-import_v002 create_cluster_and_add_emr_steps 2021-05-11T07:05:00+00:00 EmrCreateJobFlowOperator 2021-05-11T08:05:29.901982+00:00 2021-05-11T08:05:31.586504+00:00 0:00:01.684522 26841 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 2 default 2021-05-11T08:05:27.441187+00:00 2 default_pool
success vc-asset-import_v002 create_emr_steps 2021-05-11T07:05:00+00:00 PythonOperator 2021-05-11T08:05:09.563613+00:00 2021-05-11T08:05:12.651955+00:00 0:00:03.088342 26840 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-05-11T08:05:07.365501+00:00 2 default_pool
success campaign-flow-job_v002 check_cluster_status 2021-05-11T07:00:00+00:00 EmrJobFlowSensor 2021-05-11T08:00:57.065970+00:00 2021-05-11T08:09:59.829554+00:00 0:09:02.763584 26839 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-05-11T08:00:54.834223+00:00 2 default_pool
success campaign-flow-job_v002 create_cluster_and_add_emr_steps 2021-05-11T07:00:00+00:00 EmrCreateJobFlowOperator 2021-05-11T08:00:37.013103+00:00 2021-05-11T08:00:38.862969+00:00 0:00:01.849866 26838 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 4 default 2021-05-11T08:00:34.809508+00:00 2 default_pool
success campaign-flow-job_v002 create_emr_steps 2021-05-11T07:00:00+00:00 PythonOperator 2021-05-11T08:00:13.132836+00:00 2021-05-11T08:00:16.271518+00:00 0:00:03.138682 26837 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 5 default 2021-05-11T08:00:10.785270+00:00 2 default_pool
success booking-processing-job_v002 check_cluster_status 2021-05-11T06:00:00+00:00 EmrJobFlowSensor 2021-05-11T07:28:09.229767+00:00 2021-05-11T07:40:12.263918+00:00 0:12:03.034151 26835 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-05-11T07:28:06.697268+00:00 2 default_pool
success campaign-history-job_v002 check_cluster_status 2021-05-11T06:00:00+00:00 EmrJobFlowSensor 2021-05-11T07:28:03.328144+00:00 2021-05-11T07:37:05.971291+00:00 0:09:02.643147 26834 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-05-11T07:28:00.752386+00:00 2 default_pool
success booking-processing-job_v002 create_cluster_and_add_emr_steps 2021-05-11T06:00:00+00:00 EmrCreateJobFlowOperator 2021-05-11T07:27:49.643479+00:00 2021-05-11T07:27:51.384705+00:00 0:00:01.741226 26833 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 2 default 2021-05-11T07:27:46.679851+00:00 2 default_pool
success campaign-history-job_v002 create_cluster_and_add_emr_steps 2021-05-11T06:00:00+00:00 EmrCreateJobFlowOperator 2021-05-11T07:27:40.853512+00:00 2021-05-11T07:27:42.507288+00:00 0:00:01.653776 26832 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 2 default 2021-05-11T07:27:38.654765+00:00 2 default_pool
success booking-processing-job_v002 create_emr_steps 2021-05-11T06:00:00+00:00 PythonOperator 2021-05-11T07:27:26.846534+00:00 2021-05-11T07:27:30.183459+00:00 0:00:03.336925 26831 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-05-11T07:27:24.646447+00:00 2 default_pool
success campaign-history-job_v002 create_emr_steps 2021-05-11T06:00:00+00:00 PythonOperator 2021-05-11T07:27:20.691442+00:00 2021-05-11T07:27:23.785578+00:00 0:00:03.094136 26830 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-05-11T07:27:18.565213+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_campaign-history-job_v002 2021-05-11T06:00:00+00:00 TriggerDagRunOperator 2021-05-11T07:27:10.850930+00:00 2021-05-11T07:27:11.395017+00:00 0:00:00.544087 26829 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-05-11T07:27:08.555663+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_booking-processing-job_v002 2021-05-11T06:00:00+00:00 TriggerDagRunOperator 2021-05-11T07:27:10.771802+00:00 2021-05-11T07:27:11.204081+00:00 0:00:00.432279 26828 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-05-11T07:27:08.555695+00:00 2 default_pool
success vc-asset-import_v002 check_cluster_status 2021-05-11T06:05:00+00:00 EmrJobFlowSensor 2021-05-11T07:06:04.442952+00:00 2021-05-11T07:15:07.029275+00:00 0:09:02.586323 26827 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-05-11T07:06:02.285853+00:00 2 default_pool
success vc-asset-import_v002 create_cluster_and_add_emr_steps 2021-05-11T06:05:00+00:00 EmrCreateJobFlowOperator 2021-05-11T07:05:42.410311+00:00 2021-05-11T07:05:44.140545+00:00 0:00:01.730234 26826 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 2 default 2021-05-11T07:05:40.197829+00:00 2 default_pool
success vc-asset-import_v002 create_emr_steps 2021-05-11T06:05:00+00:00 PythonOperator 2021-05-11T07:05:20.341437+00:00 2021-05-11T07:05:23.380461+00:00 0:00:03.039024 26825 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-05-11T07:05:18.181853+00:00 2 default_pool
success campaign-flow-job_v002 check_cluster_status 2021-05-11T06:00:00+00:00 EmrJobFlowSensor 2021-05-11T07:00:48.050652+00:00 2021-05-11T07:26:53.308343+00:00 0:26:05.257691 26824 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-05-11T07:00:45.749945+00:00 2 default_pool
success campaign-flow-job_v002 create_cluster_and_add_emr_steps 2021-05-11T06:00:00+00:00 EmrCreateJobFlowOperator 2021-05-11T07:00:26.025973+00:00 2021-05-11T07:00:27.842293+00:00 0:00:01.816320 26823 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 4 default 2021-05-11T07:00:23.733506+00:00 2 default_pool
success campaign-flow-job_v002 create_emr_steps 2021-05-11T06:00:00+00:00 PythonOperator 2021-05-11T07:00:04.277505+00:00 2021-05-11T07:00:07.472884+00:00 0:00:03.195379 26822 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 5 default 2021-05-11T07:00:01.719491+00:00 2 default_pool
success booking-processing-job_v002 check_cluster_status 2021-05-11T05:00:00+00:00 EmrJobFlowSensor 2021-05-11T06:25:28.331216+00:00 2021-05-11T06:34:30.942051+00:00 0:09:02.610835 26820 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-05-11T06:25:26.060979+00:00 2 default_pool
success campaign-history-job_v002 check_cluster_status 2021-05-11T05:00:00+00:00 EmrJobFlowSensor 2021-05-11T06:25:12.278603+00:00 2021-05-11T06:40:15.826563+00:00 0:15:03.547960 26819 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-05-11T06:25:10.047158+00:00 2 default_pool
success booking-processing-job_v002 create_cluster_and_add_emr_steps 2021-05-11T05:00:00+00:00 EmrCreateJobFlowOperator 2021-05-11T06:25:06.421942+00:00 2021-05-11T06:25:08.134911+00:00 0:00:01.712969 26818 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 2 default 2021-05-11T06:25:04.042516+00:00 2 default_pool
success campaign-history-job_v002 create_cluster_and_add_emr_steps 2021-05-11T05:00:00+00:00 EmrCreateJobFlowOperator 2021-05-11T06:24:50.231992+00:00 2021-05-11T06:24:51.921962+00:00 0:00:01.689970 26817 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 2 default 2021-05-11T06:24:48.028460+00:00 2 default_pool
success booking-processing-job_v002 create_emr_steps 2021-05-11T05:00:00+00:00 PythonOperator 2021-05-11T06:24:44.372932+00:00 2021-05-11T06:24:47.734949+00:00 0:00:03.362017 26816 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-05-11T06:24:42.023889+00:00 2 default_pool
success campaign-history-job_v002 create_emr_steps 2021-05-11T05:00:00+00:00 PythonOperator 2021-05-11T06:24:28.378846+00:00 2021-05-11T06:24:31.567316+00:00 0:00:03.188470 26815 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-05-11T06:24:26.008192+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_campaign-history-job_v002 2021-05-11T05:00:00+00:00 TriggerDagRunOperator 2021-05-11T06:24:22.354402+00:00 2021-05-11T06:24:22.877269+00:00 0:00:00.522867 26814 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-05-11T06:24:20.004218+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_booking-processing-job_v002 2021-05-11T05:00:00+00:00 TriggerDagRunOperator 2021-05-11T06:24:22.367239+00:00 2021-05-11T06:24:22.952501+00:00 0:00:00.585262 26813 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-05-11T06:24:20.004246+00:00 2 default_pool
success vc-asset-import_v002 check_cluster_status 2021-05-11T05:05:00+00:00 EmrJobFlowSensor 2021-05-11T06:06:38.289340+00:00 2021-05-11T06:15:40.974399+00:00 0:09:02.685059 26812 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-05-11T06:06:36.116052+00:00 2 default_pool
success vc-asset-import_v002 create_cluster_and_add_emr_steps 2021-05-11T05:05:00+00:00 EmrCreateJobFlowOperator 2021-05-11T06:06:16.375287+00:00 2021-05-11T06:06:18.170964+00:00 0:00:01.795677 26811 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 2 default 2021-05-11T06:06:14.102859+00:00 2 default_pool
success vc-asset-import_v002 create_emr_steps 2021-05-11T05:05:00+00:00 PythonOperator 2021-05-11T06:05:56.375337+00:00 2021-05-11T06:05:59.433428+00:00 0:00:03.058091 26810 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-05-11T06:05:54.054311+00:00 2 default_pool
success campaign-flow-job_v002 check_cluster_status 2021-05-11T05:00:00+00:00 EmrJobFlowSensor 2021-05-11T06:00:53.777609+00:00 2021-05-11T06:23:58.500511+00:00 0:23:04.722902 26809 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-05-11T06:00:51.672394+00:00 2 default_pool
success campaign-flow-job_v002 create_cluster_and_add_emr_steps 2021-05-11T05:00:00+00:00 EmrCreateJobFlowOperator 2021-05-11T06:00:30.341746+00:00 2021-05-11T06:00:32.143988+00:00 0:00:01.802242 26808 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 4 default 2021-05-11T06:00:27.748467+00:00 2 default_pool