66# Changes may cause incorrect behavior and will be lost if the code is regenerated.
77# --------------------------------------------------------------------------
88
9+ from copy import deepcopy
910from typing import TYPE_CHECKING
1011
1112from azure .mgmt .core import ARMPipelineClient
1213from msrest import Deserializer , Serializer
1314
15+ from . import models
16+ from ._configuration import ResourceMoverServiceAPIConfiguration
17+ from .operations import MoveCollectionsOperations , MoveResourcesOperations , OperationsDiscoveryOperations , UnresolvedDependenciesOperations
18+
1419if TYPE_CHECKING :
1520 # pylint: disable=unused-import,ungrouped-imports
1621 from typing import Any , Optional
1722
1823 from azure .core .credentials import TokenCredential
19- from azure .core .pipeline .transport import HttpRequest , HttpResponse
20-
21- from ._configuration import ResourceMoverServiceAPIConfiguration
22- from .operations import MoveCollectionsOperations
23- from .operations import MoveResourcesOperations
24- from .operations import UnresolvedDependenciesOperations
25- from .operations import OperationsDiscoveryOperations
26- from . import models
27-
24+ from azure .core .rest import HttpRequest , HttpResponse
2825
2926class ResourceMoverServiceAPI (object ):
3027 """A first party Azure service orchestrating the move of Azure resources from one Azure region to another or between zones within a region.
@@ -34,61 +31,68 @@ class ResourceMoverServiceAPI(object):
3431 :ivar move_resources: MoveResourcesOperations operations
3532 :vartype move_resources: resource_mover_service_api.operations.MoveResourcesOperations
3633 :ivar unresolved_dependencies: UnresolvedDependenciesOperations operations
37- :vartype unresolved_dependencies: resource_mover_service_api.operations.UnresolvedDependenciesOperations
34+ :vartype unresolved_dependencies:
35+ resource_mover_service_api.operations.UnresolvedDependenciesOperations
3836 :ivar operations_discovery: OperationsDiscoveryOperations operations
39- :vartype operations_discovery: resource_mover_service_api.operations.OperationsDiscoveryOperations
37+ :vartype operations_discovery:
38+ resource_mover_service_api.operations.OperationsDiscoveryOperations
4039 :param credential: Credential needed for the client to connect to Azure.
4140 :type credential: ~azure.core.credentials.TokenCredential
4241 :param subscription_id: The Subscription ID.
4342 :type subscription_id: str
44- :param str base_url: Service URL
45- :keyword int polling_interval: Default waiting time between two polls for LRO operations if no Retry-After header is present.
43+ :param base_url: Service URL. Default value is 'https://management.azure.com'.
44+ :type base_url: str
45+ :keyword int polling_interval: Default waiting time between two polls for LRO operations if no
46+ Retry-After header is present.
4647 """
4748
4849 def __init__ (
4950 self ,
5051 credential , # type: "TokenCredential"
5152 subscription_id , # type: str
52- base_url = None , # type: Optional[ str]
53+ base_url = "https://management.azure.com" , # type: str
5354 ** kwargs # type: Any
5455 ):
5556 # type: (...) -> None
56- if not base_url :
57- base_url = 'https://management.azure.com'
58- self ._config = ResourceMoverServiceAPIConfiguration (credential , subscription_id , ** kwargs )
57+ self ._config = ResourceMoverServiceAPIConfiguration (credential = credential , subscription_id = subscription_id , ** kwargs )
5958 self ._client = ARMPipelineClient (base_url = base_url , config = self ._config , ** kwargs )
6059
6160 client_models = {k : v for k , v in models .__dict__ .items () if isinstance (v , type )}
6261 self ._serialize = Serializer (client_models )
63- self ._serialize .client_side_validation = False
6462 self ._deserialize = Deserializer (client_models )
63+ self ._serialize .client_side_validation = False
64+ self .move_collections = MoveCollectionsOperations (self ._client , self ._config , self ._serialize , self ._deserialize )
65+ self .move_resources = MoveResourcesOperations (self ._client , self ._config , self ._serialize , self ._deserialize )
66+ self .unresolved_dependencies = UnresolvedDependenciesOperations (self ._client , self ._config , self ._serialize , self ._deserialize )
67+ self .operations_discovery = OperationsDiscoveryOperations (self ._client , self ._config , self ._serialize , self ._deserialize )
68+
6569
66- self .move_collections = MoveCollectionsOperations (
67- self ._client , self ._config , self ._serialize , self ._deserialize )
68- self .move_resources = MoveResourcesOperations (
69- self ._client , self ._config , self ._serialize , self ._deserialize )
70- self .unresolved_dependencies = UnresolvedDependenciesOperations (
71- self ._client , self ._config , self ._serialize , self ._deserialize )
72- self .operations_discovery = OperationsDiscoveryOperations (
73- self ._client , self ._config , self ._serialize , self ._deserialize )
74-
75- def _send_request (self , http_request , ** kwargs ):
76- # type: (HttpRequest, Any) -> HttpResponse
70+ def _send_request (
71+ self ,
72+ request , # type: HttpRequest
73+ ** kwargs # type: Any
74+ ):
75+ # type: (...) -> HttpResponse
7776 """Runs the network request through the client's chained policies.
7877
79- :param http_request: The network request you want to make. Required.
80- :type http_request: ~azure.core.pipeline.transport.HttpRequest
81- :keyword bool stream: Whether the response payload will be streamed. Defaults to True.
78+ >>> from azure.core.rest import HttpRequest
79+ >>> request = HttpRequest("GET", "https://www.example.org/")
80+ <HttpRequest [GET], url: 'https://www.example.org/'>
81+ >>> response = client._send_request(request)
82+ <HttpResponse: 200 OK>
83+
84+ For more information on this code flow, see https://aka.ms/azsdk/python/protocol/quickstart
85+
86+ :param request: The network request you want to make. Required.
87+ :type request: ~azure.core.rest.HttpRequest
88+ :keyword bool stream: Whether the response payload will be streamed. Defaults to False.
8289 :return: The response of your network call. Does not do error handling on your response.
83- :rtype: ~azure.core.pipeline.transport .HttpResponse
90+ :rtype: ~azure.core.rest .HttpResponse
8491 """
85- path_format_arguments = {
86- 'subscriptionId' : self ._serialize .url ("self._config.subscription_id" , self ._config .subscription_id , 'str' ),
87- }
88- http_request .url = self ._client .format_url (http_request .url , ** path_format_arguments )
89- stream = kwargs .pop ("stream" , True )
90- pipeline_response = self ._client ._pipeline .run (http_request , stream = stream , ** kwargs )
91- return pipeline_response .http_response
92+
93+ request_copy = deepcopy (request )
94+ request_copy .url = self ._client .format_url (request_copy .url )
95+ return self ._client .send_request (request_copy , ** kwargs )
9296
9397 def close (self ):
9498 # type: () -> None
0 commit comments