|
1 | 1 | from gradient import config |
2 | 2 | from gradient.api_sdk import serializers |
| 3 | +from gradient.api_sdk.clients import http_client |
3 | 4 | from .common import ListResources, CreateResource, BaseRepository, GetResource, DeleteResource, StopResource |
4 | 5 | from ..serializers import JobSchema, LogRowSchema |
5 | 6 |
|
@@ -150,20 +151,22 @@ def _get_request_params(self, kwargs): |
150 | 151 | return params |
151 | 152 |
|
152 | 153 |
|
153 | | -class DeleteJobArtifacts(GetBaseJobApiUrlMixin, BaseRepository): |
| 154 | +class DeleteJobArtifacts(GetBaseJobApiUrlMixin, DeleteResource): |
154 | 155 | VALIDATION_ERROR_MESSAGE = "Failed to delete resource" |
155 | 156 |
|
156 | 157 | def get_request_url(self, **kwargs): |
157 | 158 | return "/jobs/{}/artifactsDestroy".format(kwargs.get("id")) |
158 | 159 |
|
159 | | - # def delete(self, id_, **kwargs): |
160 | | - # url = self.get_request_url(id_=id_) |
161 | | - # |
162 | | - # params = self._get_request_params(kwargs) |
163 | | - # |
164 | | - # client = self._get_client() |
165 | | - # response = client.post(url, json=kwargs.get("json"), params=params) |
166 | | - # self._validate_response(response) |
| 160 | + def _send(self, url, use_vpc=False, **kwargs): |
| 161 | + client = self._get_client(use_vpc=use_vpc) |
| 162 | + params_data = self._get_request_params(kwargs) |
| 163 | + response = self._send_request(client, url, params_data=params_data) |
| 164 | + gradient_response = http_client.GradientResponse.interpret_response(response) |
| 165 | + return gradient_response |
| 166 | + |
| 167 | + def _send_request(self, client, url, params_data=None): |
| 168 | + response = client.post(url, params=params_data) |
| 169 | + return response |
167 | 170 |
|
168 | 171 | def _get_request_params(self, kwargs): |
169 | 172 | filters = dict() |
|
0 commit comments