@@ -339,7 +339,7 @@ def _local_hash_check(self, jobid, graph):
339
339
logger .debug ('Skipping cached node %s with ID %s.' ,
340
340
self .procs [jobid ]._id , jobid )
341
341
try :
342
- self ._task_finished_cb (jobid , cached = True )
342
+ self ._task_finished_cb (jobid )
343
343
self ._remove_node_dirs ()
344
344
except Exception :
345
345
logger .debug ('Error skipping cached node %s (%s).' ,
@@ -349,14 +349,13 @@ def _local_hash_check(self, jobid, graph):
349
349
return True
350
350
return False
351
351
352
- def _task_finished_cb (self , jobid , cached = False ):
352
+ def _task_finished_cb (self , jobid ):
353
353
""" Extract outputs and assign to inputs of dependent tasks
354
354
355
355
This is called when a job is completed.
356
356
"""
357
- logger .info ('[Job %d] %s (%s).' , jobid ,
358
- 'Cached' if cached else 'Completed' ,
359
- self .procs [jobid ].fullname )
357
+ logger .info ('[Job finished] jobname: %s jobid: %d' %
358
+ (self .procs [jobid ]._id , jobid ))
360
359
if self ._status_callback :
361
360
self ._status_callback (self .procs [jobid ], 'end' )
362
361
# Update job and worker queues
0 commit comments