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_emr_steps 2021-04-13T23:00:00+00:00 PythonOperator 2021-04-14T00:10:07.111411+00:00 2021-04-14T00:10:10.625903+00:00 0:00:03.514492 16912 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-04-14T00:10:04.862643+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_campaign-history-job_v002 2021-04-13T23:00:00+00:00 TriggerDagRunOperator 2021-04-14T00:10:01.262776+00:00 2021-04-14T00:10:01.753726+00:00 0:00:00.490950 16911 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-14T00:09:58.872898+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_booking-processing-job_v002 2021-04-13T23:00:00+00:00 TriggerDagRunOperator 2021-04-14T00:10:01.275422+00:00 2021-04-14T00:10:01.851106+00:00 0:00:00.575684 16910 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-14T00:09:58.872942+00:00 2 default_pool
success vc-asset-import_v002 check_cluster_status 2021-04-13T23:05:00+00:00 EmrJobFlowSensor 2021-04-14T00:05:50.556729+00:00 2021-04-14T00:13:53.191654+00:00 0:08:02.634925 16909 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-14T00:05:48.365764+00:00 2 default_pool
success vc-asset-import_v002 create_cluster_and_add_emr_steps 2021-04-13T23:05:00+00:00 EmrCreateJobFlowOperator 2021-04-14T00:05:28.712274+00:00 2021-04-14T00:05:30.424882+00:00 0:00:01.712608 16908 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 2 default 2021-04-14T00:05:26.329343+00:00 2 default_pool
success vc-asset-import_v002 create_emr_steps 2021-04-13T23:05:00+00:00 PythonOperator 2021-04-14T00:05:06.459340+00:00 2021-04-14T00:05:09.302649+00:00 0:00:02.843309 16907 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-04-14T00:05:04.312271+00:00 2 default_pool
success campaign-flow-job_v002 check_cluster_status 2021-04-13T23:00:00+00:00 EmrJobFlowSensor 2021-04-14T00:00:54.294215+00:00 2021-04-14T00:09:56.944592+00:00 0:09:02.650377 16906 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-04-14T00:00:52.027064+00:00 2 default_pool
success campaign-flow-job_v002 create_cluster_and_add_emr_steps 2021-04-13T23:00:00+00:00 EmrCreateJobFlowOperator 2021-04-14T00:00:32.464013+00:00 2021-04-14T00:00:34.166690+00:00 0:00:01.702677 16905 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 4 default 2021-04-14T00:00:30.052747+00:00 2 default_pool
success campaign-flow-job_v002 create_emr_steps 2021-04-13T23:00:00+00:00 PythonOperator 2021-04-14T00:00:10.609626+00:00 2021-04-14T00:00:13.631506+00:00 0:00:03.021880 16904 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 5 default 2021-04-14T00:00:08.056104+00:00 2 default_pool
success campaign-history-job_v002 check_cluster_status 2021-04-13T22:00:00+00:00 EmrJobFlowSensor 2021-04-13T23:11:26.744949+00:00 2021-04-13T23:20:29.337245+00:00 0:09:02.592296 16902 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-13T23:11:24.377772+00:00 2 default_pool
success booking-processing-job_v002 check_cluster_status 2021-04-13T22:00:00+00:00 EmrJobFlowSensor 2021-04-13T23:11:14.790894+00:00 2021-04-13T23:20:17.358537+00:00 0:09:02.567643 16901 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-13T23:11:12.309596+00:00 2 default_pool
success campaign-history-job_v002 create_cluster_and_add_emr_steps 2021-04-13T22:00:00+00:00 EmrCreateJobFlowOperator 2021-04-13T23:11:06.632597+00:00 2021-04-13T23:11:08.354492+00:00 0:00:01.721895 16900 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 2 default 2021-04-13T23:11:04.346809+00:00 2 default_pool
success booking-processing-job_v002 create_cluster_and_add_emr_steps 2021-04-13T22:00:00+00:00 EmrCreateJobFlowOperator 2021-04-13T23:10:54.598644+00:00 2021-04-13T23:10:56.423912+00:00 0:00:01.825268 16899 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 2 default 2021-04-13T23:10:52.292389+00:00 2 default_pool
success campaign-history-job_v002 create_emr_steps 2021-04-13T22:00:00+00:00 PythonOperator 2021-04-13T23:10:44.804673+00:00 2021-04-13T23:10:47.762461+00:00 0:00:02.957788 16898 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-04-13T23:10:42.360815+00:00 2 default_pool
success booking-processing-job_v002 create_emr_steps 2021-04-13T22:00:00+00:00 PythonOperator 2021-04-13T23:10:32.523759+00:00 2021-04-13T23:10:35.888385+00:00 0:00:03.364626 16897 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-04-13T23:10:30.239105+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_campaign-history-job_v002 2021-04-13T22:00:00+00:00 TriggerDagRunOperator 2021-04-13T23:10:26.515952+00:00 2021-04-13T23:10:27.053542+00:00 0:00:00.537590 16896 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-13T23:10:24.235919+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_booking-processing-job_v002 2021-04-13T22:00:00+00:00 TriggerDagRunOperator 2021-04-13T23:10:26.395595+00:00 2021-04-13T23:10:26.886533+00:00 0:00:00.490938 16895 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-13T23:10:24.235955+00:00 2 default_pool
success vc-asset-import_v002 check_cluster_status 2021-04-13T22:05:00+00:00 EmrJobFlowSensor 2021-04-13T23:05:49.964320+00:00 2021-04-13T23:14:52.423073+00:00 0:09:02.458753 16894 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-13T23:05:47.823493+00:00 2 default_pool
success vc-asset-import_v002 create_cluster_and_add_emr_steps 2021-04-13T22:05:00+00:00 EmrCreateJobFlowOperator 2021-04-13T23:05:28.001205+00:00 2021-04-13T23:05:29.685542+00:00 0:00:01.684337 16893 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 2 default 2021-04-13T23:05:25.802205+00:00 2 default_pool
success vc-asset-import_v002 create_emr_steps 2021-04-13T22:05:00+00:00 PythonOperator 2021-04-13T23:05:06.074393+00:00 2021-04-13T23:05:08.956454+00:00 0:00:02.882061 16892 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-04-13T23:05:03.785795+00:00 2 default_pool
success campaign-flow-job_v002 check_cluster_status 2021-04-13T22:00:00+00:00 EmrJobFlowSensor 2021-04-13T23:01:07.846014+00:00 2021-04-13T23:10:10.610914+00:00 0:09:02.764900 16891 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-04-13T23:01:05.451019+00:00 2 default_pool
success campaign-flow-job_v002 create_cluster_and_add_emr_steps 2021-04-13T22:00:00+00:00 EmrCreateJobFlowOperator 2021-04-13T23:00:45.825380+00:00 2021-04-13T23:00:47.505018+00:00 0:00:01.679638 16890 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 4 default 2021-04-13T23:00:43.351327+00:00 2 default_pool
success campaign-flow-job_v002 create_emr_steps 2021-04-13T22:00:00+00:00 PythonOperator 2021-04-13T23:00:25.490130+00:00 2021-04-13T23:00:28.338726+00:00 0:00:02.848596 16889 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 5 default 2021-04-13T23:00:23.260151+00:00 2 default_pool
success booking-processing-job_v002 check_cluster_status 2021-04-13T21:00:00+00:00 EmrJobFlowSensor 2021-04-13T22:12:18.829600+00:00 2021-04-13T22:21:21.483982+00:00 0:09:02.654382 16887 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-13T22:12:16.546657+00:00 2 default_pool
success campaign-history-job_v002 check_cluster_status 2021-04-13T21:00:00+00:00 EmrJobFlowSensor 2021-04-13T22:12:10.751770+00:00 2021-04-13T22:22:13.674553+00:00 0:10:02.922783 16886 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-13T22:12:08.527716+00:00 2 default_pool
success booking-processing-job_v002 create_cluster_and_add_emr_steps 2021-04-13T21:00:00+00:00 EmrCreateJobFlowOperator 2021-04-13T22:11:57.029697+00:00 2021-04-13T22:11:58.768659+00:00 0:00:01.738962 16885 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 2 default 2021-04-13T22:11:54.566744+00:00 2 default_pool
success campaign-history-job_v002 create_cluster_and_add_emr_steps 2021-04-13T21:00:00+00:00 EmrCreateJobFlowOperator 2021-04-13T22:11:49.014328+00:00 2021-04-13T22:11:50.775073+00:00 0:00:01.760745 16884 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 2 default 2021-04-13T22:11:46.508569+00:00 2 default_pool
success booking-processing-job_v002 create_emr_steps 2021-04-13T21:00:00+00:00 PythonOperator 2021-04-13T22:11:35.245030+00:00 2021-04-13T22:11:38.503146+00:00 0:00:03.258116 16883 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-04-13T22:11:32.572406+00:00 2 default_pool
success campaign-history-job_v002 create_emr_steps 2021-04-13T21:00:00+00:00 PythonOperator 2021-04-13T22:11:28.678681+00:00 2021-04-13T22:11:31.549388+00:00 0:00:02.870707 16882 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-04-13T22:11:26.494988+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_campaign-history-job_v002 2021-04-13T21:00:00+00:00 TriggerDagRunOperator 2021-04-13T22:11:15.086856+00:00 2021-04-13T22:11:15.602203+00:00 0:00:00.515347 16881 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-13T22:11:12.562325+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_booking-processing-job_v002 2021-04-13T21:00:00+00:00 TriggerDagRunOperator 2021-04-13T22:11:14.995843+00:00 2021-04-13T22:11:15.432096+00:00 0:00:00.436253 16880 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-13T22:11:12.562369+00:00 2 default_pool
success vc-asset-import_v002 check_cluster_status 2021-04-13T21:05:00+00:00 EmrJobFlowSensor 2021-04-13T22:05:50.196482+00:00 2021-04-13T22:14:52.689840+00:00 0:09:02.493358 16879 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-13T22:05:48.085717+00:00 2 default_pool
success vc-asset-import_v002 create_cluster_and_add_emr_steps 2021-04-13T21:05:00+00:00 EmrCreateJobFlowOperator 2021-04-13T22:05:28.360099+00:00 2021-04-13T22:05:30.037173+00:00 0:00:01.677074 16878 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 2 default 2021-04-13T22:05:26.036515+00:00 2 default_pool
success vc-asset-import_v002 create_emr_steps 2021-04-13T21:05:00+00:00 PythonOperator 2021-04-13T22:05:08.293414+00:00 2021-04-13T22:05:11.145368+00:00 0:00:02.851954 16877 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-04-13T22:05:06.014961+00:00 2 default_pool
success campaign-flow-job_v002 check_cluster_status 2021-04-13T21:00:00+00:00 EmrJobFlowSensor 2021-04-13T22:00:59.992377+00:00 2021-04-13T22:11:02.983021+00:00 0:10:02.990644 16876 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-04-13T22:00:57.449848+00:00 2 default_pool
success campaign-flow-job_v002 create_cluster_and_add_emr_steps 2021-04-13T21:00:00+00:00 EmrCreateJobFlowOperator 2021-04-13T22:00:39.865513+00:00 2021-04-13T22:00:41.651732+00:00 0:00:01.786219 16875 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 4 default 2021-04-13T22:00:37.387530+00:00 2 default_pool
success campaign-flow-job_v002 create_emr_steps 2021-04-13T21:00:00+00:00 PythonOperator 2021-04-13T22:00:17.613388+00:00 2021-04-13T22:00:20.503122+00:00 0:00:02.889734 16874 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 5 default 2021-04-13T22:00:15.325603+00:00 2 default_pool
success campaign-history-job_v002 check_cluster_status 2021-04-13T20:00:00+00:00 EmrJobFlowSensor 2021-04-13T21:10:17.739846+00:00 2021-04-13T21:18:20.285108+00:00 0:08:02.545262 16872 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-13T21:10:15.525475+00:00 2 default_pool
success booking-processing-job_v002 check_cluster_status 2021-04-13T20:00:00+00:00 EmrJobFlowSensor 2021-04-13T21:10:09.833958+00:00 2021-04-13T21:20:12.699974+00:00 0:10:02.866016 16871 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-13T21:10:07.519722+00:00 2 default_pool
success campaign-history-job_v002 create_cluster_and_add_emr_steps 2021-04-13T20:00:00+00:00 EmrCreateJobFlowOperator 2021-04-13T21:09:55.883460+00:00 2021-04-13T21:09:57.666642+00:00 0:00:01.783182 16870 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 2 default 2021-04-13T21:09:53.508308+00:00 2 default_pool
success booking-processing-job_v002 create_cluster_and_add_emr_steps 2021-04-13T20:00:00+00:00 EmrCreateJobFlowOperator 2021-04-13T21:09:48.083772+00:00 2021-04-13T21:09:49.917125+00:00 0:00:01.833353 16869 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 2 default 2021-04-13T21:09:45.561932+00:00 2 default_pool
success campaign-history-job_v002 create_emr_steps 2021-04-13T20:00:00+00:00 PythonOperator 2021-04-13T21:09:34.320387+00:00 2021-04-13T21:09:37.262626+00:00 0:00:02.942239 16868 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-04-13T21:09:31.498105+00:00 2 default_pool
success booking-processing-job_v002 create_emr_steps 2021-04-13T20:00:00+00:00 PythonOperator 2021-04-13T21:09:26.001174+00:00 2021-04-13T21:09:29.154101+00:00 0:00:03.152927 16867 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-04-13T21:09:23.487318+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_booking-processing-job_v002 2021-04-13T20:00:00+00:00 TriggerDagRunOperator 2021-04-13T21:09:21.902883+00:00 2021-04-13T21:09:22.502029+00:00 0:00:00.599146 16866 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-13T21:09:19.464432+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_campaign-history-job_v002 2021-04-13T20:00:00+00:00 TriggerDagRunOperator 2021-04-13T21:09:21.728120+00:00 2021-04-13T21:09:22.191085+00:00 0:00:00.462965 16865 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-13T21:09:19.464401+00:00 2 default_pool
success vc-asset-import_v002 check_cluster_status 2021-04-13T20:05:00+00:00 EmrJobFlowSensor 2021-04-13T21:05:53.271500+00:00 2021-04-13T21:13:55.725336+00:00 0:08:02.453836 16864 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-13T21:05:51.164566+00:00 2 default_pool
success vc-asset-import_v002 create_cluster_and_add_emr_steps 2021-04-13T20:05:00+00:00 EmrCreateJobFlowOperator 2021-04-13T21:05:31.375789+00:00 2021-04-13T21:05:33.037585+00:00 0:00:01.661796 16863 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 2 default 2021-04-13T21:05:29.157395+00:00 2 default_pool
success vc-asset-import_v002 create_emr_steps 2021-04-13T20:05:00+00:00 PythonOperator 2021-04-13T21:05:09.680511+00:00 2021-04-13T21:05:12.900448+00:00 0:00:03.219937 16862 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-04-13T21:05:07.101461+00:00 2 default_pool
success campaign-flow-job_v002 check_cluster_status 2021-04-13T20:00:00+00:00 EmrJobFlowSensor 2021-04-13T21:01:00.924833+00:00 2021-04-13T21:09:03.501163+00:00 0:08:02.576330 16861 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-04-13T21:00:58.656882+00:00 2 default_pool
success campaign-flow-job_v002 create_cluster_and_add_emr_steps 2021-04-13T20:00:00+00:00 EmrCreateJobFlowOperator 2021-04-13T21:00:39.079907+00:00 2021-04-13T21:00:40.901293+00:00 0:00:01.821386 16860 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 4 default 2021-04-13T21:00:36.562129+00:00 2 default_pool
success campaign-flow-job_v002 create_emr_steps 2021-04-13T20:00:00+00:00 PythonOperator 2021-04-13T21:00:19.308381+00:00 2021-04-13T21:00:22.166808+00:00 0:00:02.858427 16859 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 5 default 2021-04-13T21:00:16.546303+00:00 2 default_pool
success booking-processing-job_v002 check_cluster_status 2021-04-13T19:00:00+00:00 EmrJobFlowSensor 2021-04-13T20:11:06.203097+00:00 2021-04-13T20:21:09.013674+00:00 0:10:02.810577 16857 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-13T20:11:03.756663+00:00 2 default_pool
success campaign-history-job_v002 check_cluster_status 2021-04-13T19:00:00+00:00 EmrJobFlowSensor 2021-04-13T20:10:54.054698+00:00 2021-04-13T20:20:56.869550+00:00 0:10:02.814852 16856 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-13T20:10:51.661107+00:00 2 default_pool
success booking-processing-job_v002 create_cluster_and_add_emr_steps 2021-04-13T19:00:00+00:00 EmrCreateJobFlowOperator 2021-04-13T20:10:45.953217+00:00 2021-04-13T20:10:47.666869+00:00 0:00:01.713652 16855 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 2 default 2021-04-13T20:10:43.643865+00:00 2 default_pool
success campaign-history-job_v002 create_cluster_and_add_emr_steps 2021-04-13T19:00:00+00:00 EmrCreateJobFlowOperator 2021-04-13T20:10:31.745306+00:00 2021-04-13T20:10:33.430925+00:00 0:00:01.685619 16854 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 2 default 2021-04-13T20:10:29.288465+00:00 2 default_pool
success booking-processing-job_v002 create_emr_steps 2021-04-13T19:00:00+00:00 PythonOperator 2021-04-13T20:10:23.581698+00:00 2021-04-13T20:10:26.756060+00:00 0:00:03.174362 16853 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-04-13T20:10:21.345955+00:00 2 default_pool
success campaign-history-job_v002 create_emr_steps 2021-04-13T19:00:00+00:00 PythonOperator 2021-04-13T20:10:11.774604+00:00 2021-04-13T20:10:14.687695+00:00 0:00:02.913091 16852 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-04-13T20:10:09.190642+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_booking-processing-job_v002 2021-04-13T19:00:00+00:00 TriggerDagRunOperator 2021-04-13T20:09:59.748329+00:00 2021-04-13T20:10:00.378740+00:00 0:00:00.630411 16851 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-13T20:09:57.247504+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_campaign-history-job_v002 2021-04-13T19:00:00+00:00 TriggerDagRunOperator 2021-04-13T20:09:59.574414+00:00 2021-04-13T20:10:00.006447+00:00 0:00:00.432033 16850 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-13T20:09:57.247463+00:00 2 default_pool
success primary-audience-global-ind_v003 create_cluster 2021-04-13T20:06:40.292961+00:00 PythonOperator 2021-04-13T20:07:07.071442+00:00 2021-04-13T20:07:10.438198+00:00 0:00:03.366756 16849 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-13T20:07:04.918182+00:00 2 default_pool
success primary-audience-global-ind_v003 validation 2021-04-13T20:06:40.292961+00:00 PythonOperator 2021-04-13T20:06:45.266743+00:00 2021-04-13T20:06:45.639925+00:00 0:00:00.373182 16848 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 2 default 2021-04-13T20:06:42.890769+00:00 2 default_pool
success vc-asset-import_v002 check_cluster_status 2021-04-13T19:05:00+00:00 EmrJobFlowSensor 2021-04-13T20:05:54.880687+00:00 2021-04-13T20:14:57.441658+00:00 0:09:02.560971 16847 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-13T20:05:52.707589+00:00 2 default_pool
success vc-asset-import_v002 create_cluster_and_add_emr_steps 2021-04-13T19:05:00+00:00 EmrCreateJobFlowOperator 2021-04-13T20:05:34.933905+00:00 2021-04-13T20:05:36.727998+00:00 0:00:01.794093 16846 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 2 default 2021-04-13T20:05:32.685438+00:00 2 default_pool
success vc-asset-import_v002 create_emr_steps 2021-04-13T19:05:00+00:00 PythonOperator 2021-04-13T20:05:12.861771+00:00 2021-04-13T20:05:16.087028+00:00 0:00:03.225257 16845 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-04-13T20:05:10.647504+00:00 2 default_pool
success campaign-flow-job_v002 check_cluster_status 2021-04-13T19:00:00+00:00 EmrJobFlowSensor 2021-04-13T20:00:52.667732+00:00 2021-04-13T20:09:55.434705+00:00 0:09:02.766973 16844 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-04-13T20:00:50.396636+00:00 2 default_pool
success campaign-flow-job_v002 create_cluster_and_add_emr_steps 2021-04-13T19:00:00+00:00 EmrCreateJobFlowOperator 2021-04-13T20:00:30.813155+00:00 2021-04-13T20:00:32.514841+00:00 0:00:01.701686 16843 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 4 default 2021-04-13T20:00:28.440862+00:00 2 default_pool
success campaign-flow-job_v002 create_emr_steps 2021-04-13T19:00:00+00:00 PythonOperator 2021-04-13T20:00:08.617819+00:00 2021-04-13T20:00:11.559576+00:00 0:00:02.941757 16842 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 5 default 2021-04-13T20:00:06.206515+00:00 2 default_pool
success booking-processing-job_v002 check_cluster_status 2021-04-13T18:00:00+00:00 EmrJobFlowSensor 2021-04-13T19:10:26.375077+00:00 2021-04-13T19:20:29.242697+00:00 0:10:02.867620 16840 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-13T19:10:24.204121+00:00 2 default_pool
success campaign-history-job_v002 check_cluster_status 2021-04-13T18:00:00+00:00 EmrJobFlowSensor 2021-04-13T19:10:18.438388+00:00 2021-04-13T19:19:21.092961+00:00 0:09:02.654573 16839 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-13T19:10:16.196888+00:00 2 default_pool
success booking-processing-job_v002 create_cluster_and_add_emr_steps 2021-04-13T18:00:00+00:00 EmrCreateJobFlowOperator 2021-04-13T19:10:04.541036+00:00 2021-04-13T19:10:06.518039+00:00 0:00:01.977003 16838 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 2 default 2021-04-13T19:10:02.186193+00:00 2 default_pool
success campaign-history-job_v002 create_cluster_and_add_emr_steps 2021-04-13T18:00:00+00:00 EmrCreateJobFlowOperator 2021-04-13T19:09:56.493662+00:00 2021-04-13T19:09:58.307432+00:00 0:00:01.813770 16837 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 2 default 2021-04-13T19:09:54.115197+00:00 2 default_pool
success booking-processing-job_v002 create_emr_steps 2021-04-13T18:00:00+00:00 PythonOperator 2021-04-13T19:09:42.371568+00:00 2021-04-13T19:09:45.525021+00:00 0:00:03.153453 16836 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-04-13T19:09:40.104706+00:00 2 default_pool
success campaign-history-job_v002 create_emr_steps 2021-04-13T18:00:00+00:00 PythonOperator 2021-04-13T19:09:36.233001+00:00 2021-04-13T19:09:39.127848+00:00 0:00:02.894847 16835 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-04-13T19:09:34.097643+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_campaign-history-job_v002 2021-04-13T18:00:00+00:00 TriggerDagRunOperator 2021-04-13T19:09:20.367603+00:00 2021-04-13T19:09:20.914632+00:00 0:00:00.547029 16834 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-13T19:09:18.084131+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_booking-processing-job_v002 2021-04-13T18:00:00+00:00 TriggerDagRunOperator 2021-04-13T19:09:20.275336+00:00 2021-04-13T19:09:20.713745+00:00 0:00:00.438409 16833 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-13T19:09:18.084158+00:00 2 default_pool
success vc-asset-import_v002 check_cluster_status 2021-04-13T18:05:00+00:00 EmrJobFlowSensor 2021-04-13T19:05:50.167136+00:00 2021-04-13T19:14:52.795616+00:00 0:09:02.628480 16832 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-13T19:05:47.762349+00:00 2 default_pool
success vc-asset-import_v002 create_cluster_and_add_emr_steps 2021-04-13T18:05:00+00:00 EmrCreateJobFlowOperator 2021-04-13T19:05:30.132717+00:00 2021-04-13T19:05:31.756800+00:00 0:00:01.624083 16831 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 2 default 2021-04-13T19:05:27.751099+00:00 2 default_pool
success vc-asset-import_v002 create_emr_steps 2021-04-13T18:05:00+00:00 PythonOperator 2021-04-13T19:05:07.827769+00:00 2021-04-13T19:05:10.812789+00:00 0:00:02.985020 16830 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-04-13T19:05:05.538068+00:00 2 default_pool
success campaign-flow-job_v002 check_cluster_status 2021-04-13T18:00:00+00:00 EmrJobFlowSensor 2021-04-13T19:01:05.336252+00:00 2021-04-13T19:09:07.874128+00:00 0:08:02.537876 16829 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-04-13T19:01:03.047756+00:00 2 default_pool
success campaign-flow-job_v002 create_cluster_and_add_emr_steps 2021-04-13T18:00:00+00:00 EmrCreateJobFlowOperator 2021-04-13T19:00:35.327652+00:00 2021-04-13T19:00:37.082721+00:00 0:00:01.755069 16828 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 4 default 2021-04-13T19:00:33.008174+00:00 2 default_pool
success campaign-flow-job_v002 create_emr_steps 2021-04-13T18:00:00+00:00 PythonOperator 2021-04-13T19:00:13.646849+00:00 2021-04-13T19:00:16.581679+00:00 0:00:02.934830 16827 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 5 default 2021-04-13T19:00:10.989747+00:00 2 default_pool
success booking-processing-job_v002 check_cluster_status 2021-04-13T17:00:00+00:00 EmrJobFlowSensor 2021-04-13T18:11:23.241362+00:00 2021-04-13T18:21:25.838291+00:00 0:10:02.596929 16825 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-13T18:11:20.414871+00:00 2 default_pool
success campaign-history-job_v002 check_cluster_status 2021-04-13T17:00:00+00:00 EmrJobFlowSensor 2021-04-13T18:11:20.665111+00:00 2021-04-13T18:20:23.482573+00:00 0:09:02.817462 16824 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-13T18:11:18.412682+00:00 2 default_pool
success booking-processing-job_v002 create_cluster_and_add_emr_steps 2021-04-13T17:00:00+00:00 EmrCreateJobFlowOperator 2021-04-13T18:11:01.121743+00:00 2021-04-13T18:11:02.870903+00:00 0:00:01.749160 16823 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 2 default 2021-04-13T18:10:58.466754+00:00 2 default_pool
success campaign-history-job_v002 create_cluster_and_add_emr_steps 2021-04-13T17:00:00+00:00 EmrCreateJobFlowOperator 2021-04-13T18:10:58.676704+00:00 2021-04-13T18:11:00.477884+00:00 0:00:01.801180 16822 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 2 default 2021-04-13T18:10:56.079549+00:00 2 default_pool
success booking-processing-job_v002 create_emr_steps 2021-04-13T17:00:00+00:00 PythonOperator 2021-04-13T18:10:38.244940+00:00 2021-04-13T18:10:41.304047+00:00 0:00:03.059107 16821 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-04-13T18:10:36.008596+00:00 2 default_pool
success campaign-history-job_v002 create_emr_steps 2021-04-13T17:00:00+00:00 PythonOperator 2021-04-13T18:10:38.302614+00:00 2021-04-13T18:10:41.255977+00:00 0:00:02.953363 16820 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-04-13T18:10:36.008638+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_campaign-history-job_v002 2021-04-13T17:00:00+00:00 TriggerDagRunOperator 2021-04-13T18:10:20.390838+00:00 2021-04-13T18:10:20.822224+00:00 0:00:00.431386 16819 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-13T18:10:17.985989+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_booking-processing-job_v002 2021-04-13T17:00:00+00:00 TriggerDagRunOperator 2021-04-13T18:10:20.420566+00:00 2021-04-13T18:10:20.955495+00:00 0:00:00.534929 16818 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-13T18:10:17.986016+00:00 2 default_pool
success vc-asset-import_v002 check_cluster_status 2021-04-13T17:05:00+00:00 EmrJobFlowSensor 2021-04-13T18:06:03.754815+00:00 2021-04-13T18:15:06.334442+00:00 0:09:02.579627 16817 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-13T18:06:01.538200+00:00 2 default_pool
success vc-asset-import_v002 create_cluster_and_add_emr_steps 2021-04-13T17:05:00+00:00 EmrCreateJobFlowOperator 2021-04-13T18:05:41.724426+00:00 2021-04-13T18:05:43.331669+00:00 0:00:01.607243 16816 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 2 default 2021-04-13T18:05:39.519871+00:00 2 default_pool
success vc-asset-import_v002 create_emr_steps 2021-04-13T17:05:00+00:00 PythonOperator 2021-04-13T18:05:19.757615+00:00 2021-04-13T18:05:22.669471+00:00 0:00:02.911856 16815 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-04-13T18:05:17.501141+00:00 2 default_pool
success campaign-flow-job_v002 check_cluster_status 2021-04-13T17:00:00+00:00 EmrJobFlowSensor 2021-04-13T18:01:03.430187+00:00 2021-04-13T18:10:06.073677+00:00 0:09:02.643490 16814 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-04-13T18:01:01.033796+00:00 2 default_pool
success campaign-flow-job_v002 create_cluster_and_add_emr_steps 2021-04-13T17:00:00+00:00 EmrCreateJobFlowOperator 2021-04-13T18:00:43.340043+00:00 2021-04-13T18:00:45.001131+00:00 0:00:01.661088 16813 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 4 default 2021-04-13T18:00:41.012372+00:00 2 default_pool
success campaign-flow-job_v002 create_emr_steps 2021-04-13T17:00:00+00:00 PythonOperator 2021-04-13T18:00:21.250760+00:00 2021-04-13T18:00:24.260353+00:00 0:00:03.009593 16812 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 5 default 2021-04-13T18:00:18.999526+00:00 2 default_pool
success campaign-history-job_v002 check_cluster_status 2021-04-13T16:00:00+00:00 EmrJobFlowSensor 2021-04-13T17:39:59.233439+00:00 2021-04-13T17:40:00.796818+00:00 0:00:01.563379 16811 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-13T17:39:56.891119+00:00 3 default_pool
success booking-processing-job_v002 check_cluster_status 2021-04-13T16:00:00+00:00 EmrJobFlowSensor 2021-04-13T17:39:58.076540+00:00 2021-04-13T17:39:59.634496+00:00 0:00:01.557956 16810 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-13T17:39:54.887969+00:00 3 default_pool
success booking-processing-job_v002 create_cluster_and_add_emr_steps 2021-04-13T16:00:00+00:00 EmrCreateJobFlowOperator 2021-04-13T17:28:01.942180+00:00 2021-04-13T17:28:03.658844+00:00 0:00:01.716664 16807 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 2 default 2021-04-13T17:27:59.645496+00:00 2 default_pool
success campaign-history-job_v002 create_cluster_and_add_emr_steps 2021-04-13T16:00:00+00:00 EmrCreateJobFlowOperator 2021-04-13T17:27:57.993953+00:00 2021-04-13T17:27:59.865643+00:00 0:00:01.871690 16806 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 2 default 2021-04-13T17:27:55.672211+00:00 2 default_pool
success booking-processing-job_v002 create_emr_steps 2021-04-13T16:00:00+00:00 PythonOperator 2021-04-13T17:27:40.037585+00:00 2021-04-13T17:27:43.164438+00:00 0:00:03.126853 16805 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-04-13T17:27:37.598385+00:00 2 default_pool