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-03T09:00:00+00:00 PythonOperator 2021-04-03T10:00:23.807227+00:00 2021-04-03T10:00:26.594550+00:00 0:00:02.787323 13078 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 5 default 2021-04-03T10:00:21.234836+00:00 2 default_pool
success booking-processing-job_v002 check_cluster_status 2021-04-03T08:00:00+00:00 EmrJobFlowSensor 2021-04-03T09:10:36.744110+00:00 2021-04-03T09:20:39.543416+00:00 0:10:02.799306 13076 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-03T09:10:34.390029+00:00 2 default_pool
success campaign-history-job_v002 check_cluster_status 2021-04-03T08:00:00+00:00 EmrJobFlowSensor 2021-04-03T09:10:28.696070+00:00 2021-04-03T09:19:31.316589+00:00 0:09:02.620519 13075 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-03T09:10:26.388886+00:00 2 default_pool
success booking-processing-job_v002 create_cluster_and_add_emr_steps 2021-04-03T08:00:00+00:00 EmrCreateJobFlowOperator 2021-04-03T09:10:14.759877+00:00 2021-04-03T09:10:16.499323+00:00 0:00:01.739446 13074 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 2 default 2021-04-03T09:10:12.364210+00:00 2 default_pool
success campaign-history-job_v002 create_cluster_and_add_emr_steps 2021-04-03T08:00:00+00:00 EmrCreateJobFlowOperator 2021-04-03T09:10:08.698668+00:00 2021-04-03T09:10:10.500471+00:00 0:00:01.801803 13073 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 2 default 2021-04-03T09:10:06.354530+00:00 2 default_pool
success booking-processing-job_v002 create_emr_steps 2021-04-03T08:00:00+00:00 PythonOperator 2021-04-03T09:09:52.801829+00:00 2021-04-03T09:09:55.754671+00:00 0:00:02.952842 13072 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-04-03T09:09:50.303596+00:00 2 default_pool
success campaign-history-job_v002 create_emr_steps 2021-04-03T08:00:00+00:00 PythonOperator 2021-04-03T09:09:46.612474+00:00 2021-04-03T09:09:49.330609+00:00 0:00:02.718135 13071 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-04-03T09:09:44.305458+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_booking-processing-job_v002 2021-04-03T08:00:00+00:00 TriggerDagRunOperator 2021-04-03T09:09:28.942804+00:00 2021-04-03T09:09:29.503759+00:00 0:00:00.560955 13070 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-03T09:09:26.285917+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_campaign-history-job_v002 2021-04-03T08:00:00+00:00 TriggerDagRunOperator 2021-04-03T09:09:28.752335+00:00 2021-04-03T09:09:29.150075+00:00 0:00:00.397740 13069 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-03T09:09:26.285866+00:00 2 default_pool
success vc-asset-import_v002 check_cluster_status 2021-04-03T08:05:00+00:00 EmrJobFlowSensor 2021-04-03T09:05:52.100793+00:00 2021-04-03T09:13:54.522646+00:00 0:08:02.421853 13068 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-03T09:05:49.926371+00:00 2 default_pool
success vc-asset-import_v002 create_cluster_and_add_emr_steps 2021-04-03T08:05:00+00:00 EmrCreateJobFlowOperator 2021-04-03T09:05:32.284567+00:00 2021-04-03T09:05:33.985268+00:00 0:00:01.700701 13067 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 2 default 2021-04-03T09:05:29.911245+00:00 2 default_pool
success vc-asset-import_v002 create_emr_steps 2021-04-03T08:05:00+00:00 PythonOperator 2021-04-03T09:05:10.201830+00:00 2021-04-03T09:05:13.002983+00:00 0:00:02.801153 13066 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-04-03T09:05:07.895101+00:00 2 default_pool
success campaign-flow-job_v002 check_cluster_status 2021-04-03T08:00:00+00:00 EmrJobFlowSensor 2021-04-03T09:01:05.789275+00:00 2021-04-03T09:09:08.422139+00:00 0:08:02.632864 13065 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-04-03T09:01:03.444342+00:00 2 default_pool
success campaign-flow-job_v002 create_cluster_and_add_emr_steps 2021-04-03T08:00:00+00:00 EmrCreateJobFlowOperator 2021-04-03T09:00:43.589904+00:00 2021-04-03T09:00:45.352163+00:00 0:00:01.762259 13064 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 4 default 2021-04-03T09:00:41.245367+00:00 2 default_pool
success campaign-flow-job_v002 create_emr_steps 2021-04-03T08:00:00+00:00 PythonOperator 2021-04-03T09:00:23.640196+00:00 2021-04-03T09:00:26.510034+00:00 0:00:02.869838 13063 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 5 default 2021-04-03T09:00:21.186755+00:00 2 default_pool
success booking-processing-job_v002 check_cluster_status 2021-04-03T07:00:00+00:00 EmrJobFlowSensor 2021-04-03T08:12:06.131240+00:00 2021-04-03T08:23:09.100738+00:00 0:11:02.969498 13061 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-03T08:12:03.889362+00:00 2 default_pool
success campaign-history-job_v002 check_cluster_status 2021-04-03T07:00:00+00:00 EmrJobFlowSensor 2021-04-03T08:11:56.395278+00:00 2021-04-03T08:21:59.208143+00:00 0:10:02.812865 13060 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-03T08:11:53.875106+00:00 2 default_pool
success booking-processing-job_v002 create_cluster_and_add_emr_steps 2021-04-03T07:00:00+00:00 EmrCreateJobFlowOperator 2021-04-03T08:11:44.123436+00:00 2021-04-03T08:11:45.792481+00:00 0:00:01.669045 13059 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 2 default 2021-04-03T08:11:41.845781+00:00 2 default_pool
success campaign-history-job_v002 create_cluster_and_add_emr_steps 2021-04-03T07:00:00+00:00 EmrCreateJobFlowOperator 2021-04-03T08:11:36.309799+00:00 2021-04-03T08:11:38.163613+00:00 0:00:01.853814 13058 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 2 default 2021-04-03T08:11:33.840220+00:00 2 default_pool
success booking-processing-job_v002 create_emr_steps 2021-04-03T07:00:00+00:00 PythonOperator 2021-04-03T08:11:22.009438+00:00 2021-04-03T08:11:25.072578+00:00 0:00:03.063140 13057 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-04-03T08:11:19.824928+00:00 2 default_pool
success campaign-history-job_v002 create_emr_steps 2021-04-03T07:00:00+00:00 PythonOperator 2021-04-03T08:11:12.539849+00:00 2021-04-03T08:11:15.288630+00:00 0:00:02.748781 13056 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-04-03T08:11:09.944773+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_booking-processing-job_v002 2021-04-03T07:00:00+00:00 TriggerDagRunOperator 2021-04-03T08:11:00.313349+00:00 2021-04-03T08:11:00.874915+00:00 0:00:00.561566 13055 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-03T08:10:57.879188+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_campaign-history-job_v002 2021-04-03T07:00:00+00:00 TriggerDagRunOperator 2021-04-03T08:11:00.294180+00:00 2021-04-03T08:11:00.762353+00:00 0:00:00.468173 13054 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-03T08:10:57.879152+00:00 2 default_pool
success vc-asset-import_v002 check_cluster_status 2021-04-03T07:05:00+00:00 EmrJobFlowSensor 2021-04-03T08:06:07.447690+00:00 2021-04-03T08:15:10.077660+00:00 0:09:02.629970 13053 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-03T08:06:05.277587+00:00 2 default_pool
success vc-asset-import_v002 create_cluster_and_add_emr_steps 2021-04-03T07:05:00+00:00 EmrCreateJobFlowOperator 2021-04-03T08:05:45.617374+00:00 2021-04-03T08:05:47.327472+00:00 0:00:01.710098 13052 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 2 default 2021-04-03T08:05:43.257379+00:00 2 default_pool
success vc-asset-import_v002 create_emr_steps 2021-04-03T07:05:00+00:00 PythonOperator 2021-04-03T08:05:25.727453+00:00 2021-04-03T08:05:28.543096+00:00 0:00:02.815643 13051 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-04-03T08:05:23.245489+00:00 2 default_pool
success campaign-flow-job_v002 check_cluster_status 2021-04-03T07:00:00+00:00 EmrJobFlowSensor 2021-04-03T08:00:52.890634+00:00 2021-04-03T08:10:55.691278+00:00 0:10:02.800644 13050 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-04-03T08:00:50.689622+00:00 2 default_pool
success campaign-flow-job_v002 create_cluster_and_add_emr_steps 2021-04-03T07:00:00+00:00 EmrCreateJobFlowOperator 2021-04-03T08:00:32.927547+00:00 2021-04-03T08:00:34.776432+00:00 0:00:01.848885 13049 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 4 default 2021-04-03T08:00:30.658984+00:00 2 default_pool
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