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 create_emr_steps 2021-05-04T09:00:00+00:00 PythonOperator 2021-05-04T10:10:36.109893+00:00 2021-05-04T10:10:39.131867+00:00 0:00:03.021974 24338 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-05-04T10:10:33.665580+00:00 2 default_pool
success booking-processing-job_v002 create_emr_steps 2021-05-04T09:00:00+00:00 PythonOperator 2021-05-04T10:10:32.195830+00:00 2021-05-04T10:10:35.551048+00:00 0:00:03.355218 24337 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-05-04T10:10:29.742809+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_campaign-history-job_v002 2021-05-04T09:00:00+00:00 TriggerDagRunOperator 2021-05-04T10:10:10.198515+00:00 2021-05-04T10:10:10.645633+00:00 0:00:00.447118 24336 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-05-04T10:10:07.589146+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_booking-processing-job_v002 2021-05-04T09:00:00+00:00 TriggerDagRunOperator 2021-05-04T10:10:10.211502+00:00 2021-05-04T10:10:10.766440+00:00 0:00:00.554938 24335 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-05-04T10:10:07.589189+00:00 2 default_pool
success vc-asset-import_v002 check_cluster_status 2021-05-04T09:05:00+00:00 EmrJobFlowSensor 2021-05-04T10:05:51.181885+00:00 2021-05-04T10:14:53.795917+00:00 0:09:02.614032 24334 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-05-04T10:05:49.035592+00:00 2 default_pool
success vc-asset-import_v002 create_cluster_and_add_emr_steps 2021-05-04T09:05:00+00:00 EmrCreateJobFlowOperator 2021-05-04T10:05:29.587218+00:00 2021-05-04T10:05:31.223801+00:00 0:00:01.636583 24333 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 2 default 2021-05-04T10:05:27.068678+00:00 2 default_pool
success vc-asset-import_v002 create_emr_steps 2021-05-04T09:05:00+00:00 PythonOperator 2021-05-04T10:05:07.245877+00:00 2021-05-04T10:05:10.258257+00:00 0:00:03.012380 24332 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-05-04T10:05:04.994389+00:00 2 default_pool
success campaign-flow-job_v002 check_cluster_status 2021-05-04T09:00:00+00:00 EmrJobFlowSensor 2021-05-04T10:00:56.814727+00:00 2021-05-04T10:09:59.518972+00:00 0:09:02.704245 24331 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-05-04T10:00:54.446672+00:00 2 default_pool
success campaign-flow-job_v002 create_cluster_and_add_emr_steps 2021-05-04T09:00:00+00:00 EmrCreateJobFlowOperator 2021-05-04T10:00:34.670866+00:00 2021-05-04T10:00:36.402337+00:00 0:00:01.731471 24330 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 4 default 2021-05-04T10:00:32.346350+00:00 2 default_pool
success campaign-flow-job_v002 create_emr_steps 2021-05-04T09:00:00+00:00 PythonOperator 2021-05-04T10:00:12.782824+00:00 2021-05-04T10:00:15.864897+00:00 0:00:03.082073 24329 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 5 default 2021-05-04T10:00:10.316992+00:00 2 default_pool
success campaign-history-job_v002 check_cluster_status 2021-05-04T08:00:00+00:00 EmrJobFlowSensor 2021-05-04T09:12:20.629736+00:00 2021-05-04T09:21:23.302600+00:00 0:09:02.672864 24327 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-05-04T09:12:17.976286+00:00 2 default_pool
success booking-processing-job_v002 check_cluster_status 2021-05-04T08:00:00+00:00 EmrJobFlowSensor 2021-05-04T09:12:18.181660+00:00 2021-05-04T09:22:21.489587+00:00 0:10:03.307927 24326 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-05-04T09:12:15.892791+00:00 2 default_pool
success campaign-history-job_v002 create_cluster_and_add_emr_steps 2021-05-04T08:00:00+00:00 EmrCreateJobFlowOperator 2021-05-04T09:12:00.145678+00:00 2021-05-04T09:12:01.917978+00:00 0:00:01.772300 24325 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 2 default 2021-05-04T09:11:57.874704+00:00 2 default_pool
success booking-processing-job_v002 create_cluster_and_add_emr_steps 2021-05-04T08:00:00+00:00 EmrCreateJobFlowOperator 2021-05-04T09:11:56.002672+00:00 2021-05-04T09:11:57.675869+00:00 0:00:01.673197 24324 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 2 default 2021-05-04T09:11:53.848811+00:00 2 default_pool
success campaign-history-job_v002 create_emr_steps 2021-05-04T08:00:00+00:00 PythonOperator 2021-05-04T09:11:38.596117+00:00 2021-05-04T09:11:42.048164+00:00 0:00:03.452047 24323 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-05-04T09:11:35.837306+00:00 2 default_pool
success booking-processing-job_v002 create_emr_steps 2021-05-04T08:00:00+00:00 PythonOperator 2021-05-04T09:11:34.089693+00:00 2021-05-04T09:11:37.950447+00:00 0:00:03.860754 24322 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-05-04T09:11:31.827716+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_booking-processing-job_v002 2021-05-04T08:00:00+00:00 TriggerDagRunOperator 2021-05-04T09:11:20.406368+00:00 2021-05-04T09:11:20.932374+00:00 0:00:00.526006 24321 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-05-04T09:11:17.865213+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_campaign-history-job_v002 2021-05-04T08:00:00+00:00 TriggerDagRunOperator 2021-05-04T09:11:20.284067+00:00 2021-05-04T09:11:20.716068+00:00 0:00:00.432001 24320 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-05-04T09:11:17.865168+00:00 2 default_pool
success vc-asset-import_v002 check_cluster_status 2021-05-04T08:05:00+00:00 EmrJobFlowSensor 2021-05-04T09:06:05.388142+00:00 2021-05-04T09:14:07.961218+00:00 0:08:02.573076 24319 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-05-04T09:06:03.053198+00:00 2 default_pool
success vc-asset-import_v002 create_cluster_and_add_emr_steps 2021-05-04T08:05:00+00:00 EmrCreateJobFlowOperator 2021-05-04T09:05:43.076095+00:00 2021-05-04T09:05:44.675760+00:00 0:00:01.599665 24318 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 2 default 2021-05-04T09:05:40.900258+00:00 2 default_pool
success vc-asset-import_v002 create_emr_steps 2021-05-04T08:05:00+00:00 PythonOperator 2021-05-04T09:05:23.143741+00:00 2021-05-04T09:05:26.186675+00:00 0:00:03.042934 24317 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-05-04T09:05:20.886398+00:00 2 default_pool
success campaign-flow-job_v002 check_cluster_status 2021-05-04T08:00:00+00:00 EmrJobFlowSensor 2021-05-04T09:00:58.797134+00:00 2021-05-04T09:11:01.618619+00:00 0:10:02.821485 24316 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-05-04T09:00:56.452456+00:00 2 default_pool
success campaign-flow-job_v002 create_cluster_and_add_emr_steps 2021-05-04T08:00:00+00:00 EmrCreateJobFlowOperator 2021-05-04T09:00:38.511910+00:00 2021-05-04T09:00:40.282803+00:00 0:00:01.770893 24315 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 4 default 2021-05-04T09:00:36.295233+00:00 2 default_pool
success campaign-flow-job_v002 create_emr_steps 2021-05-04T08:00:00+00:00 PythonOperator 2021-05-04T09:00:16.594879+00:00 2021-05-04T09:00:19.674658+00:00 0:00:03.079779 24314 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 5 default 2021-05-04T09:00:14.225449+00:00 2 default_pool
success campaign-history-job_v002 check_cluster_status 2021-05-04T07:00:00+00:00 EmrJobFlowSensor 2021-05-04T08:10:06.656707+00:00 2021-05-04T08:19:09.465078+00:00 0:09:02.808371 24312 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-05-04T08:10:04.166965+00:00 2 default_pool
success booking-processing-job_v002 check_cluster_status 2021-05-04T07:00:00+00:00 EmrJobFlowSensor 2021-05-04T08:10:06.705886+00:00 2021-05-04T08:19:09.556713+00:00 0:09:02.850827 24311 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-05-04T08:10:04.167006+00:00 2 default_pool
success campaign-history-job_v002 create_cluster_and_add_emr_steps 2021-05-04T07:00:00+00:00 EmrCreateJobFlowOperator 2021-05-04T08:09:44.529518+00:00 2021-05-04T08:09:46.239471+00:00 0:00:01.709953 24310 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 2 default 2021-05-04T08:09:42.061802+00:00 2 default_pool
success booking-processing-job_v002 create_cluster_and_add_emr_steps 2021-05-04T07:00:00+00:00 EmrCreateJobFlowOperator 2021-05-04T08:09:44.559437+00:00 2021-05-04T08:09:46.412974+00:00 0:00:01.853537 24309 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 2 default 2021-05-04T08:09:42.061841+00:00 2 default_pool
success booking-processing-job_v002 create_emr_steps 2021-05-04T07:00:00+00:00 PythonOperator 2021-05-04T08:09:22.297636+00:00 2021-05-04T08:09:25.699228+00:00 0:00:03.401592 24308 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-05-04T08:09:20.010955+00:00 2 default_pool
success campaign-history-job_v002 create_emr_steps 2021-05-04T07:00:00+00:00 PythonOperator 2021-05-04T08:09:22.310085+00:00 2021-05-04T08:09:25.431407+00:00 0:00:03.121322 24307 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-05-04T08:09:20.010913+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_campaign-history-job_v002 2021-05-04T07:00:00+00:00 TriggerDagRunOperator 2021-05-04T08:09:12.346836+00:00 2021-05-04T08:09:12.911861+00:00 0:00:00.565025 24306 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-05-04T08:09:10.059505+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_booking-processing-job_v002 2021-05-04T07:00:00+00:00 TriggerDagRunOperator 2021-05-04T08:09:12.338956+00:00 2021-05-04T08:09:12.837359+00:00 0:00:00.498403 24305 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-05-04T08:09:10.059534+00:00 2 default_pool
success vc-asset-import_v002 check_cluster_status 2021-05-04T07:05:00+00:00 EmrJobFlowSensor 2021-05-04T08:05:59.981950+00:00 2021-05-04T08:15:02.641051+00:00 0:09:02.659101 24304 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-05-04T08:05:57.688331+00:00 2 default_pool
success vc-asset-import_v002 create_cluster_and_add_emr_steps 2021-05-04T07:05:00+00:00 EmrCreateJobFlowOperator 2021-05-04T08:05:37.787423+00:00 2021-05-04T08:05:39.573891+00:00 0:00:01.786468 24303 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 2 default 2021-05-04T08:05:35.601615+00:00 2 default_pool
success vc-asset-import_v002 create_emr_steps 2021-05-04T07:05:00+00:00 PythonOperator 2021-05-04T08:05:17.795181+00:00 2021-05-04T08:05:20.775113+00:00 0:00:02.979932 24302 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-05-04T08:05:15.567586+00:00 2 default_pool
success campaign-flow-job_v002 check_cluster_status 2021-05-04T07:00:00+00:00 EmrJobFlowSensor 2021-05-04T08:00:57.206283+00:00 2021-05-04T08:08:59.746461+00:00 0:08:02.540178 24301 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-05-04T08:00:55.040580+00:00 2 default_pool
success campaign-flow-job_v002 create_cluster_and_add_emr_steps 2021-05-04T07:00:00+00:00 EmrCreateJobFlowOperator 2021-05-04T08:00:35.334701+00:00 2021-05-04T08:00:37.028931+00:00 0:00:01.694230 24300 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 4 default 2021-05-04T08:00:33.012790+00:00 2 default_pool
success campaign-flow-job_v002 create_emr_steps 2021-05-04T07:00:00+00:00 PythonOperator 2021-05-04T08:00:07.235143+00:00 2021-05-04T08:00:10.526875+00:00 0:00:03.291732 24299 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 5 default 2021-05-04T08:00:04.999892+00:00 2 default_pool
success campaign-history-job_v002 check_cluster_status 2021-05-04T06:00:00+00:00 EmrJobFlowSensor 2021-05-04T07:14:43.512541+00:00 2021-05-04T07:24:46.231887+00:00 0:10:02.719346 24298 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-05-04T07:14:41.065801+00:00 2 default_pool
success booking-processing-job_v002 check_cluster_status 2021-05-04T06:00:00+00:00 EmrJobFlowSensor 2021-05-04T07:14:39.351966+00:00 2021-05-04T07:24:42.093201+00:00 0:10:02.741235 24297 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-05-04T07:14:37.051825+00:00 2 default_pool
success campaign-history-job_v002 create_cluster_and_add_emr_steps 2021-05-04T06:00:00+00:00 EmrCreateJobFlowOperator 2021-05-04T07:14:21.218995+00:00 2021-05-04T07:14:22.966560+00:00 0:00:01.747565 24296 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 2 default 2021-05-04T07:14:19.012284+00:00 2 default_pool
success booking-processing-job_v002 create_cluster_and_add_emr_steps 2021-05-04T06:00:00+00:00 EmrCreateJobFlowOperator 2021-05-04T07:14:19.707107+00:00 2021-05-04T07:14:21.533576+00:00 0:00:01.826469 24295 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 2 default 2021-05-04T07:14:17.141566+00:00 2 default_pool
success campaign-history-job_v002 create_emr_steps 2021-05-04T06:00:00+00:00 PythonOperator 2021-05-04T07:13:59.585762+00:00 2021-05-04T07:14:02.680392+00:00 0:00:03.094630 24294 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-05-04T07:13:56.985043+00:00 2 default_pool
success booking-processing-job_v002 create_emr_steps 2021-05-04T06:00:00+00:00 PythonOperator 2021-05-04T07:13:57.163022+00:00 2021-05-04T07:14:00.817124+00:00 0:00:03.654102 24293 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-05-04T07:13:54.979785+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_campaign-history-job_v002 2021-05-04T06:00:00+00:00 TriggerDagRunOperator 2021-05-04T07:13:35.724740+00:00 2021-05-04T07:13:36.230611+00:00 0:00:00.505871 24292 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-05-04T07:13:32.961071+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_booking-processing-job_v002 2021-05-04T06:00:00+00:00 TriggerDagRunOperator 2021-05-04T07:13:35.609112+00:00 2021-05-04T07:13:36.036520+00:00 0:00:00.427408 24291 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-05-04T07:13:32.961098+00:00 2 default_pool
success vc-asset-import_v002 check_cluster_status 2021-05-04T06:05:00+00:00 EmrJobFlowSensor 2021-05-04T07:06:02.909007+00:00 2021-05-04T07:15:05.587806+00:00 0:09:02.678799 24289 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-05-04T07:06:00.634881+00:00 2 default_pool
success vc-asset-import_v002 create_cluster_and_add_emr_steps 2021-05-04T06:05:00+00:00 EmrCreateJobFlowOperator 2021-05-04T07:05:42.954606+00:00 2021-05-04T07:05:44.694084+00:00 0:00:01.739478 24288 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 2 default 2021-05-04T07:05:40.612224+00:00 2 default_pool
success vc-asset-import_v002 create_emr_steps 2021-05-04T06:05:00+00:00 PythonOperator 2021-05-04T07:05:20.858499+00:00 2021-05-04T07:05:23.906454+00:00 0:00:03.047955 24287 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-05-04T07:05:18.587479+00:00 2 default_pool
success campaign-flow-job_v002 check_cluster_status 2021-05-04T06:00:00+00:00 EmrJobFlowSensor 2021-05-04T07:00:58.231229+00:00 2021-05-04T07:10:00.872507+00:00 0:09:02.641278 24286 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-05-04T07:00:56.095518+00:00 2 default_pool
success campaign-flow-job_v002 create_cluster_and_add_emr_steps 2021-05-04T06:00:00+00:00 EmrCreateJobFlowOperator 2021-05-04T07:00:36.393191+00:00 2021-05-04T07:00:38.075626+00:00 0:00:01.682435 24285 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 4 default 2021-05-04T07:00:34.149251+00:00 2 default_pool
success campaign-flow-job_v002 create_emr_steps 2021-05-04T06:00:00+00:00 PythonOperator 2021-05-04T07:00:16.259498+00:00 2021-05-04T07:00:19.311483+00:00 0:00:03.051985 24284 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 5 default 2021-05-04T07:00:14.009746+00:00 2 default_pool
success booking-processing-job_v002 check_cluster_status 2021-05-04T05:00:00+00:00 EmrJobFlowSensor 2021-05-04T06:11:47.132811+00:00 2021-05-04T06:21:49.838767+00:00 0:10:02.705956 24283 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-05-04T06:11:44.886827+00:00 2 default_pool
success campaign-history-job_v002 check_cluster_status 2021-05-04T05:00:00+00:00 EmrJobFlowSensor 2021-05-04T06:11:43.111888+00:00 2021-05-04T06:21:45.741573+00:00 0:10:02.629685 24282 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-05-04T06:11:40.859231+00:00 2 default_pool
success booking-processing-job_v002 create_cluster_and_add_emr_steps 2021-05-04T05:00:00+00:00 EmrCreateJobFlowOperator 2021-05-04T06:11:27.008174+00:00 2021-05-04T06:11:28.796713+00:00 0:00:01.788539 24281 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 2 default 2021-05-04T06:11:24.814726+00:00 2 default_pool
success campaign-history-job_v002 create_cluster_and_add_emr_steps 2021-05-04T05:00:00+00:00 EmrCreateJobFlowOperator 2021-05-04T06:11:21.140459+00:00 2021-05-04T06:11:22.853772+00:00 0:00:01.713313 24280 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 2 default 2021-05-04T06:11:18.855830+00:00 2 default_pool
success booking-processing-job_v002 create_emr_steps 2021-05-04T05:00:00+00:00 PythonOperator 2021-05-04T06:11:05.382204+00:00 2021-05-04T06:11:08.764859+00:00 0:00:03.382655 24279 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-05-04T06:11:02.843890+00:00 2 default_pool
success campaign-history-job_v002 create_emr_steps 2021-05-04T05:00:00+00:00 PythonOperator 2021-05-04T06:10:59.220607+00:00 2021-05-04T06:11:02.260142+00:00 0:00:03.039535 24278 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-05-04T06:10:56.858172+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_campaign-history-job_v002 2021-05-04T05:00:00+00:00 TriggerDagRunOperator 2021-05-04T06:10:41.107039+00:00 2021-05-04T06:10:41.631599+00:00 0:00:00.524560 24277 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-05-04T06:10:38.771100+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_booking-processing-job_v002 2021-05-04T05:00:00+00:00 TriggerDagRunOperator 2021-05-04T06:10:40.997702+00:00 2021-05-04T06:10:41.405722+00:00 0:00:00.408020 24276 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-05-04T06:10:38.771134+00:00 2 default_pool
success vc-asset-import_v002 check_cluster_status 2021-05-04T05:05:00+00:00 EmrJobFlowSensor 2021-05-04T06:08:06.880816+00:00 2021-05-04T06:17:09.623539+00:00 0:09:02.742723 24275 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-05-04T06:08:04.714363+00:00 2 default_pool
success vc-asset-import_v002 create_cluster_and_add_emr_steps 2021-05-04T05:05:00+00:00 EmrCreateJobFlowOperator 2021-05-04T06:07:44.666516+00:00 2021-05-04T06:07:46.294417+00:00 0:00:01.627901 24274 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 2 default 2021-05-04T06:07:42.497149+00:00 2 default_pool
success campaign-flow-job_v002 check_cluster_status 2021-05-04T05:00:00+00:00 EmrJobFlowSensor 2021-05-04T06:07:27.784581+00:00 2021-05-04T06:10:29.586710+00:00 0:03:01.802129 24273 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-05-04T06:07:24.413314+00:00 2 default_pool
success vc-asset-import_v002 create_emr_steps 2021-05-04T05:05:00+00:00 PythonOperator 2021-05-04T06:07:25.453725+00:00 2021-05-04T06:07:29.027337+00:00 0:00:03.573612 24272 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-05-04T06:07:22.469473+00:00 2 default_pool
success campaign-flow-job_v002 create_cluster_and_add_emr_steps 2021-05-04T05:00:00+00:00 EmrCreateJobFlowOperator 2021-05-04T06:00:30.655143+00:00 2021-05-04T06:00:32.492782+00:00 0:00:01.837639 24270 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 4 default 2021-05-04T06:00:27.657803+00:00 2 default_pool
success campaign-flow-job_v002 create_emr_steps 2021-05-04T05:00:00+00:00 PythonOperator 2021-05-04T06:00:10.105216+00:00 2021-05-04T06:00:13.124427+00:00 0:00:03.019211 24269 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 5 default 2021-05-04T06:00:07.585856+00:00 2 default_pool
success booking-processing-job_v002 check_cluster_status 2021-05-04T04:00:00+00:00 EmrJobFlowSensor 2021-05-04T05:11:46.639556+00:00 2021-05-04T05:20:49.281177+00:00 0:09:02.641621 24268 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-05-04T05:11:44.455342+00:00 2 default_pool
success campaign-history-job_v002 check_cluster_status 2021-05-04T04:00:00+00:00 EmrJobFlowSensor 2021-05-04T05:11:40.601176+00:00 2021-05-04T05:20:43.298152+00:00 0:09:02.696976 24267 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-05-04T05:11:38.399929+00:00 2 default_pool
success booking-processing-job_v002 create_cluster_and_add_emr_steps 2021-05-04T04:00:00+00:00 EmrCreateJobFlowOperator 2021-05-04T05:11:24.626011+00:00 2021-05-04T05:11:26.319750+00:00 0:00:01.693739 24266 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 2 default 2021-05-04T05:11:22.358498+00:00 2 default_pool
success campaign-history-job_v002 create_cluster_and_add_emr_steps 2021-05-04T04:00:00+00:00 EmrCreateJobFlowOperator 2021-05-04T05:11:20.539478+00:00 2021-05-04T05:11:22.272907+00:00 0:00:01.733429 24265 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 2 default 2021-05-04T05:11:18.355849+00:00 2 default_pool
success booking-processing-job_v002 create_emr_steps 2021-05-04T04:00:00+00:00 PythonOperator 2021-05-04T05:11:04.859645+00:00 2021-05-04T05:11:08.219290+00:00 0:00:03.359645 24264 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-05-04T05:11:02.346500+00:00 2 default_pool
success campaign-history-job_v002 create_emr_steps 2021-05-04T04:00:00+00:00 PythonOperator 2021-05-04T05:10:58.601262+00:00 2021-05-04T05:11:01.691439+00:00 0:00:03.090177 24263 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-05-04T05:10:56.339258+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_campaign-history-job_v002 2021-05-04T04:00:00+00:00 TriggerDagRunOperator 2021-05-04T05:10:48.799210+00:00 2021-05-04T05:10:49.332611+00:00 0:00:00.533401 24262 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-05-04T05:10:46.332990+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_booking-processing-job_v002 2021-05-04T04:00:00+00:00 TriggerDagRunOperator 2021-05-04T05:10:48.571373+00:00 2021-05-04T05:10:49.018315+00:00 0:00:00.446942 24261 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-05-04T05:10:46.333025+00:00 2 default_pool
success vc-asset-import_v002 check_cluster_status 2021-05-04T04:05:00+00:00 EmrJobFlowSensor 2021-05-04T05:06:04.491439+00:00 2021-05-04T05:14:07.279228+00:00 0:08:02.787789 24260 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-05-04T05:06:02.053640+00:00 2 default_pool
success vc-asset-import_v002 create_cluster_and_add_emr_steps 2021-05-04T04:05:00+00:00 EmrCreateJobFlowOperator 2021-05-04T05:05:42.042140+00:00 2021-05-04T05:05:43.697268+00:00 0:00:01.655128 24259 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 2 default 2021-05-04T05:05:39.922815+00:00 2 default_pool
success vc-asset-import_v002 create_emr_steps 2021-05-04T04:05:00+00:00 PythonOperator 2021-05-04T05:05:22.145258+00:00 2021-05-04T05:05:25.197515+00:00 0:00:03.052257 24258 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-05-04T05:05:19.908076+00:00 2 default_pool
success campaign-flow-job_v002 check_cluster_status 2021-05-04T04:00:00+00:00 EmrJobFlowSensor 2021-05-04T05:01:31.841568+00:00 2021-05-04T05:10:34.472972+00:00 0:09:02.631404 24257 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-05-04T05:01:29.625797+00:00 2 default_pool
success campaign-flow-job_v002 create_cluster_and_add_emr_steps 2021-05-04T04:00:00+00:00 EmrCreateJobFlowOperator 2021-05-04T05:01:09.827974+00:00 2021-05-04T05:01:11.541745+00:00 0:00:01.713771 24256 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 4 default 2021-05-04T05:01:07.597284+00:00 2 default_pool
success campaign-flow-job_v002 create_emr_steps 2021-05-04T04:00:00+00:00 PythonOperator 2021-05-04T05:00:50.385631+00:00 2021-05-04T05:00:53.516926+00:00 0:00:03.131295 24255 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 5 default 2021-05-04T05:00:47.641198+00:00 2 default_pool
success campaign-history-job_v002 check_cluster_status 2021-05-04T03:00:00+00:00 EmrJobFlowSensor 2021-05-04T04:11:12.941095+00:00 2021-05-04T04:21:15.703411+00:00 0:10:02.762316 24253 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-05-04T04:11:10.676657+00:00 2 default_pool
success booking-processing-job_v002 check_cluster_status 2021-05-04T03:00:00+00:00 EmrJobFlowSensor 2021-05-04T04:11:12.934431+00:00 2021-05-04T04:21:15.920991+00:00 0:10:02.986560 24252 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-05-04T04:11:10.676698+00:00 2 default_pool
success booking-processing-job_v002 create_cluster_and_add_emr_steps 2021-05-04T03:00:00+00:00 EmrCreateJobFlowOperator 2021-05-04T04:10:50.935642+00:00 2021-05-04T04:10:52.754188+00:00 0:00:01.818546 24251 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 2 default 2021-05-04T04:10:48.654462+00:00 2 default_pool
success campaign-history-job_v002 create_cluster_and_add_emr_steps 2021-05-04T03:00:00+00:00 EmrCreateJobFlowOperator 2021-05-04T04:10:50.860539+00:00 2021-05-04T04:10:52.574275+00:00 0:00:01.713736 24250 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 2 default 2021-05-04T04:10:48.654434+00:00 2 default_pool
success campaign-history-job_v002 create_emr_steps 2021-05-04T03:00:00+00:00 PythonOperator 2021-05-04T04:10:31.159360+00:00 2021-05-04T04:10:34.237604+00:00 0:00:03.078244 24249 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-05-04T04:10:28.658711+00:00 2 default_pool
success booking-processing-job_v002 create_emr_steps 2021-05-04T03:00:00+00:00 PythonOperator 2021-05-04T04:10:29.185073+00:00 2021-05-04T04:10:32.505759+00:00 0:00:03.320686 24248 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-05-04T04:10:26.653021+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_booking-processing-job_v002 2021-05-04T03:00:00+00:00 TriggerDagRunOperator 2021-05-04T04:10:10.839361+00:00 2021-05-04T04:10:11.368048+00:00 0:00:00.528687 24247 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-05-04T04:10:08.545452+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_campaign-history-job_v002 2021-05-04T03:00:00+00:00 TriggerDagRunOperator 2021-05-04T04:10:10.791148+00:00 2021-05-04T04:10:11.227530+00:00 0:00:00.436382 24246 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-05-04T04:10:08.545403+00:00 2 default_pool
success vc-asset-import_v002 check_cluster_status 2021-05-04T03:05:00+00:00 EmrJobFlowSensor 2021-05-04T04:05:50.202976+00:00 2021-05-04T04:14:52.703641+00:00 0:09:02.500665 24245 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-05-04T04:05:48.033853+00:00 2 default_pool
success vc-asset-import_v002 create_cluster_and_add_emr_steps 2021-05-04T03:05:00+00:00 EmrCreateJobFlowOperator 2021-05-04T04:05:30.609419+00:00 2021-05-04T04:05:32.336080+00:00 0:00:01.726661 24244 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 2 default 2021-05-04T04:05:28.150763+00:00 2 default_pool
success vc-asset-import_v002 create_emr_steps 2021-05-04T03:05:00+00:00 PythonOperator 2021-05-04T04:05:08.548312+00:00 2021-05-04T04:05:11.646143+00:00 0:00:03.097831 24243 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-05-04T04:05:06.061744+00:00 2 default_pool
success campaign-flow-job_v002 check_cluster_status 2021-05-04T03:00:00+00:00 EmrJobFlowSensor 2021-05-04T04:01:04.330586+00:00 2021-05-04T04:10:07.276865+00:00 0:09:02.946279 24242 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-05-04T04:01:01.744145+00:00 2 default_pool
success campaign-flow-job_v002 create_cluster_and_add_emr_steps 2021-05-04T03:00:00+00:00 EmrCreateJobFlowOperator 2021-05-04T04:00:41.931320+00:00 2021-05-04T04:00:43.720385+00:00 0:00:01.789065 24241 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 4 default 2021-05-04T04:00:39.641938+00:00 2 default_pool
success campaign-flow-job_v002 create_emr_steps 2021-05-04T03:00:00+00:00 PythonOperator 2021-05-04T04:00:20.106731+00:00 2021-05-04T04:00:23.267283+00:00 0:00:03.160552 24240 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 5 default 2021-05-04T04:00:17.622100+00:00 2 default_pool
success campaign-history-job_v002 check_cluster_status 2021-05-04T02:00:00+00:00 EmrJobFlowSensor 2021-05-04T03:11:34.471139+00:00 2021-05-04T03:20:37.319566+00:00 0:09:02.848427 24238 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-05-04T03:11:32.066692+00:00 2 default_pool
success booking-processing-job_v002 check_cluster_status 2021-05-04T02:00:00+00:00 EmrJobFlowSensor 2021-05-04T03:11:22.244579+00:00 2021-05-04T03:20:25.016064+00:00 0:09:02.771485 24237 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-05-04T03:11:19.994303+00:00 2 default_pool
success campaign-history-job_v002 create_cluster_and_add_emr_steps 2021-05-04T02:00:00+00:00 EmrCreateJobFlowOperator 2021-05-04T03:11:12.327388+00:00 2021-05-04T03:11:14.114328+00:00 0:00:01.786940 24236 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 2 default 2021-05-04T03:11:10.049944+00:00 2 default_pool
success booking-processing-job_v002 create_cluster_and_add_emr_steps 2021-05-04T02:00:00+00:00 EmrCreateJobFlowOperator 2021-05-04T03:11:02.211856+00:00 2021-05-04T03:11:04.137175+00:00 0:00:01.925319 24235 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 2 default 2021-05-04T03:10:59.959487+00:00 2 default_pool
success campaign-history-job_v002 create_emr_steps 2021-05-04T02:00:00+00:00 PythonOperator 2021-05-04T03:10:50.386321+00:00 2021-05-04T03:10:53.411672+00:00 0:00:03.025351 24234 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-05-04T03:10:47.947186+00:00 2 default_pool
success booking-processing-job_v002 create_emr_steps 2021-05-04T02:00:00+00:00 PythonOperator 2021-05-04T03:10:40.234162+00:00 2021-05-04T03:10:43.495096+00:00 0:00:03.260934 24233 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-05-04T03:10:37.940183+00:00 2 default_pool