From ee9cf5f8c6e2b833808173fba28fc692dfc63e5a Mon Sep 17 00:00:00 2001 From: super <2903208875@qq.com> Date: Fri, 5 Jun 2026 19:30:20 +0800 Subject: [PATCH] fix brand result submission lock wait --- .../nanri/aiimage/modules/brand/service/BrandTaskService.java | 3 ++- 1 file changed, 2 insertions(+), 1 deletion(-) diff --git a/backend-java/src/main/java/com/nanri/aiimage/modules/brand/service/BrandTaskService.java b/backend-java/src/main/java/com/nanri/aiimage/modules/brand/service/BrandTaskService.java index 16672a2..d65a581 100644 --- a/backend-java/src/main/java/com/nanri/aiimage/modules/brand/service/BrandTaskService.java +++ b/backend-java/src/main/java/com/nanri/aiimage/modules/brand/service/BrandTaskService.java @@ -75,6 +75,7 @@ public class BrandTaskService { private static final DateTimeFormatter DATETIME_FORMATTER = DateTimeFormatter.ofPattern("yyyy-MM-dd HH:mm"); private static final Duration STALE_CHECK_LOCK_TTL = Duration.ofMinutes(10); + private static final long RESULT_SUBMIT_WAIT_MILLIS = 5 * 60 * 1000L; private static final String STATUS_PENDING = "pending"; private static final String STATUS_RUNNING = "running"; private static final String STATUS_SUCCESS = "success"; @@ -223,7 +224,7 @@ public class BrandTaskService { if (taskId == null || taskId <= 0) { throw new BusinessException("taskId invalid"); } - try (TaskDistributedLockService.LockHandle ignored = acquireTaskLockOrThrow(taskId, TaskDistributedLockService.DEFAULT_WAIT_MILLIS)) { + try (TaskDistributedLockService.LockHandle ignored = acquireTaskLockOrThrow(taskId, RESULT_SUBMIT_WAIT_MILLIS)) { long startedAt = System.currentTimeMillis(); BrandCrawlTaskEntity task = requireActiveTask(taskId); List sourceFiles = parseSourceFiles(task.getFilePaths());