Task Instances

  State Dag Id Task Id Execution Date Operator Start Date End Date Duration Job Id Hostname Unixname Priority Weight Queue Queued Dttm Try Number Pool Log Url
success vc-asset-import_v002 create_cluster_and_add_emr_steps 2021-05-15T05:05:00+00:00 EmrCreateJobFlowOperator 2021-05-15T06:05:35.670217+00:00 2021-05-15T06:05:37.341533+00:00 0:00:01.671316 28262 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 2 default 2021-05-15T06:05:33.553403+00:00 2 default_pool
success vc-asset-import_v002 create_emr_steps 2021-05-15T05:05:00+00:00 PythonOperator 2021-05-15T06:05:13.793843+00:00 2021-05-15T06:05:16.967017+00:00 0:00:03.173174 28261 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-05-15T06:05:11.513810+00:00 2 default_pool
success campaign-flow-job_v002 check_cluster_status 2021-05-15T05:00:00+00:00 EmrJobFlowSensor 2021-05-15T06:00:49.812415+00:00 2021-05-15T06:10:52.775783+00:00 0:10:02.963368 28260 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-05-15T06:00:47.278399+00:00 2 default_pool
success campaign-flow-job_v002 create_cluster_and_add_emr_steps 2021-05-15T05:00:00+00:00 EmrCreateJobFlowOperator 2021-05-15T06:00:29.597968+00:00 2021-05-15T06:00:31.433218+00:00 0:00:01.835250 28259 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 4 default 2021-05-15T06:00:27.203196+00:00 2 default_pool
success campaign-flow-job_v002 create_emr_steps 2021-05-15T05:00:00+00:00 PythonOperator 2021-05-15T06:00:07.607191+00:00 2021-05-15T06:00:10.712574+00:00 0:00:03.105383 28258 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 5 default 2021-05-15T06:00:05.181716+00:00 2 default_pool
success campaign-history-job_v002 check_cluster_status 2021-05-15T04:00:00+00:00 EmrJobFlowSensor 2021-05-15T05:12:11.318239+00:00 2021-05-15T05:20:13.795297+00:00 0:08:02.477058 28256 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-05-15T05:12:09.147139+00:00 2 default_pool
success booking-processing-job_v002 check_cluster_status 2021-05-15T04:00:00+00:00 EmrJobFlowSensor 2021-05-15T05:11:57.754192+00:00 2021-05-15T05:22:00.474367+00:00 0:10:02.720175 28255 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-05-15T05:11:55.132221+00:00 2 default_pool
success campaign-history-job_v002 create_cluster_and_add_emr_steps 2021-05-15T04:00:00+00:00 EmrCreateJobFlowOperator 2021-05-15T05:11:49.411123+00:00 2021-05-15T05:11:51.095573+00:00 0:00:01.684450 28254 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 2 default 2021-05-15T05:11:47.170014+00:00 2 default_pool
success booking-processing-job_v002 create_cluster_and_add_emr_steps 2021-05-15T04:00:00+00:00 EmrCreateJobFlowOperator 2021-05-15T05:11:35.635270+00:00 2021-05-15T05:11:37.331591+00:00 0:00:01.696321 28253 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 2 default 2021-05-15T05:11:33.146341+00:00 2 default_pool
success campaign-history-job_v002 create_emr_steps 2021-05-15T04:00:00+00:00 PythonOperator 2021-05-15T05:11:27.229374+00:00 2021-05-15T05:11:30.412137+00:00 0:00:03.182763 28252 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-05-15T05:11:25.108161+00:00 2 default_pool
success booking-processing-job_v002 create_emr_steps 2021-05-15T04:00:00+00:00 PythonOperator 2021-05-15T05:11:13.421149+00:00 2021-05-15T05:11:16.755238+00:00 0:00:03.334089 28251 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-05-15T05:11:11.095060+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_booking-processing-job_v002 2021-05-15T04:00:00+00:00 TriggerDagRunOperator 2021-05-15T05:11:07.404589+00:00 2021-05-15T05:11:07.916329+00:00 0:00:00.511740 28250 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-05-15T05:11:05.087098+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_campaign-history-job_v002 2021-05-15T04:00:00+00:00 TriggerDagRunOperator 2021-05-15T05:11:07.245533+00:00 2021-05-15T05:11:07.650719+00:00 0:00:00.405186 28249 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-05-15T05:11:05.087068+00:00 2 default_pool
success vc-asset-import_v002 check_cluster_status 2021-05-15T04:05:00+00:00 EmrJobFlowSensor 2021-05-15T05:06:02.761488+00:00 2021-05-15T05:15:05.338559+00:00 0:09:02.577071 28248 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-05-15T05:06:00.474640+00:00 2 default_pool
success vc-asset-import_v002 create_cluster_and_add_emr_steps 2021-05-15T04:05:00+00:00 EmrCreateJobFlowOperator 2021-05-15T05:05:40.704093+00:00 2021-05-15T05:05:42.529746+00:00 0:00:01.825653 28247 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 2 default 2021-05-15T05:05:38.400719+00:00 2 default_pool
success vc-asset-import_v002 create_emr_steps 2021-05-15T04:05:00+00:00 PythonOperator 2021-05-15T05:05:20.464855+00:00 2021-05-15T05:05:23.551390+00:00 0:00:03.086535 28246 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-05-15T05:05:18.376158+00:00 2 default_pool
success campaign-flow-job_v002 check_cluster_status 2021-05-15T04:00:00+00:00 EmrJobFlowSensor 2021-05-15T05:00:54.114525+00:00 2021-05-15T05:10:56.885581+00:00 0:10:02.771056 28245 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-05-15T05:00:51.911619+00:00 2 default_pool
success campaign-flow-job_v002 create_cluster_and_add_emr_steps 2021-05-15T04:00:00+00:00 EmrCreateJobFlowOperator 2021-05-15T05:00:32.352917+00:00 2021-05-15T05:00:34.060881+00:00 0:00:01.707964 28244 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 4 default 2021-05-15T05:00:30.041121+00:00 2 default_pool
success campaign-flow-job_v002 create_emr_steps 2021-05-15T04:00:00+00:00 PythonOperator 2021-05-15T05:00:10.537021+00:00 2021-05-15T05:00:13.641514+00:00 0:00:03.104493 28243 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 5 default 2021-05-15T05:00:07.872738+00:00 2 default_pool
success campaign-history-job_v002 check_cluster_status 2021-05-15T03:00:00+00:00 EmrJobFlowSensor 2021-05-15T04:12:33.991682+00:00 2021-05-15T04:22:36.680005+00:00 0:10:02.688323 28241 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-05-15T04:12:31.696521+00:00 2 default_pool
success booking-processing-job_v002 check_cluster_status 2021-05-15T03:00:00+00:00 EmrJobFlowSensor 2021-05-15T04:12:30.108734+00:00 2021-05-15T04:22:32.863942+00:00 0:10:02.755208 28240 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-05-15T04:12:27.668296+00:00 2 default_pool
success campaign-history-job_v002 create_cluster_and_add_emr_steps 2021-05-15T03:00:00+00:00 EmrCreateJobFlowOperator 2021-05-15T04:12:12.067597+00:00 2021-05-15T04:12:13.762113+00:00 0:00:01.694516 28239 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 2 default 2021-05-15T04:12:09.577453+00:00 2 default_pool
success booking-processing-job_v002 create_cluster_and_add_emr_steps 2021-05-15T03:00:00+00:00 EmrCreateJobFlowOperator 2021-05-15T04:12:09.861951+00:00 2021-05-15T04:12:11.867894+00:00 0:00:02.005943 28238 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 2 default 2021-05-15T04:12:07.599369+00:00 2 default_pool
success campaign-history-job_v002 create_emr_steps 2021-05-15T03:00:00+00:00 PythonOperator 2021-05-15T04:11:50.408202+00:00 2021-05-15T04:11:53.863329+00:00 0:00:03.455127 28237 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-05-15T04:11:47.562606+00:00 2 default_pool
success booking-processing-job_v002 create_emr_steps 2021-05-15T03:00:00+00:00 PythonOperator 2021-05-15T04:11:46.073908+00:00 2021-05-15T04:11:50.147576+00:00 0:00:04.073668 28236 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-05-15T04:11:43.572031+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_campaign-history-job_v002 2021-05-15T03:00:00+00:00 TriggerDagRunOperator 2021-05-15T04:11:25.967240+00:00 2021-05-15T04:11:26.703357+00:00 0:00:00.736117 28235 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-05-15T04:11:23.499923+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_booking-processing-job_v002 2021-05-15T03:00:00+00:00 TriggerDagRunOperator 2021-05-15T04:11:25.867638+00:00 2021-05-15T04:11:26.350485+00:00 0:00:00.482847 28234 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-05-15T04:11:23.499957+00:00 2 default_pool
success vc-asset-import_v002 check_cluster_status 2021-05-15T03:05:00+00:00 EmrJobFlowSensor 2021-05-15T04:05:54.881541+00:00 2021-05-15T04:14:57.609197+00:00 0:09:02.727656 28233 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-05-15T04:05:52.270778+00:00 2 default_pool
success vc-asset-import_v002 create_cluster_and_add_emr_steps 2021-05-15T03:05:00+00:00 EmrCreateJobFlowOperator 2021-05-15T04:05:34.582715+00:00 2021-05-15T04:05:36.208440+00:00 0:00:01.625725 28232 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 2 default 2021-05-15T04:05:32.270638+00:00 2 default_pool
success vc-asset-import_v002 create_emr_steps 2021-05-15T03:05:00+00:00 PythonOperator 2021-05-15T04:05:12.282611+00:00 2021-05-15T04:05:15.401475+00:00 0:00:03.118864 28231 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-05-15T04:05:10.127206+00:00 2 default_pool
success campaign-flow-job_v002 check_cluster_status 2021-05-15T03:00:00+00:00 EmrJobFlowSensor 2021-05-15T04:00:57.701080+00:00 2021-05-15T04:11:00.476573+00:00 0:10:02.775493 28230 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-05-15T04:00:55.540831+00:00 2 default_pool
success campaign-flow-job_v002 create_cluster_and_add_emr_steps 2021-05-15T03:00:00+00:00 EmrCreateJobFlowOperator 2021-05-15T04:00:37.731428+00:00 2021-05-15T04:00:39.415312+00:00 0:00:01.683884 28229 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 4 default 2021-05-15T04:00:35.391328+00:00 2 default_pool
success campaign-flow-job_v002 create_emr_steps 2021-05-15T03:00:00+00:00 PythonOperator 2021-05-15T04:00:15.598140+00:00 2021-05-15T04:00:18.733251+00:00 0:00:03.135111 28228 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 5 default 2021-05-15T04:00:13.318941+00:00 2 default_pool
success booking-processing-job_v002 check_cluster_status 2021-05-15T02:00:00+00:00 EmrJobFlowSensor 2021-05-15T03:10:25.064321+00:00 2021-05-15T03:20:28.015346+00:00 0:10:02.951025 28226 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-05-15T03:10:22.794643+00:00 2 default_pool
success campaign-history-job_v002 check_cluster_status 2021-05-15T02:00:00+00:00 EmrJobFlowSensor 2021-05-15T03:10:22.992589+00:00 2021-05-15T03:19:25.634245+00:00 0:09:02.641656 28225 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-05-15T03:10:20.794424+00:00 2 default_pool
success booking-processing-job_v002 create_cluster_and_add_emr_steps 2021-05-15T02:00:00+00:00 EmrCreateJobFlowOperator 2021-05-15T03:10:01.246436+00:00 2021-05-15T03:10:03.186744+00:00 0:00:01.940308 28224 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 2 default 2021-05-15T03:09:58.847466+00:00 2 default_pool
success campaign-history-job_v002 create_cluster_and_add_emr_steps 2021-05-15T02:00:00+00:00 EmrCreateJobFlowOperator 2021-05-15T03:09:58.932098+00:00 2021-05-15T03:10:00.629032+00:00 0:00:01.696934 28223 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 2 default 2021-05-15T03:09:56.740822+00:00 2 default_pool
success campaign-history-job_v002 create_emr_steps 2021-05-15T02:00:00+00:00 PythonOperator 2021-05-15T03:09:34.830852+00:00 2021-05-15T03:09:37.971719+00:00 0:00:03.140867 28222 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-05-15T03:09:32.695800+00:00 2 default_pool
success booking-processing-job_v002 create_emr_steps 2021-05-15T02:00:00+00:00 PythonOperator 2021-05-15T03:09:33.209518+00:00 2021-05-15T03:09:36.612857+00:00 0:00:03.403339 28221 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-05-15T03:09:30.746172+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_booking-processing-job_v002 2021-05-15T02:00:00+00:00 TriggerDagRunOperator 2021-05-15T03:09:19.159636+00:00 2021-05-15T03:09:19.687325+00:00 0:00:00.527689 28220 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-05-15T03:09:16.676300+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_campaign-history-job_v002 2021-05-15T02:00:00+00:00 TriggerDagRunOperator 2021-05-15T03:09:18.874882+00:00 2021-05-15T03:09:19.318049+00:00 0:00:00.443167 28219 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-05-15T03:09:16.676266+00:00 2 default_pool
success vc-asset-import_v002 check_cluster_status 2021-05-15T02:05:00+00:00 EmrJobFlowSensor 2021-05-15T03:06:04.412005+00:00 2021-05-15T03:22:08.072737+00:00 0:16:03.660732 28218 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-05-15T03:06:02.311298+00:00 2 default_pool
success vc-asset-import_v002 create_cluster_and_add_emr_steps 2021-05-15T02:05:00+00:00 EmrCreateJobFlowOperator 2021-05-15T03:05:42.553736+00:00 2021-05-15T03:05:44.291434+00:00 0:00:01.737698 28217 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 2 default 2021-05-15T03:05:40.288037+00:00 2 default_pool
success vc-asset-import_v002 create_emr_steps 2021-05-15T02:05:00+00:00 PythonOperator 2021-05-15T03:05:22.371531+00:00 2021-05-15T03:05:25.495129+00:00 0:00:03.123598 28216 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-05-15T03:05:20.168300+00:00 2 default_pool
success campaign-flow-job_v002 check_cluster_status 2021-05-15T02:00:00+00:00 EmrJobFlowSensor 2021-05-15T03:01:05.941635+00:00 2021-05-15T03:09:08.648543+00:00 0:08:02.706908 28215 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-05-15T03:01:03.584395+00:00 2 default_pool
success campaign-flow-job_v002 create_cluster_and_add_emr_steps 2021-05-15T02:00:00+00:00 EmrCreateJobFlowOperator 2021-05-15T03:00:44.523221+00:00 2021-05-15T03:00:46.342927+00:00 0:00:01.819706 28214 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 4 default 2021-05-15T03:00:41.565349+00:00 2 default_pool
success campaign-flow-job_v002 create_emr_steps 2021-05-15T02:00:00+00:00 PythonOperator 2021-05-15T03:00:21.566916+00:00 2021-05-15T03:00:24.745419+00:00 0:00:03.178503 28213 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 5 default 2021-05-15T03:00:19.385396+00:00 2 default_pool
success booking-processing-job_v002 check_cluster_status 2021-05-15T01:00:00+00:00 EmrJobFlowSensor 2021-05-15T02:12:05.955727+00:00 2021-05-15T02:21:08.590219+00:00 0:09:02.634492 28211 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-05-15T02:12:03.608048+00:00 2 default_pool
success campaign-history-job_v002 check_cluster_status 2021-05-15T01:00:00+00:00 EmrJobFlowSensor 2021-05-15T02:11:53.800335+00:00 2021-05-15T02:19:56.345521+00:00 0:08:02.545186 28210 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-05-15T02:11:51.596304+00:00 2 default_pool
success booking-processing-job_v002 create_cluster_and_add_emr_steps 2021-05-15T01:00:00+00:00 EmrCreateJobFlowOperator 2021-05-15T02:11:43.971837+00:00 2021-05-15T02:11:45.806515+00:00 0:00:01.834678 28209 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 2 default 2021-05-15T02:11:41.593237+00:00 2 default_pool
success campaign-history-job_v002 create_cluster_and_add_emr_steps 2021-05-15T01:00:00+00:00 EmrCreateJobFlowOperator 2021-05-15T02:11:33.877546+00:00 2021-05-15T02:11:35.597309+00:00 0:00:01.719763 28208 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 2 default 2021-05-15T02:11:31.564481+00:00 2 default_pool
success booking-processing-job_v002 create_emr_steps 2021-05-15T01:00:00+00:00 PythonOperator 2021-05-15T02:11:21.707929+00:00 2021-05-15T02:11:25.050711+00:00 0:00:03.342782 28207 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-05-15T02:11:19.552177+00:00 2 default_pool
success campaign-history-job_v002 create_emr_steps 2021-05-15T01:00:00+00:00 PythonOperator 2021-05-15T02:11:12.073854+00:00 2021-05-15T02:11:15.274022+00:00 0:00:03.200168 28206 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-05-15T02:11:09.544907+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_campaign-history-job_v002 2021-05-15T01:00:00+00:00 TriggerDagRunOperator 2021-05-15T02:11:04.142064+00:00 2021-05-15T02:11:04.686369+00:00 0:00:00.544305 28205 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-05-15T02:11:01.538321+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_booking-processing-job_v002 2021-05-15T01:00:00+00:00 TriggerDagRunOperator 2021-05-15T02:11:04.115698+00:00 2021-05-15T02:11:04.533184+00:00 0:00:00.417486 28204 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-05-15T02:11:01.538353+00:00 2 default_pool
success vc-asset-import_v002 check_cluster_status 2021-05-15T01:05:00+00:00 EmrJobFlowSensor 2021-05-15T02:06:06.962503+00:00 2021-05-15T02:15:09.613801+00:00 0:09:02.651298 28203 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-05-15T02:06:04.795987+00:00 2 default_pool
success vc-asset-import_v002 create_cluster_and_add_emr_steps 2021-05-15T01:05:00+00:00 EmrCreateJobFlowOperator 2021-05-15T02:05:45.033706+00:00 2021-05-15T02:05:46.689078+00:00 0:00:01.655372 28202 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 2 default 2021-05-15T02:05:42.712555+00:00 2 default_pool
success vc-asset-import_v002 create_emr_steps 2021-05-15T01:05:00+00:00 PythonOperator 2021-05-15T02:05:22.864772+00:00 2021-05-15T02:05:25.988657+00:00 0:00:03.123885 28201 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-05-15T02:05:20.648929+00:00 2 default_pool
success campaign-flow-job_v002 check_cluster_status 2021-05-15T01:00:00+00:00 EmrJobFlowSensor 2021-05-15T02:00:46.070979+00:00 2021-05-15T02:10:48.929614+00:00 0:10:02.858635 28200 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-05-15T02:00:44.001779+00:00 2 default_pool
success campaign-flow-job_v002 create_cluster_and_add_emr_steps 2021-05-15T01:00:00+00:00 EmrCreateJobFlowOperator 2021-05-15T02:00:26.141005+00:00 2021-05-15T02:00:27.926658+00:00 0:00:01.785653 28199 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 4 default 2021-05-15T02:00:23.990776+00:00 2 default_pool
success campaign-flow-job_v002 create_emr_steps 2021-05-15T01:00:00+00:00 PythonOperator 2021-05-15T02:00:04.353126+00:00 2021-05-15T02:00:07.458248+00:00 0:00:03.105122 28198 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 5 default 2021-05-15T02:00:01.962759+00:00 2 default_pool
success booking-processing-job_v002 check_cluster_status 2021-05-15T00:00:00+00:00 EmrJobFlowSensor 2021-05-15T01:12:10.632143+00:00 2021-05-15T01:22:13.437267+00:00 0:10:02.805124 28196 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-05-15T01:12:08.174761+00:00 2 default_pool
success campaign-history-job_v002 check_cluster_status 2021-05-15T00:00:00+00:00 EmrJobFlowSensor 2021-05-15T01:12:04.434071+00:00 2021-05-15T01:21:07.180093+00:00 0:09:02.746022 28195 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-05-15T01:12:02.111401+00:00 2 default_pool
success booking-processing-job_v002 create_cluster_and_add_emr_steps 2021-05-15T00:00:00+00:00 EmrCreateJobFlowOperator 2021-05-15T01:11:50.425992+00:00 2021-05-15T01:11:52.114854+00:00 0:00:01.688862 28194 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 2 default 2021-05-15T01:11:48.165307+00:00 2 default_pool
success campaign-history-job_v002 create_cluster_and_add_emr_steps 2021-05-15T00:00:00+00:00 EmrCreateJobFlowOperator 2021-05-15T01:11:42.329353+00:00 2021-05-15T01:11:44.156652+00:00 0:00:01.827299 28193 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 2 default 2021-05-15T01:11:40.092121+00:00 2 default_pool
success booking-processing-job_v002 create_emr_steps 2021-05-15T00:00:00+00:00 PythonOperator 2021-05-15T01:11:28.381609+00:00 2021-05-15T01:11:31.787107+00:00 0:00:03.405498 28192 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-05-15T01:11:26.043987+00:00 2 default_pool
success campaign-history-job_v002 create_emr_steps 2021-05-15T00:00:00+00:00 PythonOperator 2021-05-15T01:11:22.398037+00:00 2021-05-15T01:11:25.699328+00:00 0:00:03.301291 28191 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-05-15T01:11:20.051872+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_booking-processing-job_v002 2021-05-15T00:00:00+00:00 TriggerDagRunOperator 2021-05-15T01:11:04.437041+00:00 2021-05-15T01:11:04.960666+00:00 0:00:00.523625 28190 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-05-15T01:11:01.996735+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_campaign-history-job_v002 2021-05-15T00:00:00+00:00 TriggerDagRunOperator 2021-05-15T01:11:04.215153+00:00 2021-05-15T01:11:04.636468+00:00 0:00:00.421315 28189 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-05-15T01:11:01.996704+00:00 2 default_pool
success vc-asset-import_v002 check_cluster_status 2021-05-15T00:05:00+00:00 EmrJobFlowSensor 2021-05-15T01:05:57.612748+00:00 2021-05-15T01:15:00.368300+00:00 0:09:02.755552 28188 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-05-15T01:05:55.285422+00:00 2 default_pool
success vc-asset-import_v002 create_cluster_and_add_emr_steps 2021-05-15T00:05:00+00:00 EmrCreateJobFlowOperator 2021-05-15T01:05:37.591369+00:00 2021-05-15T01:05:39.346295+00:00 0:00:01.754926 28187 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 2 default 2021-05-15T01:05:35.226469+00:00 2 default_pool
success vc-asset-import_v002 create_emr_steps 2021-05-15T00:05:00+00:00 PythonOperator 2021-05-15T01:05:13.459372+00:00 2021-05-15T01:05:16.532702+00:00 0:00:03.073330 28186 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-05-15T01:05:11.253735+00:00 2 default_pool
success campaign-flow-job_v002 check_cluster_status 2021-05-15T00:00:00+00:00 EmrJobFlowSensor 2021-05-15T01:00:55.021106+00:00 2021-05-15T01:10:58.055565+00:00 0:10:03.034459 28185 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-05-15T01:00:52.717634+00:00 2 default_pool
success campaign-flow-job_v002 create_cluster_and_add_emr_steps 2021-05-15T00:00:00+00:00 EmrCreateJobFlowOperator 2021-05-15T01:00:35.058557+00:00 2021-05-15T01:00:36.861619+00:00 0:00:01.803062 28184 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 4 default 2021-05-15T01:00:32.704112+00:00 2 default_pool
success campaign-flow-job_v002 create_emr_steps 2021-05-15T00:00:00+00:00 PythonOperator 2021-05-15T01:00:11.075619+00:00 2021-05-15T01:00:14.398425+00:00 0:00:03.322806 28183 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 5 default 2021-05-15T01:00:08.766673+00:00 2 default_pool
success booking-processing-job_v002 check_cluster_status 2021-05-14T23:00:00+00:00 EmrJobFlowSensor 2021-05-15T00:13:34.315639+00:00 2021-05-15T00:22:36.880523+00:00 0:09:02.564884 28182 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-05-15T00:13:32.085421+00:00 2 default_pool
success campaign-history-job_v002 check_cluster_status 2021-05-14T23:00:00+00:00 EmrJobFlowSensor 2021-05-15T00:13:26.163168+00:00 2021-05-15T00:23:29.203122+00:00 0:10:03.039954 28181 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-05-15T00:13:24.041649+00:00 2 default_pool
success booking-processing-job_v002 create_cluster_and_add_emr_steps 2021-05-14T23:00:00+00:00 EmrCreateJobFlowOperator 2021-05-15T00:13:14.325145+00:00 2021-05-15T00:13:16.198618+00:00 0:00:01.873473 28180 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 2 default 2021-05-15T00:13:12.029902+00:00 2 default_pool
success campaign-history-job_v002 create_cluster_and_add_emr_steps 2021-05-14T23:00:00+00:00 EmrCreateJobFlowOperator 2021-05-15T00:13:06.161273+00:00 2021-05-15T00:13:07.875270+00:00 0:00:01.713997 28179 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 2 default 2021-05-15T00:13:04.017604+00:00 2 default_pool
success booking-processing-job_v002 create_emr_steps 2021-05-14T23:00:00+00:00 PythonOperator 2021-05-15T00:12:52.133151+00:00 2021-05-15T00:12:55.533579+00:00 0:00:03.400428 28178 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-05-15T00:12:50.013435+00:00 2 default_pool
success campaign-history-job_v002 create_emr_steps 2021-05-14T23:00:00+00:00 PythonOperator 2021-05-15T00:12:44.563323+00:00 2021-05-15T00:12:47.710489+00:00 0:00:03.147166 28177 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-05-15T00:12:42.072267+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_campaign-history-job_v002 2021-05-14T23:00:00+00:00 TriggerDagRunOperator 2021-05-15T00:12:38.800075+00:00 2021-05-15T00:12:39.327213+00:00 0:00:00.527138 28176 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-05-15T00:12:35.697643+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_booking-processing-job_v002 2021-05-14T23:00:00+00:00 TriggerDagRunOperator 2021-05-15T00:12:38.642157+00:00 2021-05-15T00:12:39.066308+00:00 0:00:00.424151 28175 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-05-15T00:12:35.697698+00:00 2 default_pool
success vc-asset-import_v002 check_cluster_status 2021-05-14T23:05:00+00:00 EmrJobFlowSensor 2021-05-15T00:05:51.173491+00:00 2021-05-15T00:14:53.738512+00:00 0:09:02.565021 28173 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-05-15T00:05:49.113952+00:00 2 default_pool
success vc-asset-import_v002 create_cluster_and_add_emr_steps 2021-05-14T23:05:00+00:00 EmrCreateJobFlowOperator 2021-05-15T00:05:29.491299+00:00 2021-05-15T00:05:31.110876+00:00 0:00:01.619577 28172 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 2 default 2021-05-15T00:05:27.148779+00:00 2 default_pool
success vc-asset-import_v002 create_emr_steps 2021-05-14T23:05:00+00:00 PythonOperator 2021-05-15T00:05:09.675376+00:00 2021-05-15T00:05:12.736244+00:00 0:00:03.060868 28171 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-05-15T00:05:07.151580+00:00 2 default_pool
success campaign-flow-job_v002 check_cluster_status 2021-05-14T23:00:00+00:00 EmrJobFlowSensor 2021-05-15T00:01:06.921922+00:00 2021-05-15T00:11:09.791869+00:00 0:10:02.869947 28170 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-05-15T00:01:04.556490+00:00 2 default_pool
success campaign-flow-job_v002 create_cluster_and_add_emr_steps 2021-05-14T23:00:00+00:00 EmrCreateJobFlowOperator 2021-05-15T00:00:46.644702+00:00 2021-05-15T00:00:48.491729+00:00 0:00:01.847027 28169 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 4 default 2021-05-15T00:00:44.425428+00:00 2 default_pool
success campaign-flow-job_v002 create_emr_steps 2021-05-14T23:00:00+00:00 PythonOperator 2021-05-15T00:00:25.123729+00:00 2021-05-15T00:00:28.337424+00:00 0:00:03.213695 28168 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 5 default 2021-05-15T00:00:22.468773+00:00 2 default_pool
success campaign-history-job_v002 check_cluster_status 2021-05-14T22:00:00+00:00 EmrJobFlowSensor 2021-05-14T23:11:36.440124+00:00 2021-05-14T23:20:38.906909+00:00 0:09:02.466785 28167 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-05-14T23:11:34.254819+00:00 2 default_pool
success booking-processing-job_v002 check_cluster_status 2021-05-14T22:00:00+00:00 EmrJobFlowSensor 2021-05-14T23:11:32.590796+00:00 2021-05-14T23:21:35.324031+00:00 0:10:02.733235 28166 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-05-14T23:11:30.272542+00:00 2 default_pool
success campaign-history-job_v002 create_cluster_and_add_emr_steps 2021-05-14T22:00:00+00:00 EmrCreateJobFlowOperator 2021-05-14T23:11:14.670849+00:00 2021-05-14T23:11:16.487018+00:00 0:00:01.816169 28165 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 2 default 2021-05-14T23:11:12.170212+00:00 2 default_pool
success booking-processing-job_v002 create_cluster_and_add_emr_steps 2021-05-14T22:00:00+00:00 EmrCreateJobFlowOperator 2021-05-14T23:11:10.805431+00:00 2021-05-14T23:11:12.570000+00:00 0:00:01.764569 28164 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 2 default 2021-05-14T23:11:08.346388+00:00 2 default_pool
success campaign-history-job_v002 create_emr_steps 2021-05-14T22:00:00+00:00 PythonOperator 2021-05-14T23:10:53.301651+00:00 2021-05-14T23:10:56.633566+00:00 0:00:03.331915 28163 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-05-14T23:10:50.250780+00:00 2 default_pool
success booking-processing-job_v002 create_emr_steps 2021-05-14T22:00:00+00:00 PythonOperator 2021-05-14T23:10:48.597969+00:00 2021-05-14T23:10:52.825623+00:00 0:00:04.227654 28162 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-05-14T23:10:46.169107+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_booking-processing-job_v002 2021-05-14T22:00:00+00:00 TriggerDagRunOperator 2021-05-14T23:10:34.611720+00:00 2021-05-14T23:10:35.121278+00:00 0:00:00.509558 28161 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-05-14T23:10:32.144497+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_campaign-history-job_v002 2021-05-14T22:00:00+00:00 TriggerDagRunOperator 2021-05-14T23:10:34.429891+00:00 2021-05-14T23:10:34.842439+00:00 0:00:00.412548 28160 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-05-14T23:10:32.144447+00:00 2 default_pool
success vc-asset-import_v002 check_cluster_status 2021-05-14T22:05:00+00:00 EmrJobFlowSensor 2021-05-14T23:09:14.076757+00:00 2021-05-14T23:18:16.626226+00:00 0:09:02.549469 28159 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-05-14T23:09:11.910873+00:00 2 default_pool
success vc-asset-import_v002 create_cluster_and_add_emr_steps 2021-05-14T22:05:00+00:00 EmrCreateJobFlowOperator 2021-05-14T23:08:54.301013+00:00 2021-05-14T23:08:56.020757+00:00 0:00:01.719744 28158 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 2 default 2021-05-14T23:08:51.885371+00:00 2 default_pool
success vc-asset-import_v002 create_emr_steps 2021-05-14T22:05:00+00:00 PythonOperator 2021-05-14T23:08:31.956950+00:00 2021-05-14T23:08:35.138668+00:00 0:00:03.181718 28157 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-05-14T23:08:29.785257+00:00 2 default_pool