The scheduler was not explicitly calling the returner function
This commit is contained in:
Thomas S Hatch 2013-04-28 20:24:22 -06:00
parent 2affd3ee2a
commit 827ee0ddb3

View File

@ -96,7 +96,7 @@ class Schedule(object):
rets.append(self.schedule_returner)
for returner in rets:
if returner in self.returners:
self.returners[returner](ret)
self.returners['{0}.returner'.format(returner)](ret)
else:
log.info(
'Job {1} using invalid returner: {0} Ignoring.'.format(