From 6d070fd820d234aac19b44a645ebd2cb30f3c122 Mon Sep 17 00:00:00 2001 From: Harry Date: Thu, 2 Oct 2025 16:07:39 +0100 Subject: [PATCH 1/2] Allow alt df engine --- oasis_data_manager/df_reader/config.py | 5 ++++- 1 file changed, 4 insertions(+), 1 deletion(-) diff --git a/oasis_data_manager/df_reader/config.py b/oasis_data_manager/df_reader/config.py index 952bf9e..fc54019 100644 --- a/oasis_data_manager/df_reader/config.py +++ b/oasis_data_manager/df_reader/config.py @@ -72,7 +72,10 @@ def clean_config(config: Union[str, InputReaderConfig]) -> ResolvedReaderConfig: def get_df_reader(config, *args, **kwargs): config = clean_config(config) - cls = load_class(config["engine"]["path"], OasisReader) + if kwargs.get("df_engine", False): + cls = load_class(kwargs["df_engine"]) + else: + cls = load_class(config["engine"]["path"], OasisReader) storage = config["engine"]["options"].pop("storage", None) or LocalStorage("/") return cls( From 6254509afdd0b89b70d0efb9f4e01c0821a60ea7 Mon Sep 17 00:00:00 2001 From: Harry Date: Fri, 3 Oct 2025 11:31:10 +0100 Subject: [PATCH 2/2] Tests work for new ODS version --- oasis_data_manager/df_reader/config.py | 1 + 1 file changed, 1 insertion(+) diff --git a/oasis_data_manager/df_reader/config.py b/oasis_data_manager/df_reader/config.py index fc54019..4875a9c 100644 --- a/oasis_data_manager/df_reader/config.py +++ b/oasis_data_manager/df_reader/config.py @@ -76,6 +76,7 @@ def get_df_reader(config, *args, **kwargs): cls = load_class(kwargs["df_engine"]) else: cls = load_class(config["engine"]["path"], OasisReader) + kwargs.pop('df_engine', None) storage = config["engine"]["options"].pop("storage", None) or LocalStorage("/") return cls(