equal
deleted
inserted
replaced
26 from pyramid.interfaces import IApplicationCreated |
26 from pyramid.interfaces import IApplicationCreated |
27 from zope.interface.interfaces import ComponentLookupError |
27 from zope.interface.interfaces import ComponentLookupError |
28 |
28 |
29 # import packages |
29 # import packages |
30 from pyams_scheduler.process import SchedulerProcess, SchedulerMessageHandler |
30 from pyams_scheduler.process import SchedulerProcess, SchedulerMessageHandler |
31 from pyams_utils.registry import set_local_registry |
31 from pyams_utils.registry import set_local_registry, get_global_registry |
32 from pyams_utils.zodb import get_connection_from_settings |
32 from pyams_utils.zodb import get_connection_from_settings |
33 from pyams_zmq.process import process_exit_func |
33 from pyams_zmq.process import process_exit_func |
34 from pyramid.events import subscriber |
34 from pyramid.events import subscriber |
35 from pyramid.settings import asbool |
35 from pyramid.settings import asbool |
36 from zope.component.globalregistry import getGlobalSiteManager |
|
37 |
36 |
38 |
37 |
39 def include_package(config): |
38 def include_package(config): |
40 """Pyramid package include""" |
39 """Pyramid package include""" |
41 |
40 |
57 |
56 |
58 # Check for upgrade mode |
57 # Check for upgrade mode |
59 if sys.argv[0].endswith('pyams_upgrade'): |
58 if sys.argv[0].endswith('pyams_upgrade'): |
60 return |
59 return |
61 |
60 |
62 registry = getGlobalSiteManager() |
61 registry = get_global_registry() |
63 settings = registry.settings |
62 settings = registry.settings |
64 start_handler = asbool(settings.get(SCHEDULER_STARTER_KEY, False)) |
63 start_handler = asbool(settings.get(SCHEDULER_STARTER_KEY, False)) |
65 if start_handler: |
64 if start_handler: |
66 # get database connection |
65 # get database connection |
67 connection = get_connection_from_settings(settings) |
66 connection = get_connection_from_settings(settings) |