pikers
/
piker
3
0
Fork 0
Code Issues 2 Pull Requests 5 Packages Projects Releases Wiki Activity

Set tractor actor name at startup

kivy_mainline_and_py3.8
Tyler Goodlet 2018-07-05 15:31:21 -04:00
parent aa259433f5
commit 73eedfd7b3
1 changed files with 7 additions and 9 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

16
piker/cli.py
View File

@ -29,14 +29,14 @@ def pikerd(loglevel, host):
""" """
get_console_log(loglevel) get_console_log(loglevel)
tractor.run( tractor.run(
None, # no main task None, # no main task - this is a daemon
statespace={ statespace={
'boker2tickersubs': {}, 'broker2tickersubs': {},
'clients': {}, 'clients': {},
'dtasks': set(), 'dtasks': set(),
}, },
outlive_main=True, # run daemon forever outlive_main=True, # run daemon forever
rpc_module_paths=['piker.broker.core'], rpc_module_paths=['piker.brokers.core'],
name='brokerd', name='brokerd',
) )
@ -140,9 +140,9 @@ def watch(loglevel, broker, rate, name, dhost):
async def launch_client(sleep=0.5, tries=10): async def launch_client(sleep=0.5, tries=10):
async with tractor.find_actor('brokerd') as portals: async with tractor.open_nursery() as nursery:
async with tractor.open_nursery() as nursery: async with tractor.find_actor('brokerd') as portal:
if not portals: if not portal:
log.warn("No broker daemon could be found") log.warn("No broker daemon could be found")
log.warning("Spawning local brokerd..") log.warning("Spawning local brokerd..")
portal = await nursery.start_actor( portal = await nursery.start_actor(
@ -157,13 +157,11 @@ def watch(loglevel, broker, rate, name, dhost):
rpc_module_paths=['piker.brokers.core'], rpc_module_paths=['piker.brokers.core'],
loglevel=loglevel, loglevel=loglevel,
) )
else:
portal = portals[0]
# run kivy app # run kivy app
await _async_main(name, portal, tickers, brokermod, rate) await _async_main(name, portal, tickers, brokermod, rate)
tractor.run(partial(launch_client, tries=1)) tractor.run(partial(launch_client, tries=1), name='kivy-watchlist')
@cli.group() @cli.group()