[AutoRelease] t2-recoveryservicessiterecovery-2024-02-08-49614(can only be merged by SDK owner) (#34241)

* code and test

* Update CHANGELOG.md

---------

Co-authored-by: azure-sdk <PythonSdkPipelines>
Co-authored-by: ChenxiJiang333 <[email protected]>

Author: azure-sdk

sdk/recoveryservices/azure-mgmt-recoveryservicessiterecovery/CHANGELOG.md

@@ -1,5 +1,12 @@
 # Release History
 
+## 1.2.0 (2024-02-22)
+
+### Features Added
+
+  - Added operation ReplicationFabricsOperations.begin_remove_infra
+  - Model A2AEnableProtectionInput has a new parameter auto_protection_of_data_disk
+
 ## 1.1.0 (2023-09-15)
 
 ### Features Added

sdk/recoveryservices/azure-mgmt-recoveryservicessiterecovery/README.md

@@ -1,7 +1,7 @@
 # Microsoft Azure SDK for Python
 
 This is the Microsoft Azure Recovery Services Site Recovery Management Client Library.
-This package has been tested with Python 3.7+.
+This package has been tested with Python 3.8+.
 For a more complete view of Azure libraries, see the [azure sdk python release](https://aka.ms/azsdk/python/all).
 
 ## _Disclaimer_
@@ -12,7 +12,7 @@ _Azure SDK Python packages support for Python 2.7 has ended 01 January 2022. For
 
 ### Prerequisites
 
-- Python 3.7+ is required to use this package.
+- Python 3.8+ is required to use this package.
 - [Azure subscription](https://azure.microsoft.com/free/)
 
 ### Install the package
@@ -59,6 +59,3 @@ Code samples for this package can be found at:
 If you encounter any bugs or have suggestions, please file an issue in the
 [Issues](https://github.com/Azure/azure-sdk-for-python/issues)
 section of the project. 
-
-
-![Impressions](https://azure-sdk-impressions.azurewebsites.net/api/impressions/azure-sdk-for-python%2Fazure-mgmt-recoveryservicessiterecovery%2FREADME.png)

sdk/recoveryservices/azure-mgmt-recoveryservicessiterecovery/_meta.json

@@ -1,5 +1,5 @@
 {
-  "commit": "a29126ca8200a6c981a4e908e41fe55730df4cad",
+  "commit": "a4d405de616be574891325c48a08298f60e6692b",
   "repository_url": "https://github.com/Azure/azure-rest-api-specs",
   "autorest": "3.9.7",
   "use": [

sdk/recoveryservices/azure-mgmt-recoveryservicessiterecovery/azure/mgmt/recoveryservicessiterecovery/_configuration.py

@@ -34,7 +34,7 @@ class SiteRecoveryManagementClientConfiguration(Configuration):  # pylint: disab
     :type resource_group_name: str
     :param resource_name: The name of the recovery services vault. Required.
     :type resource_name: str
-    :keyword api_version: Api Version. Default value is "2023-06-01". Note that overriding this
+    :keyword api_version: Api Version. Default value is "2023-08-01". Note that overriding this
      default value may result in unsupported behavior.
     :paramtype api_version: str
     """
@@ -48,7 +48,7 @@ def __init__(
         **kwargs: Any
     ) -> None:
         super(SiteRecoveryManagementClientConfiguration, self).__init__(**kwargs)
-        api_version: str = kwargs.pop("api_version", "2023-06-01")
+        api_version: str = kwargs.pop("api_version", "2023-08-01")
 
         if credential is None:
             raise ValueError("Parameter 'credential' must not be None.")

sdk/recoveryservices/azure-mgmt-recoveryservicessiterecovery/azure/mgmt/recoveryservicessiterecovery/_site_recovery_management_client.py

@@ -152,7 +152,7 @@ class SiteRecoveryManagementClient:  # pylint: disable=client-accepts-api-versio
     :type resource_name: str
     :param base_url: Service URL. Default value is "https://management.azure.com".
     :type base_url: str
-    :keyword api_version: Api Version. Default value is "2023-06-01". Note that overriding this
+    :keyword api_version: Api Version. Default value is "2023-08-01". 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

sdk/recoveryservices/azure-mgmt-recoveryservicessiterecovery/azure/mgmt/recoveryservicessiterecovery/_version.py

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

sdk/recoveryservices/azure-mgmt-recoveryservicessiterecovery/azure/mgmt/recoveryservicessiterecovery/aio/_configuration.py

@@ -34,7 +34,7 @@ class SiteRecoveryManagementClientConfiguration(Configuration):  # pylint: disab
     :type resource_group_name: str
     :param resource_name: The name of the recovery services vault. Required.
     :type resource_name: str
-    :keyword api_version: Api Version. Default value is "2023-06-01". Note that overriding this
+    :keyword api_version: Api Version. Default value is "2023-08-01". Note that overriding this
      default value may result in unsupported behavior.
     :paramtype api_version: str
     """
@@ -48,7 +48,7 @@ def __init__(
         **kwargs: Any
     ) -> None:
         super(SiteRecoveryManagementClientConfiguration, self).__init__(**kwargs)
-        api_version: str = kwargs.pop("api_version", "2023-06-01")
+        api_version: str = kwargs.pop("api_version", "2023-08-01")
 
         if credential is None:
             raise ValueError("Parameter 'credential' must not be None.")

sdk/recoveryservices/azure-mgmt-recoveryservicessiterecovery/azure/mgmt/recoveryservicessiterecovery/aio/_site_recovery_management_client.py

@@ -152,7 +152,7 @@ class SiteRecoveryManagementClient:  # pylint: disable=client-accepts-api-versio
     :type resource_name: str
     :param base_url: Service URL. Default value is "https://management.azure.com".
     :type base_url: str
-    :keyword api_version: Api Version. Default value is "2023-06-01". Note that overriding this
+    :keyword api_version: Api Version. Default value is "2023-08-01". 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

sdk/recoveryservices/azure-mgmt-recoveryservicessiterecovery/azure/mgmt/recoveryservicessiterecovery/aio/operations/_replication_fabrics_operations.py

@@ -40,6 +40,7 @@
     build_migrate_to_aad_request,
     build_purge_request,
     build_reassociate_gateway_request,
+    build_remove_infra_request,
     build_renew_certificate_request,
 )
 
@@ -1305,3 +1306,120 @@ def get_long_running_output(pipeline_response):
     begin_renew_certificate.metadata = {
         "url": "/subscriptions/{subscriptionId}/resourceGroups/{resourceGroupName}/providers/Microsoft.RecoveryServices/vaults/{resourceName}/replicationFabrics/{fabricName}/renewCertificate"
     }
+
+    async def _remove_infra_initial(  # pylint: disable=inconsistent-return-statements
+        self, resource_name: str, fabric_name: str, **kwargs: Any
+    ) -> None:
+        error_map = {
+            401: ClientAuthenticationError,
+            404: ResourceNotFoundError,
+            409: ResourceExistsError,
+            304: ResourceNotModifiedError,
+        }
+        error_map.update(kwargs.pop("error_map", {}) or {})
+
+        _headers = kwargs.pop("headers", {}) or {}
+        _params = case_insensitive_dict(kwargs.pop("params", {}) or {})
+
+        api_version: str = kwargs.pop("api_version", _params.pop("api-version", self._config.api_version))
+        cls: ClsType[None] = kwargs.pop("cls", None)
+
+        request = build_remove_infra_request(
+            resource_name=resource_name,
+            fabric_name=fabric_name,
+            resource_group_name=self._config.resource_group_name,
+            subscription_id=self._config.subscription_id,
+            api_version=api_version,
+            template_url=self._remove_infra_initial.metadata["url"],
+            headers=_headers,
+            params=_params,
+        )
+        request = _convert_request(request)
+        request.url = self._client.format_url(request.url)
+
+        _stream = False
+        pipeline_response: PipelineResponse = await self._client._pipeline.run(  # pylint: disable=protected-access
+            request, stream=_stream, **kwargs
+        )
+
+        response = pipeline_response.http_response
+
+        if response.status_code not in [202]:
+            map_error(status_code=response.status_code, response=response, error_map=error_map)
+            error = self._deserialize.failsafe_deserialize(_models.ErrorResponse, pipeline_response)
+            raise HttpResponseError(response=response, model=error, error_format=ARMErrorFormat)
+
+        response_headers = {}
+        response_headers["Location"] = self._deserialize("str", response.headers.get("Location"))
+
+        if cls:
+            return cls(pipeline_response, None, response_headers)
+
+    _remove_infra_initial.metadata = {
+        "url": "/subscriptions/{subscriptionId}/resourceGroups/{resourceGroupName}/providers/Microsoft.RecoveryServices/vaults/{resourceName}/replicationFabrics/{fabricName}/removeInfra"
+    }
+
+    @distributed_trace_async
+    async def begin_remove_infra(self, resource_name: str, fabric_name: str, **kwargs: Any) -> AsyncLROPoller[None]:
+        """Removes the appliance's infrastructure under the fabric.
+
+        Removes the appliance's infrastructure under the fabric.
+
+        :param resource_name: Resource name. Required.
+        :type resource_name: str
+        :param fabric_name: Fabric name. Required.
+        :type fabric_name: str
+        :keyword callable cls: A custom type or function that will be passed the direct response
+        :keyword str continuation_token: A continuation token to restart a poller from a saved state.
+        :keyword polling: By default, your polling method will be AsyncARMPolling. Pass in False for
+         this operation to not poll, or pass in your own initialized polling object for a personal
+         polling strategy.
+        :paramtype polling: bool or ~azure.core.polling.AsyncPollingMethod
+        :keyword int polling_interval: Default waiting time between two polls for LRO operations if no
+         Retry-After header is present.
+        :return: An instance of AsyncLROPoller that returns either None or the result of cls(response)
+        :rtype: ~azure.core.polling.AsyncLROPoller[None]
+        :raises ~azure.core.exceptions.HttpResponseError:
+        """
+        _headers = kwargs.pop("headers", {}) or {}
+        _params = case_insensitive_dict(kwargs.pop("params", {}) or {})
+
+        api_version: str = kwargs.pop("api_version", _params.pop("api-version", self._config.api_version))
+        cls: ClsType[None] = kwargs.pop("cls", None)
+        polling: Union[bool, AsyncPollingMethod] = kwargs.pop("polling", True)
+        lro_delay = kwargs.pop("polling_interval", self._config.polling_interval)
+        cont_token: Optional[str] = kwargs.pop("continuation_token", None)
+        if cont_token is None:
+            raw_result = await self._remove_infra_initial(  # type: ignore
+                resource_name=resource_name,
+                fabric_name=fabric_name,
+                api_version=api_version,
+                cls=lambda x, y, z: x,
+                headers=_headers,
+                params=_params,
+                **kwargs
+            )
+        kwargs.pop("error_map", None)
+
+        def get_long_running_output(pipeline_response):  # pylint: disable=inconsistent-return-statements
+            if cls:
+                return cls(pipeline_response, None, {})
+
+        if polling is True:
+            polling_method: AsyncPollingMethod = cast(AsyncPollingMethod, AsyncARMPolling(lro_delay, **kwargs))
+        elif polling is False:
+            polling_method = cast(AsyncPollingMethod, AsyncNoPolling())
+        else:
+            polling_method = polling
+        if cont_token:
+            return AsyncLROPoller.from_continuation_token(
+                polling_method=polling_method,
+                continuation_token=cont_token,
+                client=self._client,
+                deserialization_callback=get_long_running_output,
+            )
+        return AsyncLROPoller(self._client, raw_result, get_long_running_output, polling_method)  # type: ignore
+
+    begin_remove_infra.metadata = {
+        "url": "/subscriptions/{subscriptionId}/resourceGroups/{resourceGroupName}/providers/Microsoft.RecoveryServices/vaults/{resourceName}/replicationFabrics/{fabricName}/removeInfra"
+    }

sdk/recoveryservices/azure-mgmt-recoveryservicessiterecovery/azure/mgmt/recoveryservicessiterecovery/models/__init__.py

@@ -113,6 +113,9 @@
 from ._models_py3 import EnableProtectionInputProperties
 from ._models_py3 import EnableProtectionProviderSpecificInput
 from ._models_py3 import EncryptionDetails
+from ._models_py3 import ErrorAdditionalInfo
+from ._models_py3 import ErrorDetail
+from ._models_py3 import ErrorResponse
 from ._models_py3 import Event
 from ._models_py3 import EventCollection
 from ._models_py3 import EventProperties
@@ -690,6 +693,9 @@
     "EnableProtectionInputProperties",
     "EnableProtectionProviderSpecificInput",
     "EncryptionDetails",
+    "ErrorAdditionalInfo",
+    "ErrorDetail",
+    "ErrorResponse",
     "Event",
     "EventCollection",
     "EventProperties",