From 2fdf381f6e5597ea09428051f128c416908ffd94 Mon Sep 17 00:00:00 2001 From: Dominik Hoffmann Date: Tue, 19 Nov 2024 16:26:33 +0100 Subject: [PATCH] #26: wip Signed-off-by: Dominik Hoffmann --- .../pipelines/logging/test_log_collection.py | 11 +++++++++++ 1 file changed, 11 insertions(+) diff --git a/tests/sdk/python/rtdip_sdk/pipelines/logging/test_log_collection.py b/tests/sdk/python/rtdip_sdk/pipelines/logging/test_log_collection.py index 52dc9031a..89fd77b7e 100644 --- a/tests/sdk/python/rtdip_sdk/pipelines/logging/test_log_collection.py +++ b/tests/sdk/python/rtdip_sdk/pipelines/logging/test_log_collection.py @@ -27,6 +27,17 @@ import logging +@pytest.fixture(scope="session") +def spark(): + spark = ( + SparkSession.builder.master("local[2]") + .appName("LogCollectionTest") + .getOrCreate() + ) + yield spark + spark.stop() + + def test_logger_manager_basic_function(): df = DataFrame() monitor = IdentifyMissingDataInterval(