Skip to content

Commit f879ea7

Browse files
author
SDKAuto
committed
CodeGen from PR 14160 in Azure/azure-rest-api-specs
Merge 38bc3fb2f1607fcdcf0f2bdb40971c29a3a03046 into fc32868
1 parent 6aa6fe4 commit f879ea7

28 files changed

+16484
-14261
lines changed

‎sdk/datafactory/azure-mgmt-datafactory/MANIFEST.in‎

Lines changed: 1 addition & 0 deletions
Original file line numberDiff line numberDiff line change
@@ -1,3 +1,4 @@
1+
include _meta.json
12
recursive-include tests *.py *.yaml
23
include *.md
34
include azure/__init__.py

‎sdk/datafactory/azure-mgmt-datafactory/_meta.json‎

Lines changed: 8 additions & 0 deletions
Original file line numberDiff line numberDiff line change
@@ -0,0 +1,8 @@
1+
{
2+
"autorest": "3.3.0",
3+
"use": "@autorest/python@5.6.6",
4+
"commit": "11d0e2f771e39e72180c235687393b7a515b04ed",
5+
"repository_url": "https://github.com/Azure/azure-rest-api-specs",
6+
"autorest_command": "autorest specification/datafactory/resource-manager/readme.md --multiapi --python --python-mode=update --python-sdks-folder=/home/vsts/work/1/s/azure-sdk-for-python/sdk --track2 --use=@autorest/python@5.6.6 --version=3.3.0",
7+
"readme": "specification/datafactory/resource-manager/readme.md"
8+
}

‎sdk/datafactory/azure-mgmt-datafactory/azure/mgmt/datafactory/_data_factory_management_client.py‎

Lines changed: 35 additions & 0 deletions
Original file line numberDiff line numberDiff line change
@@ -16,6 +16,7 @@
1616
from typing import Any, Optional
1717

1818
from azure.core.credentials import TokenCredential
19+
from azure.core.pipeline.transport import HttpRequest, HttpResponse
1920

2021
from ._configuration import DataFactoryManagementClientConfiguration
2122
from .operations import Operations
@@ -35,6 +36,9 @@
3536
from .operations import DataFlowDebugSessionOperations
3637
from .operations import ManagedVirtualNetworksOperations
3738
from .operations import ManagedPrivateEndpointsOperations
39+
from .operations import PrivateEndPointConnectionsOperations
40+
from .operations import PrivateEndpointConnectionOperations
41+
from .operations import PrivateLinkResourcesOperations
3842
from . import models
3943

4044

