Compare commits

...

3 Commits

3 changed files with 15 additions and 8 deletions

View File

@ -471,11 +471,15 @@ def search(
''' '''
# global opts # global opts
brokermods = list(config['brokermods'].values()) brokermods: list[ModuleType] = list(config['brokermods'].values())
# TODO: this is coming from the `search --pdb` NOT from
# the `piker --pdb` XD ..
# -[ ] pull from the parent click ctx's values..dumdum
# assert pdb
# define tractor entrypoint # define tractor entrypoint
async def main(func): async def main(func):
async with maybe_open_pikerd( async with maybe_open_pikerd(
loglevel=config['loglevel'], loglevel=config['loglevel'],
debug_mode=pdb, debug_mode=pdb,

View File

@ -140,11 +140,10 @@ def pikerd(
if pdb: if pdb:
log.warning(( log.warning((
"\n" '\n\n'
"!!! YOU HAVE ENABLED DAEMON DEBUG MODE !!!\n" '!!! YOU HAVE ENABLED DAEMON DEBUG MODE !!!\n'
"When a `piker` daemon crashes it will block the " 'When a `piker` daemon crashes it will block the '
"task-thread until resumed from console!\n" 'task-thread until resumed from console!\n'
"\n"
)) ))
# service-actor registry endpoint socket-address set # service-actor registry endpoint socket-address set
@ -177,7 +176,7 @@ def pikerd(
from .. import service from .. import service
async def main(): async def main():
service_mngr: service.Services service_mngr: service.ServiceMngr
async with ( async with (
service.open_pikerd( service.open_pikerd(

View File

@ -119,6 +119,10 @@ async def open_piker_runtime(
# spawn other specialized daemons I think? # spawn other specialized daemons I think?
enable_modules=enable_modules, enable_modules=enable_modules,
# TODO: how to configure this?
# keep it on by default if debug mode is set?
maybe_enable_greenback=False,
**tractor_kwargs, **tractor_kwargs,
) as actor, ) as actor,