|
|
@@ -350,7 +350,7 @@ class ResultSet(ResultBase):
|
|
|
def failed(self):
|
|
|
"""Did any of the tasks fail?
|
|
|
|
|
|
- :returns: :const:`True` if any of the tasks failed.
|
|
|
+ :returns: :const:`True` if one of the tasks failed.
|
|
|
(i.e., raised an exception)
|
|
|
|
|
|
"""
|
|
|
@@ -359,7 +359,7 @@ class ResultSet(ResultBase):
|
|
|
def waiting(self):
|
|
|
"""Are any of the tasks incomplete?
|
|
|
|
|
|
- :returns: :const:`True` if any of the tasks is still
|
|
|
+ :returns: :const:`True` if one of the tasks are still
|
|
|
waiting for execution.
|
|
|
|
|
|
"""
|
|
|
@@ -368,7 +368,7 @@ class ResultSet(ResultBase):
|
|
|
def ready(self):
|
|
|
"""Did all of the tasks complete? (either by success of failure).
|
|
|
|
|
|
- :returns: :const:`True` if all of the tasks been
|
|
|
+ :returns: :const:`True` if all of the tasks has been
|
|
|
executed.
|
|
|
|
|
|
"""
|
|
|
@@ -435,7 +435,7 @@ class ResultSet(ResultBase):
|
|
|
time.sleep(interval)
|
|
|
elapsed += interval
|
|
|
if timeout and elapsed >= timeout:
|
|
|
- raise TimeoutError("The operation timed out")
|
|
|
+ raise TimeoutError('The operation timed out')
|
|
|
|
|
|
def get(self, timeout=None, propagate=True, interval=0.5):
|
|
|
"""See :meth:`join`
|
|
|
@@ -694,7 +694,7 @@ class EagerResult(AsyncResult):
|
|
|
self._state = states.REVOKED
|
|
|
|
|
|
def __repr__(self):
|
|
|
- return "<EagerResult: %s>" % self.id
|
|
|
+ return '<EagerResult: %s>' % self.id
|
|
|
|
|
|
@property
|
|
|
def result(self):
|
Ask Solem