Skip to content

Commit e8c09a0

Browse files
fix: try to make operations faster
1 parent 7bf1e8f commit e8c09a0

File tree

2 files changed

+6
-6
lines changed

2 files changed

+6
-6
lines changed

app/operation/group.py

Lines changed: 4 additions & 4 deletions
Original file line numberDiff line numberDiff line change
@@ -40,7 +40,7 @@ async def modify_group(self, db: AsyncSession, group_id: int, modified_group: Gr
4040
db_group = await modify_group(db, db_group, modified_group)
4141

4242
users = await get_users(db, group_ids=[db_group.id])
43-
await node_manager.update_users(users)
43+
asyncio.create_task(node_manager.update_users(users))
4444

4545
group = GroupResponse.model_validate(db_group)
4646

@@ -58,7 +58,7 @@ async def remove_group(self, db: AsyncSession, group_id: int, admin: Admin) -> N
5858
await remove_group(db, db_group)
5959
users = await get_users(db, usernames=username_list)
6060

61-
await node_manager.update_users(users)
61+
asyncio.create_task(node_manager.update_users(users))
6262

6363
logger.info(f'Group "{db_group.name}" deleted by admin "{admin.username}"')
6464

@@ -69,7 +69,7 @@ async def bulk_add_groups(self, db: AsyncSession, bulk_model: BulkGroup):
6969

7070
users, users_count = await add_groups_to_users(db, bulk_model)
7171

72-
await node_manager.update_users(users)
72+
asyncio.create_task(node_manager.update_users(users))
7373

7474
if self.operator_type in (OperatorType.API, OperatorType.WEB):
7575
return {"detail": f"operation has been successfuly done on {users_count} users"}
@@ -80,7 +80,7 @@ async def bulk_remove_groups(self, db: AsyncSession, bulk_model: BulkGroup):
8080

8181
users, users_count = await remove_groups_from_users(db, bulk_model)
8282

83-
await node_manager.update_users(users)
83+
asyncio.create_task(node_manager.update_users(users))
8484

8585
if self.operator_type in (OperatorType.API, OperatorType.WEB):
8686
return {"detail": f"operation has been successfuly done on {users_count} users"}

app/operation/user.py

Lines changed: 2 additions & 2 deletions
Original file line numberDiff line numberDiff line change
@@ -87,9 +87,9 @@ async def update_user(self, db_user: User) -> UserNotificationResponse:
8787

8888
if db_user.status in (UserStatus.active, UserStatus.on_hold):
8989
user_inbounds = await db_user.inbounds()
90-
await node_manager.update_user(user, inbounds=user_inbounds)
90+
asyncio.create_task(node_manager.update_user(user, inbounds=user_inbounds))
9191
else:
92-
await node_manager.remove_user(user)
92+
asyncio.create_task(node_manager.update_user(user))
9393

9494
return user
9595

0 commit comments

Comments
 (0)