super/crawler-plugin
1
0
Fork 0
Code Issues Pull Requests Actions Packages Projects Releases Wiki Activity

fix brand result submission lock wait

Browse Source
This commit is contained in:
super
2026-06-05 19:30:20 +08:00
parent e98a1a1207
commit ee9cf5f8c6
1 changed files with 2 additions and 1 deletions
Download Patch File Download Diff File Expand all files Collapse all files

3
backend-java/src/main/java/com/nanri/aiimage/modules/brand/service/BrandTaskService.java
View File

@@ -75,6 +75,7 @@ public class BrandTaskService {
private static final DateTimeFormatter DATETIME_FORMATTER = DateTimeFormatter.ofPattern("yyyy-MM-dd HH:mm"); 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 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_PENDING = "pending";
private static final String STATUS_RUNNING = "running"; private static final String STATUS_RUNNING = "running";
private static final String STATUS_SUCCESS = "success"; private static final String STATUS_SUCCESS = "success";
@@ -223,7 +224,7 @@ public class BrandTaskService {
if (taskId == null || taskId <= 0) { if (taskId == null || taskId <= 0) {
throw new BusinessException("taskId invalid"); 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(); long startedAt = System.currentTimeMillis();
BrandCrawlTaskEntity task = requireActiveTask(taskId); BrandCrawlTaskEntity task = requireActiveTask(taskId);
List<BrandSourceFileDto> sourceFiles = parseSourceFiles(task.getFilePaths()); List<BrandSourceFileDto> sourceFiles = parseSourceFiles(task.getFilePaths());