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
This commit is contained in:
Monty Taylor 2018-07-05 13:13:31 -05:00
parent 87bbe26ab5
commit b8aa756515
No known key found for this signature in database
GPG Key ID: 7BAE94BC7141A594
1 changed files with 0 additions and 34 deletions

View File

@ -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")