Method DrainProgress

agent/tools_executor.go:243–253

()

}

func (e *StreamingToolExecutor) hasRunningWork() bool {
	e.mu.Lock()
	defer e.mu.Unlock()
	for _, slot := range e.slots {
		if slot.State == ToolStateExecuting {
			return true
		}
	}
	return false
}

func (e *StreamingToolExecutor) HasRunningWork() bool {
	return e.hasRunningWork()
}