|
|
@ -4,7 +4,7 @@ import times
|
|
|
|
from uuid import uuid4
|
|
|
|
from uuid import uuid4
|
|
|
|
try:
|
|
|
|
try:
|
|
|
|
from cPickle import loads, dumps, UnpicklingError
|
|
|
|
from cPickle import loads, dumps, UnpicklingError
|
|
|
|
except ImportError: # noqa
|
|
|
|
except ImportError: # noqa
|
|
|
|
from pickle import loads, dumps, UnpicklingError # noqa
|
|
|
|
from pickle import loads, dumps, UnpicklingError # noqa
|
|
|
|
from .local import LocalStack
|
|
|
|
from .local import LocalStack
|
|
|
|
from .connections import resolve_connection
|
|
|
|
from .connections import resolve_connection
|
|
|
@ -16,8 +16,9 @@ def enum(name, *sequential, **named):
|
|
|
|
values = dict(zip(sequential, range(len(sequential))), **named)
|
|
|
|
values = dict(zip(sequential, range(len(sequential))), **named)
|
|
|
|
return type(name, (), values)
|
|
|
|
return type(name, (), values)
|
|
|
|
|
|
|
|
|
|
|
|
Status = enum('Status', QUEUED='queued', FINISHED='finished', FAILED='failed',
|
|
|
|
Status = enum('Status',
|
|
|
|
STARTED='started')
|
|
|
|
QUEUED='queued', FINISHED='finished', FAILED='failed',
|
|
|
|
|
|
|
|
STARTED='started')
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
def unpickle(pickled_string):
|
|
|
|
def unpickle(pickled_string):
|
|
|
@ -287,7 +288,7 @@ class Job(object):
|
|
|
|
self._result = unpickle(obj.get('result')) if obj.get('result') else None # noqa
|
|
|
|
self._result = unpickle(obj.get('result')) if obj.get('result') else None # noqa
|
|
|
|
self.exc_info = obj.get('exc_info')
|
|
|
|
self.exc_info = obj.get('exc_info')
|
|
|
|
self.timeout = int(obj.get('timeout')) if obj.get('timeout') else None
|
|
|
|
self.timeout = int(obj.get('timeout')) if obj.get('timeout') else None
|
|
|
|
self.result_ttl = int(obj.get('result_ttl')) if obj.get('result_ttl') else None # noqa
|
|
|
|
self.result_ttl = int(obj.get('result_ttl')) if obj.get('result_ttl') else None # noqa
|
|
|
|
self._status = as_text(obj.get('status') if obj.get('status') else None)
|
|
|
|
self._status = as_text(obj.get('status') if obj.get('status') else None)
|
|
|
|
self.meta = unpickle(obj.get('meta')) if obj.get('meta') else {}
|
|
|
|
self.meta = unpickle(obj.get('meta')) if obj.get('meta') else {}
|
|
|
|
|
|
|
|
|
|
|
@ -354,7 +355,6 @@ class Job(object):
|
|
|
|
assert self.id == _job_stack.pop()
|
|
|
|
assert self.id == _job_stack.pop()
|
|
|
|
return self._result
|
|
|
|
return self._result
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
def get_ttl(self, default_ttl=None):
|
|
|
|
def get_ttl(self, default_ttl=None):
|
|
|
|
"""Returns ttl for a job that determines how long a job and its result
|
|
|
|
"""Returns ttl for a job that determines how long a job and its result
|
|
|
|
will be persisted. In the future, this method will also be responsible
|
|
|
|
will be persisted. In the future, this method will also be responsible
|
|
|
@ -390,7 +390,6 @@ class Job(object):
|
|
|
|
connection = pipeline if pipeline is not None else self.connection
|
|
|
|
connection = pipeline if pipeline is not None else self.connection
|
|
|
|
connection.expire(self.key, ttl)
|
|
|
|
connection.expire(self.key, ttl)
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
def __str__(self):
|
|
|
|
def __str__(self):
|
|
|
|
return '<Job %s: %s>' % (self.id, self.description)
|
|
|
|
return '<Job %s: %s>' % (self.id, self.description)
|
|
|
|
|
|
|
|
|
|
|
|