Merge "Fake mode service does not start after the changes to the oslo service package changes."
This commit is contained in:
commit
f995d833b5
@ -49,10 +49,10 @@ def main(conf):
|
||||
def start_fake_taskmanager(conf):
|
||||
topic = conf.taskmanager_queue
|
||||
from trove.common.rpc import service as rpc_service
|
||||
from trove.taskmanager import manager
|
||||
manager_impl = manager.Manager()
|
||||
taskman_service = rpc_service.Service(None, topic=topic,
|
||||
manager=manager_impl)
|
||||
from trove.common.rpc import version as rpc_version
|
||||
taskman_service = rpc_service.RpcService(
|
||||
topic=topic, rpc_api_version=rpc_version.RPC_API_VERSION,
|
||||
manager='trove.taskmanager.manager.Manager')
|
||||
taskman_service.start()
|
||||
|
||||
|
||||
|
Loading…
x
Reference in New Issue
Block a user