add cache handling

ECCC-MSC · Feb 20, 2024 · c443579 · c443579
1 parent 29180ed
commit c443579
Showing 1 changed file with 6 additions and 1 deletion.
diff --git a/msc_wis2node/publisher.py b/msc_wis2node/publisher.py
@@ -150,7 +150,7 @@ def identify(self, path: str) -> Union[dict, None]:
 
         return None
 
-    def publish_to_wis2(self, dataset: str, url: str) -> None:
+    def publish_to_wis2(self, dataset: dict, url: str) -> None:
         """
         WIS2 publisher
 
@@ -175,6 +175,11 @@ def publish_to_wis2(self, dataset: str, url: str) -> None:
             url=url
         )
 
+        cache = dataset.get('cache', True)
+        if not cache:
+            LOGGER.info(f'Setting properties.cache={cache}')
+            message['properties']['cache'] = False
+
         LOGGER.debug('Removing system and version from data_id')
         data_id = message['properties']['data_id']
         tokens = data_id.split('/')