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