Skip to content

Commit 2de93cb

Browse files
committed
fix(jobs): avoid using create_task for updating user in node
1 parent 2896619 commit 2de93cb

File tree

1 file changed

+2
-2
lines changed

1 file changed

+2
-2
lines changed

app/jobs/review_users.py

Lines changed: 2 additions & 2 deletions
Original file line numberDiff line numberDiff line change
@@ -33,7 +33,7 @@ async def reset_user_by_next_report(db: AsyncSession, db_user: User):
3333
inbounds = await db_user.inbounds()
3434
user = UserNotificationResponse.model_validate(db_user)
3535

36-
asyncio.create_task(node_manager.update_user(user, inbounds))
36+
await node_manager.update_user(user, inbounds)
3737
asyncio.create_task(notification.user_data_reset_by_next(user, SYSTEM_ADMIN))
3838

3939
logger.info(f'User "{db_user.username}" next plan activated')
@@ -42,7 +42,7 @@ async def reset_user_by_next_report(db: AsyncSession, db_user: User):
4242
async def change_status(db: AsyncSession, db_user: User, status: UserStatus):
4343
user = UserNotificationResponse.model_validate(db_user)
4444
if user.status is not UserStatus.active:
45-
asyncio.create_task(node_manager.remove_user(user))
45+
await node_manager.remove_user(user)
4646
asyncio.create_task(notification.user_status_change(user, SYSTEM_ADMIN))
4747

4848
logger.info(f'User "{db_user.username}" status changed to {status.value}')

0 commit comments

Comments
 (0)