Warning
This document is for an in-development version of Galaxy. You can alternatively view this page in the latest release if it exists or view the top of the latest release's documentation.
Source code for galaxy.jobs.runners.state_handler_factory
import logging
import galaxy.jobs.runners.state_handlers
from galaxy.util.submodules import import_submodules
log = logging.getLogger(__name__)
def _get_state_handlers_dict():
state_handlers = {}
for module in import_submodules(galaxy.jobs.runners.state_handlers, ordered=True):
for func in getattr(module, "__all__", []):
if func not in state_handlers:
state_handlers[func] = []
state_handlers[func].append(getattr(module, func))
log.debug("Loaded '%s' state handler from module %s", func, module.__name__)
return state_handlers