diff --git a/apps/worker/worker_app/tasks/_startup.py b/apps/worker/worker_app/tasks/_startup.py index df2047cb4..47b0b3a76 100644 --- a/apps/worker/worker_app/tasks/_startup.py +++ b/apps/worker/worker_app/tasks/_startup.py @@ -334,4 +334,3 @@ def _recover_stuck_voice_clones_on_ready(sender, **kwargs): logger.info("Worker 启动音色克隆恢复完成,共标记 %d 个卡死任务为 failed", recovered) except Exception as e: logger.error("启动音色克隆恢复失败(beat 巡检仍会兜底标 failed): %s", e, exc_info=True) - diff --git a/apps/worker/worker_app/tasks/cleanup.py b/apps/worker/worker_app/tasks/cleanup.py index 91991635d..c4116c2d2 100644 --- a/apps/worker/worker_app/tasks/cleanup.py +++ b/apps/worker/worker_app/tasks/cleanup.py @@ -166,4 +166,3 @@ def scheduled_cleanup_stale_voice_clones( finally: if session is not None: session.close() - diff --git a/packages/adapters/sqlalchemy_impl/voice_clone_profile_repository.py b/packages/adapters/sqlalchemy_impl/voice_clone_profile_repository.py index 8ad36e4a8..827f09d12 100644 --- a/packages/adapters/sqlalchemy_impl/voice_clone_profile_repository.py +++ b/packages/adapters/sqlalchemy_impl/voice_clone_profile_repository.py @@ -149,7 +149,7 @@ class SQLAlchemyVoiceCloneProfileRepository: Returns: 清理的记录数 """ - from datetime import datetime, timedelta, UTC + from datetime import UTC, datetime, timedelta cutoff = datetime.now(UTC) - timedelta(minutes=timeout_minutes) models = (