diff --git a/internal/server/task_run_handlers.go b/internal/server/task_run_handlers.go
index 5bbb4b61..435616c2 100644
--- a/internal/server/task_run_handlers.go
+++ b/internal/server/task_run_handlers.go
@@ -502,6 +502,10 @@ func (s *Server) handleTaskRunEvents(w http.ResponseWriter, r *http.Request) {
 	if err := writeStoredEvents(replay); err != nil {
 		return
 	}
+	// 刷新后只重放已落库事件，避免 interrupted 任务没有 done/error 时把连接挂住。
+	if r.URL.Query().Get("replay_only") == "1" {
+		return
+	}
 	for _, stored := range replay {
 		if stored.Event.Type == stream.EventDone || stored.Event.Type == stream.EventError {
 			return