File tree Expand file tree Collapse file tree 2 files changed +7
-3
lines changed Expand file tree Collapse file tree 2 files changed +7
-3
lines changed Original file line number Diff line number Diff line change @@ -10,7 +10,7 @@ Job Classes
10
10
=================
11
11
12
12
.. autoclass :: pyres.job.Job
13
- :members:
13
+ :members:
14
14
15
15
Worker Classes
16
16
=================
@@ -25,4 +25,4 @@ Failure Classes
25
25
:members:
26
26
27
27
.. autoclass :: pyres.failure.RedisBackend
28
- :members:
28
+ :members:
Original file line number Diff line number Diff line change @@ -60,7 +60,6 @@ def perform(self):
60
60
called regardless of whether an exception is ultimately thrown
61
61
by the perform method.
62
62
63
- #@ add entry_point loading
64
63
65
64
"""
66
65
payload_class_str = self ._payload ["class" ]
@@ -106,6 +105,11 @@ def fail(self, exception):
106
105
return fail
107
106
108
107
def retry (self , payload_class , args ):
108
+ """This method provides a way to retry a job after a failure.
109
+ If the jobclass defined by the payload containes a ``retry_every`` attribute then pyres
110
+ will attempt to retry the job until successful or until timeout defined by ``retry_timeout`` on the payload class.
111
+
112
+ """
109
113
retry_every = getattr (payload_class , 'retry_every' , None )
110
114
retry_timeout = getattr (payload_class , 'retry_timeout' , 0 )
111
115
You can’t perform that action at this time.
0 commit comments