diff --git a/internal/proxy/task_scheduler.go b/internal/proxy/task_scheduler.go index a8f3e14017..34d54d249d 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() - sched.processTask(t, sched.ddQueue) + go sched.processTask(t, sched.ddQueue) } } }