diff --git a/arkindex_worker/cache.py b/arkindex_worker/cache.py index 2ab9ea79f34a0cd5543340dd710880e0b218968f..b3a7536e6eeacdada14efcd8bb7318cd11a127e2 100644 --- a/arkindex_worker/cache.py +++ b/arkindex_worker/cache.py @@ -378,11 +378,13 @@ def merge_parents_cache(paths: list, current_database: Path): def unsupported_cache(func): def wrapper(self, *args, **kwargs): + results = func(self, *args, **kwargs) + if not self.is_read_only and not self.use_cache: logger.warning( f"This API helper `{func.__name__}` did not update the cache database" ) - return func(self, *args, **kwargs) + return results return wrapper diff --git a/tests/test_dataset_worker.py b/tests/test_dataset_worker.py index afc1b2a4ffb71f4c7296d48c081ed00a9a930e26..c8bb9ebe02d8894fe1a94e70706b6c05d6806a8d 100644 --- a/tests/test_dataset_worker.py +++ b/tests/test_dataset_worker.py @@ -525,10 +525,6 @@ def test_run_update_dataset_state_api_error( (logging.INFO, "Loaded Worker Fake worker @ 123412 from API"), (logging.INFO, "Processing Dataset (dataset_id) (1/1)"), (logging.INFO, "Building Dataset (dataset_id) (1/1)"), - ( - logging.WARNING, - "This API helper `update_dataset_state` did not update the cache database", - ), *[ ( logging.INFO, @@ -540,10 +536,6 @@ def test_run_update_dataset_state_api_error( logging.WARNING, "An API error occurred while processing dataset dataset_id: 500 Internal Server Error - None", ), - ( - logging.WARNING, - "This API helper `update_dataset_state` did not update the cache database", - ), *[ ( logging.INFO,