Function runSessionTaskFailCommand

internal/cli/task.go:1785–1828

(
	cmd *cobra.Command,
	deps commandDeps,
	runIDs []string,
	flags taskFailCommandFlags,
)

}

func runSessionTaskFailCommand(
	cmd *cobra.Command,
	deps commandDeps,
	runIDs []string,
	flags taskFailCommandFlags,
) error {
	if cmd.Flags().Changed("reason") {
		return errors.New(
			"cli: choose either --error for session-bound failure or --reason for force failure",
		)
	}
	if len(runIDs) != 1 {
		return errors.New("cli: --error supports exactly one run id")
	}
	request := AgentTaskFailRequest{Error: strings.TrimSpace(flags.errorMessage)}
	if request.Error == "" {
		return errors.New("cli: --error is required")
	}
	if cmd.Flags().Changed("metadata") {
		metadata, err := parseAgentTaskJSONFlag("metadata", flags.metadataRaw)
		if err != nil {
			return err
		}
		request.Metadata = metadata
	}
	client, err := clientFromDeps(deps)
	if err != nil {
		return err
	}
	credentials, err := requireAgentCommandIdentity(
		cmd.Context(),
		deps,
		client,
		agentActionCLI("task.fail"),
	)
	if err != nil {
		return err
	}
	record, err := client.AgentTaskFail(cmd.Context(), runIDs[0], request, credentials)
	if err != nil {
		return err
	}
	return writeCommandOutput(cmd, agentTaskLeaseBundle(record))
}

func runForceTaskFailCommand(
	cmd *cobra.Command,