Skip to content

Commit 76fa2e0

Browse files
committed
squashme: style
1 parent b1ee652 commit 76fa2e0

2 files changed

Lines changed: 7 additions & 4 deletions

File tree

components/renku_data_services/crc/blueprints.py

Lines changed: 2 additions & 3 deletions
Original file line numberDiff line numberDiff line change
@@ -1,6 +1,7 @@
11
"""Compute resource control (CRC) app."""
22

33
import asyncio
4+
from contextlib import suppress
45
from dataclasses import dataclass
56

67
from sanic import HTTPResponse, Request, empty, json
@@ -353,14 +354,12 @@ async def _delete(
353354
member_id=member_id,
354355
member_type=MemberType(member_type),
355356
)
356-
try:
357+
with suppress(errors.MissingResourceError):
357358
await self.repo.revoke_resource_pool_members(
358359
api_user=user,
359360
resource_pool_id=resource_pool_id,
360361
members=[identifier],
361362
)
362-
except errors.MissingResourceError:
363-
pass # Already removed or was not part of the pool
364363
return HTTPResponse(status=204)
365364

366365
return "/resource_pools/<resource_pool_id>/members/<member_type>/<member_id>", ["DELETE"], _delete

components/renku_data_services/crc/db.py

Lines changed: 5 additions & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -1245,7 +1245,11 @@ async def _unprohibit_resource_pool_users(
12451245
@with_db_transaction
12461246
@Authz.authz_change(op=AuthzOperation.create, resource=ResourceType.resource_pool)
12471247
async def _prohibit_resource_pool_users(
1248-
self, api_user: base_models.APIUser, resource_pool_id: int, user_ids: Collection[str], session: AsyncSession
1248+
self,
1249+
api_user: base_models.APIUser,
1250+
resource_pool_id: int,
1251+
user_ids: Collection[str],
1252+
session: AsyncSession | None = None,
12491253
) -> models.ResourcePoolMembershipChange:
12501254
specs = [(uid, ResourceType.user, Role.PROHIBITED) for uid in user_ids]
12511255
return self._build_pool_membership_changes(resource_pool_id, specs, Change.ADD)

0 commit comments

Comments
 (0)