测试

2025-12-09 09:35:38 +08:00
parent 6853624bd2
commit ad1ae1a54a
1 changed files with 1 additions and 1 deletions
--- 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管理器连接失败，任务停止执行")
+            logger.error(f"❌ Redis管理器连接失败，任务停止执行111")
            raise Exception("Redis连接失败")
        
        lock = redis_manager.create_lock(f"celery_task:{task_name}", timeout=300)  # 5分钟超时