IMGW: Use ttl of 5 minutes for caching

earthobservations · Dec 29, 2023 · 41e1e63 · 41e1e63
1 parent ce16132
commit 41e1e63
Show file tree

Hide file tree

Showing 3 changed files with 7 additions and 2 deletions.
diff --git a/CHANGELOG.rst b/CHANGELOG.rst
@@ -11,6 +11,7 @@ Development
 - NWS Observation: Read json data from bytes
 - EA Hydrology: Read json data from bytes
 - Replace partial with lambda in most places
+- IMGW: Use ttl of 5 minutes for caching
 
 0.69.0 (18.12.2023)
 *******************

diff --git a/wetterdienst/provider/imgw/hydrology/api.py b/wetterdienst/provider/imgw/hydrology/api.py
@@ -142,7 +142,9 @@ def _collect_station_parameter(self, station_id: str, parameter: Enum, dataset:
         """
         urls = self._get_urls(dataset)
         with ThreadPoolExecutor() as p:
-            files_in_bytes = p.map(lambda file: download_file(url=file, settings=self.sr.settings), urls)
+            files_in_bytes = p.map(
+                lambda file: download_file(url=file, settings=self.sr.settings, ttl=CacheExpiry.FIVE_MINUTES), urls
+            )
         data = []
         file_schema = self._file_schema[self.sr.resolution.name.lower()][dataset.name.lower()]
         for file_in_bytes in files_in_bytes:

diff --git a/wetterdienst/provider/imgw/meteorology/api.py b/wetterdienst/provider/imgw/meteorology/api.py
@@ -364,7 +364,9 @@ def _collect_station_parameter(self, station_id: str, parameter: Enum, dataset:
         """
         urls = self._get_urls(dataset)
         with ThreadPoolExecutor() as p:
-            files_in_bytes = p.map(lambda file: download_file(url=file, settings=self.sr.settings), urls)
+            files_in_bytes = p.map(
+                lambda file: download_file(url=file, settings=self.sr.settings, ttl=CacheExpiry.FIVE_MINUTES), urls
+            )
         data = []
         file_schema = self._file_schema[self.sr.resolution.name.lower()][dataset.name.lower()]
         for file_in_bytes in files_in_bytes: