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 3ed38314aa
commit 8bea537798
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() {
try {
// 清除日志默认保存天数大于零、最少保留最近一天的日志数据
// if (systemProperties.getLogStorage() <= 1) {
// SnailJobLog.LOCAL.error("retry clear log storage error", systemProperties.getLogStorage());
// return;
// }
if (systemProperties.getLogStorage() <= 1) {
SnailJobLog.LOCAL.error("retry clear log storage error", systemProperties.getLogStorage());
return;
}
// clean retry log
LocalDateTime endTime = LocalDateTime.now();
LocalDateTime endTime = LocalDateTime.now().minusDays(systemProperties.getLogStorage());
long total = PartitionTaskUtils.process(startId -> retryTaskBatchList(startId, endTime),
this::processRetryLogPartitionTasks, 0);