[AutoRelease] t2-durabletask-2025-04-15-53452(can only be merged by SDK owner)

sdk/durabletask/azure-mgmt-durabletask/CHANGELOG.md

@@ -1,5 +1,28 @@
 # Release History
 
+## 1.0.0b2 (2025-04-15)
+
+### Features Added
+
+  - Client `DurableTaskMgmtClient` added operation group `retention_policies`
+  - Added enum `PurgeableOrchestrationState`
+  - Added model `RetentionPolicy`
+  - Added model `RetentionPolicyDetails`
+  - Added model `RetentionPolicyProperties`
+  - Added model `RetentionPoliciesOperations`
+  - Method `RetentionPolicy.__init__` has a new overload `def __init__(self: None, properties: Optional[_models.RetentionPolicyProperties])`
+  - Method `RetentionPolicy.__init__` has a new overload `def __init__(self: None, mapping: Mapping[str, Any])`
+  - Method `RetentionPolicyDetails.__init__` has a new overload `def __init__(self: None, retention_period_in_days: int, orchestration_state: Optional[Union[str, _models.PurgeableOrchestrationState]])`
+  - Method `RetentionPolicyDetails.__init__` has a new overload `def __init__(self: None, mapping: Mapping[str, Any])`
+  - Method `RetentionPolicyProperties.__init__` has a new overload `def __init__(self: None, retention_policies: Optional[List[_models.RetentionPolicyDetails]])`
+  - Method `RetentionPolicyProperties.__init__` has a new overload `def __init__(self: None, mapping: Mapping[str, Any])`
+  - Method `RetentionPoliciesOperations.begin_create_or_replace` has a new overload `def begin_create_or_replace(self: None, resource_group_name: str, scheduler_name: str, resource: RetentionPolicy, content_type: str)`
+  - Method `RetentionPoliciesOperations.begin_create_or_replace` has a new overload `def begin_create_or_replace(self: None, resource_group_name: str, scheduler_name: str, resource: JSON, content_type: str)`
+  - Method `RetentionPoliciesOperations.begin_create_or_replace` has a new overload `def begin_create_or_replace(self: None, resource_group_name: str, scheduler_name: str, resource: IO[bytes], content_type: str)`
+  - Method `RetentionPoliciesOperations.begin_update` has a new overload `def begin_update(self: None, resource_group_name: str, scheduler_name: str, properties: RetentionPolicy, content_type: str)`
+  - Method `RetentionPoliciesOperations.begin_update` has a new overload `def begin_update(self: None, resource_group_name: str, scheduler_name: str, properties: JSON, content_type: str)`
+  - Method `RetentionPoliciesOperations.begin_update` has a new overload `def begin_update(self: None, resource_group_name: str, scheduler_name: str, properties: IO[bytes], content_type: str)`
+
 ## 1.0.0b1 (2025-03-25)
 
 ### Other Changes

sdk/durabletask/azure-mgmt-durabletask/README.md

@@ -24,7 +24,7 @@ pip install azure-identity
 
 ### Authentication
 
