implement reset_cache

Author: geetu040

openml/_api/clients/http.py

@@ -322,6 +322,7 @@ def request(
         path: str,
         *,
         use_cache: bool = False,
+        reset_cache: bool = False,
         use_api_key: bool = False,
         **request_kwargs: Any,
     ) -> Response:
@@ -345,7 +346,7 @@ def request(
         timeout = request_kwargs.pop("timeout", self.timeout)
         files = request_kwargs.pop("files", None)
 
-        if use_cache and self.cache is not None:
+        if use_cache and not reset_cache and self.cache is not None:
             cache_key = self.cache.get_key(url, params)
             try:
                 return self.cache.load(cache_key)
@@ -379,6 +380,7 @@ def request(
         assert response is not None
 
         if use_cache and self.cache is not None:
+            cache_key = self.cache.get_key(url, params)
             self.cache.save(cache_key, response)
 
         return response
@@ -388,13 +390,15 @@ def get(
         path: str,
         *,
         use_cache: bool = False,
+        reset_cache: bool = False,
         use_api_key: bool = False,
         **request_kwargs: Any,
     ) -> Response:
         return self.request(
             method="GET",
             path=path,
             use_cache=use_cache,
+            reset_cache=reset_cache,
             use_api_key=use_api_key,
             **request_kwargs,
         )

tests/test_api/test_http.py

@@ -103,6 +103,24 @@ def test_get_cache_expires(self):
         self.assertEqual(response2.status_code, 200)
         self.assertEqual(response1.content, response2.content)
 
+    @pytest.mark.uses_test_server()
+    def test_get_reset_cache(self):
+        path = "task/1"
+
+        url = self._get_url(path=path)
+        key = self.cache.get_key(url, {})
+        cache_path = self.cache._key_to_path(key) / "meta.json"
+
+        response1 = self.http_client.get(path, use_cache=True)
+        response1_cache_time_stamp = cache_path.stat().st_ctime
+
+        response2 = self.http_client.get(path, use_cache=True, reset_cache=True)
+        response2_cache_time_stamp = cache_path.stat().st_ctime
+
+        self.assertNotEqual(response1_cache_time_stamp, response2_cache_time_stamp)
+        self.assertEqual(response2.status_code, 200)
+        self.assertEqual(response1.content, response2.content)
+
     @pytest.mark.uses_test_server()
     def test_post_and_delete(self):
         task_xml = """