File tree Expand file tree Collapse file tree 1 file changed +12
-8
lines changed
Expand file tree Collapse file tree 1 file changed +12
-8
lines changed Original file line number Diff line number Diff line change @@ -237,20 +237,24 @@ def purge(self):
237237 self .metadata .expire ()
238238
239239 def start (self , ** params ):
240- return self ._project .jobq .start (self , ** params )
240+ return self .update (state = 'running' , ** params )
241+
242+ def finish (self , ** params ):
243+ return self .update (state = 'finished' , ** params )
244+
245+ def delete (self , ** params ):
246+ return self .update (state = 'deleted' , ** params )
241247
242248 def update (self , ** params ):
243- return self ._project .jobq .update (self , ** params )
249+ try :
250+ job = next (self ._project .jobq .update (self , ** params ))
251+ return job ['prevstate' ]
252+ except StopIteration :
253+ raise NotFound ("Job {} doesn't exist" .format (self .key ))
244254
245255 def cancel (self ):
246256 self ._project .jobq .request_cancel (self )
247257
248- def finish (self , ** params ):
249- return self ._project .jobq .finish (self , ** params )
250-
251- def delete (self , ** params ):
252- return self ._project .jobq .delete (self , ** params )
253-
254258
255259class _Proxy (object ):
256260 """A proxy to create a class instance and proxy its methods to origin"""
You can’t perform that action at this time.
0 commit comments