diff --git a/internal/proxy/task_scheduler.go b/internal/proxy/task_scheduler.go index 34d54d249d..a8f3e14017 100644 --- a/internal/proxy/task_scheduler.go +++ b/internal/proxy/task_scheduler.go @@ -482,7 +482,7 @@ func (sched *taskScheduler) definitionLoop() { case <-sched.ddQueue.utChan(): if !sched.ddQueue.utEmpty() { t := sched.scheduleDdTask() - go sched.processTask(t, sched.ddQueue) + sched.processTask(t, sched.ddQueue) } } }