Function newTaskNextCommand

internal/cli/task.go:1570–1637

(deps commandDeps)

}

func newTaskNextCommand(deps commandDeps) *cobra.Command {
	var (
		workspaceID          string
		requiredCapabilities []string
		priorityMin          int
		leaseSeconds         int64
		wait                 bool
		idempotencyKey       string
	)

	cmd := &cobra.Command{
		Use:   taskNextKey,
		Short: "Claim the next task run for the current agent session",
		Args:  cobra.NoArgs,
		Example: `  # Claim the next available run for this session
  agh task next

  # Wait until matching work is claimable and request a five-minute lease
  agh task next --wait --lease-seconds 300 -o json

  # Filter by required caller capability
  agh task next --capability go.test --priority-min 10`,
		RunE: func(cmd *cobra.Command, _ []string) error {
			if err := validateAgentTaskLeaseSeconds(leaseSeconds); err != nil {
				return err
			}
			if priorityMin < 0 {
				return fmt.Errorf("cli: --priority-min must be zero or positive: %d", priorityMin)
			}
			request := AgentTaskClaimNextRequest{
				WorkspaceID:          strings.TrimSpace(workspaceID),
				RequiredCapabilities: trimAgentTaskCapabilities(requiredCapabilities),
				PriorityMin:          priorityMin,
				LeaseSeconds:         leaseSeconds,
				Wait:                 wait,
				IdempotencyKey:       strings.TrimSpace(idempotencyKey),
			}

			client, err := clientFromDeps(deps)
			if err != nil {
				return err
			}
			credentials, err := requireAgentCommandIdentity(
				cmd.Context(),
				deps,
				client,
				agentActionCLI("task.next"),
			)
			if err != nil {
				return err
			}
			record, err := client.AgentTaskClaimNext(cmd.Context(), request, credentials)
			if err != nil {
				return err
			}
			return writeCommandOutput(cmd, agentTaskNextBundle(record))
		},
	}