Warning

This document is for an old release 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__)



[docs]def build_state_handlers():
    return _get_state_handlers_dict()



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