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-flow-job_v002 trigger_dagrun_campaign-history-job_v002 2021-07-03T10:00:00+00:00 TriggerDagRunOperator 2021-07-03T11:09:13.073751+00:00 2021-07-03T11:09:13.570411+00:00 0:00:00.496660 49223 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-07-03T11:09:10.544642+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_booking-processing-job_v002 2021-07-03T10:00:00+00:00 TriggerDagRunOperator 2021-07-03T11:09:12.965228+00:00 2021-07-03T11:09:13.340465+00:00 0:00:00.375237 49222 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-07-03T11:09:10.544693+00:00 2 default_pool
success vc-asset-import_v002 check_cluster_status 2021-07-03T10:05:00+00:00 EmrJobFlowSensor 2021-07-03T11:05:50.443229+00:00 2021-07-03T11:14:53.190616+00:00 0:09:02.747387 49221 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-07-03T11:05:48.208242+00:00 2 default_pool
success vc-asset-import_v002 create_cluster_and_add_emr_steps 2021-07-03T10:05:00+00:00 EmrCreateJobFlowOperator 2021-07-03T11:05:28.838319+00:00 2021-07-03T11:05:30.556518+00:00 0:00:01.718199 49220 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 2 default 2021-07-03T11:05:26.263989+00:00 2 default_pool
success vc-asset-import_v002 create_emr_steps 2021-07-03T10:05:00+00:00 PythonOperator 2021-07-03T11:05:08.303059+00:00 2021-07-03T11:05:11.912310+00:00 0:00:03.609251 49219 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-07-03T11:05:06.126815+00:00 2 default_pool
success livepop-shuffle-job_v002 check_cluster_status 2021-07-03T10:00:00+00:00 EmrJobFlowSensor 2021-07-03T11:01:03.927866+00:00 2021-07-03T11:11:06.797807+00:00 0:10:02.869941 49218 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-07-03T11:01:01.783272+00:00 2 default_pool
success campaign-flow-job_v002 check_cluster_status 2021-07-03T10:00:00+00:00 EmrJobFlowSensor 2021-07-03T11:00:58.011763+00:00 2021-07-03T11:09:00.753572+00:00 0:08:02.741809 49217 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-07-03T11:00:55.731444+00:00 2 default_pool
success livepop-shuffle-job_v002 create_cluster_and_add_emr_steps 2021-07-03T10:00:00+00:00 EmrCreateJobFlowOperator 2021-07-03T11:00:40.221290+00:00 2021-07-03T11:00:42.028773+00:00 0:00:01.807483 49216 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 2 default 2021-07-03T11:00:37.773195+00:00 2 default_pool
success campaign-flow-job_v002 create_cluster_and_add_emr_steps 2021-07-03T10:00:00+00:00 EmrCreateJobFlowOperator 2021-07-03T11:00:36.001867+00:00 2021-07-03T11:00:37.682429+00:00 0:00:01.680562 49215 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 4 default 2021-07-03T11:00:33.715649+00:00 2 default_pool
success livepop-shuffle-job_v002 create_emr_steps 2021-07-03T10:00:00+00:00 PythonOperator 2021-07-03T11:00:20.165948+00:00 2021-07-03T11:00:23.898982+00:00 0:00:03.733034 49214 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-07-03T11:00:17.769499+00:00 2 default_pool
success campaign-flow-job_v002 create_emr_steps 2021-07-03T10:00:00+00:00 PythonOperator 2021-07-03T11:00:13.972162+00:00 2021-07-03T11:00:17.623917+00:00 0:00:03.651755 49213 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 5 default 2021-07-03T11:00:11.696910+00:00 2 default_pool
success vc-asset-import_v002 check_cluster_status 2021-07-03T09:05:00+00:00 EmrJobFlowSensor 2021-07-03T10:13:02.551261+00:00 2021-07-03T10:15:04.457026+00:00 0:02:01.905765 49211 airflow-worker-2.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-07-03T10:12:59.982893+00:00 3 default_pool
success campaign-history-job_v002 check_cluster_status 2021-07-03T09:00:00+00:00 EmrJobFlowSensor 2021-07-03T10:11:17.927377+00:00 2021-07-03T10:21:20.719459+00:00 0:10:02.792082 49210 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-07-03T10:11:15.733889+00:00 2 default_pool
success booking-processing-job_v002 check_cluster_status 2021-07-03T09:00:00+00:00 EmrJobFlowSensor 2021-07-03T10:11:14.005158+00:00 2021-07-03T10:20:16.772470+00:00 0:09:02.767312 49209 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-07-03T10:11:11.725585+00:00 2 default_pool
success campaign-history-job_v002 create_cluster_and_add_emr_steps 2021-07-03T09:00:00+00:00 EmrCreateJobFlowOperator 2021-07-03T10:10:56.076288+00:00 2021-07-03T10:10:57.898360+00:00 0:00:01.822072 49208 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 2 default 2021-07-03T10:10:53.714036+00:00 2 default_pool
success booking-processing-job_v002 create_cluster_and_add_emr_steps 2021-07-03T09:00:00+00:00 EmrCreateJobFlowOperator 2021-07-03T10:10:52.062806+00:00 2021-07-03T10:10:53.716242+00:00 0:00:01.653436 49207 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 2 default 2021-07-03T10:10:49.766654+00:00 2 default_pool
success campaign-history-job_v002 create_emr_steps 2021-07-03T09:00:00+00:00 PythonOperator 2021-07-03T10:10:35.983078+00:00 2021-07-03T10:10:39.373425+00:00 0:00:03.390347 49206 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-07-03T10:10:33.696507+00:00 2 default_pool
success booking-processing-job_v002 create_emr_steps 2021-07-03T09:00:00+00:00 PythonOperator 2021-07-03T10:10:30.295254+00:00 2021-07-03T10:10:34.229693+00:00 0:00:03.934439 49205 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-07-03T10:10:27.752943+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_campaign-history-job_v002 2021-07-03T09:00:00+00:00 TriggerDagRunOperator 2021-07-03T10:10:15.796000+00:00 2021-07-03T10:10:16.196655+00:00 0:00:00.400655 49204 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-07-03T10:10:13.513262+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_booking-processing-job_v002 2021-07-03T09:00:00+00:00 TriggerDagRunOperator 2021-07-03T10:10:15.728765+00:00 2021-07-03T10:10:16.245389+00:00 0:00:00.516624 49203 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-07-03T10:10:13.513296+00:00 2 default_pool
success vc-asset-import_v002 create_cluster_and_add_emr_steps 2021-07-03T09:05:00+00:00 EmrCreateJobFlowOperator 2021-07-03T10:05:33.265088+00:00 2021-07-03T10:05:35.003905+00:00 0:00:01.738817 49201 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 2 default 2021-07-03T10:05:31.085514+00:00 2 default_pool
success vc-asset-import_v002 create_emr_steps 2021-07-03T09:05:00+00:00 PythonOperator 2021-07-03T10:05:11.363762+00:00 2021-07-03T10:05:14.959092+00:00 0:00:03.595330 49200 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-07-03T10:05:09.070520+00:00 2 default_pool
success campaign-flow-job_v002 check_cluster_status 2021-07-03T09:00:00+00:00 EmrJobFlowSensor 2021-07-03T10:00:59.137355+00:00 2021-07-03T10:10:01.905400+00:00 0:09:02.768045 49199 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-07-03T10:00:56.563445+00:00 2 default_pool
success livepop-shuffle-job_v002 check_cluster_status 2021-07-03T09:00:00+00:00 EmrJobFlowSensor 2021-07-03T10:00:48.804839+00:00 2021-07-03T10:10:51.935943+00:00 0:10:03.131104 49198 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-07-03T10:00:46.435957+00:00 2 default_pool
success campaign-flow-job_v002 create_cluster_and_add_emr_steps 2021-07-03T09:00:00+00:00 EmrCreateJobFlowOperator 2021-07-03T10:00:37.065839+00:00 2021-07-03T10:00:38.769817+00:00 0:00:01.703978 49197 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 4 default 2021-07-03T10:00:34.392168+00:00 2 default_pool
success livepop-shuffle-job_v002 create_cluster_and_add_emr_steps 2021-07-03T09:00:00+00:00 EmrCreateJobFlowOperator 2021-07-03T10:00:28.684483+00:00 2021-07-03T10:00:30.462628+00:00 0:00:01.778145 49196 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 2 default 2021-07-03T10:00:26.458241+00:00 2 default_pool
success campaign-flow-job_v002 create_emr_steps 2021-07-03T09:00:00+00:00 PythonOperator 2021-07-03T10:00:15.120195+00:00 2021-07-03T10:00:18.720564+00:00 0:00:03.600369 49195 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 5 default 2021-07-03T10:00:12.358691+00:00 2 default_pool
success livepop-shuffle-job_v002 create_emr_steps 2021-07-03T09:00:00+00:00 PythonOperator 2021-07-03T10:00:06.557202+00:00 2021-07-03T10:00:10.227330+00:00 0:00:03.670128 49194 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-07-03T10:00:04.285907+00:00 2 default_pool
success booking-processing-job_v002 check_cluster_status 2021-07-03T08:00:00+00:00 EmrJobFlowSensor 2021-07-03T09:12:25.618959+00:00 2021-07-03T09:21:28.415334+00:00 0:09:02.796375 49192 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-07-03T09:12:22.950895+00:00 2 default_pool
success campaign-history-job_v002 check_cluster_status 2021-07-03T08:00:00+00:00 EmrJobFlowSensor 2021-07-03T09:12:21.184621+00:00 2021-07-03T09:21:24.016459+00:00 0:09:02.831838 49191 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-07-03T09:12:18.951539+00:00 2 default_pool
success booking-processing-job_v002 create_cluster_and_add_emr_steps 2021-07-03T08:00:00+00:00 EmrCreateJobFlowOperator 2021-07-03T09:12:05.282701+00:00 2021-07-03T09:12:07.095020+00:00 0:00:01.812319 49190 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 2 default 2021-07-03T09:12:02.937525+00:00 2 default_pool
success campaign-history-job_v002 create_cluster_and_add_emr_steps 2021-07-03T08:00:00+00:00 EmrCreateJobFlowOperator 2021-07-03T09:11:59.348499+00:00 2021-07-03T09:12:01.046699+00:00 0:00:01.698200 49189 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 2 default 2021-07-03T09:11:56.935390+00:00 2 default_pool
success booking-processing-job_v002 create_emr_steps 2021-07-03T08:00:00+00:00 PythonOperator 2021-07-03T09:11:41.090164+00:00 2021-07-03T09:11:45.129983+00:00 0:00:04.039819 49188 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-07-03T09:11:38.920554+00:00 2 default_pool
success campaign-history-job_v002 create_emr_steps 2021-07-03T08:00:00+00:00 PythonOperator 2021-07-03T09:11:37.380783+00:00 2021-07-03T09:11:40.809344+00:00 0:00:03.428561 49187 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-07-03T09:11:34.975691+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_booking-processing-job_v002 2021-07-03T08:00:00+00:00 TriggerDagRunOperator 2021-07-03T09:11:21.219951+00:00 2021-07-03T09:11:21.722024+00:00 0:00:00.502073 49186 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-07-03T09:11:18.905636+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_campaign-history-job_v002 2021-07-03T08:00:00+00:00 TriggerDagRunOperator 2021-07-03T09:11:21.071712+00:00 2021-07-03T09:11:21.484689+00:00 0:00:00.412977 49185 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-07-03T09:11:18.905603+00:00 2 default_pool
success vc-asset-import_v002 check_cluster_status 2021-07-03T08:05:00+00:00 EmrJobFlowSensor 2021-07-03T09:06:06.608926+00:00 2021-07-03T09:15:09.328358+00:00 0:09:02.719432 49184 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-07-03T09:06:04.456522+00:00 2 default_pool
success vc-asset-import_v002 create_cluster_and_add_emr_steps 2021-07-03T08:05:00+00:00 EmrCreateJobFlowOperator 2021-07-03T09:05:46.522449+00:00 2021-07-03T09:05:48.195167+00:00 0:00:01.672718 49183 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 2 default 2021-07-03T09:05:44.355309+00:00 2 default_pool
success vc-asset-import_v002 create_emr_steps 2021-07-03T08:05:00+00:00 PythonOperator 2021-07-03T09:05:24.836476+00:00 2021-07-03T09:05:28.172205+00:00 0:00:03.335729 49182 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-07-03T09:05:22.443736+00:00 2 default_pool
success campaign-flow-job_v002 check_cluster_status 2021-07-03T08:00:00+00:00 EmrJobFlowSensor 2021-07-03T09:01:02.454505+00:00 2021-07-03T09:11:05.492594+00:00 0:10:03.038089 49181 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-07-03T09:01:00.053551+00:00 2 default_pool
success livepop-shuffle-job_v002 check_cluster_status 2021-07-03T08:00:00+00:00 EmrJobFlowSensor 2021-07-03T09:01:00.706919+00:00 2021-07-03T09:12:04.037171+00:00 0:11:03.330252 49180 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-07-03T09:00:58.057246+00:00 2 default_pool
success campaign-flow-job_v002 create_cluster_and_add_emr_steps 2021-07-03T08:00:00+00:00 EmrCreateJobFlowOperator 2021-07-03T09:00:40.824537+00:00 2021-07-03T09:00:42.535680+00:00 0:00:01.711143 49179 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 4 default 2021-07-03T09:00:37.908117+00:00 2 default_pool
success livepop-shuffle-job_v002 create_cluster_and_add_emr_steps 2021-07-03T08:00:00+00:00 EmrCreateJobFlowOperator 2021-07-03T09:00:38.203171+00:00 2021-07-03T09:00:40.343866+00:00 0:00:02.140695 49178 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 2 default 2021-07-03T09:00:35.901130+00:00 2 default_pool
success campaign-flow-job_v002 create_emr_steps 2021-07-03T08:00:00+00:00 PythonOperator 2021-07-03T09:00:12.033155+00:00 2021-07-03T09:00:15.799416+00:00 0:00:03.766261 49177 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 5 default 2021-07-03T09:00:09.823393+00:00 2 default_pool
success livepop-shuffle-job_v002 create_emr_steps 2021-07-03T08:00:00+00:00 PythonOperator 2021-07-03T09:00:08.377537+00:00 2021-07-03T09:00:11.742322+00:00 0:00:03.364785 49176 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-07-03T09:00:05.824531+00:00 2 default_pool
success booking-processing-job_v002 check_cluster_status 2021-07-03T07:00:00+00:00 EmrJobFlowSensor 2021-07-03T08:11:34.987068+00:00 2021-07-03T08:20:37.687485+00:00 0:09:02.700417 49174 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-07-03T08:11:32.683514+00:00 2 default_pool
success campaign-history-job_v002 check_cluster_status 2021-07-03T07:00:00+00:00 EmrJobFlowSensor 2021-07-03T08:11:24.765203+00:00 2021-07-03T08:20:27.480200+00:00 0:09:02.714997 49173 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-07-03T08:11:22.639272+00:00 2 default_pool
success booking-processing-job_v002 create_cluster_and_add_emr_steps 2021-07-03T07:00:00+00:00 EmrCreateJobFlowOperator 2021-07-03T08:11:12.794334+00:00 2021-07-03T08:11:14.516944+00:00 0:00:01.722610 49172 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 2 default 2021-07-03T08:11:10.611086+00:00 2 default_pool
success campaign-history-job_v002 create_cluster_and_add_emr_steps 2021-07-03T07:00:00+00:00 EmrCreateJobFlowOperator 2021-07-03T08:10:54.848993+00:00 2021-07-03T08:10:56.569211+00:00 0:00:01.720218 49171 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 2 default 2021-07-03T08:10:52.596718+00:00 2 default_pool
success booking-processing-job_v002 create_emr_steps 2021-07-03T07:00:00+00:00 PythonOperator 2021-07-03T08:10:40.839966+00:00 2021-07-03T08:10:44.723492+00:00 0:00:03.883526 49170 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-07-03T08:10:38.647889+00:00 2 default_pool
success campaign-history-job_v002 create_emr_steps 2021-07-03T07:00:00+00:00 PythonOperator 2021-07-03T08:10:32.692146+00:00 2021-07-03T08:10:36.094691+00:00 0:00:03.402545 49169 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-07-03T08:10:30.552461+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_campaign-history-job_v002 2021-07-03T07:00:00+00:00 TriggerDagRunOperator 2021-07-03T08:10:16.839402+00:00 2021-07-03T08:10:17.351238+00:00 0:00:00.511836 49168 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-07-03T08:10:14.540065+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_booking-processing-job_v002 2021-07-03T07:00:00+00:00 TriggerDagRunOperator 2021-07-03T08:10:16.776692+00:00 2021-07-03T08:10:17.209875+00:00 0:00:00.433183 49167 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-07-03T08:10:14.540097+00:00 2 default_pool
success vc-asset-import_v002 check_cluster_status 2021-07-03T07:05:00+00:00 EmrJobFlowSensor 2021-07-03T08:05:50.283549+00:00 2021-07-03T08:14:53.015621+00:00 0:09:02.732072 49166 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-07-03T08:05:48.010108+00:00 2 default_pool
success vc-asset-import_v002 create_cluster_and_add_emr_steps 2021-07-03T07:05:00+00:00 EmrCreateJobFlowOperator 2021-07-03T08:05:28.437435+00:00 2021-07-03T08:05:30.223235+00:00 0:00:01.785800 49165 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 2 default 2021-07-03T08:05:26.058040+00:00 2 default_pool
success vc-asset-import_v002 create_emr_steps 2021-07-03T07:05:00+00:00 PythonOperator 2021-07-03T08:05:08.326057+00:00 2021-07-03T08:05:11.614785+00:00 0:00:03.288728 49164 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-07-03T08:05:05.973478+00:00 2 default_pool
success campaign-flow-job_v002 check_cluster_status 2021-07-03T07:00:00+00:00 EmrJobFlowSensor 2021-07-03T08:01:03.783585+00:00 2021-07-03T08:10:06.590336+00:00 0:09:02.806751 49163 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-07-03T08:01:01.599062+00:00 2 default_pool
success livepop-shuffle-job_v002 check_cluster_status 2021-07-03T07:00:00+00:00 EmrJobFlowSensor 2021-07-03T08:00:59.878913+00:00 2021-07-03T08:11:02.902324+00:00 0:10:03.023411 49162 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-07-03T08:00:57.658131+00:00 2 default_pool
success campaign-flow-job_v002 create_cluster_and_add_emr_steps 2021-07-03T07:00:00+00:00 EmrCreateJobFlowOperator 2021-07-03T08:00:41.831885+00:00 2021-07-03T08:00:43.627669+00:00 0:00:01.795784 49161 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 4 default 2021-07-03T08:00:39.578010+00:00 2 default_pool
success livepop-shuffle-job_v002 create_cluster_and_add_emr_steps 2021-07-03T07:00:00+00:00 EmrCreateJobFlowOperator 2021-07-03T08:00:37.686063+00:00 2021-07-03T08:00:39.383154+00:00 0:00:01.697091 49160 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 2 default 2021-07-03T08:00:35.571654+00:00 2 default_pool
success campaign-flow-job_v002 create_emr_steps 2021-07-03T07:00:00+00:00 PythonOperator 2021-07-03T08:00:19.706882+00:00 2021-07-03T08:00:23.422908+00:00 0:00:03.716026 49159 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 5 default 2021-07-03T08:00:17.525240+00:00 2 default_pool
success livepop-shuffle-job_v002 create_emr_steps 2021-07-03T07:00:00+00:00 PythonOperator 2021-07-03T08:00:16.296070+00:00 2021-07-03T08:00:19.685018+00:00 0:00:03.388948 49158 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-07-03T08:00:13.518122+00:00 2 default_pool
success campaign-history-job_v002 check_cluster_status 2021-07-03T06:00:00+00:00 EmrJobFlowSensor 2021-07-03T07:12:06.208537+00:00 2021-07-03T07:21:09.040419+00:00 0:09:02.831882 49156 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-07-03T07:12:03.656518+00:00 2 default_pool
success booking-processing-job_v002 check_cluster_status 2021-07-03T06:00:00+00:00 EmrJobFlowSensor 2021-07-03T07:12:04.020209+00:00 2021-07-03T07:21:06.696706+00:00 0:09:02.676497 49155 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-07-03T07:12:01.656007+00:00 2 default_pool
success booking-processing-job_v002 create_cluster_and_add_emr_steps 2021-07-03T06:00:00+00:00 EmrCreateJobFlowOperator 2021-07-03T07:11:42.096513+00:00 2021-07-03T07:11:43.984124+00:00 0:00:01.887611 49154 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 2 default 2021-07-03T07:11:39.555975+00:00 2 default_pool
success campaign-history-job_v002 create_cluster_and_add_emr_steps 2021-07-03T06:00:00+00:00 EmrCreateJobFlowOperator 2021-07-03T07:11:41.965215+00:00 2021-07-03T07:11:43.828613+00:00 0:00:01.863398 49153 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 2 default 2021-07-03T07:11:39.556004+00:00 2 default_pool
success booking-processing-job_v002 create_emr_steps 2021-07-03T06:00:00+00:00 PythonOperator 2021-07-03T07:11:19.996736+00:00 2021-07-03T07:11:23.585097+00:00 0:00:03.588361 49152 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-07-03T07:11:17.527131+00:00 2 default_pool
success campaign-history-job_v002 create_emr_steps 2021-07-03T06:00:00+00:00 PythonOperator 2021-07-03T07:11:19.837377+00:00 2021-07-03T07:11:23.588008+00:00 0:00:03.750631 49151 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-07-03T07:11:17.527167+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_booking-processing-job_v002 2021-07-03T06:00:00+00:00 TriggerDagRunOperator 2021-07-03T07:11:00.585674+00:00 2021-07-03T07:11:00.982206+00:00 0:00:00.396532 49150 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-07-03T07:10:57.552782+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_campaign-history-job_v002 2021-07-03T06:00:00+00:00 TriggerDagRunOperator 2021-07-03T07:11:00.380169+00:00 2021-07-03T07:11:00.992294+00:00 0:00:00.612125 49149 airflow-worker-2.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-07-03T07:10:57.552741+00:00 2 default_pool
success vc-asset-import_v002 check_cluster_status 2021-07-03T06:05:00+00:00 EmrJobFlowSensor 2021-07-03T07:06:03.256233+00:00 2021-07-03T07:14:05.987808+00:00 0:08:02.731575 49148 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-07-03T07:06:01.073173+00:00 2 default_pool
success vc-asset-import_v002 create_cluster_and_add_emr_steps 2021-07-03T06:05:00+00:00 EmrCreateJobFlowOperator 2021-07-03T07:05:37.151422+00:00 2021-07-03T07:05:38.834922+00:00 0:00:01.683500 49147 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 2 default 2021-07-03T07:05:35.011229+00:00 2 default_pool
success vc-asset-import_v002 create_emr_steps 2021-07-03T06:05:00+00:00 PythonOperator 2021-07-03T07:05:07.363549+00:00 2021-07-03T07:05:10.689802+00:00 0:00:03.326253 49146 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-07-03T07:05:05.045875+00:00 2 default_pool
success livepop-shuffle-job_v002 check_cluster_status 2021-07-03T06:00:00+00:00 EmrJobFlowSensor 2021-07-03T07:01:06.848990+00:00 2021-07-03T07:11:09.786576+00:00 0:10:02.937586 49145 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-07-03T07:01:04.568543+00:00 2 default_pool
success campaign-flow-job_v002 check_cluster_status 2021-07-03T06:00:00+00:00 EmrJobFlowSensor 2021-07-03T07:00:48.620798+00:00 2021-07-03T07:10:51.666359+00:00 0:10:03.045561 49144 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-07-03T07:00:46.406635+00:00 2 default_pool
success livepop-shuffle-job_v002 create_cluster_and_add_emr_steps 2021-07-03T06:00:00+00:00 EmrCreateJobFlowOperator 2021-07-03T07:00:42.727906+00:00 2021-07-03T07:00:44.398098+00:00 0:00:01.670192 49143 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 2 default 2021-07-03T07:00:40.462199+00:00 2 default_pool
success campaign-flow-job_v002 create_cluster_and_add_emr_steps 2021-07-03T06:00:00+00:00 EmrCreateJobFlowOperator 2021-07-03T07:00:28.755943+00:00 2021-07-03T07:00:30.559615+00:00 0:00:01.803672 49142 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 4 default 2021-07-03T07:00:26.387586+00:00 2 default_pool
success livepop-shuffle-job_v002 create_emr_steps 2021-07-03T06:00:00+00:00 PythonOperator 2021-07-03T07:00:20.492246+00:00 2021-07-03T07:00:24.235743+00:00 0:00:03.743497 49141 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-07-03T07:00:18.348162+00:00 2 default_pool
success campaign-flow-job_v002 create_emr_steps 2021-07-03T06:00:00+00:00 PythonOperator 2021-07-03T07:00:06.783527+00:00 2021-07-03T07:00:10.540577+00:00 0:00:03.757050 49140 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 5 default 2021-07-03T07:00:04.327782+00:00 2 default_pool
success vc-asset-import_v002 check_cluster_status 2021-07-03T05:05:00+00:00 EmrJobFlowSensor 2021-07-03T06:13:13.826366+00:00 2021-07-03T06:15:15.585661+00:00 0:02:01.759295 49138 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-07-03T06:13:11.559540+00:00 3 default_pool
success livepop-shuffle-job_v002 check_cluster_status 2021-07-03T05:00:00+00:00 EmrJobFlowSensor 2021-07-03T06:13:09.757813+00:00 2021-07-03T06:13:11.219679+00:00 0:00:01.461866 49137 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-07-03T06:13:07.468726+00:00 3 default_pool
success booking-processing-job_v002 check_cluster_status 2021-07-03T05:00:00+00:00 EmrJobFlowSensor 2021-07-03T06:11:33.533498+00:00 2021-07-03T06:21:36.415526+00:00 0:10:02.882028 49136 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-07-03T06:11:31.352338+00:00 2 default_pool
success campaign-history-job_v002 check_cluster_status 2021-07-03T05:00:00+00:00 EmrJobFlowSensor 2021-07-03T06:11:27.412774+00:00 2021-07-03T06:19:30.083498+00:00 0:08:02.670724 49135 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-07-03T06:11:25.302541+00:00 2 default_pool
success booking-processing-job_v002 create_cluster_and_add_emr_steps 2021-07-03T05:00:00+00:00 EmrCreateJobFlowOperator 2021-07-03T06:11:07.425933+00:00 2021-07-03T06:11:09.169905+00:00 0:00:01.743972 49134 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 2 default 2021-07-03T06:11:05.284544+00:00 2 default_pool
success campaign-history-job_v002 create_cluster_and_add_emr_steps 2021-07-03T05:00:00+00:00 EmrCreateJobFlowOperator 2021-07-03T06:10:51.500065+00:00 2021-07-03T06:10:53.184534+00:00 0:00:01.684469 49133 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 2 default 2021-07-03T06:10:49.259262+00:00 2 default_pool
success booking-processing-job_v002 create_emr_steps 2021-07-03T05:00:00+00:00 PythonOperator 2021-07-03T06:10:35.608501+00:00 2021-07-03T06:10:39.239811+00:00 0:00:03.631310 49132 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-07-03T06:10:33.265667+00:00 2 default_pool
success campaign-history-job_v002 create_emr_steps 2021-07-03T05:00:00+00:00 PythonOperator 2021-07-03T06:10:27.644066+00:00 2021-07-03T06:10:31.269647+00:00 0:00:03.625581 49131 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-07-03T06:10:25.271987+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_campaign-history-job_v002 2021-07-03T05:00:00+00:00 TriggerDagRunOperator 2021-07-03T06:10:21.617196+00:00 2021-07-03T06:10:22.116199+00:00 0:00:00.499003 49130 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-07-03T06:10:19.192737+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_booking-processing-job_v002 2021-07-03T05:00:00+00:00 TriggerDagRunOperator 2021-07-03T06:10:21.406450+00:00 2021-07-03T06:10:21.788398+00:00 0:00:00.381948 49129 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-07-03T06:10:19.192769+00:00 2 default_pool
success vc-asset-import_v002 create_cluster_and_add_emr_steps 2021-07-03T05:05:00+00:00 EmrCreateJobFlowOperator 2021-07-03T06:05:49.408525+00:00 2021-07-03T06:05:51.154307+00:00 0:00:01.745782 49127 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 2 default 2021-07-03T06:05:46.894924+00:00 2 default_pool
success vc-asset-import_v002 create_emr_steps 2021-07-03T05:05:00+00:00 PythonOperator 2021-07-03T06:05:11.189184+00:00 2021-07-03T06:05:14.088822+00:00 0:00:02.899638 49126 airflow-worker-2.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-07-03T06:05:08.802690+00:00 2 default_pool
success livepop-shuffle-job_v002 create_cluster_and_add_emr_steps 2021-07-03T05:00:00+00:00 EmrCreateJobFlowOperator 2021-07-03T06:01:06.533558+00:00 2021-07-03T06:01:08.226648+00:00 0:00:01.693090 49124 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 2 default 2021-07-03T06:01:04.387235+00:00 2 default_pool
success campaign-flow-job_v002 check_cluster_status 2021-07-03T05:00:00+00:00 EmrJobFlowSensor 2021-07-03T06:00:56.463118+00:00 2021-07-03T06:09:59.183091+00:00 0:09:02.719973 49123 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-07-03T06:00:54.314977+00:00 2 default_pool
success livepop-shuffle-job_v002 create_emr_steps 2021-07-03T05:00:00+00:00 PythonOperator 2021-07-03T06:00:42.827794+00:00 2021-07-03T06:00:46.420796+00:00 0:00:03.593002 49122 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-07-03T06:00:40.294852+00:00 2 default_pool
success campaign-flow-job_v002 create_cluster_and_add_emr_steps 2021-07-03T05:00:00+00:00 EmrCreateJobFlowOperator 2021-07-03T06:00:34.606667+00:00 2021-07-03T06:00:36.376666+00:00 0:00:01.769999 49121 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 4 default 2021-07-03T06:00:32.349933+00:00 2 default_pool
success campaign-flow-job_v002 create_emr_steps 2021-07-03T05:00:00+00:00 PythonOperator 2021-07-03T06:00:04.660229+00:00 2021-07-03T06:00:08.260402+00:00 0:00:03.600173 49120 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 5 default 2021-07-03T06:00:02.226753+00:00 2 default_pool
success booking-processing-job_v002 check_cluster_status 2021-07-03T04:00:00+00:00 EmrJobFlowSensor 2021-07-03T05:11:59.296530+00:00 2021-07-03T05:22:02.159014+00:00 0:10:02.862484 49118 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-07-03T05:11:57.128116+00:00 2 default_pool
success campaign-history-job_v002 check_cluster_status 2021-07-03T04:00:00+00:00 EmrJobFlowSensor 2021-07-03T05:11:57.411069+00:00 2021-07-03T05:21:00.167678+00:00 0:09:02.756609 49117 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-07-03T05:11:55.162865+00:00 2 default_pool
success booking-processing-job_v002 create_cluster_and_add_emr_steps 2021-07-03T04:00:00+00:00 EmrCreateJobFlowOperator 2021-07-03T05:11:39.527391+00:00 2021-07-03T05:11:41.188476+00:00 0:00:01.661085 49116 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 2 default 2021-07-03T05:11:37.105533+00:00 2 default_pool
success campaign-history-job_v002 create_cluster_and_add_emr_steps 2021-07-03T04:00:00+00:00 EmrCreateJobFlowOperator 2021-07-03T05:11:37.196219+00:00 2021-07-03T05:11:39.207010+00:00 0:00:02.010791 49115 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 2 default 2021-07-03T05:11:35.103264+00:00 2 default_pool