Function newTaskBlockCommand

internal/cli/task.go:1427–1475

(deps commandDeps)

}

func newTaskBlockCommand(deps commandDeps) *cobra.Command {
	input := taskBlockInput{}
	cmd := &cobra.Command{
		Use:   "block <id>",
		Short: "Block a task with a typed reason",
		Args:  exactOneNonBlankArg(),
		RunE: func(cmd *cobra.Command, args []string) error {
			request, err := buildTaskBlockRequest(cmd, input, cliNow(deps.now))
			if err != nil {
				return err
			}
			if request.RunID != "" && !input.AsAgent {
				return errors.New("cli: --run-id requires --as-agent so the active lease can be resolved")
			}
			client, err := clientFromDeps(deps)
			if err != nil {
				return err
			}
			var block TaskBlockRecord
			if input.AsAgent {
				credentials, credErr := requireAgentCommandIdentity(
					cmd.Context(),
					deps,
					client,
					agentActionCLI("task.block"),
				)
				if credErr != nil {
					return credErr
				}
				block, err = client.BlockTaskAsAgent(cmd.Context(), args[0], request, credentials)
			} else {
				block, err = client.BlockTask(cmd.Context(), args[0], request)
			}
			if err != nil {
				return err
			}
			return writeCommandOutput(cmd, taskBlockBundle(block))
		},
	}
	cmd.Flags().StringVar(&input.KindRaw, taskKindKey, "", "Block kind: needs_input, capability, or transient")
	cmd.Flags().StringVar(&input.Reason, taskReasonKey, "", "Block reason")
	cmd.Flags().StringVar(&input.DetailsRaw, "details", "", "Optional block details JSON")
	cmd.Flags().StringVar(&input.ExpiresIn, "expires-in", "", "Optional transient block duration")
	cmd.Flags().StringVar(&input.RunID, "run-id", "", "Active run ID to park when blocking")
	cmd.Flags().BoolVar(&input.AsAgent, "as-agent", false, "Block using the current AGH-managed agent session identity")
	mustMarkFlagRequired(cmd, taskKindKey)
	mustMarkFlagRequired(cmd, taskReasonKey)
	return cmd
}

func newTaskUnblockCommand(deps commandDeps) *cobra.Command {
	var blockID string