Task Instances

  State Dag Id Task Id Execution Date Operator Start Date End Date Duration Job Id Hostname Unixname Priority Weight Queue Queued Dttm Try Number Pool Log Url
success campaign-history-job_v002 create_cluster_and_add_emr_steps 2021-07-02T22:00:00+00:00 EmrCreateJobFlowOperator 2021-07-02T23:10:36.049881+00:00 2021-07-02T23:10:37.828160+00:00 0:00:01.778279 49008 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 2 default 2021-07-02T23:10:33.609839+00:00 2 default_pool
success booking-processing-job_v002 create_cluster_and_add_emr_steps 2021-07-02T22:00:00+00:00 EmrCreateJobFlowOperator 2021-07-02T23:10:28.030530+00:00 2021-07-02T23:10:29.741764+00:00 0:00:01.711234 49007 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 2 default 2021-07-02T23:10:25.663359+00:00 2 default_pool
success campaign-history-job_v002 create_emr_steps 2021-07-02T22:00:00+00:00 PythonOperator 2021-07-02T23:10:13.357200+00:00 2021-07-02T23:10:17.024080+00:00 0:00:03.666880 49006 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-07-02T23:10:09.652804+00:00 2 default_pool
success booking-processing-job_v002 create_emr_steps 2021-07-02T22:00:00+00:00 PythonOperator 2021-07-02T23:10:07.839902+00:00 2021-07-02T23:10:13.194700+00:00 0:00:05.354798 49005 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-07-02T23:10:05.587563+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_booking-processing-job_v002 2021-07-02T22:00:00+00:00 TriggerDagRunOperator 2021-07-02T23:09:57.921492+00:00 2021-07-02T23:09:58.442032+00:00 0:00:00.520540 49004 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-07-02T23:09:55.564699+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_campaign-history-job_v002 2021-07-02T22:00:00+00:00 TriggerDagRunOperator 2021-07-02T23:09:57.740473+00:00 2021-07-02T23:09:58.127505+00:00 0:00:00.387032 49003 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-07-02T23:09:55.564666+00:00 2 default_pool
success vc-asset-import_v002 check_cluster_status 2021-07-02T22:05:00+00:00 EmrJobFlowSensor 2021-07-02T23:06:01.346787+00:00 2021-07-02T23:14:03.895140+00:00 0:08:02.548353 49002 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-07-02T23:05:59.153292+00:00 2 default_pool
success vc-asset-import_v002 create_cluster_and_add_emr_steps 2021-07-02T22:05:00+00:00 EmrCreateJobFlowOperator 2021-07-02T23:05:37.440109+00:00 2021-07-02T23:05:39.234761+00:00 0:00:01.794652 49001 airflow-worker-2.airflow-worker.bigdata.svc.cluster.local airflow 2 default 2021-07-02T23:05:35.059044+00:00 2 default_pool
success vc-asset-import_v002 create_emr_steps 2021-07-02T22:05:00+00:00 PythonOperator 2021-07-02T23:05:07.363271+00:00 2021-07-02T23:05:10.696759+00:00 0:00:03.333488 49000 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-07-02T23:05:05.149175+00:00 2 default_pool
success livepop-shuffle-job_v002 check_cluster_status 2021-07-02T22:00:00+00:00 EmrJobFlowSensor 2021-07-02T23:01:06.954605+00:00 2021-07-02T23:11:09.872985+00:00 0:10:02.918380 48999 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-07-02T23:01:04.652472+00:00 2 default_pool
success campaign-delta-past-delete-job_v002 check_cluster_status 2021-07-01T23:00:00+00:00 EmrJobFlowSensor 2021-07-02T23:00:49.109916+00:00 2021-07-02T23:10:51.859600+00:00 0:10:02.749684 48998 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-07-02T23:00:46.564424+00:00 2 default_pool
success campaign-flow-job_v002 check_cluster_status 2021-07-02T22:00:00+00:00 EmrJobFlowSensor 2021-07-02T23:00:49.107732+00:00 2021-07-02T23:09:51.833488+00:00 0:09:02.725756 48997 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-07-02T23:00:46.564394+00:00 2 default_pool
success livepop-shuffle-job_v002 create_cluster_and_add_emr_steps 2021-07-02T22:00:00+00:00 EmrCreateJobFlowOperator 2021-07-02T23:00:44.787263+00:00 2021-07-02T23:00:46.564756+00:00 0:00:01.777493 48996 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 2 default 2021-07-02T23:00:42.567259+00:00 2 default_pool
success campaign-delta-past-delete-job_v002 create_cluster_and_add_emr_steps 2021-07-01T23:00:00+00:00 EmrCreateJobFlowOperator 2021-07-02T23:00:27.319701+00:00 2021-07-02T23:00:29.070014+00:00 0:00:01.750313 48995 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 2 default 2021-07-02T23:00:24.558982+00:00 2 default_pool
success campaign-flow-job_v002 create_cluster_and_add_emr_steps 2021-07-02T22:00:00+00:00 EmrCreateJobFlowOperator 2021-07-02T23:00:26.781275+00:00 2021-07-02T23:00:28.472464+00:00 0:00:01.691189 48994 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 4 default 2021-07-02T23:00:24.559029+00:00 2 default_pool
success livepop-shuffle-job_v002 create_emr_steps 2021-07-02T22:00:00+00:00 PythonOperator 2021-07-02T23:00:24.953202+00:00 2021-07-02T23:00:28.759290+00:00 0:00:03.806088 48993 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-07-02T23:00:22.486859+00:00 2 default_pool
success campaign-delta-past-delete-job_v002 create_emr_steps 2021-07-01T23:00:00+00:00 PythonOperator 2021-07-02T23:00:07.396548+00:00 2021-07-02T23:00:11.218567+00:00 0:00:03.822019 48992 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-07-02T23:00:04.428118+00:00 2 default_pool
success campaign-flow-job_v002 create_emr_steps 2021-07-02T22:00:00+00:00 PythonOperator 2021-07-02T23:00:05.529671+00:00 2021-07-02T23:00:09.630622+00:00 0:00:04.100951 48991 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 5 default 2021-07-02T23:00:02.425178+00:00 2 default_pool
success booking-processing-job_v002 check_cluster_status 2021-07-02T21:00:00+00:00 EmrJobFlowSensor 2021-07-02T22:11:08.799623+00:00 2021-07-02T22:21:11.617912+00:00 0:10:02.818289 48989 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-07-02T22:11:06.486824+00:00 2 default_pool
success campaign-history-job_v002 check_cluster_status 2021-07-02T21:00:00+00:00 EmrJobFlowSensor 2021-07-02T22:11:02.687413+00:00 2021-07-02T22:21:05.605163+00:00 0:10:02.917750 48988 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-07-02T22:11:00.484138+00:00 2 default_pool
success booking-processing-job_v002 create_cluster_and_add_emr_steps 2021-07-02T21:00:00+00:00 EmrCreateJobFlowOperator 2021-07-02T22:10:46.574957+00:00 2021-07-02T22:10:48.277362+00:00 0:00:01.702405 48987 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 2 default 2021-07-02T22:10:44.443278+00:00 2 default_pool
success campaign-history-job_v002 create_cluster_and_add_emr_steps 2021-07-02T21:00:00+00:00 EmrCreateJobFlowOperator 2021-07-02T22:10:40.686961+00:00 2021-07-02T22:10:42.508267+00:00 0:00:01.821306 48986 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 2 default 2021-07-02T22:10:38.443347+00:00 2 default_pool
success booking-processing-job_v002 create_emr_steps 2021-07-02T21:00:00+00:00 PythonOperator 2021-07-02T22:10:27.076044+00:00 2021-07-02T22:10:30.700754+00:00 0:00:03.624710 48985 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-07-02T22:10:24.406198+00:00 2 default_pool
success campaign-history-job_v002 create_emr_steps 2021-07-02T21:00:00+00:00 PythonOperator 2021-07-02T22:10:19.026447+00:00 2021-07-02T22:10:22.487470+00:00 0:00:03.461023 48984 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-07-02T22:10:16.471503+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_booking-processing-job_v002 2021-07-02T21:00:00+00:00 TriggerDagRunOperator 2021-07-02T22:10:12.780994+00:00 2021-07-02T22:10:13.321161+00:00 0:00:00.540167 48983 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-07-02T22:10:10.400247+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_campaign-history-job_v002 2021-07-02T21:00:00+00:00 TriggerDagRunOperator 2021-07-02T22:10:12.615130+00:00 2021-07-02T22:10:13.068947+00:00 0:00:00.453817 48982 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-07-02T22:10:10.400199+00:00 2 default_pool
success vc-asset-import_v002 check_cluster_status 2021-07-02T21:05:00+00:00 EmrJobFlowSensor 2021-07-02T22:05:58.103006+00:00 2021-07-02T22:15:00.806398+00:00 0:09:02.703392 48981 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-07-02T22:05:55.895529+00:00 2 default_pool
success vc-asset-import_v002 create_cluster_and_add_emr_steps 2021-07-02T21:05:00+00:00 EmrCreateJobFlowOperator 2021-07-02T22:05:37.993105+00:00 2021-07-02T22:05:39.624353+00:00 0:00:01.631248 48980 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 2 default 2021-07-02T22:05:35.823030+00:00 2 default_pool
success vc-asset-import_v002 create_emr_steps 2021-07-02T21:05:00+00:00 PythonOperator 2021-07-02T22:05:13.898593+00:00 2021-07-02T22:05:17.491033+00:00 0:00:03.592440 48979 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-07-02T22:05:11.801472+00:00 2 default_pool
success campaign-flow-job_v002 check_cluster_status 2021-07-02T21:00:00+00:00 EmrJobFlowSensor 2021-07-02T22:01:05.680610+00:00 2021-07-02T22:10:08.339663+00:00 0:09:02.659053 48978 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-07-02T22:01:03.404001+00:00 2 default_pool
success livepop-shuffle-job_v002 check_cluster_status 2021-07-02T21:00:00+00:00 EmrJobFlowSensor 2021-07-02T22:01:03.853161+00:00 2021-07-02T22:12:07.051841+00:00 0:11:03.198680 48977 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-07-02T22:01:01.450993+00:00 2 default_pool
success campaign-flow-job_v002 create_cluster_and_add_emr_steps 2021-07-02T21:00:00+00:00 EmrCreateJobFlowOperator 2021-07-02T22:00:42.095913+00:00 2021-07-02T22:00:43.900181+00:00 0:00:01.804268 48976 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 4 default 2021-07-02T22:00:39.393727+00:00 2 default_pool
success livepop-shuffle-job_v002 create_cluster_and_add_emr_steps 2021-07-02T21:00:00+00:00 EmrCreateJobFlowOperator 2021-07-02T22:00:39.721922+00:00 2021-07-02T22:00:41.780953+00:00 0:00:02.059031 48975 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 2 default 2021-07-02T22:00:37.386864+00:00 2 default_pool
success campaign-flow-job_v002 create_emr_steps 2021-07-02T21:00:00+00:00 PythonOperator 2021-07-02T22:00:19.970861+00:00 2021-07-02T22:00:23.411602+00:00 0:00:03.440741 48974 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 5 default 2021-07-02T22:00:17.322561+00:00 2 default_pool
success livepop-shuffle-job_v002 create_emr_steps 2021-07-02T21:00:00+00:00 PythonOperator 2021-07-02T22:00:19.772130+00:00 2021-07-02T22:00:23.482322+00:00 0:00:03.710192 48973 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-07-02T22:00:17.322592+00:00 2 default_pool
success campaign-history-job_v002 check_cluster_status 2021-07-02T20:00:00+00:00 EmrJobFlowSensor 2021-07-02T21:12:33.059637+00:00 2021-07-02T21:21:35.818085+00:00 0:09:02.758448 48971 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-07-02T21:12:30.796022+00:00 2 default_pool
success booking-processing-job_v002 check_cluster_status 2021-07-02T20:00:00+00:00 EmrJobFlowSensor 2021-07-02T21:12:20.884370+00:00 2021-07-02T21:21:23.641307+00:00 0:09:02.756937 48970 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-07-02T21:12:18.738024+00:00 2 default_pool
success campaign-history-job_v002 create_cluster_and_add_emr_steps 2021-07-02T20:00:00+00:00 EmrCreateJobFlowOperator 2021-07-02T21:12:10.937185+00:00 2021-07-02T21:12:12.644467+00:00 0:00:01.707282 48969 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 2 default 2021-07-02T21:12:08.726426+00:00 2 default_pool
success booking-processing-job_v002 create_cluster_and_add_emr_steps 2021-07-02T20:00:00+00:00 EmrCreateJobFlowOperator 2021-07-02T21:11:59.029353+00:00 2021-07-02T21:12:00.779958+00:00 0:00:01.750605 48968 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 2 default 2021-07-02T21:11:56.717557+00:00 2 default_pool
success campaign-history-job_v002 create_emr_steps 2021-07-02T20:00:00+00:00 PythonOperator 2021-07-02T21:11:51.017634+00:00 2021-07-02T21:11:54.450867+00:00 0:00:03.433233 48967 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-07-02T21:11:48.709885+00:00 2 default_pool
success booking-processing-job_v002 create_emr_steps 2021-07-02T20:00:00+00:00 PythonOperator 2021-07-02T21:11:37.147146+00:00 2021-07-02T21:11:40.808459+00:00 0:00:03.661313 48966 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-07-02T21:11:34.768872+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_booking-processing-job_v002 2021-07-02T20:00:00+00:00 TriggerDagRunOperator 2021-07-02T21:11:31.290599+00:00 2021-07-02T21:11:31.715437+00:00 0:00:00.424838 48965 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-07-02T21:11:28.853353+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_campaign-history-job_v002 2021-07-02T20:00:00+00:00 TriggerDagRunOperator 2021-07-02T21:11:31.289544+00:00 2021-07-02T21:11:31.844615+00:00 0:00:00.555071 48964 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-07-02T21:11:28.853305+00:00 2 default_pool
success vc-asset-import_v002 check_cluster_status 2021-07-02T20:05:00+00:00 EmrJobFlowSensor 2021-07-02T21:05:52.254838+00:00 2021-07-02T21:13:54.925696+00:00 0:08:02.670858 48963 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-07-02T21:05:50.138819+00:00 2 default_pool
success vc-asset-import_v002 create_cluster_and_add_emr_steps 2021-07-02T20:05:00+00:00 EmrCreateJobFlowOperator 2021-07-02T21:05:30.512295+00:00 2021-07-02T21:05:32.266982+00:00 0:00:01.754687 48962 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 2 default 2021-07-02T21:05:28.119533+00:00 2 default_pool
success vc-asset-import_v002 create_emr_steps 2021-07-02T20:05:00+00:00 PythonOperator 2021-07-02T21:05:08.358121+00:00 2021-07-02T21:05:11.962441+00:00 0:00:03.604320 48961 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-07-02T21:05:06.087793+00:00 2 default_pool
success livepop-shuffle-job_v002 check_cluster_status 2021-07-02T20:00:00+00:00 EmrJobFlowSensor 2021-07-02T21:01:07.834445+00:00 2021-07-02T21:11:10.731486+00:00 0:10:02.897041 48960 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-07-02T21:01:05.614174+00:00 2 default_pool
success campaign-flow-job_v002 check_cluster_status 2021-07-02T20:00:00+00:00 EmrJobFlowSensor 2021-07-02T21:01:04.110979+00:00 2021-07-02T21:11:06.962895+00:00 0:10:02.851916 48959 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-07-02T21:01:01.653933+00:00 2 default_pool
success livepop-shuffle-job_v002 create_cluster_and_add_emr_steps 2021-07-02T20:00:00+00:00 EmrCreateJobFlowOperator 2021-07-02T21:00:45.789231+00:00 2021-07-02T21:00:47.452869+00:00 0:00:01.663638 48958 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 2 default 2021-07-02T21:00:43.586430+00:00 2 default_pool
success campaign-flow-job_v002 create_cluster_and_add_emr_steps 2021-07-02T20:00:00+00:00 EmrCreateJobFlowOperator 2021-07-02T21:00:41.975153+00:00 2021-07-02T21:00:43.890781+00:00 0:00:01.915628 48957 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 4 default 2021-07-02T21:00:39.646186+00:00 2 default_pool
success livepop-shuffle-job_v002 create_emr_steps 2021-07-02T20:00:00+00:00 PythonOperator 2021-07-02T21:00:15.907680+00:00 2021-07-02T21:00:19.349990+00:00 0:00:03.442310 48956 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-07-02T21:00:13.521619+00:00 2 default_pool
success campaign-flow-job_v002 create_emr_steps 2021-07-02T20:00:00+00:00 PythonOperator 2021-07-02T21:00:11.904935+00:00 2021-07-02T21:00:15.631108+00:00 0:00:03.726173 48955 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 5 default 2021-07-02T21:00:09.516548+00:00 2 default_pool
success campaign-history-job_v002 check_cluster_status 2021-07-02T19:00:00+00:00 EmrJobFlowSensor 2021-07-02T20:12:04.602709+00:00 2021-07-02T20:22:07.576545+00:00 0:10:02.973836 48953 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-07-02T20:12:02.285772+00:00 2 default_pool
success booking-processing-job_v002 check_cluster_status 2021-07-02T19:00:00+00:00 EmrJobFlowSensor 2021-07-02T20:11:58.419231+00:00 2021-07-02T20:22:01.337585+00:00 0:10:02.918354 48952 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-07-02T20:11:56.217083+00:00 2 default_pool
success campaign-history-job_v002 create_cluster_and_add_emr_steps 2021-07-02T19:00:00+00:00 EmrCreateJobFlowOperator 2021-07-02T20:11:42.533454+00:00 2021-07-02T20:11:44.390384+00:00 0:00:01.856930 48951 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 2 default 2021-07-02T20:11:40.203233+00:00 2 default_pool
success booking-processing-job_v002 create_cluster_and_add_emr_steps 2021-07-02T19:00:00+00:00 EmrCreateJobFlowOperator 2021-07-02T20:11:36.444493+00:00 2021-07-02T20:11:38.254471+00:00 0:00:01.809978 48950 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 2 default 2021-07-02T20:11:34.198014+00:00 2 default_pool
success campaign-history-job_v002 create_emr_steps 2021-07-02T19:00:00+00:00 PythonOperator 2021-07-02T20:11:20.559695+00:00 2021-07-02T20:11:24.278841+00:00 0:00:03.719146 48949 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-07-02T20:11:18.187275+00:00 2 default_pool
success booking-processing-job_v002 create_emr_steps 2021-07-02T19:00:00+00:00 PythonOperator 2021-07-02T20:11:14.650069+00:00 2021-07-02T20:11:18.696724+00:00 0:00:04.046655 48948 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-07-02T20:11:12.263805+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_booking-processing-job_v002 2021-07-02T19:00:00+00:00 TriggerDagRunOperator 2021-07-02T20:11:08.991377+00:00 2021-07-02T20:11:09.504366+00:00 0:00:00.512989 48947 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-07-02T20:11:06.181895+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_campaign-history-job_v002 2021-07-02T19:00:00+00:00 TriggerDagRunOperator 2021-07-02T20:11:08.750474+00:00 2021-07-02T20:11:09.174948+00:00 0:00:00.424474 48946 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-07-02T20:11:06.181862+00:00 2 default_pool
success vc-asset-import_v002 check_cluster_status 2021-07-02T19:05:00+00:00 EmrJobFlowSensor 2021-07-02T20:06:04.054176+00:00 2021-07-02T20:14:06.644315+00:00 0:08:02.590139 48945 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-07-02T20:06:01.696710+00:00 2 default_pool
success vc-asset-import_v002 create_cluster_and_add_emr_steps 2021-07-02T19:05:00+00:00 EmrCreateJobFlowOperator 2021-07-02T20:05:41.863229+00:00 2021-07-02T20:05:43.561453+00:00 0:00:01.698224 48944 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 2 default 2021-07-02T20:05:39.593108+00:00 2 default_pool
success vc-asset-import_v002 create_emr_steps 2021-07-02T19:05:00+00:00 PythonOperator 2021-07-02T20:05:19.906507+00:00 2021-07-02T20:05:23.280245+00:00 0:00:03.373738 48943 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-07-02T20:05:17.538316+00:00 2 default_pool
success campaign-flow-job_v002 check_cluster_status 2021-07-02T19:00:00+00:00 EmrJobFlowSensor 2021-07-02T20:00:59.350391+00:00 2021-07-02T20:11:02.194789+00:00 0:10:02.844398 48942 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-07-02T20:00:57.188475+00:00 2 default_pool
success livepop-shuffle-job_v002 check_cluster_status 2021-07-02T19:00:00+00:00 EmrJobFlowSensor 2021-07-02T20:00:47.318276+00:00 2021-07-02T20:10:50.268400+00:00 0:10:02.950124 48941 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-07-02T20:00:45.168436+00:00 2 default_pool
success campaign-flow-job_v002 create_cluster_and_add_emr_steps 2021-07-02T19:00:00+00:00 EmrCreateJobFlowOperator 2021-07-02T20:00:37.316652+00:00 2021-07-02T20:00:38.992067+00:00 0:00:01.675415 48940 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 4 default 2021-07-02T20:00:35.161963+00:00 2 default_pool
success livepop-shuffle-job_v002 create_cluster_and_add_emr_steps 2021-07-02T19:00:00+00:00 EmrCreateJobFlowOperator 2021-07-02T20:00:27.283566+00:00 2021-07-02T20:00:29.082630+00:00 0:00:01.799064 48939 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 2 default 2021-07-02T20:00:25.106393+00:00 2 default_pool
success campaign-flow-job_v002 create_emr_steps 2021-07-02T19:00:00+00:00 PythonOperator 2021-07-02T20:00:15.371611+00:00 2021-07-02T20:00:18.904558+00:00 0:00:03.532947 48938 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 5 default 2021-07-02T20:00:13.097746+00:00 2 default_pool
success livepop-shuffle-job_v002 create_emr_steps 2021-07-02T19:00:00+00:00 PythonOperator 2021-07-02T20:00:05.706381+00:00 2021-07-02T20:00:09.371247+00:00 0:00:03.664866 48937 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-07-02T20:00:03.157522+00:00 2 default_pool
success booking-processing-job_v002 check_cluster_status 2021-07-02T18:00:00+00:00 EmrJobFlowSensor 2021-07-02T19:11:00.226898+00:00 2021-07-02T19:20:03.054396+00:00 0:09:02.827498 48935 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-07-02T19:10:57.645963+00:00 2 default_pool
success campaign-history-job_v002 check_cluster_status 2021-07-02T18:00:00+00:00 EmrJobFlowSensor 2021-07-02T19:10:53.961496+00:00 2021-07-02T19:19:56.560966+00:00 0:09:02.599470 48934 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-07-02T19:10:51.570732+00:00 2 default_pool
success booking-processing-job_v002 create_cluster_and_add_emr_steps 2021-07-02T18:00:00+00:00 EmrCreateJobFlowOperator 2021-07-02T19:10:37.683822+00:00 2021-07-02T19:10:39.571442+00:00 0:00:01.887620 48933 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 2 default 2021-07-02T19:10:35.492990+00:00 2 default_pool
success campaign-history-job_v002 create_cluster_and_add_emr_steps 2021-07-02T18:00:00+00:00 EmrCreateJobFlowOperator 2021-07-02T19:10:34.024780+00:00 2021-07-02T19:10:35.730797+00:00 0:00:01.706017 48932 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 2 default 2021-07-02T19:10:31.555192+00:00 2 default_pool
success booking-processing-job_v002 create_emr_steps 2021-07-02T18:00:00+00:00 PythonOperator 2021-07-02T19:10:18.045490+00:00 2021-07-02T19:10:21.645717+00:00 0:00:03.600227 48931 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-07-02T19:10:15.442840+00:00 2 default_pool
success campaign-history-job_v002 create_emr_steps 2021-07-02T18:00:00+00:00 PythonOperator 2021-07-02T19:10:10.043068+00:00 2021-07-02T19:10:13.488216+00:00 0:00:03.445148 48930 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-07-02T19:10:07.491349+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_campaign-history-job_v002 2021-07-02T18:00:00+00:00 TriggerDagRunOperator 2021-07-02T19:09:57.718591+00:00 2021-07-02T19:09:58.263671+00:00 0:00:00.545080 48929 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-07-02T19:09:55.421913+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_booking-processing-job_v002 2021-07-02T18:00:00+00:00 TriggerDagRunOperator 2021-07-02T19:09:57.664379+00:00 2021-07-02T19:09:58.057982+00:00 0:00:00.393603 48928 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-07-02T19:09:55.421946+00:00 2 default_pool
success vc-asset-import_v002 check_cluster_status 2021-07-02T18:05:00+00:00 EmrJobFlowSensor 2021-07-02T19:05:49.138283+00:00 2021-07-02T19:14:51.855162+00:00 0:09:02.716879 48927 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-07-02T19:05:46.955740+00:00 2 default_pool
success vc-asset-import_v002 create_cluster_and_add_emr_steps 2021-07-02T18:05:00+00:00 EmrCreateJobFlowOperator 2021-07-02T19:05:26.992659+00:00 2021-07-02T19:05:28.648498+00:00 0:00:01.655839 48926 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 2 default 2021-07-02T19:05:24.906412+00:00 2 default_pool
success vc-asset-import_v002 create_emr_steps 2021-07-02T18:05:00+00:00 PythonOperator 2021-07-02T19:05:05.457157+00:00 2021-07-02T19:05:09.210168+00:00 0:00:03.753011 48925 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-07-02T19:05:02.968200+00:00 2 default_pool
success campaign-flow-job_v002 check_cluster_status 2021-07-02T18:00:00+00:00 EmrJobFlowSensor 2021-07-02T19:00:49.007399+00:00 2021-07-02T19:09:51.719492+00:00 0:09:02.712093 48924 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-07-02T19:00:46.457638+00:00 2 default_pool
success livepop-shuffle-job_v002 check_cluster_status 2021-07-02T18:00:00+00:00 EmrJobFlowSensor 2021-07-02T19:00:48.718439+00:00 2021-07-02T19:10:51.531397+00:00 0:10:02.812958 48923 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-07-02T19:00:46.457669+00:00 2 default_pool
success livepop-shuffle-job_v002 create_cluster_and_add_emr_steps 2021-07-02T18:00:00+00:00 EmrCreateJobFlowOperator 2021-07-02T19:00:26.767275+00:00 2021-07-02T19:00:28.653647+00:00 0:00:01.886372 48922 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 2 default 2021-07-02T19:00:24.278367+00:00 2 default_pool
success campaign-flow-job_v002 create_cluster_and_add_emr_steps 2021-07-02T18:00:00+00:00 EmrCreateJobFlowOperator 2021-07-02T19:00:26.690583+00:00 2021-07-02T19:00:28.385256+00:00 0:00:01.694673 48921 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 4 default 2021-07-02T19:00:24.278323+00:00 2 default_pool
success campaign-flow-job_v002 create_emr_steps 2021-07-02T18:00:00+00:00 PythonOperator 2021-07-02T19:00:06.767542+00:00 2021-07-02T19:00:10.127139+00:00 0:00:03.359597 48920 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 5 default 2021-07-02T19:00:04.240743+00:00 2 default_pool
success livepop-shuffle-job_v002 create_emr_steps 2021-07-02T18:00:00+00:00 PythonOperator 2021-07-02T19:00:06.640088+00:00 2021-07-02T19:00:10.312529+00:00 0:00:03.672441 48919 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-07-02T19:00:04.240772+00:00 2 default_pool
success booking-processing-job_v002 check_cluster_status 2021-07-02T17:00:00+00:00 EmrJobFlowSensor 2021-07-02T18:11:26.680987+00:00 2021-07-02T18:20:29.598741+00:00 0:09:02.917754 48917 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-07-02T18:11:23.743252+00:00 2 default_pool
success campaign-history-job_v002 check_cluster_status 2021-07-02T17:00:00+00:00 EmrJobFlowSensor 2021-07-02T18:11:24.353102+00:00 2021-07-02T18:20:27.567790+00:00 0:09:03.214688 48916 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-07-02T18:11:21.749359+00:00 2 default_pool
success booking-processing-job_v002 create_cluster_and_add_emr_steps 2021-07-02T17:00:00+00:00 EmrCreateJobFlowOperator 2021-07-02T18:11:04.704574+00:00 2021-07-02T18:11:06.508497+00:00 0:00:01.803923 48915 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 2 default 2021-07-02T18:11:01.743709+00:00 2 default_pool
success campaign-history-job_v002 create_cluster_and_add_emr_steps 2021-07-02T17:00:00+00:00 EmrCreateJobFlowOperator 2021-07-02T18:11:02.182662+00:00 2021-07-02T18:11:04.575543+00:00 0:00:02.392881 48914 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 2 default 2021-07-02T18:10:59.775173+00:00 2 default_pool
success campaign-history-job_v002 create_emr_steps 2021-07-02T17:00:00+00:00 PythonOperator 2021-07-02T18:10:41.987348+00:00 2021-07-02T18:10:45.760245+00:00 0:00:03.772897 48913 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-07-02T18:10:39.702092+00:00 2 default_pool
success booking-processing-job_v002 create_emr_steps 2021-07-02T17:00:00+00:00 PythonOperator 2021-07-02T18:10:41.997061+00:00 2021-07-02T18:10:45.709612+00:00 0:00:03.712551 48912 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-07-02T18:10:39.702062+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_campaign-history-job_v002 2021-07-02T17:00:00+00:00 TriggerDagRunOperator 2021-07-02T18:10:26.030973+00:00 2021-07-02T18:10:26.468627+00:00 0:00:00.437654 48911 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-07-02T18:10:23.640790+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_booking-processing-job_v002 2021-07-02T17:00:00+00:00 TriggerDagRunOperator 2021-07-02T18:10:25.910070+00:00 2021-07-02T18:10:26.442976+00:00 0:00:00.532906 48910 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-07-02T18:10:23.640819+00:00 2 default_pool
success vc-asset-import_v002 check_cluster_status 2021-07-02T17:05:00+00:00 EmrJobFlowSensor 2021-07-02T18:05:59.653388+00:00 2021-07-02T18:15:02.225811+00:00 0:09:02.572423 48909 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-07-02T18:05:57.392075+00:00 2 default_pool
success vc-asset-import_v002 create_cluster_and_add_emr_steps 2021-07-02T17:05:00+00:00 EmrCreateJobFlowOperator 2021-07-02T18:05:37.480414+00:00 2021-07-02T18:05:39.119209+00:00 0:00:01.638795 48908 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 2 default 2021-07-02T18:05:35.342779+00:00 2 default_pool
success vc-asset-import_v002 create_emr_steps 2021-07-02T17:05:00+00:00 PythonOperator 2021-07-02T18:05:13.556545+00:00 2021-07-02T18:05:17.187504+00:00 0:00:03.630959 48907 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-07-02T18:05:11.320439+00:00 2 default_pool
success campaign-flow-job_v002 check_cluster_status 2021-07-02T17:00:00+00:00 EmrJobFlowSensor 2021-07-02T18:01:09.295340+00:00 2021-07-02T18:10:11.930357+00:00 0:09:02.635017 48906 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-07-02T18:01:06.892496+00:00 2 default_pool
success livepop-shuffle-job_v002 check_cluster_status 2021-07-02T17:00:00+00:00 EmrJobFlowSensor 2021-07-02T18:00:49.062175+00:00 2021-07-02T18:10:51.951614+00:00 0:10:02.889439 48905 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-07-02T18:00:46.810689+00:00 2 default_pool
success campaign-flow-job_v002 create_cluster_and_add_emr_steps 2021-07-02T17:00:00+00:00 EmrCreateJobFlowOperator 2021-07-02T18:00:47.049405+00:00 2021-07-02T18:00:48.971679+00:00 0:00:01.922274 48904 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 4 default 2021-07-02T18:00:44.808266+00:00 2 default_pool