diff --git a/internal/flink/command_compute_pool_delete.go b/internal/flink/command_compute_pool_delete.go index 0908c21cfd..ea75523102 100644 --- a/internal/flink/command_compute_pool_delete.go +++ b/internal/flink/command_compute_pool_delete.go @@ -7,10 +7,8 @@ import ( "github.com/spf13/cobra" pcmd "github.com/confluentinc/cli/v3/pkg/cmd" - "github.com/confluentinc/cli/v3/pkg/config" "github.com/confluentinc/cli/v3/pkg/deletion" "github.com/confluentinc/cli/v3/pkg/errors" - "github.com/confluentinc/cli/v3/pkg/featureflags" "github.com/confluentinc/cli/v3/pkg/resource" "github.com/confluentinc/cli/v3/pkg/utils" ) @@ -51,7 +49,7 @@ func (c *command) computePoolDelete(cmd *cobra.Command, args []string) error { return err == nil } - if err := c.validateAndConfirmComputePoolDeletion(cmd, args, existenceFunc, resource.FlinkComputePool, computePool.Spec.GetDisplayName()); err != nil { + if err := validateAndConfirmComputePoolDeletion(cmd, args, existenceFunc, resource.FlinkComputePool, computePool.Spec.GetDisplayName()); err != nil { return err } @@ -79,11 +77,7 @@ func confirmMultipleDeletionString(idList []string) string { "After that, they will be permanently deleted. \n", utils.ArrayToCommaDelimitedString(idList, "and")) } -func (c *command) validateAndConfirmComputePoolDeletion(cmd *cobra.Command, args []string, checkExistence func(string) bool, resourceType, name string) error { - if !featureflags.Manager.BoolVariation("flink.statement.30_days_retention_time", c.Context, config.CliLaunchDarklyClient, true, true) { - return deletion.ValidateAndConfirmDeletion(cmd, args, checkExistence, resourceType, name) - } - +func validateAndConfirmComputePoolDeletion(cmd *cobra.Command, args []string, checkExistence func(string) bool, resourceType, name string) error { if err := resource.ValidatePrefixes(resourceType, args); err != nil { return err }