From d00bb5e4756570cf9a22a6c7dbcc7ec5e40b1723 Mon Sep 17 00:00:00 2001 From: "mark.tian" Date: Tue, 9 Dec 2025 10:01:00 +0800 Subject: [PATCH] =?UTF-8?q?=E6=B5=8B=E8=AF=95?= MIME-Version: 1.0 Content-Type: text/plain; charset=UTF-8 Content-Transfer-Encoding: 8bit --- app/celery_tasks.py | 2 +- 1 file changed, 1 insertion(+), 1 deletion(-) diff --git a/app/celery_tasks.py b/app/celery_tasks.py index 023099e..5767028 100644 --- a/app/celery_tasks.py +++ b/app/celery_tasks.py @@ -38,7 +38,7 @@ def push_data_to_dtc_task(self): # 获取分布式锁，使用任务名称作为锁标识 connection_success = redis_manager.connect() if not connection_success: - logger.error(f"❌ Redis管理器连接失败，任务停止执行111") + logger.error(f"❌ Redis管理器连接失败，任务停止执行") raise Exception("Redis连接失败") lock = redis_manager.create_lock(f"celery_task:{task_name}", timeout=300) # 5分钟超时