Fix spawn attr typo, merge tractor kwargs
parent
7ca05238af
commit
1931da97f4
|
@ -96,7 +96,8 @@ async def spawn_brokerd(
|
||||||
brokermod = get_brokermod(brokername)
|
brokermod = get_brokermod(brokername)
|
||||||
dname = f'brokerd.{brokername}'
|
dname = f'brokerd.{brokername}'
|
||||||
|
|
||||||
extra_tractor_kwargs = getattr(brokermod, '_spawnkwargs', {})
|
extra_tractor_kwargs = getattr(brokermod, '_spawn_kwargs', {})
|
||||||
|
tractor_kwargs.update(extra_tractor_kwargs)
|
||||||
|
|
||||||
# TODO: raise exception when _root_nursery == None?
|
# TODO: raise exception when _root_nursery == None?
|
||||||
global _root_nursery
|
global _root_nursery
|
||||||
|
@ -104,7 +105,7 @@ async def spawn_brokerd(
|
||||||
dname,
|
dname,
|
||||||
enable_modules=_data_mods + [brokermod.__name__],
|
enable_modules=_data_mods + [brokermod.__name__],
|
||||||
loglevel=loglevel,
|
loglevel=loglevel,
|
||||||
**extra_tractor_kwargs
|
**tractor_kwargs
|
||||||
)
|
)
|
||||||
return dname
|
return dname
|
||||||
|
|
||||||
|
|
Loading…
Reference in New Issue