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 test-1-dag-on-cn-airflow task_3 2020-05-22T00:00:00+00:00 BashOperator 2021-02-01T06:41:08.910712+00:00 2021-02-01T06:41:09.720404+00:00 0:00:00.809692 8260 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 2 default 2021-02-01T06:41:01.518472+00:00 2 default_pool
success test-1-dag-on-cn-airflow task_2 2020-05-19T00:00:00+00:00 BashOperator 2021-02-01T06:41:08.990399+00:00 2021-02-01T06:41:09.737681+00:00 0:00:00.747282 8259 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 2 default 2021-02-01T06:41:01.518539+00:00 2 default_pool
success test-1-dag-on-cn-airflow task_3 2020-05-20T00:00:00+00:00 BashOperator 2021-02-01T06:41:08.715144+00:00 2021-02-01T06:41:09.521355+00:00 0:00:00.806211 8258 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 2 default 2021-02-01T06:41:01.518518+00:00 2 default_pool
success test-1-dag-on-cn-airflow task_1 2020-05-23T00:00:00+00:00 BashOperator 2021-02-01T06:41:08.453931+00:00 2021-02-01T06:41:09.177383+00:00 0:00:00.723452 8257 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 4 default 2021-02-01T06:41:01.518496+00:00 2 default_pool
success test-2-dag-on-cn-airflow task_4 2020-05-21T00:00:00+00:00 BashOperator 2021-02-01T06:40:55.775571+00:00 2021-02-01T06:40:56.028398+00:00 0:00:00.252827 8256 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-02-01T06:40:51.505732+00:00 2 default_pool
success test-2-dag-on-cn-airflow task_2 2020-05-22T00:00:00+00:00 BashOperator 2021-02-01T06:40:55.703546+00:00 2021-02-01T06:40:56.008168+00:00 0:00:00.304622 8255 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 2 default 2021-02-01T06:40:51.505803+00:00 2 default_pool
success test-2-dag-on-cn-airflow task_1 2020-05-23T00:00:00+00:00 BashOperator 2021-02-01T06:40:55.543085+00:00 2021-02-01T06:40:56.001040+00:00 0:00:00.457955 8254 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 4 default 2021-02-01T06:40:51.505823+00:00 2 default_pool
success test-2-dag-on-cn-airflow task_3 2020-05-22T00:00:00+00:00 BashOperator 2021-02-01T06:40:55.540914+00:00 2021-02-01T06:40:55.969920+00:00 0:00:00.429006 8253 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 2 default 2021-02-01T06:40:51.505780+00:00 2 default_pool
success test-1-dag-on-cn-airflow task_2 2020-05-21T00:00:00+00:00 BashOperator 2021-02-01T06:40:51.992839+00:00 2021-02-01T06:40:52.626988+00:00 0:00:00.634149 8252 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 2 default 2021-02-01T06:40:47.502389+00:00 2 default_pool
success test-1-dag-on-cn-airflow task_1 2020-05-22T00:00:00+00:00 BashOperator 2021-02-01T06:40:51.630116+00:00 2021-02-01T06:40:52.201462+00:00 0:00:00.571346 8251 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 4 default 2021-02-01T06:40:47.502411+00:00 2 default_pool
success test-1-dag-on-cn-airflow task_3 2020-05-21T00:00:00+00:00 BashOperator 2021-02-01T06:40:50.104062+00:00 2021-02-01T06:40:50.348903+00:00 0:00:00.244841 8250 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 2 default 2021-02-01T06:40:47.502346+00:00 2 default_pool
success test-2-dag-on-cn-airflow task_2 2020-05-21T00:00:00+00:00 BashOperator 2021-02-01T06:40:43.298284+00:00 2021-02-01T06:40:43.570980+00:00 0:00:00.272696 8249 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 2 default 2021-02-01T06:40:39.490945+00:00 2 default_pool
success test-2-dag-on-cn-airflow task_4 2020-05-20T00:00:00+00:00 BashOperator 2021-02-01T06:40:43.268706+00:00 2021-02-01T06:40:43.544057+00:00 0:00:00.275351 8248 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-02-01T06:40:39.490897+00:00 2 default_pool
success test-2-dag-on-cn-airflow task_1 2020-05-22T00:00:00+00:00 BashOperator 2021-02-01T06:40:42.648801+00:00 2021-02-01T06:40:42.931366+00:00 0:00:00.282565 8247 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 4 default 2021-02-01T06:40:39.490956+00:00 2 default_pool
success test-2-dag-on-cn-airflow task_3 2020-05-21T00:00:00+00:00 BashOperator 2021-02-01T06:40:42.646491+00:00 2021-02-01T06:40:42.939383+00:00 0:00:00.292892 8246 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 2 default 2021-02-01T06:40:39.490932+00:00 2 default_pool
success test-1-dag-on-cn-airflow task_1 2020-05-21T00:00:00+00:00 BashOperator 2021-02-01T06:40:35.099746+00:00 2021-02-01T06:40:35.337024+00:00 0:00:00.237278 8245 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 4 default 2021-02-01T06:40:33.495523+00:00 2 default_pool
success test-2-dag-on-cn-airflow task_3 2020-05-20T00:00:00+00:00 BashOperator 2021-02-01T06:40:29.210948+00:00 2021-02-01T06:40:29.801001+00:00 0:00:00.590053 8243 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 2 default 2021-02-01T06:40:25.477362+00:00 2 default_pool
success test-2-dag-on-cn-airflow task_2 2020-05-20T00:00:00+00:00 BashOperator 2021-02-01T06:40:29.117205+00:00 2021-02-01T06:40:29.611128+00:00 0:00:00.493923 8242 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 2 default 2021-02-01T06:40:25.477375+00:00 2 default_pool
success test-2-dag-on-cn-airflow task_1 2020-05-21T00:00:00+00:00 BashOperator 2021-02-01T06:40:28.767021+00:00 2021-02-01T06:40:29.089537+00:00 0:00:00.322516 8241 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 4 default 2021-02-01T06:40:25.477386+00:00 2 default_pool
success test-2-dag-on-cn-airflow task_4 2020-05-19T00:00:00+00:00 BashOperator 2021-02-01T06:40:28.678043+00:00 2021-02-01T06:40:29.007813+00:00 0:00:00.329770 8240 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-02-01T06:40:25.477327+00:00 2 default_pool
success test-1-dag-on-cn-airflow task_1 2020-05-20T00:00:00+00:00 BashOperator 2021-02-01T06:40:21.830265+00:00 2021-02-01T06:40:21.995804+00:00 0:00:00.165539 8239 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 4 default 2021-02-01T06:40:19.473793+00:00 2 default_pool
success test-1-dag-on-cn-airflow task_3 2020-05-19T00:00:00+00:00 BashOperator 2021-02-01T06:40:21.089681+00:00 2021-02-01T06:40:21.332596+00:00 0:00:00.242915 8238 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 2 default 2021-02-01T06:40:19.473760+00:00 2 default_pool
success test-2-dag-on-cn-airflow task_3 2020-05-19T00:00:00+00:00 BashOperator 2021-02-01T06:40:17.950813+00:00 2021-02-01T06:40:18.226611+00:00 0:00:00.275798 8237 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 2 default 2021-02-01T06:40:11.449357+00:00 2 default_pool
success test-2-dag-on-cn-airflow task_4 2020-05-18T00:00:00+00:00 BashOperator 2021-02-01T06:40:17.861388+00:00 2021-02-01T06:40:18.171311+00:00 0:00:00.309923 8236 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-02-01T06:40:11.449329+00:00 2 default_pool
success test-2-dag-on-cn-airflow task_2 2020-05-19T00:00:00+00:00 BashOperator 2021-02-01T06:40:17.765101+00:00 2021-02-01T06:40:18.094545+00:00 0:00:00.329444 8235 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 2 default 2021-02-01T06:40:11.449370+00:00 2 default_pool
success test-2-dag-on-cn-airflow task_1 2020-05-20T00:00:00+00:00 BashOperator 2021-02-01T06:40:16.766141+00:00 2021-02-01T06:40:17.207377+00:00 0:00:00.441236 8233 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 4 default 2021-02-01T06:40:11.449380+00:00 2 default_pool
success test-1-dag-on-cn-airflow task_3 2020-05-18T00:00:00+00:00 BashOperator 2021-02-01T06:40:13.567839+00:00 2021-02-01T06:40:14.958659+00:00 0:00:01.390820 8232 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 2 default 2021-02-01T06:40:07.446301+00:00 2 default_pool
success test-1-dag-on-cn-airflow task_4 2020-05-17T00:00:00+00:00 BashOperator 2021-02-01T06:40:13.381721+00:00 2021-02-01T06:40:14.460508+00:00 0:00:01.078787 8231 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-02-01T06:40:07.446265+00:00 2 default_pool
success test-1-dag-on-cn-airflow task_1 2020-05-19T00:00:00+00:00 BashOperator 2021-02-01T06:40:12.153637+00:00 2021-02-01T06:40:13.257634+00:00 0:00:01.103997 8230 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 4 default 2021-02-01T06:40:07.446325+00:00 2 default_pool
success test-1-dag-on-cn-airflow task_2 2020-05-18T00:00:00+00:00 BashOperator 2021-02-01T06:40:09.620624+00:00 2021-02-01T06:40:09.796747+00:00 0:00:00.176123 8229 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 2 default 2021-02-01T06:40:07.446314+00:00 2 default_pool
success test-2-dag-on-cn-airflow task_4 2020-05-17T00:00:00+00:00 BashOperator 2021-02-01T06:40:02.788490+00:00 2021-02-01T06:40:03.368320+00:00 0:00:00.579830 8227 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-02-01T06:39:59.444139+00:00 2 default_pool
success test-2-dag-on-cn-airflow task_2 2020-05-18T00:00:00+00:00 BashOperator 2021-02-01T06:40:02.745433+00:00 2021-02-01T06:40:03.266388+00:00 0:00:00.520955 8226 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 2 default 2021-02-01T06:39:59.444182+00:00 2 default_pool
success test-2-dag-on-cn-airflow task_3 2020-05-18T00:00:00+00:00 BashOperator 2021-02-01T06:40:02.360141+00:00 2021-02-01T06:40:02.586805+00:00 0:00:00.226664 8225 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 2 default 2021-02-01T06:39:59.444169+00:00 2 default_pool
success test-2-dag-on-cn-airflow task_1 2020-05-19T00:00:00+00:00 BashOperator 2021-02-01T06:40:02.315407+00:00 2021-02-01T06:40:02.531855+00:00 0:00:00.216448 8224 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 4 default 2021-02-01T06:39:59.444192+00:00 2 default_pool
success test-1-dag-on-cn-airflow task_1 2020-05-18T00:00:00+00:00 BashOperator 2021-02-01T06:39:56.506706+00:00 2021-02-01T06:39:56.838943+00:00 0:00:00.332237 8223 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 4 default 2021-02-01T06:39:53.439227+00:00 2 default_pool
success test-1-dag-on-cn-airflow task_3 2020-05-17T00:00:00+00:00 BashOperator 2021-02-01T06:39:56.430337+00:00 2021-02-01T06:39:56.743121+00:00 0:00:00.312784 8222 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 2 default 2021-02-01T06:39:53.439179+00:00 2 default_pool
success test-1-dag-on-cn-airflow task_2 2020-05-17T00:00:00+00:00 BashOperator 2021-02-01T06:39:54.949926+00:00 2021-02-01T06:39:55.215542+00:00 0:00:00.265616 8221 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 2 default 2021-02-01T06:39:53.439214+00:00 2 default_pool
success test-2-dag-on-cn-airflow task_3 2020-05-17T00:00:00+00:00 BashOperator 2021-02-01T06:39:48.241586+00:00 2021-02-01T06:39:48.444902+00:00 0:00:00.203316 8220 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 2 default 2021-02-01T06:39:45.427028+00:00 2 default_pool
success test-2-dag-on-cn-airflow task_2 2020-05-17T00:00:00+00:00 BashOperator 2021-02-01T06:39:48.177920+00:00 2021-02-01T06:39:48.389745+00:00 0:00:00.211825 8219 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 2 default 2021-02-01T06:39:45.427064+00:00 2 default_pool
success test-2-dag-on-cn-airflow task_1 2020-05-18T00:00:00+00:00 BashOperator 2021-02-01T06:39:46.932456+00:00 2021-02-01T06:39:47.193687+00:00 0:00:00.261231 8218 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 4 default 2021-02-01T06:39:45.427077+00:00 2 default_pool
success test-1-dag-on-cn-airflow task_1 2020-05-17T00:00:00+00:00 BashOperator 2021-02-01T06:39:40.810387+00:00 2021-02-01T06:39:40.970888+00:00 0:00:00.160501 8217 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 4 default 2021-02-01T06:39:39.429988+00:00 2 default_pool
success test-2-dag-on-cn-airflow task_1 2020-05-17T00:00:00+00:00 BashOperator 2021-02-01T06:39:32.793659+00:00 2021-02-01T06:39:32.953003+00:00 0:00:00.159344 8216 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 4 default 2021-02-01T06:39:31.408567+00:00 2 default_pool
success Custom-EMR-cluster_v001 create_cluster_n_add_steps 2020-12-30T12:58:54.515684+00:00 PythonOperator 2020-12-30T12:59:05.525095+00:00 2020-12-30T12:59:08.317901+00:00 0:00:02.792806 6744 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2020-12-30T12:59:03.713266+00:00 2 default_pool
success Custom-EMR-cluster_v001 create_cluster_n_add_steps 2020-12-29T17:57:45.104202+00:00 PythonOperator 2020-12-29T17:57:55.054054+00:00 2020-12-29T17:57:57.791429+00:00 0:00:02.737375 6724 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2020-12-29T17:57:53.189995+00:00 2 default_pool
success primary-audience-global-cassandra_v003 create_cluster 2020-12-28T14:04:24.342511+00:00 PythonOperator 2020-12-28T14:04:46.619830+00:00 2020-12-28T14:04:49.628002+00:00 0:00:03.008172 6696 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2020-12-28T14:04:44.750836+00:00 2 default_pool
success primary-audience-global-cassandra_v003 validation 2020-12-28T14:04:24.342511+00:00 PythonOperator 2020-12-28T14:04:32.429056+00:00 2020-12-28T14:04:32.661136+00:00 0:00:00.232080 6695 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 2 default 2020-12-28T14:04:30.747706+00:00 2 default_pool
success primary-audience-global-cassandra_v003 create_cluster 2020-12-28T13:21:41.392150+00:00 PythonOperator 2020-12-28T13:22:09.890224+00:00 2020-12-28T13:22:12.762295+00:00 0:00:02.872071 6693 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2020-12-28T13:22:08.133467+00:00 2 default_pool
success primary-audience-global-cassandra_v003 validation 2020-12-28T13:21:41.392150+00:00 PythonOperator 2020-12-28T13:21:57.833069+00:00 2020-12-28T13:21:58.013100+00:00 0:00:00.180031 6692 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 2 default 2020-12-28T13:21:56.122421+00:00 2 default_pool
success Custom-EMR-cluster_v001 create_cluster_n_add_steps 2020-12-28T13:04:04.301449+00:00 PythonOperator 2020-12-28T13:04:16.928530+00:00 2020-12-28T13:04:19.604580+00:00 0:00:02.676050 6691 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2020-12-28T13:04:15.122524+00:00 2 default_pool
success primary-audience-global-cassandra_v003 create_cluster 2020-12-28T12:19:09.895604+00:00 PythonOperator 2020-12-28T12:19:33.569348+00:00 2020-12-28T12:19:36.624333+00:00 0:00:03.054985 6689 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2020-12-28T12:19:31.819181+00:00 2 default_pool
success primary-audience-global-cassandra_v003 validation 2020-12-28T12:19:09.895604+00:00 PythonOperator 2020-12-28T12:19:21.592357+00:00 2020-12-28T12:19:21.892978+00:00 0:00:00.300621 6688 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 2 default 2020-12-28T12:19:19.807178+00:00 2 default_pool
success primary-audience-global-cassandra_v003 create_cluster 2020-12-28T06:59:53.268603+00:00 PythonOperator 2020-12-28T07:00:31.347053+00:00 2020-12-28T07:00:34.370206+00:00 0:00:03.023153 6682 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2020-12-28T07:00:29.491504+00:00 2 default_pool
success primary-audience-global-cassandra_v003 validation 2020-12-28T06:59:53.268603+00:00 PythonOperator 2020-12-28T07:00:19.282769+00:00 2020-12-28T07:00:19.572463+00:00 0:00:00.289694 6681 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 2 default 2020-12-28T07:00:17.480725+00:00 2 default_pool
success primary-audience-global-cassandra_v003 create_cluster 2020-12-24T15:26:09.307725+00:00 PythonOperator 2020-12-24T15:26:37.315923+00:00 2020-12-24T15:26:40.352470+00:00 0:00:03.036547 6592 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2020-12-24T15:26:35.627748+00:00 2 default_pool
success primary-audience-global-cassandra_v003 validation 2020-12-24T15:26:09.307725+00:00 PythonOperator 2020-12-24T15:26:25.366259+00:00 2020-12-24T15:26:25.669415+00:00 0:00:00.303156 6591 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 2 default 2020-12-24T15:26:23.612790+00:00 2 default_pool
success primary-audience-global-cassandra_v003 create_cluster 2020-12-24T13:42:30.523984+00:00 PythonOperator 2020-12-24T13:43:22.316530+00:00 2020-12-24T13:43:25.339781+00:00 0:00:03.023251 6589 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2020-12-24T13:43:20.650619+00:00 2 default_pool
success primary-audience-global-cassandra_v003 validation 2020-12-24T13:42:30.523984+00:00 PythonOperator 2020-12-24T13:42:58.765498+00:00 2020-12-24T13:42:59.039438+00:00 0:00:00.273940 6588 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 2 default 2020-12-24T13:42:56.640043+00:00 2 default_pool
success Custom-EMR-cluster_v001 create_cluster_n_add_steps 2020-12-24T13:14:29.080912+00:00 PythonOperator 2020-12-24T13:14:43.800012+00:00 2020-12-24T13:14:46.434996+00:00 0:00:02.634984 6586 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2020-12-24T13:14:42.102069+00:00 2 default_pool
success primary-audience-global-cassandra_v003 create_cluster 2020-12-24T12:45:23.588300+00:00 PythonOperator 2020-12-24T12:45:42.193458+00:00 2020-12-24T12:45:45.087002+00:00 0:00:02.893544 6585 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2020-12-24T12:45:40.488463+00:00 2 default_pool
success primary-audience-global-cassandra_v003 validation 2020-12-24T12:45:23.588300+00:00 PythonOperator 2020-12-24T12:45:30.162084+00:00 2020-12-24T12:45:30.353599+00:00 0:00:00.191515 6584 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 2 default 2020-12-24T12:45:28.477742+00:00 2 default_pool
success Custom-EMR-cluster_v001 create_cluster_n_add_steps 2020-12-24T09:08:43.242879+00:00 PythonOperator 2020-12-24T09:08:47.920351+00:00 2020-12-24T09:08:50.525429+00:00 0:00:02.605078 6579 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2020-12-24T09:08:46.279767+00:00 2 default_pool
success booking-processing-job_v002 check_cluster_status 2020-11-18T13:00:00+00:00 EmrJobFlowSensor 2020-11-18T14:11:47.569740+00:00 2020-11-18T14:23:50.447731+00:00 0:12:02.877991 5722 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2020-11-18T14:11:45.793013+00:00 2 default_pool
success booking-processing-job_v002 create_emr_steps 2020-11-18T14:11:35.930647+00:00 PythonOperator 2020-11-18T14:11:47.476299+00:00 2020-11-18T14:11:50.399725+00:00 0:00:02.923426 5721 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2020-11-18T14:11:45.792980+00:00 2 default_pool
success booking-processing-job_v002 create_cluster_and_add_emr_steps 2020-11-18T13:00:00+00:00 EmrCreateJobFlowOperator 2020-11-18T14:11:39.472737+00:00 2020-11-18T14:11:41.159640+00:00 0:00:01.686903 5720 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 2 default 2020-11-18T14:11:37.783763+00:00 2 default_pool
success booking-processing-job_v002 create_emr_steps 2020-11-18T13:00:00+00:00 PythonOperator 2020-11-18T14:11:29.449633+00:00 2020-11-18T14:11:32.278850+00:00 0:00:02.829217 5719 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2020-11-18T14:11:27.765827+00:00 2 default_pool
success campaign-delta-past-delete-job_v002 check_cluster_status 2020-11-16T23:00:00+00:00 EmrJobFlowSensor 2020-11-17T23:00:23.678482+00:00 2020-11-17T23:09:26.199196+00:00 0:09:02.520714 5703 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2020-11-17T23:00:22.130517+00:00 2 default_pool
success campaign-delta-past-delete-job_v002 create_cluster_and_add_emr_steps 2020-11-16T23:00:00+00:00 EmrCreateJobFlowOperator 2020-11-17T23:00:13.799650+00:00 2020-11-17T23:00:15.471026+00:00 0:00:01.671376 5702 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 2 default 2020-11-17T23:00:12.161855+00:00 2 default_pool
success campaign-delta-past-delete-job_v002 create_emr_steps 2020-11-16T23:00:00+00:00 PythonOperator 2020-11-17T23:00:05.687852+00:00 2020-11-17T23:00:08.501452+00:00 0:00:02.813600 5701 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2020-11-17T23:00:04.116341+00:00 2 default_pool
success campaign-delta-past-delete-job_v002 check_cluster_status 2020-11-15T23:00:00+00:00 EmrJobFlowSensor 2020-11-16T23:00:31.659528+00:00 2020-11-16T23:10:34.359678+00:00 0:10:02.700150 5676 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2020-11-16T23:00:30.060413+00:00 2 default_pool
success campaign-delta-past-delete-job_v002 create_cluster_and_add_emr_steps 2020-11-15T23:00:00+00:00 EmrCreateJobFlowOperator 2020-11-16T23:00:21.625158+00:00 2020-11-16T23:00:23.220487+00:00 0:00:01.595329 5675 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 2 default 2020-11-16T23:00:20.050530+00:00 2 default_pool
success campaign-delta-past-delete-job_v002 create_emr_steps 2020-11-15T23:00:00+00:00 PythonOperator 2020-11-16T23:00:11.686325+00:00 2020-11-16T23:00:14.482720+00:00 0:00:02.796395 5674 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2020-11-16T23:00:10.044342+00:00 2 default_pool
success campaign-delta-past-delete-job_v002 check_cluster_status 2020-11-14T23:00:00+00:00 EmrJobFlowSensor 2020-11-15T23:00:23.104748+00:00 2020-11-15T23:09:25.554845+00:00 0:09:02.450097 5649 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2020-11-15T23:00:21.539873+00:00 2 default_pool
success campaign-delta-past-delete-job_v002 create_cluster_and_add_emr_steps 2020-11-14T23:00:00+00:00 EmrCreateJobFlowOperator 2020-11-15T23:00:13.165099+00:00 2020-11-15T23:00:14.710893+00:00 0:00:01.545794 5648 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 2 default 2020-11-15T23:00:11.529504+00:00 2 default_pool
success campaign-delta-past-delete-job_v002 create_emr_steps 2020-11-14T23:00:00+00:00 PythonOperator 2020-11-15T23:00:03.202875+00:00 2020-11-15T23:00:05.950238+00:00 0:00:02.747363 5647 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2020-11-15T23:00:01.534089+00:00 2 default_pool
success campaign-delta-past-delete-job_v002 check_cluster_status 2020-11-13T23:00:00+00:00 EmrJobFlowSensor 2020-11-14T23:00:29.843665+00:00 2020-11-14T23:09:32.339129+00:00 0:09:02.495464 5622 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2020-11-14T23:00:28.210051+00:00 2 default_pool
success campaign-delta-past-delete-job_v002 create_cluster_and_add_emr_steps 2020-11-13T23:00:00+00:00 EmrCreateJobFlowOperator 2020-11-14T23:00:19.849177+00:00 2020-11-14T23:00:21.535450+00:00 0:00:01.686273 5621 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 2 default 2020-11-14T23:00:18.199331+00:00 2 default_pool
success campaign-delta-past-delete-job_v002 create_emr_steps 2020-11-13T23:00:00+00:00 PythonOperator 2020-11-14T23:00:09.845770+00:00 2020-11-14T23:00:12.583841+00:00 0:00:02.738071 5620 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2020-11-14T23:00:08.196803+00:00 2 default_pool
success campaign-delta-past-delete-job_v002 check_cluster_status 2020-11-12T23:00:00+00:00 EmrJobFlowSensor 2020-11-13T23:00:46.583070+00:00 2020-11-13T23:10:49.220192+00:00 0:10:02.637122 5595 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2020-11-13T23:00:44.990564+00:00 2 default_pool
success campaign-delta-past-delete-job_v002 create_cluster_and_add_emr_steps 2020-11-12T23:00:00+00:00 EmrCreateJobFlowOperator 2020-11-13T23:00:28.532738+00:00 2020-11-13T23:00:30.189871+00:00 0:00:01.657133 5594 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 2 default 2020-11-13T23:00:26.967642+00:00 2 default_pool
success campaign-delta-past-delete-job_v002 create_emr_steps 2020-11-12T23:00:00+00:00 PythonOperator 2020-11-13T23:00:10.494573+00:00 2020-11-13T23:00:13.154807+00:00 0:00:02.660234 5593 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2020-11-13T23:00:08.951679+00:00 2 default_pool
success campaign-delta-past-delete-job_v002 check_cluster_status 2020-11-11T23:00:00+00:00 EmrJobFlowSensor 2020-11-12T23:00:28.307300+00:00 2020-11-12T23:10:30.997757+00:00 0:10:02.690457 5569 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2020-11-12T23:00:26.689200+00:00 2 default_pool
success campaign-delta-past-delete-job_v002 create_cluster_and_add_emr_steps 2020-11-11T23:00:00+00:00 EmrCreateJobFlowOperator 2020-11-12T23:00:18.272194+00:00 2020-11-12T23:00:19.910650+00:00 0:00:01.638456 5568 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 2 default 2020-11-12T23:00:16.671050+00:00 2 default_pool
success campaign-delta-past-delete-job_v002 create_emr_steps 2020-11-11T23:00:00+00:00 PythonOperator 2020-11-12T23:00:08.283400+00:00 2020-11-12T23:00:10.995858+00:00 0:00:02.712458 5567 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2020-11-12T23:00:06.662872+00:00 2 default_pool
success campaign-delta-past-delete-job_v002 check_cluster_status 2020-11-10T23:00:00+00:00 EmrJobFlowSensor 2020-11-11T23:00:27.066764+00:00 2020-11-11T23:10:29.768469+00:00 0:10:02.701705 5542 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2020-11-11T23:00:25.386783+00:00 2 default_pool
success campaign-delta-past-delete-job_v002 create_cluster_and_add_emr_steps 2020-11-10T23:00:00+00:00 EmrCreateJobFlowOperator 2020-11-11T23:00:17.018724+00:00 2020-11-11T23:00:18.590904+00:00 0:00:01.572180 5541 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 2 default 2020-11-11T23:00:15.389215+00:00 2 default_pool
success campaign-delta-past-delete-job_v002 create_emr_steps 2020-11-10T23:00:00+00:00 PythonOperator 2020-11-11T23:00:08.951066+00:00 2020-11-11T23:00:11.639213+00:00 0:00:02.688147 5540 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2020-11-11T23:00:07.381838+00:00 2 default_pool
success campaign-delta-past-delete-job_v002 check_cluster_status 2020-11-09T23:00:00+00:00 EmrJobFlowSensor 2020-11-10T23:00:22.965656+00:00 2020-11-10T23:10:25.668593+00:00 0:10:02.702937 5515 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2020-11-10T23:00:21.199021+00:00 2 default_pool
success campaign-delta-past-delete-job_v002 create_cluster_and_add_emr_steps 2020-11-09T23:00:00+00:00 EmrCreateJobFlowOperator 2020-11-10T23:00:13.053735+00:00 2020-11-10T23:00:14.675955+00:00 0:00:01.622220 5514 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 2 default 2020-11-10T23:00:11.191765+00:00 2 default_pool
success campaign-delta-past-delete-job_v002 create_emr_steps 2020-11-09T23:00:00+00:00 PythonOperator 2020-11-10T23:00:02.886386+00:00 2020-11-10T23:00:05.571486+00:00 0:00:02.685100 5513 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2020-11-10T23:00:01.199917+00:00 2 default_pool
success Custom-EMR-cluster_v001 create_cluster_n_add_steps 2020-11-10T15:14:41.887887+00:00 PythonOperator 2020-11-10T15:14:45.398827+00:00 2020-11-10T15:14:48.073576+00:00 0:00:02.674749 5504 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2020-11-10T15:14:43.566229+00:00 2 default_pool
success Custom-EMR-cluster_v001 create_cluster_n_add_steps 2020-11-10T06:56:52.091410+00:00 PythonOperator 2020-11-10T06:56:58.201598+00:00 2020-11-10T06:57:00.956569+00:00 0:00:02.754971 5495 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2020-11-10T06:56:56.458741+00:00 2 default_pool
success booking-processing-job_v002 check_cluster_status 2020-11-10T05:00:00+00:00 EmrJobFlowSensor 2020-11-10T06:22:55.268979+00:00 2020-11-10T06:34:58.241120+00:00 0:12:02.972141 5493 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2020-11-10T06:22:53.625611+00:00 2 default_pool
success booking-processing-job_v002 create_cluster_and_add_emr_steps 2020-11-10T05:00:00+00:00 EmrCreateJobFlowOperator 2020-11-10T06:22:45.625851+00:00 2020-11-10T06:22:47.321684+00:00 0:00:01.695833 5492 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 2 default 2020-11-10T06:22:43.627481+00:00 2 default_pool
success booking-processing-job_v002 create_emr_steps 2020-11-10T05:00:00+00:00 PythonOperator 2020-11-10T06:10:30.667516+00:00 2020-11-10T06:10:33.449874+00:00 0:00:02.782358 5491 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2020-11-10T06:10:28.955299+00:00 2 default_pool
success booking-processing-job_v002 check_cluster_status 2020-11-10T04:00:00+00:00 EmrJobFlowSensor 2020-11-10T06:10:30.677910+00:00 2020-11-10T06:22:33.775462+00:00 0:12:03.097552 5490 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2020-11-10T06:10:28.955330+00:00 2 default_pool
success booking-processing-job_v002 create_cluster_and_add_emr_steps 2020-11-10T04:00:00+00:00 EmrCreateJobFlowOperator 2020-11-10T06:10:22.676402+00:00 2020-11-10T06:10:24.399713+00:00 0:00:01.723311 5489 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 2 default 2020-11-10T06:10:20.953695+00:00 2 default_pool
success booking-processing-job_v002 check_cluster_status 2020-11-06T12:00:54.278096+00:00 EmrJobFlowSensor 2020-11-10T05:58:08.102350+00:00 2020-11-10T06:10:11.144630+00:00 0:12:03.042280 5488 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2020-11-10T05:58:06.310279+00:00 2 default_pool
success booking-processing-job_v002 create_emr_steps 2020-11-10T04:00:00+00:00 PythonOperator 2020-11-10T05:58:08.018370+00:00 2020-11-10T05:58:11.164217+00:00 0:00:03.145847 5487 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2020-11-10T05:58:06.310251+00:00 2 default_pool
success booking-processing-job_v002 create_cluster_and_add_emr_steps 2020-11-06T12:00:54.278096+00:00 EmrCreateJobFlowOperator 2020-11-10T05:58:00.056031+00:00 2020-11-10T05:58:01.847646+00:00 0:00:01.791615 5486 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 2 default 2020-11-10T05:57:58.288057+00:00 2 default_pool
success campaign-delta-past-delete-job_v002 check_cluster_status 2020-11-08T23:00:00+00:00 EmrJobFlowSensor 2020-11-09T23:00:27.597271+00:00 2020-11-09T23:10:30.235522+00:00 0:10:02.638251 5478 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2020-11-09T23:00:25.942624+00:00 2 default_pool