[redisenterprise] Retarget to 2026-06-01-preview; add migration group; fix migration undo LRO

src/redisenterprise/HISTORY.rst

@@ -2,6 +2,17 @@
 
 Release History
 ===============
+1.5.0b1
+- Preview release. Adds support for the 2025-08-01-preview, 2026-02-01-preview, and 2026-06-01-preview API versions.
+- Added a new command group `az redisenterprise migration` to migrate an existing Azure Cache for Redis instance into an Azure Managed Redis (Redis Enterprise) cluster:
+  - `start`: start a migration from a source Azure Cache for Redis resource. The source properties are exposed as flat arguments: `--source-resource-id`, `--skip-data-migration`, `--switch-dns`, and `--force-migrate`.
+  - `validate`: validate whether a source Azure Cache for Redis resource can be migrated to the target cluster.
+  - `undo`: cancel or roll back an in-progress migration.
+  - `list` / `show`: view migration attempts on a cluster.
+- Added `--maintenance-config`/`--maintenance-configuration` to `az redisenterprise create` and `az redisenterprise update` to configure cluster-level maintenance, including custom maintenance windows that control when maintenance is applied to the cluster.
+- Added `--notify-keyspace-events` to `az redisenterprise database create` and `az redisenterprise database update` to configure Redis keyspace notifications. Defaults to disabled (empty string); when set, the value must include at least 'K' (keyspace events) or 'E' (keyevent events), for example 'AKE' to enable all standard events.
+- Added `--access-string` to `az redisenterprise database access-policy-assignment create` and `update` to set a custom Redis ACL permissions string for the assignment (for example, `+@read ~cache:*`); defaults to `+@all ~*` when not specified.
+
 1.4.0
 - add a new command `az redisenterprise test-connection` to test the connection to a cluster.
 

src/redisenterprise/azext_redisenterprise/_params.py

@@ -45,6 +45,10 @@ def load_arguments(self, _):
                    validator=get_default_location_from_resource_group)
         c.argument('high_availability', arg_type=get_enum_type(['Disabled', 'Enabled']), options_list=['--high-availability'], help='Enabled by default. If highAvailability is disabled, the data set is not replicated. This affects the availability SLA, and increases the risk of data loss.')
         c.argument('public_network_access', arg_type=get_enum_type(['Disabled', 'Enabled']), options_list=['--public-network-access'], help='Whether or not public network traffic can access the Redis cluster. Only Enabled or Disabled can be set. null is returned only for clusters created using an old API version which do not have this property and cannot be set.')
