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 check_cluster_status 2021-04-03T10:00:00+00:00 EmrJobFlowSensor 2021-04-03T11:01:05.031970+00:00 2021-04-03T11:11:07.833000+00:00 0:10:02.801030 13095 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-04-03T11:01:02.814752+00:00 2 default_pool
success campaign-flow-job_v002 create_cluster_and_add_emr_steps 2021-04-03T10:00:00+00:00 EmrCreateJobFlowOperator 2021-04-03T11:00:43.101160+00:00 2021-04-03T11:00:44.766341+00:00 0:00:01.665181 13094 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 4 default 2021-04-03T11:00:40.795181+00:00 2 default_pool
success campaign-flow-job_v002 create_emr_steps 2021-04-03T10:00:00+00:00 PythonOperator 2021-04-03T11:00:21.629893+00:00 2021-04-03T11:00:24.555713+00:00 0:00:02.925820 13093 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 5 default 2021-04-03T11:00:18.772559+00:00 2 default_pool
success booking-processing-job_v002 check_cluster_status 2021-04-03T09:00:00+00:00 EmrJobFlowSensor 2021-04-03T10:10:26.592192+00:00 2021-04-03T10:20:29.364078+00:00 0:10:02.771886 13091 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-03T10:10:24.178286+00:00 2 default_pool
success campaign-history-job_v002 check_cluster_status 2021-04-03T09:00:00+00:00 EmrJobFlowSensor 2021-04-03T10:10:06.574653+00:00 2021-04-03T10:19:09.459985+00:00 0:09:02.885332 13090 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-03T10:10:04.098016+00:00 2 default_pool
success booking-processing-job_v002 create_cluster_and_add_emr_steps 2021-04-03T09:00:00+00:00 EmrCreateJobFlowOperator 2021-04-03T10:10:06.380536+00:00 2021-04-03T10:10:08.153962+00:00 0:00:01.773426 13089 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 2 default 2021-04-03T10:10:04.098055+00:00 2 default_pool
success campaign-history-job_v002 create_cluster_and_add_emr_steps 2021-04-03T09:00:00+00:00 EmrCreateJobFlowOperator 2021-04-03T10:09:46.372234+00:00 2021-04-03T10:09:48.206154+00:00 0:00:01.833920 13088 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 2 default 2021-04-03T10:09:44.074850+00:00 2 default_pool
success booking-processing-job_v002 create_emr_steps 2021-04-03T09:00:00+00:00 PythonOperator 2021-04-03T10:09:44.207212+00:00 2021-04-03T10:09:47.104345+00:00 0:00:02.897133 13087 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-04-03T10:09:42.071807+00:00 2 default_pool
success campaign-history-job_v002 create_emr_steps 2021-04-03T09:00:00+00:00 PythonOperator 2021-04-03T10:09:24.326195+00:00 2021-04-03T10:09:27.141904+00:00 0:00:02.815709 13086 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-04-03T10:09:22.053943+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_campaign-history-job_v002 2021-04-03T09:00:00+00:00 TriggerDagRunOperator 2021-04-03T10:09:18.662292+00:00 2021-04-03T10:09:19.335310+00:00 0:00:00.673018 13085 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-03T10:09:16.048637+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_booking-processing-job_v002 2021-04-03T09:00:00+00:00 TriggerDagRunOperator 2021-04-03T10:09:18.296803+00:00 2021-04-03T10:09:18.729698+00:00 0:00:00.432895 13084 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-03T10:09:16.048674+00:00 2 default_pool
success vc-asset-import_v002 check_cluster_status 2021-04-03T09:05:00+00:00 EmrJobFlowSensor 2021-04-03T10:05:58.230137+00:00 2021-04-03T10:15:00.958390+00:00 0:09:02.728253 13083 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-03T10:05:55.812243+00:00 2 default_pool
success vc-asset-import_v002 create_cluster_and_add_emr_steps 2021-04-03T09:05:00+00:00 EmrCreateJobFlowOperator 2021-04-03T10:05:35.961427+00:00 2021-04-03T10:05:37.593070+00:00 0:00:01.631643 13082 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 2 default 2021-04-03T10:05:33.787686+00:00 2 default_pool
success vc-asset-import_v002 create_emr_steps 2021-04-03T09:05:00+00:00 PythonOperator 2021-04-03T10:05:09.906704+00:00 2021-04-03T10:05:12.593463+00:00 0:00:02.686759 13081 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-04-03T10:05:07.749429+00:00 2 default_pool
success campaign-flow-job_v002 check_cluster_status 2021-04-03T09:00:00+00:00 EmrJobFlowSensor 2021-04-03T10:01:05.714149+00:00 2021-04-03T10:09:08.387605+00:00 0:08:02.673456 13080 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-04-03T10:01:03.342512+00:00 2 default_pool
success campaign-flow-job_v002 create_cluster_and_add_emr_steps 2021-04-03T09:00:00+00:00 EmrCreateJobFlowOperator 2021-04-03T10:00:45.543173+00:00 2021-04-03T10:00:47.271738+00:00 0:00:01.728565 13079 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 4 default 2021-04-03T10:00:43.251617+00:00 2 default_pool
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