gtsoft/gtsoft-snail-job-server
1
0
Fork 0
Code Issues Pull Requests 1 Actions Packages Projects 1 Releases Wiki Activity

feat(1.4.0-beta1): 1. 恢复代码

Browse Source
This commit is contained in:
opensnail 2025-02-26 23:27:57 +08:00
parent 5f242ddc28
commit 93eed6c9cd
1 changed files with 5 additions and 5 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

10
snail-job-server/snail-job-server-retry-task/src/main/java/com/aizuda/snailjob/server/retry/task/support/schedule/CleanerSchedule.java
View File

@ -86,13 +86,13 @@ public class CleanerSchedule extends AbstractSchedule implements Lifecycle {
protected void doExecute() { protected void doExecute() {
try { try {
// 清除日志默认保存天数大于零、最少保留最近一天的日志数据 // 清除日志默认保存天数大于零、最少保留最近一天的日志数据
// if (systemProperties.getLogStorage() <= 1) { if (systemProperties.getLogStorage() <= 1) {
// SnailJobLog.LOCAL.error("retry clear log storage error", systemProperties.getLogStorage()); SnailJobLog.LOCAL.error("retry clear log storage error", systemProperties.getLogStorage());
// return; return;
// } }
// clean retry log // clean retry log
LocalDateTime endTime = LocalDateTime.now(); LocalDateTime endTime = LocalDateTime.now().minusDays(systemProperties.getLogStorage());
long total = PartitionTaskUtils.process(startId -> retryTaskBatchList(startId, endTime), long total = PartitionTaskUtils.process(startId -> retryTaskBatchList(startId, endTime),
this::processRetryLogPartitionTasks, 0); this::processRetryLogPartitionTasks, 0);