|
1 | 1 | from typing import Optional |
2 | | -from labelbox.exceptions import ( |
3 | | - MalformedQueryException, |
| 2 | +from lbox.exceptions import ( |
4 | 3 | ResourceNotFoundError, |
5 | | - UnprocessableEntityError, |
6 | 4 | ) |
7 | 5 | from typing import Set, Iterator, Any, List |
8 | 6 | from pydantic import ( |
@@ -161,11 +159,12 @@ def get(self) -> "Member": |
161 | 159 | """ |
162 | 160 | params = {"userId": self.id} |
163 | 161 |
|
164 | | - result = self.client.execute(query, params, experimental=True) |
165 | | - if not result: |
166 | | - raise ResourceNotFoundError( |
167 | | - message="Failed to find user as user does not exist" |
168 | | - ) |
| 162 | + result = self.client.execute( |
| 163 | + query, |
| 164 | + params, |
| 165 | + experimental=True, |
| 166 | + raise_return_resource_not_found=True, |
| 167 | + ) |
169 | 168 |
|
170 | 169 | user = { |
171 | 170 | **result["user"], |
@@ -241,14 +240,13 @@ def update(self) -> "Member": |
241 | 240 | if self.id == self._current_user_id: |
242 | 241 | raise ValueError("Unable to update self") |
243 | 242 |
|
244 | | - try: |
245 | | - result = self.client.execute(query, params, experimental=True) |
246 | | - if not result: |
247 | | - raise ResourceNotFoundError( |
248 | | - message="Failed to update member as member does not exist" |
249 | | - ) |
250 | | - except MalformedQueryException as e: |
251 | | - raise UnprocessableEntityError("Failed to update member") from e |
| 243 | + self.client.execute( |
| 244 | + query, |
| 245 | + params, |
| 246 | + experimental=True, |
| 247 | + raise_return_resource_not_found=True, |
| 248 | + ) |
| 249 | + |
252 | 250 | return self |
253 | 251 |
|
254 | 252 | def delete(self) -> bool: |
@@ -281,11 +279,13 @@ def delete(self) -> bool: |
281 | 279 |
|
282 | 280 | params = {"id": self.id} |
283 | 281 |
|
284 | | - result = self.client.execute(query, params, experimental=True) |
285 | | - if not result: |
286 | | - raise ResourceNotFoundError( |
287 | | - message="Failed to delete member as member does not exist" |
288 | | - ) |
| 282 | + result = self.client.execute( |
| 283 | + query, |
| 284 | + params, |
| 285 | + experimental=True, |
| 286 | + raise_return_resource_not_found=True, |
| 287 | + ) |
| 288 | + |
289 | 289 | return result["updateUser"]["deleted"] |
290 | 290 |
|
291 | 291 | def _get_project_memberships(self, user_id: str) -> Set[ProjectMembership]: |
|
0 commit comments