yumoqing/longtasks
1
0
Fork 0
Code Issues Pull Requests Actions Packages Projects Releases Wiki Activity

bugfix

Browse Source
This commit is contained in:
yumoqing 2025-11-06 11:26:12 +08:00
parent a068932515
commit 557eaeb90e
1 changed files with 2 additions and 0 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

2
longtasks/longtasks.py
View File

@ -1,4 +1,5 @@
# -*- coding:utf-8 -*- # -*- coding:utf-8 -*-
from traceback import format_exc
import asyncio import asyncio
import aioredis import aioredis
from random import randint from random import randint
@ -170,6 +171,7 @@ class LongTasks:
}) })
# 从 processing_queue 移除该项 # 从 processing_queue 移除该项
await self.redis.lrem(self.processing_queue, 1, task_id) await self.redis.lrem(self.processing_queue, 1, task_id)
debug(f'{e=}\n{format_exc()}')
continue continue
# 3) 写回成功结果并移除 processing_queue 项 # 3) 写回成功结果并移除 processing_queue 项