@@ -75,6 +79,12 @@ class DataFactoryManagementClient(object):
7579
:vartype managed_virtual_networks: azure.mgmt.datafactory.operations.ManagedVirtualNetworksOperations
7680
:ivar managed_private_endpoints: ManagedPrivateEndpointsOperations operations
7781
:vartype managed_private_endpoints: azure.mgmt.datafactory.operations.ManagedPrivateEndpointsOperations
82+
:ivar private_end_point_connections: PrivateEndPointConnectionsOperations operations
83+
:vartype private_end_point_connections: azure.mgmt.datafactory.operations.PrivateEndPointConnectionsOperations
84+
:ivar private_endpoint_connection: PrivateEndpointConnectionOperations operations
85+
:vartype private_endpoint_connection: azure.mgmt.datafactory.operations.PrivateEndpointConnectionOperations
86+
:ivar private_link_resources: PrivateLinkResourcesOperations operations
87+
:vartype private_link_resources: azure.mgmt.datafactory.operations.PrivateLinkResourcesOperations
7888
:param credential: Credential needed for the client to connect to Azure.
7989
:type credential: ~azure.core.credentials.TokenCredential
8090
:param subscription_id: The subscription identifier.
@@ -98,6 +108,7 @@ def __init__(
98108

99109
client_models = {k: v for k, v in models.__dict__.items() if isinstance(v, type)}
100110
self._serialize = Serializer(client_models)
111+
self._serialize.client_side_validation = False
101112
self._deserialize = Deserializer(client_models)
102113

103114
self.operations = Operations(
@@ -134,6 +145,30 @@ def __init__(
134145
self._client, self._config, self._serialize, self._deserialize)
135146
self.managed_private_endpoints = ManagedPrivateEndpointsOperations(
136147
self._client, self._config, self._serialize, self._deserialize)
148+
self.private_end_point_connections = PrivateEndPointConnectionsOperations(
149+
self._client, self._config, self._serialize, self._deserialize)
150+
self.private_endpoint_connection = PrivateEndpointConnectionOperations(
151+
self._client, self._config, self._serialize, self._deserialize)
152+
self.private_link_resources = PrivateLinkResourcesOperations(
153+
self._client, self._config, self._serialize, self._deserialize)
154+
155+
def _send_request(self, http_request, **kwargs):
156+
# type: (HttpRequest, Any) -> HttpResponse
157+
"""Runs the network request through the client's chained policies.
158+
159+
:param http_request: The network request you want to make. Required.
160+
:type http_request: ~azure.core.pipeline.transport.HttpRequest
161+
:keyword bool stream: Whether the response payload will be streamed. Defaults to True.
162+
:return: The response of your network call. Does not do error handling on your response.
163+
:rtype: ~azure.core.pipeline.transport.HttpResponse
164+
"""
165+
path_format_arguments = {
166+
'subscriptionId': self._serialize.url("self._config.subscription_id", self._config.subscription_id, 'str'),
167+
}
168+
http_request.url = self._client.format_url(http_request.url, **path_format_arguments)
169+
stream = kwargs.pop("stream", True)
170+
pipeline_response = self._client._pipeline.run(http_request, stream=stream, **kwargs)
171+
return pipeline_response.http_response
137172

138173
def close(self):
139174
# type: () -> None

‎sdk/datafactory/azure-mgmt-datafactory/azure/mgmt/datafactory/_metadata.json‎

Lines changed: 122 additions & 0 deletions
Original file line numberDiff line numberDiff line change
@@ -0,0 +1,122 @@
1+
{
2+
"chosen_version": "2018-06-01",
3+
"total_api_version_list": ["2018-06-01"],
4+
"client": {
5+
"name": "DataFactoryManagementClient",
6+
"filename": "_data_factory_management_client",
7+
"description": "The Azure Data Factory V2 management API provides a RESTful set of web services that interact with Azure Data Factory V2 services.",
8+
"base_url": "\u0027https://management.azure.com\u0027",
9+
"custom_base_url": null,
10+
"azure_arm": true,
11+
"has_lro_operations": true,
12+
"client_side_validation": false,
13+
"sync_imports": "{\"typing\": {\"azurecore\": {\"azure.core.credentials\": [\"TokenCredential\"]}}, \"regular\": {\"azurecore\": {\"azure.profiles\": [\"KnownProfiles\", \"ProfileDefinition\"], \"azure.profiles.multiapiclient\": [\"MultiApiClientMixin\"], \"msrest\": [\"Deserializer\", \"Serializer\"], \"azure.mgmt.core\": [\"ARMPipelineClient\"]}, \"local\": {\"._configuration\": [\"DataFactoryManagementClientConfiguration\"]}}, \"conditional\": {\"stdlib\": {\"typing\": [\"Any\", \"Optional\"]}, \"azurecore\": {\"azure.core.pipeline.transport\": [\"HttpRequest\", \"HttpResponse\"]}}}",
14+
"async_imports": "{\"typing\": {\"azurecore\": {\"azure.core.credentials_async\": [\"AsyncTokenCredential\"]}}, \"regular\": {\"azurecore\": {\"azure.profiles\": [\"KnownProfiles\", \"ProfileDefinition\"], \"azure.profiles.multiapiclient\": [\"MultiApiClientMixin\"], \"msrest\": [\"Deserializer\", \"Serializer\"], \"azure.mgmt.core\": [\"AsyncARMPipelineClient\"]}, \"local\": {\"._configuration\": [\"DataFactoryManagementClientConfiguration\"]}}, \"conditional\": {\"stdlib\": {\"typing\": [\"Any\", \"Optional\"]}, \"azurecore\": {\"azure.core.pipeline.transport\": [\"AsyncHttpResponse\", \"HttpRequest\"]}}}"
15+
},
16+
"global_parameters": {
17+
"sync": {
18+
"credential": {
19+
"signature": "credential, # type: \"TokenCredential\"",
20+
"description": "Credential needed for the client to connect to Azure.",
21+
"docstring_type": "~azure.core.credentials.TokenCredential",
22+
"required": true
23+
},
24+
"subscription_id": {
25+
"signature": "subscription_id, # type: str",
26+
"description": "The subscription identifier.",
27+
"docstring_type": "str",
28+
"required": true
29+
}
30+
},
31+
"async": {
32+
"credential": {
33+
"signature": "credential: \"AsyncTokenCredential\",",
34+
"description": "Credential needed for the client to connect to Azure.",
35+
"docstring_type": "~azure.core.credentials_async.AsyncTokenCredential",
36+
"required": true
37+
},
38+
"subscription_id": {
39+
"signature": "subscription_id: str,",
40+
"description": "The subscription identifier.",
41+
"docstring_type": "str",
42+
"required": true
43+
}
44+
},
45+
"constant": {
46+
},
47+
"call": "credential, subscription_id",
48+
"service_client_specific": {
49+
"sync": {
50+
"api_version": {
51+
"signature": "api_version=None, # type: Optional[str]",
52+
"description": "API version to use if no profile is provided, or if missing in profile.",
53+
"docstring_type": "str",
54+
"required": false
55+
},
56+
"base_url": {
57+
"signature": "base_url=None, # type: Optional[str]",
58+
"description": "Service URL",
59+
"docstring_type": "str",
60+
"required": false
61+
},
62+
"profile": {
63+
"signature": "profile=KnownProfiles.default, # type: KnownProfiles",
64+
"description": "A profile definition, from KnownProfiles to dict.",
65+
"docstring_type": "azure.profiles.KnownProfiles",
66+
"required": false
67+
}
68+
},
69+
"async": {
70+
"api_version": {
71+
"signature": "api_version: Optional[str] = None,",
72+
"description": "API version to use if no profile is provided, or if missing in profile.",
73+
"docstring_type": "str",
74+
"required": false
75+
},
76+
"base_url": {
77+
"signature": "base_url: Optional[str] = None,",
78+
"description": "Service URL",
79+
"docstring_type": "str",
80+
"required": false
81+
},
82+
"profile": {
83+
"signature": "profile: KnownProfiles = KnownProfiles.default,",
84+
"description": "A profile definition, from KnownProfiles to dict.",
85+
"docstring_type": "azure.profiles.KnownProfiles",
86+
"required": false
87+
}
88+
}
89+
}
90+
},
91+
"config": {
92+
"credential": true,
93+
"credential_scopes": ["https://management.azure.com/.default"],
94+
"credential_default_policy_type": "BearerTokenCredentialPolicy",
95+
"credential_default_policy_type_has_async_version": true,
96+
"credential_key_header_name": null,
97+
"sync_imports": "{\"regular\": {\"azurecore\": {\"azure.core.configuration\": [\"Configuration\"], \"azure.core.pipeline\": [\"policies\"], \"azure.mgmt.core.policies\": [\"ARMHttpLoggingPolicy\"]}, \"local\": {\"._version\": [\"VERSION\"]}}, \"conditional\": {\"stdlib\": {\"typing\": [\"Any\"]}}, \"typing\": {\"azurecore\": {\"azure.core.credentials\": [\"TokenCredential\"]}}}",
98+
"async_imports": "{\"regular\": {\"azurecore\": {\"azure.core.configuration\": [\"Configuration\"], \"azure.core.pipeline\": [\"policies\"], \"azure.mgmt.core.policies\": [\"ARMHttpLoggingPolicy\"]}, \"local\": {\".._version\": [\"VERSION\"]}}, \"conditional\": {\"stdlib\": {\"typing\": [\"Any\"]}}, \"typing\": {\"azurecore\": {\"azure.core.credentials_async\": [\"AsyncTokenCredential\"]}}}"
99+
},
100+
"operation_groups": {
101+
"operations": "Operations",
102+
"factories": "FactoriesOperations",
103+
"exposure_control": "ExposureControlOperations",
104+
"integration_runtimes": "IntegrationRuntimesOperations",
105+
"integration_runtime_object_metadata": "IntegrationRuntimeObjectMetadataOperations",
106+
"integration_runtime_nodes": "IntegrationRuntimeNodesOperations",
107+
"linked_services": "LinkedServicesOperations",
108+
"datasets": "DatasetsOperations",
109+
"pipelines": "PipelinesOperations",
110+
"pipeline_runs": "PipelineRunsOperations",
111+
"activity_runs": "ActivityRunsOperations",
112+
"triggers": "TriggersOperations",
113+
"trigger_runs": "TriggerRunsOperations",
114+
"data_flows": "DataFlowsOperations",
115+
"data_flow_debug_session": "DataFlowDebugSessionOperations",
116+
"managed_virtual_networks": "ManagedVirtualNetworksOperations",
117+
"managed_private_endpoints": "ManagedPrivateEndpointsOperations",
118+
"private_end_point_connections": "PrivateEndPointConnectionsOperations",
119+
"private_endpoint_connection": "PrivateEndpointConnectionOperations",
120+
"private_link_resources": "PrivateLinkResourcesOperations"
121+
}
122+
}

‎sdk/datafactory/azure-mgmt-datafactory/azure/mgmt/datafactory/_version.py‎

Lines changed: 1 addition & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -6,4 +6,4 @@
66
# Changes may cause incorrect behavior and will be lost if the code is regenerated.
77
# --------------------------------------------------------------------------
88

9-
VERSION = "1.1.0"
9+
VERSION = "1.0.0"

‎sdk/datafactory/azure-mgmt-datafactory/azure/mgmt/datafactory/aio/_data_factory_management_client.py‎

Lines changed: 34 additions & 0 deletions
Original file line numberDiff line numberDiff line change
@@ -8,6 +8,7 @@
88

99
from typing import Any, Optional, TYPE_CHECKING
1010

11+
from azure.core.pipeline.transport import AsyncHttpResponse, HttpRequest
1112
from azure.mgmt.core import AsyncARMPipelineClient
1213
from msrest import Deserializer, Serializer
1314

@@ -33,6 +34,9 @@
3334
from .operations import DataFlowDebugSessionOperations
3435
from .operations import ManagedVirtualNetworksOperations
3536
from .operations import ManagedPrivateEndpointsOperations
37+
from .operations import PrivateEndPointConnectionsOperations
38+
from .operations import PrivateEndpointConnectionOperations
39+
from .operations import PrivateLinkResourcesOperations
3640
from .. import models
3741

3842

@@ -73,6 +77,12 @@ class DataFactoryManagementClient(object):
7377
:vartype managed_virtual_networks: azure.mgmt.datafactory.aio.operations.ManagedVirtualNetworksOperations
7478
:ivar managed_private_endpoints: ManagedPrivateEndpointsOperations operations
7579
:vartype managed_private_endpoints: azure.mgmt.datafactory.aio.operations.ManagedPrivateEndpointsOperations
80+
:ivar private_end_point_connections: PrivateEndPointConnectionsOperations operations
81+
:vartype private_end_point_connections: azure.mgmt.datafactory.aio.operations.PrivateEndPointConnectionsOperations
82+
:ivar private_endpoint_connection: PrivateEndpointConnectionOperations operations
83+
:vartype private_endpoint_connection: azure.mgmt.datafactory.aio.operations.PrivateEndpointConnectionOperations
84+
:ivar private_link_resources: PrivateLinkResourcesOperations operations
85+
:vartype private_link_resources: azure.mgmt.datafactory.aio.operations.PrivateLinkResourcesOperations
7686
:param credential: Credential needed for the client to connect to Azure.
7787
:type credential: ~azure.core.credentials_async.AsyncTokenCredential
7888
:param subscription_id: The subscription identifier.
@@ -95,6 +105,7 @@ def __init__(
95105

96106
client_models = {k: v for k, v in models.__dict__.items() if isinstance(v, type)}
97107
self._serialize = Serializer(client_models)
108+
self._serialize.client_side_validation = False
98109
self._deserialize = Deserializer(client_models)
99110

100111
self.operations = Operations(
@@ -131,6 +142,29 @@ def __init__(
131142
self._client, self._config, self._serialize, self._deserialize)
132143
self.managed_private_endpoints = ManagedPrivateEndpointsOperations(
133144
self._client, self._config, self._serialize, self._deserialize)
145+
self.private_end_point_connections = PrivateEndPointConnectionsOperations(
146+
self._client, self._config, self._serialize, self._deserialize)
147+
self.private_endpoint_connection = PrivateEndpointConnectionOperations(
148+
self._client, self._config, self._serialize, self._deserialize)
149+
self.private_link_resources = PrivateLinkResourcesOperations(
150+
self._client, self._config, self._serialize, self._deserialize)
151+
152+
async def _send_request(self, http_request: HttpRequest, **kwargs: Any) -> AsyncHttpResponse:
153+
"""Runs the network request through the client's chained policies.
154+
155+
:param http_request: The network request you want to make. Required.
156+
:type http_request: ~azure.core.pipeline.transport.HttpRequest
157+
:keyword bool stream: Whether the response payload will be streamed. Defaults to True.
158+
:return: The response of your network call. Does not do error handling on your response.
159+
:rtype: ~azure.core.pipeline.transport.AsyncHttpResponse
160+
"""
161+
path_format_arguments = {
162+
'subscriptionId': self._serialize.url("self._config.subscription_id", self._config.subscription_id, 'str'),
163+
}
164+
http_request.url = self._client.format_url(http_request.url, **path_format_arguments)
165+
stream = kwargs.pop("stream", True)
166+
pipeline_response = await self._client._pipeline.run(http_request, stream=stream, **kwargs)
167+
return pipeline_response.http_response
134168

135169
async def close(self) -> None:
136170
await self._client.close()

‎sdk/datafactory/azure-mgmt-datafactory/azure/mgmt/datafactory/aio/operations/__init__.py‎

Lines changed: 6 additions & 0 deletions
Original file line numberDiff line numberDiff line change
@@ -23,6 +23,9 @@
2323
from ._data_flow_debug_session_operations import DataFlowDebugSessionOperations
2424
from ._managed_virtual_networks_operations import ManagedVirtualNetworksOperations
2525
from ._managed_private_endpoints_operations import ManagedPrivateEndpointsOperations
26+
from ._private_end_point_connections_operations import PrivateEndPointConnectionsOperations
27+
from ._private_endpoint_connection_operations import PrivateEndpointConnectionOperations
28+
from ._private_link_resources_operations import PrivateLinkResourcesOperations
2629

2730
__all__ = [
2831
'Operations',
@@ -42,4 +45,7 @@
4245
'DataFlowDebugSessionOperations',
4346
'ManagedVirtualNetworksOperations',
4447
'ManagedPrivateEndpointsOperations',
48+
'PrivateEndPointConnectionsOperations',
49+
'PrivateEndpointConnectionOperations',
50+
'PrivateLinkResourcesOperations',
4551
]

‎sdk/datafactory/azure-mgmt-datafactory/azure/mgmt/datafactory/aio/operations/_data_flow_debug_session_operations.py‎

Lines changed: 4 additions & 4 deletions
Original file line numberDiff line numberDiff line change
@@ -119,8 +119,8 @@ async def begin_create(
119119
:type request: ~azure.mgmt.datafactory.models.CreateDataFlowDebugSessionRequest
120120
:keyword callable cls: A custom type or function that will be passed the direct response
121121
:keyword str continuation_token: A continuation token to restart a poller from a saved state.
122-
:keyword polling: True for ARMPolling, False for no polling, or a
123-
polling object for personal polling strategy
122+
:keyword polling: Pass in True if you'd like the AsyncARMPolling polling method,
123+
False for no polling, or your own initialized polling object for a personal polling strategy.
124124
:paramtype polling: bool or ~azure.core.polling.AsyncPollingMethod
125125
:keyword int polling_interval: Default waiting time between two polls for LRO operations if no Retry-After header is present.
126126
:return: An instance of AsyncLROPoller that returns either CreateDataFlowDebugSessionResponse or the result of cls(response)
@@ -452,8 +452,8 @@ async def begin_execute_command(
452452
:type request: ~azure.mgmt.datafactory.models.DataFlowDebugCommandRequest
453453
:keyword callable cls: A custom type or function that will be passed the direct response
454454
:keyword str continuation_token: A continuation token to restart a poller from a saved state.
455-
:keyword polling: True for ARMPolling, False for no polling, or a
456-
polling object for personal polling strategy
455+
:keyword polling: Pass in True if you'd like the AsyncARMPolling polling method,
456+
False for no polling, or your own initialized polling object for a personal polling strategy.
457457
:paramtype polling: bool or ~azure.core.polling.AsyncPollingMethod
458458
:keyword int polling_interval: Default waiting time between two polls for LRO operations if no Retry-After header is present.
459459
:return: An instance of AsyncLROPoller that returns either DataFlowDebugCommandResponse or the result of cls(response)

‎sdk/datafactory/azure-mgmt-datafactory/azure/mgmt/datafactory/aio/operations/_integration_runtime_object_metadata_operations.py‎

Lines changed: 2 additions & 2 deletions
Original file line numberDiff line numberDiff line change
@@ -110,8 +110,8 @@ async def begin_refresh(
110110
:type integration_runtime_name: str
111111
:keyword callable cls: A custom type or function that will be passed the direct response
112112
:keyword str continuation_token: A continuation token to restart a poller from a saved state.
113-
:keyword polling: True for ARMPolling, False for no polling, or a
114-
polling object for personal polling strategy
113+
:keyword polling: Pass in True if you'd like the AsyncARMPolling polling method,
114+
False for no polling, or your own initialized polling object for a personal polling strategy.
115115
:paramtype polling: bool or ~azure.core.polling.AsyncPollingMethod
116116
:keyword int polling_interval: Default waiting time between two polls for LRO operations if no Retry-After header is present.
117117
:return: An instance of AsyncLROPoller that returns either SsisObjectMetadataStatusResponse or the result of cls(response)

0 commit comments

Comments
 (0)