-By default, [Azure Active Directory](https://aka.ms/awps/aad) token authentication depends on correct configure of following environment variables.
+By default, [Azure Active Directory](https://aka.ms/awps/aad) token authentication depends on correct configuration of the following environment variables.
 
 - `AZURE_CLIENT_ID` for Azure client ID.
 - `AZURE_TENANT_ID` for Azure tenant ID.

sdk/durabletask/azure-mgmt-durabletask/_meta.json

@@ -1,6 +1,6 @@
 {
-  "commit": "7b8c7b5a83ea874d6edf8f01d44bd923a664f31e",
+  "commit": "9db97082212bc1bb0f428681766d69a9e8a7435d",
   "repository_url": "https://github.com/Azure/azure-rest-api-specs",
   "typespec_src": "specification/durabletask/DurableTask.Management",
-  "@azure-tools/typespec-python": "0.39.1"
+  "@azure-tools/typespec-python": "0.42.2"
 }

sdk/durabletask/azure-mgmt-durabletask/apiview-properties.json

@@ -8,6 +8,9 @@
         "azure.mgmt.durabletask.models.OperationDisplay": "Azure.ResourceManager.CommonTypes.OperationDisplay",
         "azure.mgmt.durabletask.models.Resource": "Azure.ResourceManager.CommonTypes.Resource",
         "azure.mgmt.durabletask.models.ProxyResource": "Azure.ResourceManager.CommonTypes.ProxyResource",
+        "azure.mgmt.durabletask.models.RetentionPolicy": "Microsoft.DurableTask.RetentionPolicy",
+        "azure.mgmt.durabletask.models.RetentionPolicyDetails": "Microsoft.DurableTask.RetentionPolicyDetails",
+        "azure.mgmt.durabletask.models.RetentionPolicyProperties": "Microsoft.DurableTask.RetentionPolicyProperties",
         "azure.mgmt.durabletask.models.TrackedResource": "Azure.ResourceManager.CommonTypes.TrackedResource",
         "azure.mgmt.durabletask.models.Scheduler": "Microsoft.DurableTask.Scheduler",
         "azure.mgmt.durabletask.models.SchedulerProperties": "Microsoft.DurableTask.SchedulerProperties",
@@ -23,6 +26,7 @@
         "azure.mgmt.durabletask.models.CreatedByType": "Azure.ResourceManager.CommonTypes.createdByType",
         "azure.mgmt.durabletask.models.ProvisioningState": "Microsoft.DurableTask.ProvisioningState",
         "azure.mgmt.durabletask.models.RedundancyState": "Microsoft.DurableTask.RedundancyState",
+        "azure.mgmt.durabletask.models.PurgeableOrchestrationState": "Microsoft.DurableTask.PurgeableOrchestrationState",
         "azure.mgmt.durabletask.DurableTaskMgmtClient.operations.list": "Azure.ResourceManager.Operations.list",
         "azure.mgmt.durabletask.DurableTaskMgmtClient.schedulers.get": "Microsoft.DurableTask.Schedulers.get",
         "azure.mgmt.durabletask.DurableTaskMgmtClient.schedulers.begin_create_or_update": "Microsoft.DurableTask.Schedulers.createOrUpdate",
@@ -33,6 +37,11 @@
         "azure.mgmt.durabletask.DurableTaskMgmtClient.task_hubs.get": "Microsoft.DurableTask.TaskHubs.get",
         "azure.mgmt.durabletask.DurableTaskMgmtClient.task_hubs.begin_create_or_update": "Microsoft.DurableTask.TaskHubs.createOrUpdate",
         "azure.mgmt.durabletask.DurableTaskMgmtClient.task_hubs.begin_delete": "Microsoft.DurableTask.TaskHubs.delete",
-        "azure.mgmt.durabletask.DurableTaskMgmtClient.task_hubs.list_by_scheduler": "Microsoft.DurableTask.TaskHubs.listByScheduler"
+        "azure.mgmt.durabletask.DurableTaskMgmtClient.task_hubs.list_by_scheduler": "Microsoft.DurableTask.TaskHubs.listByScheduler",
+        "azure.mgmt.durabletask.DurableTaskMgmtClient.retention_policies.get": "Microsoft.DurableTask.RetentionPolicies.get",
+        "azure.mgmt.durabletask.DurableTaskMgmtClient.retention_policies.begin_create_or_replace": "Microsoft.DurableTask.RetentionPolicies.createOrReplace",
+        "azure.mgmt.durabletask.DurableTaskMgmtClient.retention_policies.begin_update": "Microsoft.DurableTask.RetentionPolicies.update",
+        "azure.mgmt.durabletask.DurableTaskMgmtClient.retention_policies.begin_delete": "Microsoft.DurableTask.RetentionPolicies.delete",
+        "azure.mgmt.durabletask.DurableTaskMgmtClient.retention_policies.list_by_scheduler": "Microsoft.DurableTask.RetentionPolicies.listByScheduler"
     }
 }

sdk/durabletask/azure-mgmt-durabletask/azure/mgmt/durabletask/_client.py

@@ -17,7 +17,7 @@
 
 from ._configuration import DurableTaskMgmtClientConfiguration
 from ._serialization import Deserializer, Serializer
-from .operations import Operations, SchedulersOperations, TaskHubsOperations
+from .operations import Operations, RetentionPoliciesOperations, SchedulersOperations, TaskHubsOperations
 
 if TYPE_CHECKING:
     from azure.core.credentials import TokenCredential