+        c.argument('maintenance_configuration', options_list=['--maintenance-config', '--maintenance-configuration'],
+                   type=validate_file_or_dict, help='Cluster-level maintenance configuration. Expected value: '
+                   'json-string/@json-file. Example: \'{"maintenance-windows":[{"duration":"PT5H","type":"Weekly",'
+                   '"start-hour-utc":1,"schedule":{"day-of-week":"Monday"}}]}\'')
         c.argument('sku', arg_type=get_enum_type(['Balanced_B0', 'Balanced_B1', 'Balanced_B10', 'Balanced_B100', 'Balanced_B1000', 'Balanced_B150', 'Balanced_B20', 'Balanced_B250', 'Balanced_B3', 'Balanced_B350', 'Balanced_B5', 'Balanced_B50', 'Balanced_B500', 'Balanced_B700', 'ComputeOptimized_X10', 'ComputeOptimized_X100', 'ComputeOptimized_X150', 'ComputeOptimized_X20', 'ComputeOptimized_X250', 'ComputeOptimized_X3', 'ComputeOptimized_X350', 'ComputeOptimized_X5', 'ComputeOptimized_X50', 'ComputeOptimized_X500', 'ComputeOptimized_X700', 'EnterpriseFlash_F1500', 'EnterpriseFlash_F300', 'EnterpriseFlash_F700', 'Enterprise_E1', 'Enterprise_E10', 'Enterprise_E100', 'Enterprise_E20', 'Enterprise_E200', 'Enterprise_E400', 'Enterprise_E5', 'Enterprise_E50', 'FlashOptimized_A1000', 'FlashOptimized_A1500', 'FlashOptimized_A2000', 'FlashOptimized_A250', 'FlashOptimized_A4500', 'FlashOptimized_A500', 'FlashOptimized_A700', 'MemoryOptimized_M10', 'MemoryOptimized_M100', 'MemoryOptimized_M1000', 'MemoryOptimized_M150', 'MemoryOptimized_M1500', 'MemoryOptimized_M20', 'MemoryOptimized_M2000', 'MemoryOptimized_M250', 'MemoryOptimized_M350', 'MemoryOptimized_M50', 'MemoryOptimized_M500', 'MemoryOptimized_M700']), help='The type of RedisEnterprise cluster '
                    'to deploy. Possible values: (Enterprise_E10, EnterpriseFlash_F300 etc.)')
         c.argument('capacity', type=int, help='The size of the RedisEnterprise cluster. Defaults to 2 or 3 or not applicable depending on SKU.'
@@ -54,8 +58,8 @@ def load_arguments(self, _):
         c.argument('minimum_tls_version', arg_type=get_enum_type(['1.0', '1.1', '1.2']), help='The minimum TLS version '
                    'for the cluster to support, e.g. \'1.2\'')
         c.argument('key_encryption_key_url', options_list=['--key-encryption-key-url'],
-                   type=str, help='Key encryption key Url, versioned only.'
-                   'Ex: https://contosovault.vault.azure.net/keys/contosokek/562a4bb76b524a1493a6afe8e536ee78',
+                   type=str, help='Key encryption key Url, versioned only. '
+                   'Ex: `https://contosovault.vault.azure.net/keys/contosokek/562a4bb76b524a1493a6afe8e536ee78`',
                    arg_group='Encryption')
         c.argument('identity_type', options_list=['--identity-type'],
                    arg_type=get_enum_type(['None', 'SystemAssigned', 'UserAssigned', 'SystemAssigned, UserAssigned']),
@@ -114,7 +118,7 @@ def load_arguments(self, _):
                    'for the cluster to support, e.g. \'1.2\'')
         c.argument('key_encryption_key_url', options_list=['--key-encryption-key-url'], type=str,
                    help='Key encryption key Url, versioned only. '
-                   'Ex: https://contosovault.vault.azure.net/keys/contosokek/562a4bb76b524a1493a6afe8e536ee78',
+                   'Ex: `https://contosovault.vault.azure.net/keys/contosokek/562a4bb76b524a1493a6afe8e536ee78`',
                    arg_group='Encryption')
         c.argument('identity_type', options_list=['--identity-type'],
                    arg_type=get_enum_type(['None', 'SystemAssigned', 'UserAssigned', 'SystemAssigned, UserAssigned']),

src/redisenterprise/azext_redisenterprise/aaz/latest/redisenterprise/_create.py

@@ -19,9 +19,9 @@ class Create(AAZCommand):
     """
 
     _aaz_info = {
-        "version": "2025-07-01",
+        "version": "2026-06-01-preview",
         "resources": [
-            ["mgmt-plane", "/subscriptions/{}/resourcegroups/{}/providers/microsoft.cache/redisenterprise/{}", "2025-07-01"],
+            ["mgmt-plane", "/subscriptions/{}/resourcegroups/{}/providers/microsoft.cache/redisenterprise/{}", "2026-06-01-preview"],
         ]
     }
 
@@ -150,6 +150,11 @@ def _build_arguments_schema(cls, *args, **kwargs):
             help="Enabled by default. If highAvailability is disabled, the data set is not replicated. This affects the availability SLA, and increases the risk of data loss.",
             enum={"Disabled": "Disabled", "Enabled": "Enabled"},
         )
+        _args_schema.maintenance_configuration = AAZObjectArg(
+            options=["--maintenance-config", "--maintenance-configuration"],
+            arg_group="Properties",
+            help="Cluster-level maintenance configuration.",
+        )
         _args_schema.minimum_tls_version = AAZStrArg(
             options=["--minimum-tls-version"],
             arg_group="Properties",
@@ -164,6 +169,49 @@ def _build_arguments_schema(cls, *args, **kwargs):
             enum={"Disabled": "Disabled", "Enabled": "Enabled"},
         )
 
+        maintenance_configuration = cls._args_schema.maintenance_configuration
+        maintenance_configuration.maintenance_windows = AAZListArg(
+            options=["maintenance-windows"],
+            help="Custom maintenance windows that apply to the cluster.",
+        )
+
+        maintenance_windows = cls._args_schema.maintenance_configuration.maintenance_windows
+        maintenance_windows.Element = AAZObjectArg()
+
+        _element = cls._args_schema.maintenance_configuration.maintenance_windows.Element
+        _element.duration = AAZStrArg(
+            options=["duration"],
+            help="Duration in ISO-8601 format, for example 'PT5H'.",
+            required=True,
+        )
+        _element.schedule = AAZObjectArg(
+            options=["schedule"],
+            help="Recurring schedule for the maintenance window.",
+            required=True,
+        )
+        _element.start_hour_utc = AAZIntArg(
+            options=["start-hour-utc"],
+            help="Start hour (0-23) in UTC when the maintenance window begins.",
+            required=True,
+            fmt=AAZIntArgFormat(
+                maximum=23,
+                minimum=0,
+            ),
+        )
+        _element.type = AAZStrArg(
+            options=["type"],
+            help="Maintenance window type.",
+            required=True,
+            enum={"Weekly": "Weekly"},
+        )
+
+        schedule = cls._args_schema.maintenance_configuration.maintenance_windows.Element.schedule
+        schedule.day_of_week = AAZStrArg(
+            options=["day-of-week"],
+            help="Day of week. Required when the maintenance window type is 'Weekly'.",
+            enum={"Friday": "Friday", "Monday": "Monday", "Saturday": "Saturday", "Sunday": "Sunday", "Thursday": "Thursday", "Tuesday": "Tuesday", "Wednesday": "Wednesday"},
+        )
+
         # define Arg Group "Sku"
 
         _args_schema = cls._args_schema
@@ -262,7 +310,7 @@ def url_parameters(self):
         def query_parameters(self):
             parameters = {
                 **self.serialize_query_param(
-                    "api-version", "2025-07-01",
+                    "api-version", "2026-06-01-preview",
                     required=True,
                 ),
             }
@@ -313,6 +361,7 @@ def content(self):
             if properties is not None:
                 properties.set_prop("encryption", AAZObjectType)
                 properties.set_prop("highAvailability", AAZStrType, ".high_availability")
+                properties.set_prop("maintenanceConfiguration", AAZObjectType, ".maintenance_configuration")
                 properties.set_prop("minimumTlsVersion", AAZStrType, ".minimum_tls_version")
                 properties.set_prop("publicNetworkAccess", AAZStrType, ".public_network_access", typ_kwargs={"flags": {"required": True}, "nullable": True})
 
@@ -330,6 +379,25 @@ def content(self):
                 key_encryption_key_identity.set_prop("identityType", AAZStrType, ".key_encryption_identity_type")
                 key_encryption_key_identity.set_prop("userAssignedIdentityResourceId", AAZStrType, ".user_assigned_identity_resource_id")
 
+            maintenance_configuration = _builder.get(".properties.maintenanceConfiguration")
+            if maintenance_configuration is not None:
+                maintenance_configuration.set_prop("maintenanceWindows", AAZListType, ".maintenance_windows")
+
+            maintenance_windows = _builder.get(".properties.maintenanceConfiguration.maintenanceWindows")
+            if maintenance_windows is not None:
+                maintenance_windows.set_elements(AAZObjectType, ".")
+
+            _elements = _builder.get(".properties.maintenanceConfiguration.maintenanceWindows[]")
+            if _elements is not None:
+                _elements.set_prop("duration", AAZStrType, ".duration", typ_kwargs={"flags": {"required": True}})
+                _elements.set_prop("schedule", AAZObjectType, ".schedule", typ_kwargs={"flags": {"required": True}})
+                _elements.set_prop("startHourUtc", AAZIntType, ".start_hour_utc", typ_kwargs={"flags": {"required": True}})
+                _elements.set_prop("type", AAZStrType, ".type", typ_kwargs={"flags": {"required": True}})
+
+            schedule = _builder.get(".properties.maintenanceConfiguration.maintenanceWindows[].schedule")
+            if schedule is not None:
+                schedule.set_prop("dayOfWeek", AAZStrType, ".day_of_week")
+
             sku = _builder.get(".sku")
             if sku is not None:
                 sku.set_prop("capacity", AAZIntType, ".capacity")
@@ -382,6 +450,11 @@ def _build_schema_on_200_201(cls):
             _schema_on_200_201.sku = AAZObjectType(
                 flags={"required": True},
             )
+            _schema_on_200_201.system_data = AAZObjectType(
+                serialized_name="systemData",
+                flags={"read_only": True},
+            )
+            _CreateHelper._build_schema_system_data_read(_schema_on_200_201.system_data)
             _schema_on_200_201.tags = AAZDictType()
             _schema_on_200_201.type = AAZStrType(
                 flags={"read_only": True},
@@ -426,6 +499,13 @@ def _build_schema_on_200_201(cls):
                 serialized_name="hostName",
                 flags={"read_only": True},
             )
+            properties.maintenance_configuration = AAZObjectType(
+                serialized_name="maintenanceConfiguration",
+            )
+            properties.migrated_endpoint = AAZStrType(
+                serialized_name="migratedEndpoint",
+                flags={"read_only": True},
+            )
             properties.minimum_tls_version = AAZStrType(
                 serialized_name="minimumTlsVersion",
             )
@@ -476,6 +556,34 @@ def _build_schema_on_200_201(cls):
                 serialized_name="userAssignedIdentityResourceId",
             )
 
+            maintenance_configuration = cls._schema_on_200_201.properties.maintenance_configuration
+            maintenance_configuration.maintenance_windows = AAZListType(
+                serialized_name="maintenanceWindows",
+            )
+
+            maintenance_windows = cls._schema_on_200_201.properties.maintenance_configuration.maintenance_windows
+            maintenance_windows.Element = AAZObjectType()
+
+            _element = cls._schema_on_200_201.properties.maintenance_configuration.maintenance_windows.Element
+            _element.duration = AAZStrType(
+                flags={"required": True},
+            )
+            _element.schedule = AAZObjectType(
+                flags={"required": True},
+            )
+            _element.start_hour_utc = AAZIntType(
+                serialized_name="startHourUtc",
+                flags={"required": True},
+            )
+            _element.type = AAZStrType(
+                flags={"required": True},
+            )
+
+            schedule = cls._schema_on_200_201.properties.maintenance_configuration.maintenance_windows.Element.schedule
+            schedule.day_of_week = AAZStrType(
+                serialized_name="dayOfWeek",
+            )
+
             private_endpoint_connections = cls._schema_on_200_201.properties.private_endpoint_connections
             private_endpoint_connections.Element = AAZObjectType()
 
@@ -489,11 +597,20 @@ def _build_schema_on_200_201(cls):
             _element.properties = AAZObjectType(
                 flags={"client_flatten": True},
             )
+            _element.system_data = AAZObjectType(
+                serialized_name="systemData",
+                flags={"read_only": True},
+            )
+            _CreateHelper._build_schema_system_data_read(_element.system_data)
             _element.type = AAZStrType(
                 flags={"read_only": True},
             )
 
             properties = cls._schema_on_200_201.properties.private_endpoint_connections.Element.properties
+            properties.group_ids = AAZListType(
+                serialized_name="groupIds",
+                flags={"read_only": True},
+            )
             properties.private_endpoint = AAZObjectType(
                 serialized_name="privateEndpoint",
             )
@@ -506,6 +623,9 @@ def _build_schema_on_200_201(cls):
                 flags={"read_only": True},
             )
 
+            group_ids = cls._schema_on_200_201.properties.private_endpoint_connections.Element.properties.group_ids
+            group_ids.Element = AAZStrType()
+
             private_endpoint = cls._schema_on_200_201.properties.private_endpoint_connections.Element.properties.private_endpoint
             private_endpoint.id = AAZStrType(
                 flags={"read_only": True},
@@ -536,5 +656,49 @@ def _build_schema_on_200_201(cls):
 class _CreateHelper:
     """Helper class for Create"""
 
+    _schema_system_data_read = None
+
+    @classmethod
+    def _build_schema_system_data_read(cls, _schema):
+        if cls._schema_system_data_read is not None:
+            _schema.created_at = cls._schema_system_data_read.created_at
+            _schema.created_by = cls._schema_system_data_read.created_by
+            _schema.created_by_type = cls._schema_system_data_read.created_by_type
+            _schema.last_modified_at = cls._schema_system_data_read.last_modified_at
+            _schema.last_modified_by = cls._schema_system_data_read.last_modified_by
+            _schema.last_modified_by_type = cls._schema_system_data_read.last_modified_by_type
+            return
+
+        cls._schema_system_data_read = _schema_system_data_read = AAZObjectType(
+            flags={"read_only": True}
+        )
+
+        system_data_read = _schema_system_data_read
+        system_data_read.created_at = AAZStrType(
+            serialized_name="createdAt",
+        )
+        system_data_read.created_by = AAZStrType(
+            serialized_name="createdBy",
+        )
+        system_data_read.created_by_type = AAZStrType(
+            serialized_name="createdByType",
+        )
+        system_data_read.last_modified_at = AAZStrType(
+            serialized_name="lastModifiedAt",
+        )
+        system_data_read.last_modified_by = AAZStrType(
+            serialized_name="lastModifiedBy",
+        )
+        system_data_read.last_modified_by_type = AAZStrType(
+            serialized_name="lastModifiedByType",
+        )
+
+        _schema.created_at = cls._schema_system_data_read.created_at
+        _schema.created_by = cls._schema_system_data_read.created_by
+        _schema.created_by_type = cls._schema_system_data_read.created_by_type
+        _schema.last_modified_at = cls._schema_system_data_read.last_modified_at
+        _schema.last_modified_by = cls._schema_system_data_read.last_modified_by
+        _schema.last_modified_by_type = cls._schema_system_data_read.last_modified_by_type
+
 
 __all__ = ["Create"]

src/redisenterprise/azext_redisenterprise/aaz/latest/redisenterprise/_delete.py

@@ -20,9 +20,9 @@ class Delete(AAZCommand):
     """
 
     _aaz_info = {
-        "version": "2025-07-01",
+        "version": "2026-06-01-preview",
         "resources": [
-            ["mgmt-plane", "/subscriptions/{}/resourcegroups/{}/providers/microsoft.cache/redisenterprise/{}", "2025-07-01"],
+            ["mgmt-plane", "/subscriptions/{}/resourcegroups/{}/providers/microsoft.cache/redisenterprise/{}", "2026-06-01-preview"],
         ]
     }
 
@@ -143,7 +143,7 @@ def url_parameters(self):
         def query_parameters(self):
             parameters = {
                 **self.serialize_query_param(
-                    "api-version", "2025-07-01",
+                    "api-version", "2026-06-01-preview",
                     required=True,
                 ),
             }