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 trigger_dagrun_campaign-history-job_v002 2021-05-14T03:00:00+00:00 TriggerDagRunOperator 2021-05-14T04:10:27.263073+00:00 2021-05-14T04:10:27.659180+00:00 0:00:00.396107 27872 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-05-14T04:10:24.843699+00:00 2 default_pool
success vc-asset-import_v002 check_cluster_status 2021-05-14T03:05:00+00:00 EmrJobFlowSensor 2021-05-14T04:06:58.436127+00:00 2021-05-14T04:16:01.091301+00:00 0:09:02.655174 27871 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-05-14T04:06:56.163500+00:00 2 default_pool
success vc-asset-import_v002 create_cluster_and_add_emr_steps 2021-05-14T03:05:00+00:00 EmrCreateJobFlowOperator 2021-05-14T04:06:36.150586+00:00 2021-05-14T04:06:37.792840+00:00 0:00:01.642254 27870 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 2 default 2021-05-14T04:06:34.090455+00:00 2 default_pool
success vc-asset-import_v002 create_emr_steps 2021-05-14T03:05:00+00:00 PythonOperator 2021-05-14T04:06:14.698645+00:00 2021-05-14T04:06:17.846726+00:00 0:00:03.148081 27869 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-05-14T04:06:12.009746+00:00 2 default_pool
success campaign-flow-job_v002 check_cluster_status 2021-05-14T03:00:00+00:00 EmrJobFlowSensor 2021-05-14T04:01:03.517618+00:00 2021-05-14T04:10:06.342366+00:00 0:09:02.824748 27867 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-05-14T04:01:00.732072+00:00 2 default_pool
success campaign-flow-job_v002 create_cluster_and_add_emr_steps 2021-05-14T03:00:00+00:00 EmrCreateJobFlowOperator 2021-05-14T04:00:29.069071+00:00 2021-05-14T04:00:30.749080+00:00 0:00:01.680009 27866 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 4 default 2021-05-14T04:00:26.704399+00:00 2 default_pool
success campaign-flow-job_v002 create_emr_steps 2021-05-14T03:00:00+00:00 PythonOperator 2021-05-14T04:00:06.925875+00:00 2021-05-14T04:00:10.115392+00:00 0:00:03.189517 27865 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 5 default 2021-05-14T04:00:04.683868+00:00 2 default_pool
success campaign-history-job_v002 check_cluster_status 2021-05-14T02:00:00+00:00 EmrJobFlowSensor 2021-05-14T03:10:11.568850+00:00 2021-05-14T03:18:14.202559+00:00 0:08:02.633709 27864 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-05-14T03:10:09.341925+00:00 2 default_pool
success booking-processing-job_v002 check_cluster_status 2021-05-14T02:00:00+00:00 EmrJobFlowSensor 2021-05-14T03:09:59.603986+00:00 2021-05-14T03:20:02.539968+00:00 0:10:02.935982 27863 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-05-14T03:09:57.285305+00:00 2 default_pool
success campaign-history-job_v002 create_cluster_and_add_emr_steps 2021-05-14T02:00:00+00:00 EmrCreateJobFlowOperator 2021-05-14T03:09:49.510274+00:00 2021-05-14T03:09:51.161280+00:00 0:00:01.651006 27862 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 2 default 2021-05-14T03:09:47.274714+00:00 2 default_pool
success booking-processing-job_v002 create_cluster_and_add_emr_steps 2021-05-14T02:00:00+00:00 EmrCreateJobFlowOperator 2021-05-14T03:09:37.388088+00:00 2021-05-14T03:09:39.096368+00:00 0:00:01.708280 27861 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 2 default 2021-05-14T03:09:35.266047+00:00 2 default_pool
success campaign-history-job_v002 create_emr_steps 2021-05-14T02:00:00+00:00 PythonOperator 2021-05-14T03:09:25.615459+00:00 2021-05-14T03:09:28.749392+00:00 0:00:03.133933 27860 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-05-14T03:09:23.252022+00:00 2 default_pool
success booking-processing-job_v002 create_emr_steps 2021-05-14T02:00:00+00:00 PythonOperator 2021-05-14T03:09:11.394823+00:00 2021-05-14T03:09:14.794636+00:00 0:00:03.399813 27859 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-05-14T03:09:09.240692+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_campaign-history-job_v002 2021-05-14T02:00:00+00:00 TriggerDagRunOperator 2021-05-14T03:08:59.651132+00:00 2021-05-14T03:09:00.188694+00:00 0:00:00.537562 27858 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-05-14T03:08:57.235393+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_booking-processing-job_v002 2021-05-14T02:00:00+00:00 TriggerDagRunOperator 2021-05-14T03:08:59.401409+00:00 2021-05-14T03:08:59.815213+00:00 0:00:00.413804 27857 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-05-14T03:08:57.235425+00:00 2 default_pool
success vc-asset-import_v002 check_cluster_status 2021-05-14T02:05:00+00:00 EmrJobFlowSensor 2021-05-14T03:06:13.056232+00:00 2021-05-14T03:15:15.690068+00:00 0:09:02.633836 27856 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-05-14T03:06:10.944153+00:00 2 default_pool
success vc-asset-import_v002 create_cluster_and_add_emr_steps 2021-05-14T02:05:00+00:00 EmrCreateJobFlowOperator 2021-05-14T03:05:51.161451+00:00 2021-05-14T03:05:52.967590+00:00 0:00:01.806139 27855 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 2 default 2021-05-14T03:05:48.923798+00:00 2 default_pool
success vc-asset-import_v002 create_emr_steps 2021-05-14T02:05:00+00:00 PythonOperator 2021-05-14T03:05:23.330980+00:00 2021-05-14T03:05:26.431773+00:00 0:00:03.100793 27854 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-05-14T03:05:20.961734+00:00 2 default_pool
success campaign-flow-job_v002 check_cluster_status 2021-05-14T02:00:00+00:00 EmrJobFlowSensor 2021-05-14T03:01:51.097492+00:00 2021-05-14T03:08:53.688744+00:00 0:07:02.591252 27853 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-05-14T03:01:48.656300+00:00 2 default_pool
success campaign-flow-job_v002 create_cluster_and_add_emr_steps 2021-05-14T02:00:00+00:00 EmrCreateJobFlowOperator 2021-05-14T03:00:36.514998+00:00 2021-05-14T03:00:38.302042+00:00 0:00:01.787044 27851 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 4 default 2021-05-14T03:00:34.385419+00:00 2 default_pool
success campaign-flow-job_v002 create_emr_steps 2021-05-14T02:00:00+00:00 PythonOperator 2021-05-14T03:00:14.902749+00:00 2021-05-14T03:00:17.986920+00:00 0:00:03.084171 27850 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 5 default 2021-05-14T03:00:12.378157+00:00 2 default_pool
success campaign-history-job_v002 check_cluster_status 2021-05-14T01:00:00+00:00 EmrJobFlowSensor 2021-05-14T02:15:10.521695+00:00 2021-05-14T02:24:13.259867+00:00 0:09:02.738172 27849 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-05-14T02:15:07.918292+00:00 2 default_pool
success booking-processing-job_v002 check_cluster_status 2021-05-14T01:00:00+00:00 EmrJobFlowSensor 2021-05-14T02:15:08.306039+00:00 2021-05-14T02:25:11.648163+00:00 0:10:03.342124 27848 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-05-14T02:15:05.914952+00:00 2 default_pool
success campaign-history-job_v002 create_cluster_and_add_emr_steps 2021-05-14T01:00:00+00:00 EmrCreateJobFlowOperator 2021-05-14T02:14:48.701092+00:00 2021-05-14T02:14:50.496832+00:00 0:00:01.795740 27847 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 2 default 2021-05-14T02:14:45.965692+00:00 2 default_pool
success booking-processing-job_v002 create_cluster_and_add_emr_steps 2021-05-14T01:00:00+00:00 EmrCreateJobFlowOperator 2021-05-14T02:14:46.377216+00:00 2021-05-14T02:14:48.453758+00:00 0:00:02.076542 27846 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 2 default 2021-05-14T02:14:43.965396+00:00 2 default_pool
success campaign-history-job_v002 create_emr_steps 2021-05-14T01:00:00+00:00 PythonOperator 2021-05-14T02:14:26.448708+00:00 2021-05-14T02:14:29.614586+00:00 0:00:03.165878 27845 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-05-14T02:14:23.958130+00:00 2 default_pool
success booking-processing-job_v002 create_emr_steps 2021-05-14T01:00:00+00:00 PythonOperator 2021-05-14T02:14:24.517078+00:00 2021-05-14T02:14:27.976170+00:00 0:00:03.459092 27844 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-05-14T02:14:21.949250+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_campaign-history-job_v002 2021-05-14T01:00:00+00:00 TriggerDagRunOperator 2021-05-14T02:14:16.125583+00:00 2021-05-14T02:14:16.640611+00:00 0:00:00.515028 27843 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-05-14T02:14:13.837488+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_booking-processing-job_v002 2021-05-14T01:00:00+00:00 TriggerDagRunOperator 2021-05-14T02:14:16.052136+00:00 2021-05-14T02:14:16.440467+00:00 0:00:00.388331 27842 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-05-14T02:14:13.837520+00:00 2 default_pool
success vc-asset-import_v002 check_cluster_status 2021-05-14T01:05:00+00:00 EmrJobFlowSensor 2021-05-14T02:06:19.354140+00:00 2021-05-14T02:14:21.836416+00:00 0:08:02.482276 27841 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-05-14T02:06:17.044245+00:00 2 default_pool
success vc-asset-import_v002 create_cluster_and_add_emr_steps 2021-05-14T01:05:00+00:00 EmrCreateJobFlowOperator 2021-05-14T02:05:57.165251+00:00 2021-05-14T02:05:58.823189+00:00 0:00:01.657938 27840 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 2 default 2021-05-14T02:05:54.934569+00:00 2 default_pool
success vc-asset-import_v002 create_emr_steps 2021-05-14T01:05:00+00:00 PythonOperator 2021-05-14T02:05:25.123193+00:00 2021-05-14T02:05:28.271815+00:00 0:00:03.148622 27839 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-05-14T02:05:22.906491+00:00 2 default_pool
success campaign-flow-job_v002 check_cluster_status 2021-05-14T01:00:00+00:00 EmrJobFlowSensor 2021-05-14T02:01:48.697535+00:00 2021-05-14T02:13:51.770744+00:00 0:12:03.073209 27838 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-05-14T02:01:46.353031+00:00 2 default_pool
success campaign-flow-job_v002 create_cluster_and_add_emr_steps 2021-05-14T01:00:00+00:00 EmrCreateJobFlowOperator 2021-05-14T02:01:26.488835+00:00 2021-05-14T02:01:28.278324+00:00 0:00:01.789489 27837 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 4 default 2021-05-14T02:01:24.265246+00:00 2 default_pool
success campaign-flow-job_v002 create_emr_steps 2021-05-14T01:00:00+00:00 PythonOperator 2021-05-14T02:01:06.549507+00:00 2021-05-14T02:01:09.637719+00:00 0:00:03.088212 27836 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 5 default 2021-05-14T02:01:04.187458+00:00 2 default_pool
success booking-processing-job_v002 check_cluster_status 2021-05-14T00:00:00+00:00 EmrJobFlowSensor 2021-05-14T01:14:36.020825+00:00 2021-05-14T01:23:38.830632+00:00 0:09:02.809807 27834 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-05-14T01:14:33.790887+00:00 2 default_pool
success campaign-history-job_v002 check_cluster_status 2021-05-14T00:00:00+00:00 EmrJobFlowSensor 2021-05-14T01:14:23.823207+00:00 2021-05-14T01:22:26.449171+00:00 0:08:02.625964 27833 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-05-14T01:14:21.730528+00:00 2 default_pool
success booking-processing-job_v002 create_cluster_and_add_emr_steps 2021-05-14T00:00:00+00:00 EmrCreateJobFlowOperator 2021-05-14T01:14:14.042699+00:00 2021-05-14T01:14:15.852056+00:00 0:00:01.809357 27832 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 2 default 2021-05-14T01:14:11.728215+00:00 2 default_pool
success campaign-history-job_v002 create_cluster_and_add_emr_steps 2021-05-14T00:00:00+00:00 EmrCreateJobFlowOperator 2021-05-14T01:14:02.008555+00:00 2021-05-14T01:14:03.814576+00:00 0:00:01.806021 27831 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 2 default 2021-05-14T01:13:59.770855+00:00 2 default_pool
success booking-processing-job_v002 create_emr_steps 2021-05-14T00:00:00+00:00 PythonOperator 2021-05-14T01:13:52.074749+00:00 2021-05-14T01:13:55.387598+00:00 0:00:03.312849 27830 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-05-14T01:13:49.756924+00:00 2 default_pool
success campaign-history-job_v002 create_emr_steps 2021-05-14T00:00:00+00:00 PythonOperator 2021-05-14T01:13:41.953263+00:00 2021-05-14T01:13:45.420229+00:00 0:00:03.466966 27829 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-05-14T01:13:39.692057+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_booking-processing-job_v002 2021-05-14T00:00:00+00:00 TriggerDagRunOperator 2021-05-14T01:13:36.011153+00:00 2021-05-14T01:13:36.531597+00:00 0:00:00.520444 27828 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-05-14T01:13:33.692865+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_campaign-history-job_v002 2021-05-14T00:00:00+00:00 TriggerDagRunOperator 2021-05-14T01:13:35.857189+00:00 2021-05-14T01:13:36.263588+00:00 0:00:00.406399 27827 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-05-14T01:13:33.692840+00:00 2 default_pool
success vc-asset-import_v002 check_cluster_status 2021-05-14T00:05:00+00:00 EmrJobFlowSensor 2021-05-14T01:06:01.367362+00:00 2021-05-14T01:15:04.136540+00:00 0:09:02.769178 27826 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-05-14T01:05:59.052056+00:00 2 default_pool
success vc-asset-import_v002 create_cluster_and_add_emr_steps 2021-05-14T00:05:00+00:00 EmrCreateJobFlowOperator 2021-05-14T01:05:39.408754+00:00 2021-05-14T01:05:41.145344+00:00 0:00:01.736590 27825 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 2 default 2021-05-14T01:05:36.960768+00:00 2 default_pool
success vc-asset-import_v002 create_emr_steps 2021-05-14T00:05:00+00:00 PythonOperator 2021-05-14T01:05:19.287455+00:00 2021-05-14T01:05:22.312695+00:00 0:00:03.025240 27824 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-05-14T01:05:16.954372+00:00 2 default_pool
success campaign-flow-job_v002 check_cluster_status 2021-05-14T00:00:00+00:00 EmrJobFlowSensor 2021-05-14T01:01:04.817419+00:00 2021-05-14T01:13:07.984158+00:00 0:12:03.166739 27823 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-05-14T01:01:02.478670+00:00 2 default_pool
success campaign-flow-job_v002 create_cluster_and_add_emr_steps 2021-05-14T00:00:00+00:00 EmrCreateJobFlowOperator 2021-05-14T01:00:42.665059+00:00 2021-05-14T01:00:44.505696+00:00 0:00:01.840637 27822 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 4 default 2021-05-14T01:00:40.391098+00:00 2 default_pool
success campaign-flow-job_v002 create_emr_steps 2021-05-14T00:00:00+00:00 PythonOperator 2021-05-14T01:00:22.733231+00:00 2021-05-14T01:00:25.870751+00:00 0:00:03.137520 27821 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 5 default 2021-05-14T01:00:20.325793+00:00 2 default_pool
success campaign-history-job_v002 check_cluster_status 2021-05-13T23:00:00+00:00 EmrJobFlowSensor 2021-05-14T00:12:14.721232+00:00 2021-05-14T00:22:17.743205+00:00 0:10:03.021973 27819 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-05-14T00:12:12.406414+00:00 2 default_pool
success booking-processing-job_v002 check_cluster_status 2021-05-13T23:00:00+00:00 EmrJobFlowSensor 2021-05-14T00:12:06.479588+00:00 2021-05-14T00:22:09.328342+00:00 0:10:02.848754 27818 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-05-14T00:12:04.389387+00:00 2 default_pool
success campaign-history-job_v002 create_cluster_and_add_emr_steps 2021-05-13T23:00:00+00:00 EmrCreateJobFlowOperator 2021-05-14T00:11:52.541959+00:00 2021-05-14T00:11:54.212104+00:00 0:00:01.670145 27817 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 2 default 2021-05-14T00:11:50.326381+00:00 2 default_pool
success booking-processing-job_v002 create_cluster_and_add_emr_steps 2021-05-13T23:00:00+00:00 EmrCreateJobFlowOperator 2021-05-14T00:11:42.644253+00:00 2021-05-14T00:11:44.455275+00:00 0:00:01.811022 27816 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 2 default 2021-05-14T00:11:40.318523+00:00 2 default_pool
success campaign-history-job_v002 create_emr_steps 2021-05-13T23:00:00+00:00 PythonOperator 2021-05-14T00:11:32.491604+00:00 2021-05-14T00:11:35.607668+00:00 0:00:03.116064 27815 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-05-14T00:11:30.307588+00:00 2 default_pool
success booking-processing-job_v002 create_emr_steps 2021-05-13T23:00:00+00:00 PythonOperator 2021-05-14T00:11:22.504136+00:00 2021-05-14T00:11:25.836344+00:00 0:00:03.332208 27814 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-05-14T00:11:20.360396+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_booking-processing-job_v002 2021-05-13T23:00:00+00:00 TriggerDagRunOperator 2021-05-14T00:11:08.745260+00:00 2021-05-14T00:11:09.306682+00:00 0:00:00.561422 27813 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-05-14T00:11:06.359342+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_campaign-history-job_v002 2021-05-13T23:00:00+00:00 TriggerDagRunOperator 2021-05-14T00:11:08.722154+00:00 2021-05-14T00:11:09.164578+00:00 0:00:00.442424 27812 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-05-14T00:11:06.359294+00:00 2 default_pool
success vc-asset-import_v002 check_cluster_status 2021-05-13T23:05:00+00:00 EmrJobFlowSensor 2021-05-14T00:06:14.249375+00:00 2021-05-14T00:15:16.970924+00:00 0:09:02.721549 27811 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-05-14T00:06:11.926483+00:00 2 default_pool
success vc-asset-import_v002 create_cluster_and_add_emr_steps 2021-05-13T23:05:00+00:00 EmrCreateJobFlowOperator 2021-05-14T00:05:52.054118+00:00 2021-05-14T00:05:53.731907+00:00 0:00:01.677789 27810 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 2 default 2021-05-14T00:05:49.909456+00:00 2 default_pool
success vc-asset-import_v002 create_emr_steps 2021-05-13T23:05:00+00:00 PythonOperator 2021-05-14T00:05:28.071296+00:00 2021-05-14T00:05:31.155630+00:00 0:00:03.084334 27809 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-05-14T00:05:25.852525+00:00 2 default_pool
success campaign-flow-job_v002 check_cluster_status 2021-05-13T23:00:00+00:00 EmrJobFlowSensor 2021-05-14T00:00:57.585333+00:00 2021-05-14T00:11:00.520880+00:00 0:10:02.935547 27808 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-05-14T00:00:55.303026+00:00 2 default_pool
success campaign-flow-job_v002 create_cluster_and_add_emr_steps 2021-05-13T23:00:00+00:00 EmrCreateJobFlowOperator 2021-05-14T00:00:37.574278+00:00 2021-05-14T00:00:39.409382+00:00 0:00:01.835104 27807 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 4 default 2021-05-14T00:00:35.284455+00:00 2 default_pool
success campaign-flow-job_v002 create_emr_steps 2021-05-13T23:00:00+00:00 PythonOperator 2021-05-14T00:00:16.116026+00:00 2021-05-14T00:00:19.361246+00:00 0:00:03.245220 27806 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 5 default 2021-05-14T00:00:13.264741+00:00 2 default_pool
success booking-processing-job_v002 check_cluster_status 2021-05-13T22:00:00+00:00 EmrJobFlowSensor 2021-05-13T23:10:40.508177+00:00 2021-05-13T23:19:43.059340+00:00 0:09:02.551163 27804 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-05-13T23:10:38.293861+00:00 2 default_pool
success campaign-history-job_v002 check_cluster_status 2021-05-13T22:00:00+00:00 EmrJobFlowSensor 2021-05-13T23:10:28.503550+00:00 2021-05-13T23:19:31.133473+00:00 0:09:02.629923 27803 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-05-13T23:10:26.301514+00:00 2 default_pool
success booking-processing-job_v002 create_cluster_and_add_emr_steps 2021-05-13T22:00:00+00:00 EmrCreateJobFlowOperator 2021-05-13T23:10:18.481518+00:00 2021-05-13T23:10:20.280640+00:00 0:00:01.799122 27802 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 2 default 2021-05-13T23:10:16.252678+00:00 2 default_pool
success campaign-history-job_v002 create_cluster_and_add_emr_steps 2021-05-13T22:00:00+00:00 EmrCreateJobFlowOperator 2021-05-13T23:10:06.571713+00:00 2021-05-13T23:10:08.292259+00:00 0:00:01.720546 27801 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 2 default 2021-05-13T23:10:04.243380+00:00 2 default_pool
success booking-processing-job_v002 create_emr_steps 2021-05-13T22:00:00+00:00 PythonOperator 2021-05-13T23:09:56.519024+00:00 2021-05-13T23:09:59.851668+00:00 0:00:03.332644 27800 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-05-13T23:09:54.237527+00:00 2 default_pool
success campaign-history-job_v002 create_emr_steps 2021-05-13T22:00:00+00:00 PythonOperator 2021-05-13T23:09:44.618057+00:00 2021-05-13T23:09:47.762622+00:00 0:00:03.144565 27799 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-05-13T23:09:42.281339+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_campaign-history-job_v002 2021-05-13T22:00:00+00:00 TriggerDagRunOperator 2021-05-13T23:09:18.567551+00:00 2021-05-13T23:09:19.077794+00:00 0:00:00.510243 27798 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-05-13T23:09:16.198711+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_booking-processing-job_v002 2021-05-13T22:00:00+00:00 TriggerDagRunOperator 2021-05-13T23:09:18.430919+00:00 2021-05-13T23:09:18.860424+00:00 0:00:00.429505 27797 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-05-13T23:09:16.198742+00:00 2 default_pool
success vc-asset-import_v002 check_cluster_status 2021-05-13T22:05:00+00:00 EmrJobFlowSensor 2021-05-13T23:06:01.978728+00:00 2021-05-13T23:15:04.639207+00:00 0:09:02.660479 27796 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-05-13T23:05:59.826671+00:00 2 default_pool
success vc-asset-import_v002 create_cluster_and_add_emr_steps 2021-05-13T22:05:00+00:00 EmrCreateJobFlowOperator 2021-05-13T23:05:39.978645+00:00 2021-05-13T23:05:41.628101+00:00 0:00:01.649456 27795 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 2 default 2021-05-13T23:05:37.808586+00:00 2 default_pool
success vc-asset-import_v002 create_emr_steps 2021-05-13T22:05:00+00:00 PythonOperator 2021-05-13T23:05:17.889635+00:00 2021-05-13T23:05:20.988758+00:00 0:00:03.099123 27794 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-05-13T23:05:15.791071+00:00 2 default_pool
success campaign-flow-job_v002 check_cluster_status 2021-05-13T22:00:00+00:00 EmrJobFlowSensor 2021-05-13T23:00:55.761185+00:00 2021-05-13T23:08:58.582364+00:00 0:08:02.821179 27793 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-05-13T23:00:53.439033+00:00 2 default_pool
success campaign-delta-past-delete-job_v002 check_cluster_status 2021-05-12T23:00:00+00:00 EmrJobFlowSensor 2021-05-13T23:00:51.538193+00:00 2021-05-13T23:10:54.192801+00:00 0:10:02.654608 27792 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-05-13T23:00:49.435590+00:00 2 default_pool
success campaign-flow-job_v002 create_cluster_and_add_emr_steps 2021-05-13T22:00:00+00:00 EmrCreateJobFlowOperator 2021-05-13T23:00:33.632146+00:00 2021-05-13T23:00:35.317579+00:00 0:00:01.685433 27791 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 4 default 2021-05-13T23:00:31.421338+00:00 2 default_pool
success campaign-delta-past-delete-job_v002 create_cluster_and_add_emr_steps 2021-05-12T23:00:00+00:00 EmrCreateJobFlowOperator 2021-05-13T23:00:29.794186+00:00 2021-05-13T23:00:31.552810+00:00 0:00:01.758624 27790 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 2 default 2021-05-13T23:00:27.423206+00:00 2 default_pool
success campaign-flow-job_v002 create_emr_steps 2021-05-13T22:00:00+00:00 PythonOperator 2021-05-13T23:00:12.305386+00:00 2021-05-13T23:00:15.606577+00:00 0:00:03.301191 27789 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 5 default 2021-05-13T23:00:09.467042+00:00 2 default_pool
success campaign-delta-past-delete-job_v002 create_emr_steps 2021-05-12T23:00:00+00:00 PythonOperator 2021-05-13T23:00:07.951635+00:00 2021-05-13T23:00:11.820657+00:00 0:00:03.869022 27788 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-05-13T23:00:05.443097+00:00 2 default_pool
success campaign-history-job_v002 check_cluster_status 2021-05-13T21:00:00+00:00 EmrJobFlowSensor 2021-05-13T22:11:13.487124+00:00 2021-05-13T22:21:16.564714+00:00 0:10:03.077590 27786 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-05-13T22:11:11.226508+00:00 2 default_pool
success booking-processing-job_v002 check_cluster_status 2021-05-13T21:00:00+00:00 EmrJobFlowSensor 2021-05-13T22:11:07.355992+00:00 2021-05-13T22:20:10.026631+00:00 0:09:02.670639 27785 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-05-13T22:11:05.219853+00:00 2 default_pool
success campaign-history-job_v002 create_cluster_and_add_emr_steps 2021-05-13T21:00:00+00:00 EmrCreateJobFlowOperator 2021-05-13T22:10:51.431426+00:00 2021-05-13T22:10:53.208620+00:00 0:00:01.777194 27784 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 2 default 2021-05-13T22:10:49.206199+00:00 2 default_pool
success booking-processing-job_v002 create_cluster_and_add_emr_steps 2021-05-13T21:00:00+00:00 EmrCreateJobFlowOperator 2021-05-13T22:10:45.734375+00:00 2021-05-13T22:10:47.387054+00:00 0:00:01.652679 27783 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 2 default 2021-05-13T22:10:43.266107+00:00 2 default_pool
success campaign-history-job_v002 create_emr_steps 2021-05-13T21:00:00+00:00 PythonOperator 2021-05-13T22:10:30.426701+00:00 2021-05-13T22:10:33.727483+00:00 0:00:03.300782 27782 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-05-13T22:10:27.249305+00:00 2 default_pool
success booking-processing-job_v002 create_emr_steps 2021-05-13T21:00:00+00:00 PythonOperator 2021-05-13T22:10:25.681486+00:00 2021-05-13T22:10:29.639887+00:00 0:00:03.958401 27781 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-05-13T22:10:23.194118+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_campaign-history-job_v002 2021-05-13T21:00:00+00:00 TriggerDagRunOperator 2021-05-13T22:10:07.835640+00:00 2021-05-13T22:10:08.368366+00:00 0:00:00.532726 27780 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-05-13T22:10:05.118376+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_booking-processing-job_v002 2021-05-13T21:00:00+00:00 TriggerDagRunOperator 2021-05-13T22:10:07.189910+00:00 2021-05-13T22:10:07.579458+00:00 0:00:00.389548 27779 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-05-13T22:10:05.118414+00:00 2 default_pool
success vc-asset-import_v002 check_cluster_status 2021-05-13T21:05:00+00:00 EmrJobFlowSensor 2021-05-13T22:05:58.953624+00:00 2021-05-13T22:15:01.701183+00:00 0:09:02.747559 27778 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-05-13T22:05:56.611225+00:00 2 default_pool
success vc-asset-import_v002 create_cluster_and_add_emr_steps 2021-05-13T21:05:00+00:00 EmrCreateJobFlowOperator 2021-05-13T22:05:36.950078+00:00 2021-05-13T22:05:38.703690+00:00 0:00:01.753612 27777 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 2 default 2021-05-13T22:05:34.655310+00:00 2 default_pool
success vc-asset-import_v002 create_emr_steps 2021-05-13T21:05:00+00:00 PythonOperator 2021-05-13T22:05:16.649632+00:00 2021-05-13T22:05:19.687518+00:00 0:00:03.037886 27776 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-05-13T22:05:14.555392+00:00 2 default_pool
success campaign-flow-job_v002 check_cluster_status 2021-05-13T21:00:00+00:00 EmrJobFlowSensor 2021-05-13T22:00:56.454846+00:00 2021-05-13T22:09:59.425626+00:00 0:09:02.970780 27775 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-05-13T22:00:54.051964+00:00 2 default_pool
success campaign-flow-job_v002 create_cluster_and_add_emr_steps 2021-05-13T21:00:00+00:00 EmrCreateJobFlowOperator 2021-05-13T22:00:34.271935+00:00 2021-05-13T22:00:35.934841+00:00 0:00:01.662906 27774 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 4 default 2021-05-13T22:00:32.035222+00:00 2 default_pool
success campaign-flow-job_v002 create_emr_steps 2021-05-13T21:00:00+00:00 PythonOperator 2021-05-13T22:00:12.313530+00:00 2021-05-13T22:00:15.428495+00:00 0:00:03.114965 27773 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 5 default 2021-05-13T22:00:10.020411+00:00 2 default_pool
success campaign-history-job_v002 check_cluster_status 2021-05-13T20:00:00+00:00 EmrJobFlowSensor 2021-05-13T21:11:18.840075+00:00 2021-05-13T21:21:21.657283+00:00 0:10:02.817208 27771 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-05-13T21:11:16.508421+00:00 2 default_pool
success booking-processing-job_v002 check_cluster_status 2021-05-13T20:00:00+00:00 EmrJobFlowSensor 2021-05-13T21:11:15.054574+00:00 2021-05-13T21:21:17.988966+00:00 0:10:02.934392 27770 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-05-13T21:11:12.559177+00:00 2 default_pool
success campaign-history-job_v002 create_cluster_and_add_emr_steps 2021-05-13T20:00:00+00:00 EmrCreateJobFlowOperator 2021-05-13T21:10:57.013303+00:00 2021-05-13T21:10:58.716410+00:00 0:00:01.703107 27769 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 2 default 2021-05-13T21:10:54.485193+00:00 2 default_pool
success booking-processing-job_v002 create_cluster_and_add_emr_steps 2021-05-13T20:00:00+00:00 EmrCreateJobFlowOperator 2021-05-13T21:10:55.071509+00:00 2021-05-13T21:10:56.948325+00:00 0:00:01.876816 27768 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 2 default 2021-05-13T21:10:52.488657+00:00 2 default_pool
success campaign-history-job_v002 create_emr_steps 2021-05-13T20:00:00+00:00 PythonOperator 2021-05-13T21:10:36.724533+00:00 2021-05-13T21:10:39.796643+00:00 0:00:03.072110 27767 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-05-13T21:10:34.446088+00:00 2 default_pool
success booking-processing-job_v002 create_emr_steps 2021-05-13T20:00:00+00:00 PythonOperator 2021-05-13T21:10:33.169949+00:00 2021-05-13T21:10:36.501201+00:00 0:00:03.331252 27766 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-05-13T21:10:30.478961+00:00 2 default_pool