Преглед на файлове

修改task_runner run runTask stoped处理错误

yjp преди 7 месеца
родител
ревизия
81f399ebed
променени са 1 файла, в които са добавени 1 реда и са изтрити 1 реда
  1. 1 1
      convenient/domain/task_runner/task_runner.go

+ 1 - 1
convenient/domain/task_runner/task_runner.go

@@ -313,7 +313,7 @@ func runTask(taskEntity *task.Entity, runner Runner, dbSchema string, dbExecutor
 		return
 	}
 
-	if stopped {
+	if !stopped {
 		return
 	}