Changeset View
Changeset View
Standalone View
Standalone View
swh/graph/tests/conftest.py
import multiprocessing | import multiprocessing | ||||
import pytest | import pytest | ||||
from pathlib import Path | |||||
from aiohttp.test_utils import TestServer, TestClient, loop_context | from aiohttp.test_utils import TestServer, TestClient, loop_context | ||||
from pathlib import Path | |||||
from swh.graph.graph import load as graph_load | from swh.graph.graph import load as graph_load | ||||
from swh.graph.client import RemoteGraphClient | from swh.graph.client import RemoteGraphClient | ||||
from swh.graph.backend import Backend | from swh.graph.backend import Backend | ||||
from swh.graph.server.app import make_app | from swh.graph.server.app import make_app | ||||
SWH_GRAPH_ROOT = Path(__file__).parents[3] | SWH_GRAPH_TESTS_ROOT = Path(__file__).parents[0] | ||||
TEST_GRAPH_PATH = SWH_GRAPH_ROOT / 'tests/dataset/output/example' | TEST_GRAPH_PATH = SWH_GRAPH_TESTS_ROOT / 'dataset/output/example' | ||||
class GraphServerProcess(multiprocessing.Process): | class GraphServerProcess(multiprocessing.Process): | ||||
def __init__(self, q, *args, **kwargs): | def __init__(self, q, *args, **kwargs): | ||||
self.q = q | self.q = q | ||||
super().__init__(*args, **kwargs) | super().__init__(*args, **kwargs) | ||||
def run(self): | def run(self): | ||||
Show All 25 Lines |