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 <[email protected]> Authored: Sun Mar 12 10:33:49 2017 -0700 Committer: Bolke de Bruin <[email protected]> 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() -
