pikers
/
piker
3
0
Fork 0
Code Issues 4 Pull Requests 6 Packages Projects Releases Wiki Activity

Ensure we set the test config dir in the root actor.. 

Not sure how this worked before but we need to also override the
`piker._config_dir: Path` in the root actor when running in `pytest`; my
guess is something in the old test suite was masking this problem after
the change to passing the dir path down through the runtime vars via
`tractor`?

Also this drops the ems related fixtures/factories since they're
specific enough to define in the clearing engine tests directly.
pre_overruns_ctxcancelled
Tyler Goodlet 2023-04-04 12:59:30 -04:00
parent 426f3ff38b
commit 0de2101eb4
1 changed files with 8 additions and 35 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

43
tests/conftest.py
View File

@ -5,6 +5,7 @@ import os
from pathlib import Path from pathlib import Path
import pytest import pytest
import pytest_trio
import tractor import tractor
from piker import ( from piker import (
config, config,
@ -13,7 +14,6 @@ from piker.service import (
Services, Services,
) )
from piker.log import get_console_log from piker.log import get_console_log
from piker.clearing._client import open_ems
def pytest_addoption(parser): def pytest_addoption(parser):
@ -122,6 +122,8 @@ async def _open_test_pikerd(
# or just in sequence per test, so we keep root. # or just in sequence per test, so we keep root.
drop_root_perms_for_ahab=False, drop_root_perms_for_ahab=False,
debug_mode=True,
**kwargs, **kwargs,
) as service_manager, ) as service_manager,
@ -153,6 +155,11 @@ def open_test_pikerd(
tmpconfdir.mkdir() tmpconfdir.mkdir()
tmpconfdir_str: str = str(tmpconfdir) tmpconfdir_str: str = str(tmpconfdir)
# override config dir in the root actor (aka
# this top level testing process).
from piker import config
config._config_dir = tmpconfdir
# NOTE: on linux the tmp config dir is generally located at: # NOTE: on linux the tmp config dir is generally located at:
# /tmp/pytest-of-<username>/pytest-<run#>/test_<current_test_name>/ # /tmp/pytest-of-<username>/pytest-<run#>/test_<current_test_name>/
# the default `pytest` config ensures that only the last 4 test # the default `pytest` config ensures that only the last 4 test
@ -183,37 +190,3 @@ def open_test_pikerd(
# - no leaked subprocs or shm buffers # - no leaked subprocs or shm buffers
# - all requested container service are torn down # - all requested container service are torn down
# - certain ``tractor`` runtime state? # - certain ``tractor`` runtime state?
@acm
async def _open_test_pikerd_and_ems(
fqsn,
mode,
loglevel,
open_test_pikerd
):
async with (
open_test_pikerd() as (_, _, _, services),
open_ems(
fqsn,
mode=mode,
loglevel=loglevel,
) as ems_services,
):
yield (services, ems_services)
@pytest.fixture
def open_test_pikerd_and_ems(
open_test_pikerd,
fqme: str = 'xbtusdt.kraken',
mode: str = 'paper',
loglevel: str = 'info',
):
yield partial(
_open_test_pikerd_and_ems,
fqme,
mode,
loglevel,
open_test_pikerd
)