Method Fail

internal/bridge/taskmanager.go:219–234

Fail marks a task as failed with a reason and closes its result channel.

(sessionID string, taskID uint32, reason string)

// Fail marks a task as failed with a reason and closes its result channel.
func (tm *TaskManager) Fail(sessionID string, taskID uint32, reason string) {
	task := tm.Get(sessionID, taskID)
	if task == nil {
		return
	}
	task.mu.Lock()
	defer task.mu.Unlock()

	if task.State == TaskCompleted || task.State == TaskFailed {
		return // already terminal
	}
	task.State = TaskFailed
	task.Error = reason
	task.UpdatedAt = time.Now()
	close(task.resultCh)
}

// StartSessionListener ensures a single subscriber exists for the given session.
// The subscriber fans out incoming results to per-task channels based on TaskID.