chore(backtest): 移除回测轮询服务的冗余日志
Co-authored-by: Cursor <cursoragent@cursor.com>
This commit is contained in:
-3
@@ -32,8 +32,6 @@ class BacktestPollingService(
|
|||||||
@Scheduled(fixedDelay = 10000) // 10 秒
|
@Scheduled(fixedDelay = 10000) // 10 秒
|
||||||
fun pollPendingTasks() {
|
fun pollPendingTasks() {
|
||||||
try {
|
try {
|
||||||
logger.debug("开始轮询待执行的回测任务")
|
|
||||||
|
|
||||||
// 1. 检查是否有长时间处于 RUNNING 状态的任务(可能是应用重启导致的)
|
// 1. 检查是否有长时间处于 RUNNING 状态的任务(可能是应用重启导致的)
|
||||||
val runningTasks = backtestTaskRepository.findByStatus("RUNNING")
|
val runningTasks = backtestTaskRepository.findByStatus("RUNNING")
|
||||||
if (runningTasks.isNotEmpty()) {
|
if (runningTasks.isNotEmpty()) {
|
||||||
@@ -72,7 +70,6 @@ class BacktestPollingService(
|
|||||||
.sortedBy { it.createdAt }
|
.sortedBy { it.createdAt }
|
||||||
|
|
||||||
if (pendingTasks.isEmpty()) {
|
if (pendingTasks.isEmpty()) {
|
||||||
logger.debug("没有待执行的回测任务")
|
|
||||||
return
|
return
|
||||||
}
|
}
|
||||||
|
|
||||||
|
|||||||
Reference in New Issue
Block a user