@@ -32,14 +32,16 @@ class DurableTaskMgmtClient:
     :vartype schedulers: azure.mgmt.durabletask.operations.SchedulersOperations
     :ivar task_hubs: TaskHubsOperations operations
     :vartype task_hubs: azure.mgmt.durabletask.operations.TaskHubsOperations
+    :ivar retention_policies: RetentionPoliciesOperations operations
+    :vartype retention_policies: azure.mgmt.durabletask.operations.RetentionPoliciesOperations
     :param credential: Credential used to authenticate requests to the service. Required.
     :type credential: ~azure.core.credentials.TokenCredential
     :param subscription_id: The ID of the target subscription. The value must be an UUID. Required.
     :type subscription_id: str
     :param base_url: Service host. Default value is "https://management.azure.com".
     :type base_url: str
     :keyword api_version: The API version to use for this operation. Default value is
-     "2024-10-01-preview". Note that overriding this default value may result in unsupported
+     "2025-04-01-preview". Note that overriding this default value may result in unsupported
      behavior.
     :paramtype api_version: str
     :keyword int polling_interval: Default waiting time between two polls for LRO operations if no
@@ -83,6 +85,9 @@ def __init__(
         self.operations = Operations(self._client, self._config, self._serialize, self._deserialize)
         self.schedulers = SchedulersOperations(self._client, self._config, self._serialize, self._deserialize)
         self.task_hubs = TaskHubsOperations(self._client, self._config, self._serialize, self._deserialize)
+        self.retention_policies = RetentionPoliciesOperations(
+            self._client, self._config, self._serialize, self._deserialize
+        )
 
     def send_request(self, request: HttpRequest, *, stream: bool = False, **kwargs: Any) -> HttpResponse:
         """Runs the network request through the client's chained policies.

sdk/durabletask/azure-mgmt-durabletask/azure/mgmt/durabletask/_configuration.py

@@ -30,7 +30,7 @@ class DurableTaskMgmtClientConfiguration:  # pylint: disable=too-many-instance-a
     :param base_url: Service host. Default value is "https://management.azure.com".
     :type base_url: str
     :keyword api_version: The API version to use for this operation. Default value is
-     "2024-10-01-preview". Note that overriding this default value may result in unsupported
+     "2025-04-01-preview". Note that overriding this default value may result in unsupported
      behavior.
     :paramtype api_version: str
     """
@@ -42,7 +42,7 @@ def __init__(
         base_url: str = "https://management.azure.com",
         **kwargs: Any
     ) -> None:
-        api_version: str = kwargs.pop("api_version", "2024-10-01-preview")
+        api_version: str = kwargs.pop("api_version", "2025-04-01-preview")
 
         if credential is None:
             raise ValueError("Parameter 'credential' must not be None.")

sdk/durabletask/azure-mgmt-durabletask/azure/mgmt/durabletask/_model_base.py

@@ -2,8 +2,9 @@
 # coding=utf-8
 # --------------------------------------------------------------------------
 # Copyright (c) Microsoft Corporation. All rights reserved.
-# Licensed under the MIT License. See License.txt in the project root for
-# license information.
+# Licensed under the MIT License. See License.txt in the project root for license information.
+# Code generated by Microsoft (R) Python Code Generator.
+# Changes may cause incorrect behavior and will be lost if the code is regenerated.
 # --------------------------------------------------------------------------
 # pylint: disable=protected-access, broad-except
 

sdk/durabletask/azure-mgmt-durabletask/azure/mgmt/durabletask/_patch.py

@@ -1,7 +1,8 @@
-# ------------------------------------
-# Copyright (c) Microsoft Corporation.
-# Licensed under the MIT License.
-# ------------------------------------
+# coding=utf-8
+# --------------------------------------------------------------------------
+# Copyright (c) Microsoft Corporation. All rights reserved.
+# Licensed under the MIT License. See License.txt in the project root for license information.
+# --------------------------------------------------------------------------
 """Customize generated code here.
 
 Follow our quickstart for examples: https://aka.ms/azsdk/python/dpcodegen/python/customize

sdk/durabletask/azure-mgmt-durabletask/azure/mgmt/durabletask/_serialization.py

@@ -1,28 +1,10 @@
 # pylint: disable=line-too-long,useless-suppression,too-many-lines
+# coding=utf-8
 # --------------------------------------------------------------------------
-#
 # Copyright (c) Microsoft Corporation. All rights reserved.
-#
-# The MIT License (MIT)
-#
-# Permission is hereby granted, free of charge, to any person obtaining a copy
-# of this software and associated documentation files (the ""Software""), to
-# deal in the Software without restriction, including without limitation the
-# rights to use, copy, modify, merge, publish, distribute, sublicense, and/or
-# sell copies of the Software, and to permit persons to whom the Software is
-# furnished to do so, subject to the following conditions:
-#
-# The above copyright notice and this permission notice shall be included in
-# all copies or substantial portions of the Software.
-#
-# THE SOFTWARE IS PROVIDED *AS IS*, WITHOUT WARRANTY OF ANY KIND, EXPRESS OR
-# IMPLIED, INCLUDING BUT NOT LIMITED TO THE WARRANTIES OF MERCHANTABILITY,
-# FITNESS FOR A PARTICULAR PURPOSE AND NONINFRINGEMENT. IN NO EVENT SHALL THE
-# AUTHORS OR COPYRIGHT HOLDERS BE LIABLE FOR ANY CLAIM, DAMAGES OR OTHER
-# LIABILITY, WHETHER IN AN ACTION OF CONTRACT, TORT OR OTHERWISE, ARISING
-# FROM, OUT OF OR IN CONNECTION WITH THE SOFTWARE OR THE USE OR OTHER DEALINGS
-# IN THE SOFTWARE.
-#
+# Licensed under the MIT License. See License.txt in the project root for license information.
+# Code generated by Microsoft (R) Python Code Generator.
+# Changes may cause incorrect behavior and will be lost if the code is regenerated.
 # --------------------------------------------------------------------------
 
 # pyright: reportUnnecessaryTypeIgnoreComment=false

sdk/durabletask/azure-mgmt-durabletask/azure/mgmt/durabletask/_validation.py

@@ -0,0 +1,50 @@
+# --------------------------------------------------------------------------
+# Copyright (c) Microsoft Corporation. All rights reserved.
+# Licensed under the MIT License. See License.txt in the project root for license information.
+# Code generated by Microsoft (R) Python Code Generator.
+# Changes may cause incorrect behavior and will be lost if the code is regenerated.
+# --------------------------------------------------------------------------
+import functools
+
+
+def api_version_validation(**kwargs):
+    params_added_on = kwargs.pop("params_added_on", {})
+    method_added_on = kwargs.pop("method_added_on", "")
+
+    def decorator(func):
+        @functools.wraps(func)
+        def wrapper(*args, **kwargs):
+            try:
+                # this assumes the client has an _api_version attribute
+                client = args[0]
+                client_api_version = client._config.api_version  # pylint: disable=protected-access
+            except AttributeError:
+                return func(*args, **kwargs)
+
+            if method_added_on > client_api_version:
+                raise ValueError(
+                    f"'{func.__name__}' is not available in API version "
+                    f"{client_api_version}. Pass service API version {method_added_on} or newer to your client."
+                )
+
+            unsupported = {
+                parameter: api_version
+                for api_version, parameters in params_added_on.items()
+                for parameter in parameters
+                if parameter in kwargs and api_version > client_api_version
+            }
+            if unsupported:
+                raise ValueError(
+                    "".join(
+                        [
+                            f"'{param}' is not available in API version {client_api_version}. "
+                            f"Use service API version {version} or newer.\n"
+                            for param, version in unsupported.items()
+                        ]
+                    )
+                )
+            return func(*args, **kwargs)
+
+        return wrapper
+
+    return decorator

sdk/durabletask/azure-mgmt-durabletask/azure/mgmt/durabletask/_version.py

@@ -6,4 +6,4 @@
 # Changes may cause incorrect behavior and will be lost if the code is regenerated.
 # --------------------------------------------------------------------------
 
-VERSION = "1.0.0b1"
+VERSION = "1.0.0b2"

sdk/durabletask/azure-mgmt-durabletask/azure/mgmt/durabletask/aio/_client.py

@@ -17,7 +17,7 @@
 
 from .._serialization import Deserializer, Serializer
 from ._configuration import DurableTaskMgmtClientConfiguration
-from .operations import Operations, SchedulersOperations, TaskHubsOperations
+from .operations import Operations, RetentionPoliciesOperations, SchedulersOperations, TaskHubsOperations
 
 if TYPE_CHECKING:
     from azure.core.credentials_async import AsyncTokenCredential
@@ -32,14 +32,16 @@ class DurableTaskMgmtClient:
     :vartype schedulers: azure.mgmt.durabletask.aio.operations.SchedulersOperations
     :ivar task_hubs: TaskHubsOperations operations
     :vartype task_hubs: azure.mgmt.durabletask.aio.operations.TaskHubsOperations
+    :ivar retention_policies: RetentionPoliciesOperations operations
+    :vartype retention_policies: azure.mgmt.durabletask.aio.operations.RetentionPoliciesOperations
     :param credential: Credential used to authenticate requests to the service. Required.
     :type credential: ~azure.core.credentials_async.AsyncTokenCredential
     :param subscription_id: The ID of the target subscription. The value must be an UUID. Required.
     :type subscription_id: str
     :param base_url: Service host. Default value is "https://management.azure.com".
     :type base_url: str
     :keyword api_version: The API version to use for this operation. Default value is
-     "2024-10-01-preview". Note that overriding this default value may result in unsupported
+     "2025-04-01-preview". Note that overriding this default value may result in unsupported
      behavior.
     :paramtype api_version: str
     :keyword int polling_interval: Default waiting time between two polls for LRO operations if no
@@ -83,6 +85,9 @@ def __init__(
         self.operations = Operations(self._client, self._config, self._serialize, self._deserialize)
         self.schedulers = SchedulersOperations(self._client, self._config, self._serialize, self._deserialize)
         self.task_hubs = TaskHubsOperations(self._client, self._config, self._serialize, self._deserialize)
+        self.retention_policies = RetentionPoliciesOperations(
+            self._client, self._config, self._serialize, self._deserialize
+        )
 
     def send_request(
         self, request: HttpRequest, *, stream: bool = False, **kwargs: Any

sdk/durabletask/azure-mgmt-durabletask/azure/mgmt/durabletask/aio/_configuration.py

@@ -30,7 +30,7 @@ class DurableTaskMgmtClientConfiguration:  # pylint: disable=too-many-instance-a
     :param base_url: Service host. Default value is "https://management.azure.com".
     :type base_url: str
     :keyword api_version: The API version to use for this operation. Default value is
-     "2024-10-01-preview". Note that overriding this default value may result in unsupported
+     "2025-04-01-preview". Note that overriding this default value may result in unsupported
      behavior.
     :paramtype api_version: str
     """
@@ -42,7 +42,7 @@ def __init__(
         base_url: str = "https://management.azure.com",
         **kwargs: Any
     ) -> None:
-        api_version: str = kwargs.pop("api_version", "2024-10-01-preview")
+        api_version: str = kwargs.pop("api_version", "2025-04-01-preview")
 
         if credential is None:
             raise ValueError("Parameter 'credential' must not be None.")

sdk/durabletask/azure-mgmt-durabletask/azure/mgmt/durabletask/aio/_patch.py

@@ -1,7 +1,8 @@
-# ------------------------------------
-# Copyright (c) Microsoft Corporation.
-# Licensed under the MIT License.
-# ------------------------------------
+# coding=utf-8
+# --------------------------------------------------------------------------
+# Copyright (c) Microsoft Corporation. All rights reserved.
+# Licensed under the MIT License. See License.txt in the project root for license information.
+# --------------------------------------------------------------------------
 """Customize generated code here.
 
 Follow our quickstart for examples: https://aka.ms/azsdk/python/dpcodegen/python/customize

sdk/durabletask/azure-mgmt-durabletask/azure/mgmt/durabletask/aio/operations/__init__.py

@@ -15,6 +15,7 @@
 from ._operations import Operations  # type: ignore
 from ._operations import SchedulersOperations  # type: ignore
 from ._operations import TaskHubsOperations  # type: ignore
+from ._operations import RetentionPoliciesOperations  # type: ignore
 
 from ._patch import __all__ as _patch_all
 from ._patch import *
@@ -24,6 +25,7 @@
     "Operations",
     "SchedulersOperations",
     "TaskHubsOperations",
+    "RetentionPoliciesOperations",
 ]
 __all__.extend([p for p in _patch_all if p not in __all__])  # pyright: ignore
 _patch_sdk()