@@ -179,9 +179,9 @@ def list(self, count=None, start=None, spider=None, state=None,
179179 lacks_tag = lacks_tag , startts = startts , endts = endts )
180180 return list (self .iter (** params ))
181181
182- def schedule (self , spider = None , units = None , priority = None , meta = None ,
183- add_tag = None , job_args = None , job_settings = None , cmd_args = None ,
184- ** params ):
182+ def run (self , spider = None , units = None , priority = None , meta = None ,
183+ add_tag = None , job_args = None , job_settings = None , cmd_args = None ,
184+ ** params ):
185185 """Schedule a new job and returns its job key.
186186
187187 :param spider: a spider name string
@@ -200,7 +200,7 @@ def schedule(self, spider=None, units=None, priority=None, meta=None,
200200
201201 Usage::
202202
203- >>> project.jobs.schedule ('spider1', job_args={'arg1': 'val1'})
203+ >>> project.jobs.run ('spider1', job_args={'arg1': 'val1'})
204204 '123/1/1'
205205 """
206206 if not spider and not self .spider :
@@ -218,10 +218,9 @@ def schedule(self, spider=None, units=None, priority=None, meta=None,
218218 update_kwargs (params , units = units , priority = priority , add_tag = add_tag ,
219219 cmd_args = cmd_args , job_settings = job_settings , meta = meta )
220220
221- # FIXME improve to schedule multiple jobs
221+ # FIXME improve to run multiple jobs
222222 try :
223- response = self ._client ._connection ._post (
224- 'schedule' , 'json' , params )
223+ response = self ._client ._connection ._post ('run' , 'json' , params )
225224 except BadRequest as exc :
226225 if 'already scheduled' in str (exc ):
227226 raise DuplicateJobError (exc )
0 commit comments