Method taskLogs

coderd/aitasks.go:834–869

@Summary Get AI task logs @ID get-ai-task-logs @Security CoderSessionToken @Produce json @Tags Tasks @Param user path string true "Username, user ID, or 'me' for the authenticated user" @Param task path string true "Task ID, or task name" @Success 200 {object} codersdk.TaskLogsResponse @Router /api/

(rw http.ResponseWriter, r *http.Request)

// @Success 200 {object} codersdk.TaskLogsResponse
// @Router /api/v2/tasks/{user}/{task}/logs [get]
func (api *API) taskLogs(rw http.ResponseWriter, r *http.Request) {
	ctx := r.Context()
	task := httpmw.TaskParam(r)

	switch task.Status {
	case database.TaskStatusActive:
		// Active tasks: fetch live logs from AgentAPI.
		out, err := api.fetchLiveTaskLogs(r, task)
		if err != nil {
			httperror.WriteResponseError(ctx, rw, err)
			return
		}

		httpapi.Write(ctx, rw, http.StatusOK, out)

	case database.TaskStatusPaused, database.TaskStatusPending, database.TaskStatusInitializing:
		// In pause, pending and initializing states, we attempt to fetch
		// the snapshot from database to provide continuity.
		out, err := api.fetchSnapshotTaskLogs(ctx, task.ID)
		if err != nil {
			httperror.WriteResponseError(ctx, rw, err)
			return
		}

		httpapi.Write(ctx, rw, http.StatusOK, out)

	default:
		// Cases: database.TaskStatusError, database.TaskStatusUnknown.
		// - Error: snapshot would be stale from previous pause.
		// - Unknown: cannot determine reliable state.
		httpapi.Write(ctx, rw, http.StatusConflict, codersdk.Response{
			Message: "Cannot fetch logs for task in current state.",
			Detail:  fmt.Sprintf("Task status is %q.", task.Status),
		})
	}
}

func (api *API) fetchLiveTaskLogs(r *http.Request, task database.Task) (codersdk.TaskLogsResponse, error) {
	var out codersdk.TaskLogsResponse