from heat.engine import service as engine
db_api.configure()
+ config.register_engine_opts()
srv = engine.EngineService(cfg.CONF.host, rpc_api.ENGINE_TOPIC)
launcher = service.launch(srv)
launcher.wait()
from oslo.config import cfg
import webob
-from heat.common import config
from heat.common import context
from heat.db import api as db_api
from heat.engine import api
super(EngineService, self).__init__(host, topic)
# stg == "Stack Thread Groups"
self.stg = {}
- config.register_engine_opts()
def _start_in_thread(self, stack_id, func, *args, **kwargs):
if stack_id not in self.stg: