From b8aa7565150ba67b52d401b903cf56577de6a3b1 Mon Sep 17 00:00:00 2001 From: Monty Taylor Date: Thu, 5 Jul 2018 13:13:31 -0500 Subject: [PATCH] Remove Task class This is not use in the nodepool codebase anymore. The tasks submitted to the TaskManager all exist inside of shade/sdk now. Change-Id: Ie914be9f8687f4634996fb880e5c383dab7de6f0 --- nodepool/task_manager.py | 34 ---------------------------------- 1 file changed, 34 deletions(-) diff --git a/nodepool/task_manager.py b/nodepool/task_manager.py index 701760ae3..0a174c43f 100644 --- a/nodepool/task_manager.py +++ b/nodepool/task_manager.py @@ -16,12 +16,10 @@ # See the License for the specific language governing permissions and # limitations under the License. -import sys import threading import logging import queue import time -import requests.exceptions from nodepool import stats @@ -30,38 +28,6 @@ class ManagerStoppedException(Exception): pass -class Task(object): - def __init__(self, **kw): - self._wait_event = threading.Event() - self._exception = None - self._traceback = None - self._result = None - self.args = kw - - def done(self, result): - self._result = result - self._wait_event.set() - - def exception(self, e, tb): - self._exception = e - self._traceback = tb - self._wait_event.set() - - def wait(self): - self._wait_event.wait() - if self._exception: - raise self._exception.with_traceback(self._traceback) - return self._result - - def run(self, client): - try: - self.done(self.main(client)) - except requests.exceptions.ProxyError as e: - raise e - except Exception as e: - self.exception(e, sys.exc_info()[2]) - - class TaskManager(object): log = logging.getLogger("nodepool.TaskManager")