"...ssh:/git@developer.sourcefind.cn:2222/OpenDAS/dynamo.git" did not exist on "b48d4c3bbaf9b5f6b44f544445000c1b6ab303cf"
Unverified Commit a936ba5a authored by Neal Vaidya's avatar Neal Vaidya Committed by GitHub
Browse files

fix: read store_kv arg from env when using decorator (#5421)


Signed-off-by: default avatarNeal Vaidya <nealv@nvidia.com>
parent 2430fcac
...@@ -36,7 +36,8 @@ def dynamo_worker(enable_nats: bool = True): ...@@ -36,7 +36,8 @@ def dynamo_worker(enable_nats: bool = True):
async def wrapper(*args, **kwargs): async def wrapper(*args, **kwargs):
loop = asyncio.get_running_loop() loop = asyncio.get_running_loop()
request_plane = os.environ.get("DYN_REQUEST_PLANE", "tcp") request_plane = os.environ.get("DYN_REQUEST_PLANE", "tcp")
runtime = DistributedRuntime(loop, "etcd", request_plane, enable_nats) store_kv = os.environ.get("DYN_STORE_KV", "etcd")
runtime = DistributedRuntime(loop, store_kv, request_plane, enable_nats)
await func(runtime, *args, **kwargs) await func(runtime, *args, **kwargs)
......
Markdown is supported
0% or .
You are about to add 0 people to the discussion. Proceed with caution.
Finish editing this message first!
Please register or to comment