Function newTaskReviewRequestCommand

internal/cli/task.go:984–1049

(deps commandDeps)

}

func newTaskReviewRequestCommand(deps commandDeps) *cobra.Command {
	var (
		reasonRaw string
		policyRaw string
		round     int
		attempt   int
		parentID  string
		asAgent   bool
	)
	cmd := &cobra.Command{
		Use:   "request <run-id>",
		Short: "Request review for a task run",
		Args:  exactOneNonBlankArg(),
		RunE: func(cmd *cobra.Command, args []string) error {
			client, err := clientFromDeps(deps)
			if err != nil {
				return err
			}
			request, err := buildTaskRunReviewRequest(
				args[0],
				reasonRaw,
				policyRaw,
				round,
				attempt,
				parentID,
			)
			if err != nil {
				return err
			}
			var review TaskRunReviewRequestRecord
			if asAgent {
				credentials, identityErr := requireAgentCommandIdentity(
					cmd.Context(),
					deps,
					client,
					agentActionCLI("task.review.request"),
				)
				if identityErr != nil {
					return identityErr
				}
				review, err = client.RequestTaskRunReviewAsAgent(
					cmd.Context(),
					args[0],
					request,
					credentials,
				)
			} else {
				review, err = client.RequestTaskRunReview(cmd.Context(), args[0], request)
			}
			if err != nil {
				return err
			}
			return writeCommandOutput(cmd, taskRunReviewRequestBundle(&review))
		},
	}
	cmd.Flags().StringVar(&reasonRaw, "reason", "", "Reason for requesting review")
	cmd.Flags().
		StringVar(&policyRaw, "policy", "", "Review policy: always, on_success, or on_failure")