@@ -181,7 +181,7 @@ def _update_nodelist(self, job, nodespec):
181181 job ._nodelist .sort ()
182182
183183 def poll (self , * jobs ):
184- def out_ready (job ):
184+ def output_ready (job ):
185185 # We report a job as finished only when its stdout/stderr are
186186 # written back to the working directory
187187 stdout = os .path .join (job .workdir , job .stdout )
@@ -209,7 +209,7 @@ def out_ready(job):
209209 f'assuming all jobs completed' )
210210 for job in jobs :
211211 job ._state = 'COMPLETED'
212- if job .cancelled or out_ready (job ):
212+ if job .cancelled or output_ready (job ):
213213 job ._completed = True
214214 else :
215215 self .log (f'Job { job .jobid } output has not been written '
@@ -239,7 +239,7 @@ def out_ready(job):
239239 self .log (f'Job { job .jobid } not known to scheduler, '
240240 f'assuming job completed' )
241241 job ._state = 'COMPLETED'
242- if job .cancelled or out_ready (job ):
242+ if job .cancelled or output_ready (job ):
243243 job ._completed = True
244244 else :
245245 self .log (f'Job { job .jobid } output has not been written '
@@ -277,7 +277,7 @@ def out_ready(job):
277277
278278 # We report a job as finished only when its stdout/stderr are
279279 # written back to the working directory
280- done = job .cancelled or out_ready (job )
280+ done = job .cancelled or output_ready (job )
281281 if done :
282282 job ._completed = True
283283 elif (job .state in ['QUEUED' , 'HELD' , 'WAITING' ] and
0 commit comments