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 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
success campaign-flow-job_v002 trigger_dagrun_booking-processing-job_v002 2021-05-13T20:00:00+00:00 TriggerDagRunOperator 2021-05-13T21:10:24.863034+00:00 2021-05-13T21:10:25.384044+00:00 0:00:00.521010 27765 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-05-13T21:10:22.410408+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_campaign-history-job_v002 2021-05-13T20:00:00+00:00 TriggerDagRunOperator 2021-05-13T21:10:24.722064+00:00 2021-05-13T21:10:25.124783+00:00 0:00:00.402719 27764 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-05-13T21:10:22.410359+00:00 2 default_pool
success vc-asset-import_v002 check_cluster_status 2021-05-13T20:05:00+00:00 EmrJobFlowSensor 2021-05-13T21:06:02.269133+00:00 2021-05-13T21:14:04.923684+00:00 0:08:02.654551 27763 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-05-13T21:05:59.984164+00:00 2 default_pool
success vc-asset-import_v002 create_cluster_and_add_emr_steps 2021-05-13T20:05:00+00:00 EmrCreateJobFlowOperator 2021-05-13T21:05:40.113094+00:00 2021-05-13T21:05:41.736453+00:00 0:00:01.623359 27762 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 2 default 2021-05-13T21:05:37.941462+00:00 2 default_pool
success vc-asset-import_v002 create_emr_steps 2021-05-13T20:05:00+00:00 PythonOperator 2021-05-13T21:05:18.358756+00:00 2021-05-13T21:05:21.486094+00:00 0:00:03.127338 27761 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-05-13T21:05:15.979351+00:00 2 default_pool
success campaign-flow-job_v002 check_cluster_status 2021-05-13T20:00:00+00:00 EmrJobFlowSensor 2021-05-13T21:00:57.886797+00:00 2021-05-13T21:10:00.632377+00:00 0:09:02.745580 27760 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-05-13T21:00:55.461394+00:00 2 default_pool
success campaign-flow-job_v002 create_cluster_and_add_emr_steps 2021-05-13T20:00:00+00:00 EmrCreateJobFlowOperator 2021-05-13T21:00:37.738958+00:00 2021-05-13T21:00:39.608274+00:00 0:00:01.869316 27759 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 4 default 2021-05-13T21:00:35.395633+00:00 2 default_pool
success campaign-flow-job_v002 create_emr_steps 2021-05-13T20:00:00+00:00 PythonOperator 2021-05-13T21:00:15.709189+00:00 2021-05-13T21:00:18.893688+00:00 0:00:03.184499 27758 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 5 default 2021-05-13T21:00:13.357486+00:00 2 default_pool
success campaign-history-job_v002 check_cluster_status 2021-05-13T19:00:00+00:00 EmrJobFlowSensor 2021-05-13T20:11:10.119795+00:00 2021-05-13T20:20:12.774663+00:00 0:09:02.654868 27756 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-05-13T20:11:07.921943+00:00 2 default_pool
success booking-processing-job_v002 check_cluster_status 2021-05-13T19:00:00+00:00 EmrJobFlowSensor 2021-05-13T20:11:04.212631+00:00 2021-05-13T20:21:07.308915+00:00 0:10:03.096284 27755 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-05-13T20:11:01.916288+00:00 2 default_pool
success campaign-history-job_v002 create_cluster_and_add_emr_steps 2021-05-13T19:00:00+00:00 EmrCreateJobFlowOperator 2021-05-13T20:10:48.272516+00:00 2021-05-13T20:10:49.979514+00:00 0:00:01.706998 27754 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 2 default 2021-05-13T20:10:45.908206+00:00 2 default_pool
success booking-processing-job_v002 create_cluster_and_add_emr_steps 2021-05-13T19:00:00+00:00 EmrCreateJobFlowOperator 2021-05-13T20:10:42.130049+00:00 2021-05-13T20:10:43.994217+00:00 0:00:01.864168 27753 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 2 default 2021-05-13T20:10:39.951174+00:00 2 default_pool
success campaign-history-job_v002 create_emr_steps 2021-05-13T19:00:00+00:00 PythonOperator 2021-05-13T20:10:26.770222+00:00 2021-05-13T20:10:30.066789+00:00 0:00:03.296567 27752 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-05-13T20:10:23.887528+00:00 2 default_pool
success booking-processing-job_v002 create_emr_steps 2021-05-13T19:00:00+00:00 PythonOperator 2021-05-13T20:10:22.017661+00:00 2021-05-13T20:10:26.029737+00:00 0:00:04.012076 27751 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-05-13T20:10:19.854132+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_booking-processing-job_v002 2021-05-13T19:00:00+00:00 TriggerDagRunOperator 2021-05-13T20:10:10.298361+00:00 2021-05-13T20:10:10.811849+00:00 0:00:00.513488 27750 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-05-13T20:10:07.844152+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_campaign-history-job_v002 2021-05-13T19:00:00+00:00 TriggerDagRunOperator 2021-05-13T20:10:10.074528+00:00 2021-05-13T20:10:10.489379+00:00 0:00:00.414851 27749 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-05-13T20:10:07.844115+00:00 2 default_pool
success vc-asset-import_v002 check_cluster_status 2021-05-13T19:05:00+00:00 EmrJobFlowSensor 2021-05-13T20:05:59.834106+00:00 2021-05-13T20:14:02.360718+00:00 0:08:02.526612 27748 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-05-13T20:05:57.520828+00:00 2 default_pool
success vc-asset-import_v002 create_cluster_and_add_emr_steps 2021-05-13T19:05:00+00:00 EmrCreateJobFlowOperator 2021-05-13T20:05:37.818145+00:00 2021-05-13T20:05:39.608635+00:00 0:00:01.790490 27747 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 2 default 2021-05-13T20:05:35.553781+00:00 2 default_pool
success vc-asset-import_v002 create_emr_steps 2021-05-13T19:05:00+00:00 PythonOperator 2021-05-13T20:05:15.641069+00:00 2021-05-13T20:05:18.737196+00:00 0:00:03.096127 27746 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-05-13T20:05:13.443693+00:00 2 default_pool
success campaign-flow-job_v002 check_cluster_status 2021-05-13T19:00:00+00:00 EmrJobFlowSensor 2021-05-13T20:00:46.878421+00:00 2021-05-13T20:09:49.467255+00:00 0:09:02.588834 27745 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-05-13T20:00:44.794858+00:00 2 default_pool
success campaign-flow-job_v002 create_cluster_and_add_emr_steps 2021-05-13T19:00:00+00:00 EmrCreateJobFlowOperator 2021-05-13T20:00:26.877943+00:00 2021-05-13T20:00:28.574690+00:00 0:00:01.696747 27744 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 4 default 2021-05-13T20:00:24.754448+00:00 2 default_pool
success campaign-flow-job_v002 create_emr_steps 2021-05-13T19:00:00+00:00 PythonOperator 2021-05-13T20:00:05.357601+00:00 2021-05-13T20:00:08.530992+00:00 0:00:03.173391 27743 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 5 default 2021-05-13T20:00:02.735948+00:00 2 default_pool
success campaign-history-job_v002 check_cluster_status 2021-05-13T18:00:00+00:00 EmrJobFlowSensor 2021-05-13T19:12:50.722720+00:00 2021-05-13T19:33:55.091900+00:00 0:21:04.369180 27741 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-05-13T19:12:48.360401+00:00 2 default_pool
success booking-processing-job_v002 check_cluster_status 2021-05-13T18:00:00+00:00 EmrJobFlowSensor 2021-05-13T19:12:36.828536+00:00 2021-05-13T19:22:39.569975+00:00 0:10:02.741439 27740 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-05-13T19:12:34.311904+00:00 2 default_pool
success campaign-history-job_v002 create_cluster_and_add_emr_steps 2021-05-13T18:00:00+00:00 EmrCreateJobFlowOperator 2021-05-13T19:12:28.439433+00:00 2021-05-13T19:12:30.181775+00:00 0:00:01.742342 27739 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 2 default 2021-05-13T19:12:26.315314+00:00 2 default_pool
success booking-processing-job_v002 create_cluster_and_add_emr_steps 2021-05-13T18:00:00+00:00 EmrCreateJobFlowOperator 2021-05-13T19:12:14.444814+00:00 2021-05-13T19:12:16.135558+00:00 0:00:01.690744 27738 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 2 default 2021-05-13T19:12:12.291275+00:00 2 default_pool
success campaign-history-job_v002 create_emr_steps 2021-05-13T18:00:00+00:00 PythonOperator 2021-05-13T19:12:06.543248+00:00 2021-05-13T19:12:09.589559+00:00 0:00:03.046311 27737 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-05-13T19:12:04.288871+00:00 2 default_pool
success booking-processing-job_v002 create_emr_steps 2021-05-13T18:00:00+00:00 PythonOperator 2021-05-13T19:11:52.359565+00:00 2021-05-13T19:11:55.622797+00:00 0:00:03.263232 27736 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-05-13T19:11:50.227882+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_booking-processing-job_v002 2021-05-13T18:00:00+00:00 TriggerDagRunOperator 2021-05-13T19:11:40.619332+00:00 2021-05-13T19:11:41.115720+00:00 0:00:00.496388 27735 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-05-13T19:11:38.221859+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_campaign-history-job_v002 2021-05-13T18:00:00+00:00 TriggerDagRunOperator 2021-05-13T19:11:40.510770+00:00 2021-05-13T19:11:41.039016+00:00 0:00:00.528246 27734 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-05-13T19:11:38.221823+00:00 2 default_pool
success vc-asset-import_v002 check_cluster_status 2021-05-13T18:05:00+00:00 EmrJobFlowSensor 2021-05-13T19:06:02.064385+00:00 2021-05-13T19:15:04.838401+00:00 0:09:02.774016 27733 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-05-13T19:05:59.873876+00:00 2 default_pool