(self, uri, *args, **kwargs)
| 116 | return requests.put("http://%s%s" % (self.base_url, uri), *args, **kwargs) |
| 117 | |
| 118 | def put_task(self, uri, *args, **kwargs): |
| 119 | self._ensure_async(kwargs) |
| 120 | resp = self.put(uri, *args, **kwargs) |
| 121 | if resp.status_code != 202: |
| 122 | return resp |
| 123 | |
| 124 | _id = resp.json()['ID'] |
| 125 | resp = self.get("/api/tasks/" + str(_id) + "/wait") |
| 126 | self.check_equal(resp.status_code, 200) |
| 127 | |
| 128 | return self.get("/api/tasks/" + str(_id)) |
| 129 | |
| 130 | def delete(self, uri, *args, **kwargs): |
| 131 | if "json" in kwargs: |