airflow-commits mailing list archives

Site index · List index
Message view « Date » · « Thread »
Top « Date » · « Thread »
From bo...@apache.org
Subject [26/28] incubator-airflow git commit: Remove remnants
Date Mon, 13 Mar 2017 02:49:30 GMT
Remove remnants


Project: http://git-wip-us.apache.org/repos/asf/incubator-airflow/repo
Commit: http://git-wip-us.apache.org/repos/asf/incubator-airflow/commit/3927e00d
Tree: http://git-wip-us.apache.org/repos/asf/incubator-airflow/tree/3927e00d
Diff: http://git-wip-us.apache.org/repos/asf/incubator-airflow/diff/3927e00d

Branch: refs/heads/v1-8-test
Commit: 3927e00dc72f6f2d14e463ff8daba3e3bcb11b73
Parents: 8df046b
Author: Bolke de Bruin <bolke@Bolkes-MacBook-Pro.local>
Authored: Sun Mar 12 10:33:49 2017 -0700
Committer: Bolke de Bruin <bolke@Bolkes-MacBook-Pro.local>
Committed: Sun Mar 12 10:33:49 2017 -0700

----------------------------------------------------------------------
 tests/executor/__init__.py      | 13 ---------
 tests/executor/test_executor.py | 56 ------------------------------------
 2 files changed, 69 deletions(-)
----------------------------------------------------------------------


http://git-wip-us.apache.org/repos/asf/incubator-airflow/blob/3927e00d/tests/executor/__init__.py
----------------------------------------------------------------------
diff --git a/tests/executor/__init__.py b/tests/executor/__init__.py
deleted file mode 100644
index a85b772..0000000
--- a/tests/executor/__init__.py
+++ /dev/null
@@ -1,13 +0,0 @@
-# -*- coding: utf-8 -*-
-#
-# Licensed under the Apache License, Version 2.0 (the "License");
-# you may not use this file except in compliance with the License.
-# You may obtain a copy of the License at
-#
-#     http://www.apache.org/licenses/LICENSE-2.0
-#
-# Unless required by applicable law or agreed to in writing, software
-# distributed under the License is distributed on an "AS IS" BASIS,
-# WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
-# See the License for the specific language governing permissions and
-# limitations under the License.

http://git-wip-us.apache.org/repos/asf/incubator-airflow/blob/3927e00d/tests/executor/test_executor.py
----------------------------------------------------------------------
diff --git a/tests/executor/test_executor.py b/tests/executor/test_executor.py
deleted file mode 100644
index 9ec6cd4..0000000
--- a/tests/executor/test_executor.py
+++ /dev/null
@@ -1,56 +0,0 @@
-# -*- coding: utf-8 -*-
-#
-# Licensed under the Apache License, Version 2.0 (the "License");
-# you may not use this file except in compliance with the License.
-# You may obtain a copy of the License at
-#
-#     http://www.apache.org/licenses/LICENSE-2.0
-#
-# Unless required by applicable law or agreed to in writing, software
-# distributed under the License is distributed on an "AS IS" BASIS,
-# WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
-# See the License for the specific language governing permissions and
-# limitations under the License.
-from airflow.executors.base_executor import BaseExecutor
-from airflow.utils.state import State
-
-from airflow import settings
-
-
-class TestExecutor(BaseExecutor):
-    """
-    TestExecutor is used for unit testing purposes.
-    """
-    def __init__(self, do_update=False, *args, **kwargs):
-        self.do_update = do_update
-        self._running = []
-        self.history = []
-
-        super(TestExecutor, self).__init__(*args, **kwargs)
-
-    def execute_async(self, key, command, queue=None):
-        self.logger.debug("{} running task instances".format(len(self.running)))
-        self.logger.debug("{} in queue".format(len(self.queued_tasks)))
-
-    def heartbeat(self):
-        session = settings.Session()
-        if self.do_update:
-            self.history.append(list(self.queued_tasks.values()))
-            while len(self._running) > 0:
-                ti = self._running.pop()
-                ti.set_state(State.SUCCESS, session)
-            for key, val in list(self.queued_tasks.items()):
-                (command, priority, queue, ti) = val
-                ti.set_state(State.RUNNING, session)
-                self._running.append(ti)
-                self.queued_tasks.pop(key)
-
-        session.commit()
-        session.close()
-
-    def terminate(self):
-        pass
-
-    def end(self):
-        self.sync()
-


Mime
View raw message