reimplement scanPlugin() as a wrapper around findHandlers()

This commit is contained in:
Mike Bonnet 2010-07-16 11:39:41 -04:00
parent 6e543a71b2
commit 0b485cd813
3 changed files with 6 additions and 2 deletions

View file

@ -75,7 +75,7 @@ def main(options, session):
pt = koji.plugin.PluginTracker(path=options.pluginpath.split(':'))
for name in options.plugin:
logger.info('Loading plugin: %s' % name)
tm.findHandlers(vars(pt.load(name)))
tm.scanPlugin(pt.load(name))
def shutdown(*args):
raise SystemExit
signal.signal(signal.SIGTERM,shutdown)

View file

@ -435,6 +435,10 @@ class TaskManager(object):
for method in v.Methods:
self.handlers[method] = v
def scanPlugin(self, plugin):
"""Find task handlers in a plugin"""
self.findHandlers(vars(plugin))
def shutdown(self):
"""Attempt to shut down cleanly"""
for task_id in self.pids.keys():

View file

@ -175,7 +175,7 @@ def main(options, session):
pt = koji.plugin.PluginTracker(path=options.pluginpath.split(':'))
for name in options.plugin:
logger.info('Loading plugin: %s' % name)
tm.findHandlers(vars(pt.load(name)))
tm.scanPlugin(pt.load(name))
def shutdown(*args):
raise SystemExit
signal.signal(signal.SIGTERM,shutdown)