|
1 | 1 | from time import time |
2 | 2 | import pytest |
3 | 3 | from openml.testing import TestAPIBase |
4 | | -from openml._api import ResourceV1API |
| 4 | +from openml._api import ResourceV1API, ResourceV2API, FallbackProxy |
5 | 5 | from openml.enums import ResourceType |
| 6 | +from openml.exceptions import OpenMLNotSupportedError |
6 | 7 |
|
7 | 8 |
|
8 | 9 | class TestResourceV1API(TestAPIBase): |
@@ -51,3 +52,56 @@ def test_tag_and_untag(self): |
51 | 52 |
|
52 | 53 | tags = self.resource.untag(resource_id, tag) |
53 | 54 | self.assertNotIn(tag, tags) |
| 55 | + |
| 56 | + |
| 57 | +class TestResourceV2API(TestResourceV1API): |
| 58 | + def setUp(self): |
| 59 | + super().setUp() |
| 60 | + |
| 61 | + self.server = "" |
| 62 | + self.base_url = "" |
| 63 | + self.api_key = "" |
| 64 | + self.http_client = self._get_http_client( |
| 65 | + server=self.server, |
| 66 | + base_url=self.base_url, |
| 67 | + api_key=self.api_key, |
| 68 | + timeout_seconds=self.timeout_seconds, |
| 69 | + retries=self.retries, |
| 70 | + retry_policy=self.retry_policy, |
| 71 | + cache=self.cache, |
| 72 | + ) |
| 73 | + |
| 74 | + self.resource = ResourceV2API(self.http_client) |
| 75 | + self.resource.resource_type = ResourceType.TASK |
| 76 | + |
| 77 | + @pytest.mark.xfail(raises=OpenMLNotSupportedError) |
| 78 | + def test_publish_and_delete(self): |
| 79 | + super().test_tag_and_untag() |
| 80 | + |
| 81 | + |
| 82 | + @pytest.mark.xfail(raises=OpenMLNotSupportedError) |
| 83 | + def test_tag_and_untag(self): |
| 84 | + super().test_tag_and_untag() |
| 85 | + |
| 86 | + |
| 87 | +class TestResourceFallbackAPI(TestResourceV1API): |
| 88 | + def setUp(self): |
| 89 | + super().setUp() |
| 90 | + |
| 91 | + self.http_client_v2 = self._get_http_client( |
| 92 | + server="", |
| 93 | + base_url="", |
| 94 | + api_key="", |
| 95 | + timeout_seconds=self.timeout_seconds, |
| 96 | + retries=self.retries, |
| 97 | + retry_policy=self.retry_policy, |
| 98 | + cache=self.cache, |
| 99 | + ) |
| 100 | + |
| 101 | + resource_v1 = ResourceV1API(self.http_client) |
| 102 | + resource_v1.resource_type = ResourceType.TASK |
| 103 | + |
| 104 | + resource_v2 = ResourceV2API(self.http_client_v2) |
| 105 | + resource_v2.resource_type = ResourceType.TASK |
| 106 | + |
| 107 | + self.resource = FallbackProxy(resource_v2, resource_v1) |
0 commit comments