From 9214b6e030cbeb46b08b7ffdd692b204a57509e5 Mon Sep 17 00:00:00 2001 From: "Dr. Dennis Wittich" Date: Tue, 4 Mar 2025 17:53:41 +0100 Subject: [PATCH] rervert glob pattern and create subfolders --- learning_loop_node/detector/outbox.py | 2 ++ learning_loop_node/tests/detector/conftest.py | 2 +- 2 files changed, 3 insertions(+), 1 deletion(-) diff --git a/learning_loop_node/detector/outbox.py b/learning_loop_node/detector/outbox.py index c704e86..84a5f72 100644 --- a/learning_loop_node/detector/outbox.py +++ b/learning_loop_node/detector/outbox.py @@ -42,6 +42,8 @@ def __init__(self) -> None: self.log = logging.getLogger() self.path = f'{GLOBALS.data_folder}/outbox' os.makedirs(self.path, exist_ok=True) + os.makedirs(f'{self.path}/priority', exist_ok=True) + os.makedirs(f'{self.path}/normal', exist_ok=True) self.log = logging.getLogger() host = environment_reader.host() diff --git a/learning_loop_node/tests/detector/conftest.py b/learning_loop_node/tests/detector/conftest.py index e02b81b..f0565e7 100644 --- a/learning_loop_node/tests/detector/conftest.py +++ b/learning_loop_node/tests/detector/conftest.py @@ -114,7 +114,7 @@ async def sio_client() -> AsyncGenerator[socketio.AsyncClient, None]: def get_outbox_files(outbox: Outbox): - files = glob(f'{outbox.path}/**/**/*', recursive=True) + files = glob(f'{outbox.path}/**/*', recursive=True) return [file for file in files if os.path.isfile(file)]