fix measurement sdk cache key calculation

meteoblue · Jul 30, 2021 · 4693f78 · 4693f78
1 parent 9c3f3e8
commit 4693f78
Show file tree

Hide file tree

Showing 2 changed files with 4 additions and 2 deletions.
diff --git a/meteoblue_dataset_sdk/client.py b/meteoblue_dataset_sdk/client.py
@@ -279,7 +279,7 @@ def _parse_measurements(data):
 
     @staticmethod
     def _hash_params_measurements(path: str, params: dict) -> str:
-        return hashlib.md5(path.encode(), json.dumps(params).encode()).hexdigest()
+        return hashlib.md5(path.encode() + json.dumps(params).encode()).hexdigest()
 
     @asynccontextmanager
     async def _query_measurement_api(self, path: str, params: dict):

diff --git a/tests/test_measurement_query.py b/tests/test_measurement_query.py
@@ -1,5 +1,6 @@
 from meteoblue_dataset_sdk import ApiError, Client
 from meteoblue_dataset_sdk.protobuf.measurements_pb2 import MeasurementApiProtobuf
+from meteoblue_dataset_sdk.caching import FileCache
 
 import asyncio
 import logging
@@ -68,7 +69,8 @@ def test_simple_query(self):
         table = "dwdClimateMeasurement10MinuteAirTemperature"
         path = f"/rawdata/{provider}/{table}/get"
 
-        client = Client(os.environ["APIKEY"])
+        cache = FileCache()
+        client = Client(os.environ["APIKEY"], cache=cache)
         result = asyncio.run(client.measurement_query(path, query))
         rows_per_page = result.rows_per_page
         current_page = result.current_page