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 create_emr_steps 2021-04-03T07:00:00+00:00 PythonOperator 2021-04-03T08:00:10.923863+00:00 2021-04-03T08:00:13.853681+00:00 0:00:02.929818 13048 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 5 default 2021-04-03T08:00:08.591893+00:00 2 default_pool
success campaign-history-job_v002 check_cluster_status 2021-04-03T06:00:00+00:00 EmrJobFlowSensor 2021-04-03T07:11:18.342945+00:00 2021-04-03T07:21:21.198924+00:00 0:10:02.855979 13046 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-03T07:11:15.955576+00:00 2 default_pool
success booking-processing-job_v002 check_cluster_status 2021-04-03T06:00:00+00:00 EmrJobFlowSensor 2021-04-03T07:11:10.523694+00:00 2021-04-03T07:20:13.147058+00:00 0:09:02.623364 13045 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-03T07:11:07.890290+00:00 2 default_pool
success campaign-history-job_v002 create_cluster_and_add_emr_steps 2021-04-03T06:00:00+00:00 EmrCreateJobFlowOperator 2021-04-03T07:10:58.030455+00:00 2021-04-03T07:10:59.867130+00:00 0:00:01.836675 13044 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 2 default 2021-04-03T07:10:55.847901+00:00 2 default_pool
success booking-processing-job_v002 create_cluster_and_add_emr_steps 2021-04-03T06:00:00+00:00 EmrCreateJobFlowOperator 2021-04-03T07:10:50.143806+00:00 2021-04-03T07:10:51.965624+00:00 0:00:01.821818 13043 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 2 default 2021-04-03T07:10:47.837211+00:00 2 default_pool
success campaign-history-job_v002 create_emr_steps 2021-04-03T06:00:00+00:00 PythonOperator 2021-04-03T07:10:36.144580+00:00 2021-04-03T07:10:39.018367+00:00 0:00:02.873787 13042 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-04-03T07:10:33.827449+00:00 2 default_pool
success booking-processing-job_v002 create_emr_steps 2021-04-03T06:00:00+00:00 PythonOperator 2021-04-03T07:10:28.192554+00:00 2021-04-03T07:10:31.237761+00:00 0:00:03.045207 13041 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-04-03T07:10:25.822117+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_campaign-history-job_v002 2021-04-03T06:00:00+00:00 TriggerDagRunOperator 2021-04-03T07:10:16.109604+00:00 2021-04-03T07:10:16.657131+00:00 0:00:00.547527 13040 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-03T07:10:13.809417+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_booking-processing-job_v002 2021-04-03T06:00:00+00:00 TriggerDagRunOperator 2021-04-03T07:10:16.043664+00:00 2021-04-03T07:10:16.435073+00:00 0:00:00.391409 13039 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-03T07:10:13.809453+00:00 2 default_pool
success vc-asset-import_v002 check_cluster_status 2021-04-03T06:05:00+00:00 EmrJobFlowSensor 2021-04-03T07:05:57.366944+00:00 2021-04-03T07:14:59.936872+00:00 0:09:02.569928 13038 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-03T07:05:55.168604+00:00 2 default_pool
success vc-asset-import_v002 create_cluster_and_add_emr_steps 2021-04-03T06:05:00+00:00 EmrCreateJobFlowOperator 2021-04-03T07:05:31.285723+00:00 2021-04-03T07:05:32.949389+00:00 0:00:01.663666 13037 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 2 default 2021-04-03T07:05:29.158475+00:00 2 default_pool
success vc-asset-import_v002 create_emr_steps 2021-04-03T06:05:00+00:00 PythonOperator 2021-04-03T07:05:09.660724+00:00 2021-04-03T07:05:12.340388+00:00 0:00:02.679664 13036 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-04-03T07:05:07.244096+00:00 2 default_pool
success campaign-flow-job_v002 check_cluster_status 2021-04-03T06:00:00+00:00 EmrJobFlowSensor 2021-04-03T07:00:52.923857+00:00 2021-04-03T07:09:55.620092+00:00 0:09:02.696235 13035 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-04-03T07:00:50.622715+00:00 2 default_pool
success campaign-flow-job_v002 create_cluster_and_add_emr_steps 2021-04-03T06:00:00+00:00 EmrCreateJobFlowOperator 2021-04-03T07:00:30.938049+00:00 2021-04-03T07:00:32.811865+00:00 0:00:01.873816 13034 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 4 default 2021-04-03T07:00:28.607397+00:00 2 default_pool
success campaign-flow-job_v002 create_emr_steps 2021-04-03T06:00:00+00:00 PythonOperator 2021-04-03T07:00:09.319524+00:00 2021-04-03T07:00:12.237709+00:00 0:00:02.918185 13033 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 5 default 2021-04-03T07:00:06.646194+00:00 2 default_pool
success booking-processing-job_v002 check_cluster_status 2021-04-03T05:00:00+00:00 EmrJobFlowSensor 2021-04-03T06:12:16.419511+00:00 2021-04-03T06:22:19.378524+00:00 0:10:02.959013 13031 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-03T06:12:14.086136+00:00 2 default_pool
success campaign-history-job_v002 check_cluster_status 2021-04-03T05:00:00+00:00 EmrJobFlowSensor 2021-04-03T06:12:12.179510+00:00 2021-04-03T06:21:14.762368+00:00 0:09:02.582858 13030 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-03T06:12:10.037562+00:00 2 default_pool
success booking-processing-job_v002 create_cluster_and_add_emr_steps 2021-04-03T05:00:00+00:00 EmrCreateJobFlowOperator 2021-04-03T06:11:56.258299+00:00 2021-04-03T06:11:57.950321+00:00 0:00:01.692022 13029 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 2 default 2021-04-03T06:11:54.036414+00:00 2 default_pool
success campaign-history-job_v002 create_cluster_and_add_emr_steps 2021-04-03T05:00:00+00:00 EmrCreateJobFlowOperator 2021-04-03T06:11:50.292392+00:00 2021-04-03T06:11:52.068086+00:00 0:00:01.775694 13028 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 2 default 2021-04-03T06:11:48.021018+00:00 2 default_pool
success booking-processing-job_v002 create_emr_steps 2021-04-03T05:00:00+00:00 PythonOperator 2021-04-03T06:11:34.538825+00:00 2021-04-03T06:11:37.502865+00:00 0:00:02.964040 13027 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-04-03T06:11:32.004708+00:00 2 default_pool
success campaign-history-job_v002 create_emr_steps 2021-04-03T05:00:00+00:00 PythonOperator 2021-04-03T06:11:30.477935+00:00 2021-04-03T06:11:33.507884+00:00 0:00:03.029949 13026 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-04-03T06:11:28.070479+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_booking-processing-job_v002 2021-04-03T05:00:00+00:00 TriggerDagRunOperator 2021-04-03T06:11:10.461315+00:00 2021-04-03T06:11:11.039822+00:00 0:00:00.578507 13025 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-03T06:11:07.996097+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_campaign-history-job_v002 2021-04-03T05:00:00+00:00 TriggerDagRunOperator 2021-04-03T06:11:10.401863+00:00 2021-04-03T06:11:10.953020+00:00 0:00:00.551157 13024 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-03T06:11:07.996057+00:00 2 default_pool
success vc-asset-import_v002 check_cluster_status 2021-04-03T05:05:00+00:00 EmrJobFlowSensor 2021-04-03T06:05:55.767466+00:00 2021-04-03T06:14:58.263489+00:00 0:09:02.496023 13023 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-03T06:05:53.534264+00:00 2 default_pool
success vc-asset-import_v002 create_cluster_and_add_emr_steps 2021-04-03T05:05:00+00:00 EmrCreateJobFlowOperator 2021-04-03T06:05:33.697078+00:00 2021-04-03T06:05:35.482099+00:00 0:00:01.785021 13022 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 2 default 2021-04-03T06:05:31.515999+00:00 2 default_pool
success vc-asset-import_v002 create_emr_steps 2021-04-03T05:05:00+00:00 PythonOperator 2021-04-03T06:05:09.904069+00:00 2021-04-03T06:05:12.575547+00:00 0:00:02.671478 13021 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-04-03T06:05:07.557803+00:00 2 default_pool
success campaign-flow-job_v002 check_cluster_status 2021-04-03T05:00:00+00:00 EmrJobFlowSensor 2021-04-03T06:00:57.337755+00:00 2021-04-03T06:11:00.051453+00:00 0:10:02.713698 13020 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-04-03T06:00:55.060908+00:00 2 default_pool
success campaign-flow-job_v002 create_cluster_and_add_emr_steps 2021-04-03T05:00:00+00:00 EmrCreateJobFlowOperator 2021-04-03T06:00:37.334256+00:00 2021-04-03T06:00:39.132760+00:00 0:00:01.798504 13019 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 4 default 2021-04-03T06:00:35.044927+00:00 2 default_pool
success campaign-flow-job_v002 create_emr_steps 2021-04-03T05:00:00+00:00 PythonOperator 2021-04-03T06:00:15.678347+00:00 2021-04-03T06:00:18.404053+00:00 0:00:02.725706 13018 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 5 default 2021-04-03T06:00:13.155761+00:00 2 default_pool
success campaign-history-job_v002 check_cluster_status 2021-04-03T04:00:00+00:00 EmrJobFlowSensor 2021-04-03T05:10:08.850242+00:00 2021-04-03T05:19:11.551748+00:00 0:09:02.701506 13016 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-03T05:10:06.355467+00:00 2 default_pool
success booking-processing-job_v002 check_cluster_status 2021-04-03T04:00:00+00:00 EmrJobFlowSensor 2021-04-03T05:10:06.852820+00:00 2021-04-03T05:20:09.798340+00:00 0:10:02.945520 13015 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-03T05:10:04.346521+00:00 2 default_pool
success booking-processing-job_v002 create_cluster_and_add_emr_steps 2021-04-03T04:00:00+00:00 EmrCreateJobFlowOperator 2021-04-03T05:09:46.630107+00:00 2021-04-03T05:09:48.461028+00:00 0:00:01.830921 13014 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 2 default 2021-04-03T05:09:44.258615+00:00 2 default_pool
success campaign-history-job_v002 create_cluster_and_add_emr_steps 2021-04-03T04:00:00+00:00 EmrCreateJobFlowOperator 2021-04-03T05:09:46.515288+00:00 2021-04-03T05:09:48.220357+00:00 0:00:01.705069 13013 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 2 default 2021-04-03T05:09:44.258584+00:00 2 default_pool
success campaign-history-job_v002 create_emr_steps 2021-04-03T04:00:00+00:00 PythonOperator 2021-04-03T05:09:27.075088+00:00 2021-04-03T05:09:29.789598+00:00 0:00:02.714510 13012 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-04-03T05:09:24.238111+00:00 2 default_pool
success booking-processing-job_v002 create_emr_steps 2021-04-03T04:00:00+00:00 PythonOperator 2021-04-03T05:09:24.848226+00:00 2021-04-03T05:09:28.211853+00:00 0:00:03.363627 13011 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-04-03T05:09:22.242202+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_booking-processing-job_v002 2021-04-03T04:00:00+00:00 TriggerDagRunOperator 2021-04-03T05:09:10.853132+00:00 2021-04-03T05:09:11.365364+00:00 0:00:00.512232 13010 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-03T05:09:08.256520+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_campaign-history-job_v002 2021-04-03T04:00:00+00:00 TriggerDagRunOperator 2021-04-03T05:09:10.591837+00:00 2021-04-03T05:09:10.998800+00:00 0:00:00.406963 13009 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-03T05:09:08.256488+00:00 2 default_pool
success vc-asset-import_v002 check_cluster_status 2021-04-03T04:05:00+00:00 EmrJobFlowSensor 2021-04-03T05:05:54.195843+00:00 2021-04-03T05:13:56.784631+00:00 0:08:02.588788 13008 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-03T05:05:51.704987+00:00 2 default_pool
success vc-asset-import_v002 create_cluster_and_add_emr_steps 2021-04-03T04:05:00+00:00 EmrCreateJobFlowOperator 2021-04-03T05:05:31.845624+00:00 2021-04-03T05:05:33.493087+00:00 0:00:01.647463 13007 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 2 default 2021-04-03T05:05:29.681395+00:00 2 default_pool
success vc-asset-import_v002 create_emr_steps 2021-04-03T04:05:00+00:00 PythonOperator 2021-04-03T05:05:09.887030+00:00 2021-04-03T05:05:12.610195+00:00 0:00:02.723165 13006 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-04-03T05:05:07.643745+00:00 2 default_pool
success campaign-flow-job_v002 check_cluster_status 2021-04-03T04:00:00+00:00 EmrJobFlowSensor 2021-04-03T05:01:01.325284+00:00 2021-04-03T05:09:04.084811+00:00 0:08:02.759527 13005 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-04-03T05:00:59.092593+00:00 2 default_pool
success campaign-flow-job_v002 create_cluster_and_add_emr_steps 2021-04-03T04:00:00+00:00 EmrCreateJobFlowOperator 2021-04-03T05:00:39.201011+00:00 2021-04-03T05:00:40.963196+00:00 0:00:01.762185 13004 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 4 default 2021-04-03T05:00:37.015122+00:00 2 default_pool
success campaign-flow-job_v002 create_emr_steps 2021-04-03T04:00:00+00:00 PythonOperator 2021-04-03T05:00:19.553062+00:00 2021-04-03T05:00:22.395218+00:00 0:00:02.842156 13003 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 5 default 2021-04-03T05:00:16.996996+00:00 2 default_pool
success booking-processing-job_v002 check_cluster_status 2021-04-03T03:00:00+00:00 EmrJobFlowSensor 2021-04-03T04:12:29.112709+00:00 2021-04-03T04:22:31.920811+00:00 0:10:02.808102 13001 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-03T04:12:26.856155+00:00 2 default_pool
success campaign-history-job_v002 check_cluster_status 2021-04-03T03:00:00+00:00 EmrJobFlowSensor 2021-04-03T04:12:25.258575+00:00 2021-04-03T04:22:28.120101+00:00 0:10:02.861526 13000 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-03T04:12:22.852807+00:00 2 default_pool
success booking-processing-job_v002 create_cluster_and_add_emr_steps 2021-04-03T03:00:00+00:00 EmrCreateJobFlowOperator 2021-04-03T04:12:07.008443+00:00 2021-04-03T04:12:08.842754+00:00 0:00:01.834311 12999 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 2 default 2021-04-03T04:12:04.757381+00:00 2 default_pool
success campaign-history-job_v002 create_cluster_and_add_emr_steps 2021-04-03T03:00:00+00:00 EmrCreateJobFlowOperator 2021-04-03T04:12:03.076847+00:00 2021-04-03T04:12:04.815479+00:00 0:00:01.738632 12998 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 2 default 2021-04-03T04:12:00.756241+00:00 2 default_pool
success booking-processing-job_v002 create_emr_steps 2021-04-03T03:00:00+00:00 PythonOperator 2021-04-03T04:11:47.012017+00:00 2021-04-03T04:11:49.932972+00:00 0:00:02.920955 12997 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-04-03T04:11:44.744052+00:00 2 default_pool
success campaign-history-job_v002 create_emr_steps 2021-04-03T03:00:00+00:00 PythonOperator 2021-04-03T04:11:41.092889+00:00 2021-04-03T04:11:43.939350+00:00 0:00:02.846461 12996 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-04-03T04:11:38.722980+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_campaign-history-job_v002 2021-04-03T03:00:00+00:00 TriggerDagRunOperator 2021-04-03T04:11:21.258220+00:00 2021-04-03T04:11:21.810953+00:00 0:00:00.552733 12995 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-03T04:11:18.754095+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_booking-processing-job_v002 2021-04-03T03:00:00+00:00 TriggerDagRunOperator 2021-04-03T04:11:21.215493+00:00 2021-04-03T04:11:21.648865+00:00 0:00:00.433372 12994 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-03T04:11:18.754143+00:00 2 default_pool
success vc-asset-import_v002 check_cluster_status 2021-04-03T03:05:00+00:00 EmrJobFlowSensor 2021-04-03T04:05:50.348373+00:00 2021-04-03T04:14:53.005461+00:00 0:09:02.657088 12993 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-03T04:05:48.152674+00:00 2 default_pool
success vc-asset-import_v002 create_cluster_and_add_emr_steps 2021-04-03T03:05:00+00:00 EmrCreateJobFlowOperator 2021-04-03T04:05:28.389750+00:00 2021-04-03T04:05:30.123449+00:00 0:00:01.733699 12992 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 2 default 2021-04-03T04:05:26.163040+00:00 2 default_pool
success vc-asset-import_v002 create_emr_steps 2021-04-03T03:05:00+00:00 PythonOperator 2021-04-03T04:05:08.463353+00:00 2021-04-03T04:05:11.364263+00:00 0:00:02.900910 12991 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-04-03T04:05:06.048827+00:00 2 default_pool
success campaign-flow-job_v002 check_cluster_status 2021-04-03T03:00:00+00:00 EmrJobFlowSensor 2021-04-03T04:00:57.818546+00:00 2021-04-03T04:11:00.619075+00:00 0:10:02.800529 12990 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-04-03T04:00:55.533433+00:00 2 default_pool
success campaign-flow-job_v002 create_cluster_and_add_emr_steps 2021-04-03T03:00:00+00:00 EmrCreateJobFlowOperator 2021-04-03T04:00:33.890061+00:00 2021-04-03T04:00:35.684434+00:00 0:00:01.794373 12989 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 4 default 2021-04-03T04:00:31.535223+00:00 2 default_pool
success campaign-flow-job_v002 create_emr_steps 2021-04-03T03:00:00+00:00 PythonOperator 2021-04-03T04:00:09.779988+00:00 2021-04-03T04:00:12.515866+00:00 0:00:02.735878 12988 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 5 default 2021-04-03T04:00:07.496188+00:00 2 default_pool
success campaign-history-job_v002 check_cluster_status 2021-04-03T02:00:00+00:00 EmrJobFlowSensor 2021-04-03T03:11:12.435062+00:00 2021-04-03T03:20:15.177045+00:00 0:09:02.741983 12986 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-03T03:11:09.965433+00:00 2 default_pool
success booking-processing-job_v002 check_cluster_status 2021-04-03T02:00:00+00:00 EmrJobFlowSensor 2021-04-03T03:11:08.327313+00:00 2021-04-03T03:20:11.107242+00:00 0:09:02.779929 12985 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-03T03:11:05.958692+00:00 2 default_pool
success campaign-history-job_v002 create_cluster_and_add_emr_steps 2021-04-03T02:00:00+00:00 EmrCreateJobFlowOperator 2021-04-03T03:10:50.365279+00:00 2021-04-03T03:10:52.194806+00:00 0:00:01.829527 12984 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 2 default 2021-04-03T03:10:47.943517+00:00 2 default_pool
success booking-processing-job_v002 create_cluster_and_add_emr_steps 2021-04-03T02:00:00+00:00 EmrCreateJobFlowOperator 2021-04-03T03:10:46.295644+00:00 2021-04-03T03:10:47.987385+00:00 0:00:01.691741 12983 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 2 default 2021-04-03T03:10:43.959164+00:00 2 default_pool
success campaign-history-job_v002 create_emr_steps 2021-04-03T02:00:00+00:00 PythonOperator 2021-04-03T03:10:30.538309+00:00 2021-04-03T03:10:33.388093+00:00 0:00:02.849784 12982 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-04-03T03:10:27.878684+00:00 2 default_pool
success booking-processing-job_v002 create_emr_steps 2021-04-03T02:00:00+00:00 PythonOperator 2021-04-03T03:10:26.433862+00:00 2021-04-03T03:10:29.865342+00:00 0:00:03.431480 12981 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-04-03T03:10:23.839256+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_campaign-history-job_v002 2021-04-03T02:00:00+00:00 TriggerDagRunOperator 2021-04-03T03:10:14.336439+00:00 2021-04-03T03:10:14.748456+00:00 0:00:00.412017 12980 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-03T03:10:11.827147+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_booking-processing-job_v002 2021-04-03T02:00:00+00:00 TriggerDagRunOperator 2021-04-03T03:10:14.355502+00:00 2021-04-03T03:10:14.904565+00:00 0:00:00.549063 12979 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-03T03:10:11.827181+00:00 2 default_pool
success vc-asset-import_v002 check_cluster_status 2021-04-03T02:05:00+00:00 EmrJobFlowSensor 2021-04-03T03:06:07.646362+00:00 2021-04-03T03:15:10.262815+00:00 0:09:02.616453 12978 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-03T03:06:05.531178+00:00 2 default_pool
success vc-asset-import_v002 create_cluster_and_add_emr_steps 2021-04-03T02:05:00+00:00 EmrCreateJobFlowOperator 2021-04-03T03:05:45.894483+00:00 2021-04-03T03:05:47.629805+00:00 0:00:01.735322 12977 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 2 default 2021-04-03T03:05:43.512237+00:00 2 default_pool
success vc-asset-import_v002 create_emr_steps 2021-04-03T02:05:00+00:00 PythonOperator 2021-04-03T03:05:23.800893+00:00 2021-04-03T03:05:26.647536+00:00 0:00:02.846643 12976 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-04-03T03:05:21.548524+00:00 2 default_pool
success campaign-flow-job_v002 check_cluster_status 2021-04-03T02:00:00+00:00 EmrJobFlowSensor 2021-04-03T03:00:57.206068+00:00 2021-04-03T03:09:59.924775+00:00 0:09:02.718707 12975 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-04-03T03:00:54.940877+00:00 2 default_pool
success campaign-flow-job_v002 create_cluster_and_add_emr_steps 2021-04-03T02:00:00+00:00 EmrCreateJobFlowOperator 2021-04-03T03:00:35.382806+00:00 2021-04-03T03:00:37.203333+00:00 0:00:01.820527 12974 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 4 default 2021-04-03T03:00:32.843832+00:00 2 default_pool
success campaign-flow-job_v002 create_emr_steps 2021-04-03T02:00:00+00:00 PythonOperator 2021-04-03T03:00:12.983727+00:00 2021-04-03T03:00:15.707589+00:00 0:00:02.723862 12973 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 5 default 2021-04-03T03:00:10.717276+00:00 2 default_pool
success campaign-history-job_v002 check_cluster_status 2021-04-03T01:00:00+00:00 EmrJobFlowSensor 2021-04-03T02:10:31.915235+00:00 2021-04-03T02:18:34.408618+00:00 0:08:02.493383 12971 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-03T02:10:29.121777+00:00 2 default_pool
success booking-processing-job_v002 check_cluster_status 2021-04-03T01:00:00+00:00 EmrJobFlowSensor 2021-04-03T02:10:29.545757+00:00 2021-04-03T02:20:32.657451+00:00 0:10:03.111694 12970 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-03T02:10:27.150426+00:00 2 default_pool
success campaign-history-job_v002 create_cluster_and_add_emr_steps 2021-04-03T01:00:00+00:00 EmrCreateJobFlowOperator 2021-04-03T02:10:09.563935+00:00 2021-04-03T02:10:11.367204+00:00 0:00:01.803269 12969 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 2 default 2021-04-03T02:10:07.066935+00:00 2 default_pool
success booking-processing-job_v002 create_cluster_and_add_emr_steps 2021-04-03T01:00:00+00:00 EmrCreateJobFlowOperator 2021-04-03T02:10:09.353892+00:00 2021-04-03T02:10:11.122362+00:00 0:00:01.768470 12968 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 2 default 2021-04-03T02:10:07.066988+00:00 2 default_pool
success campaign-history-job_v002 create_emr_steps 2021-04-03T01:00:00+00:00 PythonOperator 2021-04-03T02:09:43.236810+00:00 2021-04-03T02:09:45.968220+00:00 0:00:02.731410 12967 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-04-03T02:09:41.016062+00:00 2 default_pool
success booking-processing-job_v002 create_emr_steps 2021-04-03T01:00:00+00:00 PythonOperator 2021-04-03T02:09:41.517840+00:00 2021-04-03T02:09:44.552665+00:00 0:00:03.034825 12966 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-04-03T02:09:39.013822+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_booking-processing-job_v002 2021-04-03T01:00:00+00:00 TriggerDagRunOperator 2021-04-03T02:09:29.639441+00:00 2021-04-03T02:09:30.164098+00:00 0:00:00.524657 12965 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-03T02:09:27.006306+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_campaign-history-job_v002 2021-04-03T01:00:00+00:00 TriggerDagRunOperator 2021-04-03T02:09:29.407585+00:00 2021-04-03T02:09:29.871259+00:00 0:00:00.463674 12964 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-03T02:09:27.006276+00:00 2 default_pool
success vc-asset-import_v002 check_cluster_status 2021-04-03T01:05:00+00:00 EmrJobFlowSensor 2021-04-03T02:06:50.969133+00:00 2021-04-03T02:14:53.429351+00:00 0:08:02.460218 12963 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-03T02:06:48.822937+00:00 2 default_pool
success vc-asset-import_v002 create_cluster_and_add_emr_steps 2021-04-03T01:05:00+00:00 EmrCreateJobFlowOperator 2021-04-03T02:05:34.994045+00:00 2021-04-03T02:05:36.761064+00:00 0:00:01.767019 12962 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 2 default 2021-04-03T02:05:32.718738+00:00 2 default_pool
success vc-asset-import_v002 create_emr_steps 2021-04-03T01:05:00+00:00 PythonOperator 2021-04-03T02:05:12.873435+00:00 2021-04-03T02:05:15.551494+00:00 0:00:02.678059 12961 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-04-03T02:05:10.702027+00:00 2 default_pool
success campaign-flow-job_v002 check_cluster_status 2021-04-03T01:00:00+00:00 EmrJobFlowSensor 2021-04-03T02:01:12.592586+00:00 2021-04-03T02:09:15.198978+00:00 0:08:02.606392 12960 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-04-03T02:01:10.287195+00:00 2 default_pool
success campaign-flow-job_v002 create_cluster_and_add_emr_steps 2021-04-03T01:00:00+00:00 EmrCreateJobFlowOperator 2021-04-03T02:00:44.430249+00:00 2021-04-03T02:00:46.180949+00:00 0:00:01.750700 12959 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 4 default 2021-04-03T02:00:42.222580+00:00 2 default_pool
success campaign-flow-job_v002 create_emr_steps 2021-04-03T01:00:00+00:00 PythonOperator 2021-04-03T02:00:24.814119+00:00 2021-04-03T02:00:27.520809+00:00 0:00:02.706690 12958 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 5 default 2021-04-03T02:00:22.244771+00:00 2 default_pool
success campaign-history-job_v002 check_cluster_status 2021-04-03T00:00:00+00:00 EmrJobFlowSensor 2021-04-03T01:11:35.615045+00:00 2021-04-03T01:19:38.147459+00:00 0:08:02.532414 12956 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-03T01:11:33.251162+00:00 2 default_pool
success booking-processing-job_v002 check_cluster_status 2021-04-03T00:00:00+00:00 EmrJobFlowSensor 2021-04-03T01:11:17.517151+00:00 2021-04-03T01:21:20.272616+00:00 0:10:02.755465 12955 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-03T01:11:15.204893+00:00 2 default_pool
success campaign-history-job_v002 create_cluster_and_add_emr_steps 2021-04-03T00:00:00+00:00 EmrCreateJobFlowOperator 2021-04-03T01:11:13.751307+00:00 2021-04-03T01:11:15.555000+00:00 0:00:01.803693 12954 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 2 default 2021-04-03T01:11:11.263813+00:00 2 default_pool
success booking-processing-job_v002 create_cluster_and_add_emr_steps 2021-04-03T00:00:00+00:00 EmrCreateJobFlowOperator 2021-04-03T01:10:55.397593+00:00 2021-04-03T01:10:57.287939+00:00 0:00:01.890346 12953 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 2 default 2021-04-03T01:10:53.129483+00:00 2 default_pool
success campaign-history-job_v002 create_emr_steps 2021-04-03T00:00:00+00:00 PythonOperator 2021-04-03T01:10:51.299607+00:00 2021-04-03T01:10:54.057926+00:00 0:00:02.758319 12952 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-04-03T01:10:49.123953+00:00 2 default_pool
success booking-processing-job_v002 create_emr_steps 2021-04-03T00:00:00+00:00 PythonOperator 2021-04-03T01:10:35.437211+00:00 2021-04-03T01:10:38.443105+00:00 0:00:03.005894 12951 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-04-03T01:10:33.114587+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_booking-processing-job_v002 2021-04-03T00:00:00+00:00 TriggerDagRunOperator 2021-04-03T01:10:27.441658+00:00 2021-04-03T01:10:28.125551+00:00 0:00:00.683893 12950 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-03T01:10:25.107104+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_campaign-history-job_v002 2021-04-03T00:00:00+00:00 TriggerDagRunOperator 2021-04-03T01:10:27.450930+00:00 2021-04-03T01:10:28.000622+00:00 0:00:00.549692 12949 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-03T01:10:25.107069+00:00 2 default_pool
success vc-asset-import_v002 check_cluster_status 2021-04-03T00:05:00+00:00 EmrJobFlowSensor 2021-04-03T01:05:46.956592+00:00 2021-04-03T01:14:49.446135+00:00 0:09:02.489543 12948 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-03T01:05:44.718878+00:00 2 default_pool
success vc-asset-import_v002 create_cluster_and_add_emr_steps 2021-04-03T00:05:00+00:00 EmrCreateJobFlowOperator 2021-04-03T01:05:27.003217+00:00 2021-04-03T01:05:28.728851+00:00 0:00:01.725634 12947 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 2 default 2021-04-03T01:05:24.706123+00:00 2 default_pool
success vc-asset-import_v002 create_emr_steps 2021-04-03T00:05:00+00:00 PythonOperator 2021-04-03T01:05:05.076200+00:00 2021-04-03T01:05:07.761694+00:00 0:00:02.685494 12946 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-04-03T01:05:02.786795+00:00 2 default_pool
success campaign-flow-job_v002 check_cluster_status 2021-04-03T00:00:00+00:00 EmrJobFlowSensor 2021-04-03T01:01:14.736846+00:00 2021-04-03T01:10:17.574999+00:00 0:09:02.838153 12945 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-04-03T01:01:12.425874+00:00 2 default_pool
success campaign-flow-job_v002 create_cluster_and_add_emr_steps 2021-04-03T00:00:00+00:00 EmrCreateJobFlowOperator 2021-04-03T01:00:46.664507+00:00 2021-04-03T01:00:48.472139+00:00 0:00:01.807632 12944 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 4 default 2021-04-03T01:00:44.398816+00:00 2 default_pool
success campaign-flow-job_v002 create_emr_steps 2021-04-03T00:00:00+00:00 PythonOperator 2021-04-03T01:00:22.688779+00:00 2021-04-03T01:00:25.482156+00:00 0:00:02.793377 12943 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 5 default 2021-04-03T01:00:20.363246+00:00 2 default_pool
success booking-processing-job_v002 check_cluster_status 2021-04-02T23:00:00+00:00 EmrJobFlowSensor 2021-04-03T00:12:20.510069+00:00 2021-04-03T00:22:23.328259+00:00 0:10:02.818190 12941 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-03T00:12:18.226195+00:00 2 default_pool