Fixed reference to rpc_api
This commit is contained in:
parent
d6b53bf7ab
commit
d36562ac5a
@ -33,12 +33,11 @@ if os.path.exists(os.path.join(POSSIBLE_TOPDIR, 'senlin', '__init__.py')):
|
|||||||
from oslo_config import cfg
|
from oslo_config import cfg
|
||||||
from oslo_i18n import _lazy
|
from oslo_i18n import _lazy
|
||||||
|
|
||||||
|
from senlin.common import attr
|
||||||
from senlin.common import messaging
|
from senlin.common import messaging
|
||||||
from senlin.openstack.common import log as logging
|
from senlin.openstack.common import log as logging
|
||||||
from senlin.openstack.common import service
|
from senlin.openstack.common import service
|
||||||
|
|
||||||
from senlin.rpc import api as rpc_api
|
|
||||||
|
|
||||||
_lazy.enable_lazy()
|
_lazy.enable_lazy()
|
||||||
|
|
||||||
LOG = logging.getLogger('senlin.engine')
|
LOG = logging.getLogger('senlin.engine')
|
||||||
@ -51,7 +50,7 @@ if __name__ == '__main__':
|
|||||||
|
|
||||||
from senlin.engine import service as engine
|
from senlin.engine import service as engine
|
||||||
|
|
||||||
srv = engine.EngineService(cfg.CONF.host, rpc_api.ENGINE_TOPIC)
|
srv = engine.EngineService(cfg.CONF.host, attr.ENGINE_TOPIC)
|
||||||
launcher = service.launch(srv, workers=cfg.CONF.num_engine_workers)
|
launcher = service.launch(srv, workers=cfg.CONF.num_engine_workers)
|
||||||
# the following periodic tasks are intended serve as HA checking
|
# the following periodic tasks are intended serve as HA checking
|
||||||
# srv.create_periodic_tasks()
|
# srv.create_periodic_tasks()
|
||||||
|
Loading…
Reference in New Issue
Block a user