Display logs after the API call

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

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,