Skip to content

Commit 0c635a0

Browse files
[AutoRelease] t2-datafactory-2022-10-26-64838(Do not merge) (Azure#27060)
* code and test * Update setup.py * Update shared_requirements.txt * Update CHANGELOG.md * Update CHANGELOG.md Co-authored-by: PythonSdkPipelines <PythonSdkPipelines> Co-authored-by: zhenbiao wei <[email protected]>
1 parent e96ff47 commit 0c635a0

File tree

147 files changed

+5360
-306
lines changed

Some content is hidden

Large Commits have some content hidden by default. Use the searchbox below for content that may be hidden.

147 files changed

+5360
-306
lines changed

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

Lines changed: 6 additions & 0 deletions
Original file line numberDiff line numberDiff line change
@@ -1,5 +1,11 @@
11
# Release History
22

3+
## 2.10.0 (2022-11-22)
4+
5+
### Features Added
6+
7+
- Model ScriptActivity has a new parameter script_block_execution_timeout
8+
39
## 2.9.0 (2022-10-24)
410

511
### Features Added
Lines changed: 3 additions & 3 deletions
Original file line numberDiff line numberDiff line change
@@ -1,11 +1,11 @@
11
{
2-
"commit": "021e5ab6ec840d651d32a2c6bdf832800cdf8eb6",
2+
"commit": "21426cf85836ec17aaa4f20f58324a8666925e34",
33
"repository_url": "https://github.com/Azure/azure-rest-api-specs",
44
"autorest": "3.9.2",
55
"use": [
6-
"@autorest/python@6.1.11",
6+
"@autorest/python@6.2.1",
77
"@autorest/[email protected]"
88
],
9-
"autorest_command": "autorest specification/datafactory/resource-manager/readme.md --python --python-sdks-folder=/home/vsts/work/1/azure-sdk-for-python/sdk --use=@autorest/python@6.1.11 --use=@autorest/[email protected] --version=3.9.2 --version-tolerant=False",
9+
"autorest_command": "autorest specification/datafactory/resource-manager/readme.md --generate-sample=True --include-x-ms-examples-original-file=True --python --python-sdks-folder=/home/vsts/work/1/azure-sdk-for-python/sdk --use=@autorest/python@6.2.1 --use=@autorest/[email protected] --version=3.9.2 --version-tolerant=False",
1010
"readme": "specification/datafactory/resource-manager/readme.md"
1111
}

sdk/datafactory/azure-mgmt-datafactory/azure/mgmt/datafactory/__init__.py

Lines changed: 3 additions & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -18,7 +18,9 @@
1818
_patch_all = []
1919
from ._patch import patch_sdk as _patch_sdk
2020

21-
__all__ = ["DataFactoryManagementClient"]
21+
__all__ = [
22+
"DataFactoryManagementClient",
23+
]
2224
__all__.extend([p for p in _patch_all if p not in __all__])
2325

2426
_patch_sdk()

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

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

9+
import sys
910
from typing import Any, TYPE_CHECKING
1011

1112
from azure.core.configuration import Configuration
@@ -14,6 +15,11 @@
1415

1516
from ._version import VERSION
1617

18+
if sys.version_info >= (3, 8):
19+
from typing import Literal # pylint: disable=no-name-in-module, ungrouped-imports
20+
else:
21+
from typing_extensions import Literal # type: ignore # pylint: disable=ungrouped-imports
22+
1723
if TYPE_CHECKING:
1824
# pylint: disable=unused-import,ungrouped-imports
1925
from azure.core.credentials import TokenCredential
@@ -36,7 +42,7 @@ class DataFactoryManagementClientConfiguration(Configuration): # pylint: disabl
3642

3743
def __init__(self, credential: "TokenCredential", subscription_id: str, **kwargs: Any) -> None:
3844
super(DataFactoryManagementClientConfiguration, self).__init__(**kwargs)
39-
api_version = kwargs.pop("api_version", "2018-06-01") # type: str
45+
api_version = kwargs.pop("api_version", "2018-06-01") # type: Literal["2018-06-01"]
4046

4147
if credential is None:
4248
raise ValueError("Parameter 'credential' must not be None.")

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 = "2.9.0"
9+
VERSION = "2.10.0"

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

Lines changed: 3 additions & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -15,7 +15,9 @@
1515
_patch_all = []
1616
from ._patch import patch_sdk as _patch_sdk
1717

18-
__all__ = ["DataFactoryManagementClient"]
18+
__all__ = [
19+
"DataFactoryManagementClient",
20+
]
1921
__all__.extend([p for p in _patch_all if p not in __all__])
2022

2123
_patch_sdk()

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

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

9+
import sys
910
from typing import Any, TYPE_CHECKING
1011

1112
from azure.core.configuration import Configuration
@@ -14,6 +15,11 @@
1415

1516
from .._version import VERSION
1617

18+
if sys.version_info >= (3, 8):
19+
from typing import Literal # pylint: disable=no-name-in-module, ungrouped-imports
20+
else:
21+
from typing_extensions import Literal # type: ignore # pylint: disable=ungrouped-imports
22+
1723
if TYPE_CHECKING:
1824
# pylint: disable=unused-import,ungrouped-imports
1925
from azure.core.credentials_async import AsyncTokenCredential
@@ -36,7 +42,7 @@ class DataFactoryManagementClientConfiguration(Configuration): # pylint: disabl
3642

3743
def __init__(self, credential: "AsyncTokenCredential", subscription_id: str, **kwargs: Any) -> None:
3844
super(DataFactoryManagementClientConfiguration, self).__init__(**kwargs)
39-
api_version = kwargs.pop("api_version", "2018-06-01") # type: str
45+
api_version = kwargs.pop("api_version", "2018-06-01") # type: Literal["2018-06-01"]
4046

4147
if credential is None:
4248
raise ValueError("Parameter 'credential' must not be None.")

sdk/datafactory/azure-mgmt-datafactory/azure/mgmt/datafactory/aio/operations/_activity_runs_operations.py

Lines changed: 8 additions & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -6,6 +6,7 @@
66
# Code generated by Microsoft (R) AutoRest Code Generator.
77
# Changes may cause incorrect behavior and will be lost if the code is regenerated.
88
# --------------------------------------------------------------------------
9+
import sys
910
from typing import Any, Callable, Dict, IO, Optional, TypeVar, Union, overload
1011

1112
from azure.core.exceptions import (
@@ -27,6 +28,10 @@
2728
from ..._vendor import _convert_request
2829
from ...operations._activity_runs_operations import build_query_by_pipeline_run_request
2930

31+
if sys.version_info >= (3, 8):
32+
from typing import Literal # pylint: disable=no-name-in-module, ungrouped-imports
33+
else:
34+
from typing_extensions import Literal # type: ignore # pylint: disable=ungrouped-imports
3035
T = TypeVar("T")
3136
ClsType = Optional[Callable[[PipelineResponse[HttpRequest, AsyncHttpResponse], T, Dict[str, Any]], Any]]
3237

@@ -149,7 +154,9 @@ async def query_by_pipeline_run(
149154
_headers = case_insensitive_dict(kwargs.pop("headers", {}) or {})
150155
_params = case_insensitive_dict(kwargs.pop("params", {}) or {})
151156

152-
api_version = kwargs.pop("api_version", _params.pop("api-version", self._config.api_version)) # type: str
157+
api_version = kwargs.pop(
158+
"api_version", _params.pop("api-version", self._config.api_version)
159+
) # type: Literal["2018-06-01"]
153160
content_type = kwargs.pop("content_type", _headers.pop("Content-Type", None)) # type: Optional[str]
154161
cls = kwargs.pop("cls", None) # type: ClsType[_models.ActivityRunsQueryResponse]
155162

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

Lines changed: 26 additions & 7 deletions
Original file line numberDiff line numberDiff line change
@@ -6,6 +6,7 @@
66
# Code generated by Microsoft (R) AutoRest Code Generator.
77
# Changes may cause incorrect behavior and will be lost if the code is regenerated.
88
# --------------------------------------------------------------------------
9+
import sys
910
from typing import Any, AsyncIterable, Callable, Dict, IO, Optional, TypeVar, Union, cast, overload
1011
import urllib.parse
1112

@@ -38,6 +39,10 @@
3839
build_query_by_factory_request,
3940
)
4041

42+
if sys.version_info >= (3, 8):
43+
from typing import Literal # pylint: disable=no-name-in-module, ungrouped-imports
44+
else:
45+
from typing_extensions import Literal # type: ignore # pylint: disable=ungrouped-imports
4146
T = TypeVar("T")
4247
ClsType = Optional[Callable[[PipelineResponse[HttpRequest, AsyncHttpResponse], T, Dict[str, Any]], Any]]
4348

@@ -79,7 +84,9 @@ async def _create_initial(
7984
_headers = case_insensitive_dict(kwargs.pop("headers", {}) or {})
8085
_params = case_insensitive_dict(kwargs.pop("params", {}) or {})
8186

82-
api_version = kwargs.pop("api_version", _params.pop("api-version", self._config.api_version)) # type: str
87+
api_version = kwargs.pop(
88+
"api_version", _params.pop("api-version", self._config.api_version)
89+
) # type: Literal["2018-06-01"]
8390
content_type = kwargs.pop("content_type", _headers.pop("Content-Type", None)) # type: Optional[str]
8491
cls = kwargs.pop("cls", None) # type: ClsType[Optional[_models.CreateDataFlowDebugSessionResponse]]
8592

@@ -240,7 +247,9 @@ async def begin_create(
240247
_headers = case_insensitive_dict(kwargs.pop("headers", {}) or {})
241248
_params = case_insensitive_dict(kwargs.pop("params", {}) or {})
242249

243-
api_version = kwargs.pop("api_version", _params.pop("api-version", self._config.api_version)) # type: str
250+
api_version = kwargs.pop(
251+
"api_version", _params.pop("api-version", self._config.api_version)
252+
) # type: Literal["2018-06-01"]
244253
content_type = kwargs.pop("content_type", _headers.pop("Content-Type", None)) # type: Optional[str]
245254
cls = kwargs.pop("cls", None) # type: ClsType[_models.CreateDataFlowDebugSessionResponse]
246255
polling = kwargs.pop("polling", True) # type: Union[bool, AsyncPollingMethod]
@@ -303,7 +312,9 @@ def query_by_factory(
303312
_headers = kwargs.pop("headers", {}) or {}
304313
_params = case_insensitive_dict(kwargs.pop("params", {}) or {})
305314

306-
api_version = kwargs.pop("api_version", _params.pop("api-version", self._config.api_version)) # type: str
315+
api_version = kwargs.pop(
316+
"api_version", _params.pop("api-version", self._config.api_version)
317+
) # type: Literal["2018-06-01"]
307318
cls = kwargs.pop("cls", None) # type: ClsType[_models.QueryDataFlowDebugSessionsResponse]
308319

309320
error_map = {
@@ -462,7 +473,9 @@ async def add_data_flow(
462473
_headers = case_insensitive_dict(kwargs.pop("headers", {}) or {})
463474
_params = case_insensitive_dict(kwargs.pop("params", {}) or {})
464475

465-
api_version = kwargs.pop("api_version", _params.pop("api-version", self._config.api_version)) # type: str
476+
api_version = kwargs.pop(
477+
"api_version", _params.pop("api-version", self._config.api_version)
478+
) # type: Literal["2018-06-01"]
466479
content_type = kwargs.pop("content_type", _headers.pop("Content-Type", None)) # type: Optional[str]
467480
cls = kwargs.pop("cls", None) # type: ClsType[_models.AddDataFlowToDebugSessionResponse]
468481

@@ -598,7 +611,9 @@ async def delete( # pylint: disable=inconsistent-return-statements
598611
_headers = case_insensitive_dict(kwargs.pop("headers", {}) or {})
599612
_params = case_insensitive_dict(kwargs.pop("params", {}) or {})
600613

601-
api_version = kwargs.pop("api_version", _params.pop("api-version", self._config.api_version)) # type: str
614+
api_version = kwargs.pop(
615+
"api_version", _params.pop("api-version", self._config.api_version)
616+
) # type: Literal["2018-06-01"]
602617
content_type = kwargs.pop("content_type", _headers.pop("Content-Type", None)) # type: Optional[str]
603618
cls = kwargs.pop("cls", None) # type: ClsType[None]
604619

@@ -658,7 +673,9 @@ async def _execute_command_initial(
658673
_headers = case_insensitive_dict(kwargs.pop("headers", {}) or {})
659674
_params = case_insensitive_dict(kwargs.pop("params", {}) or {})
660675

661-
api_version = kwargs.pop("api_version", _params.pop("api-version", self._config.api_version)) # type: str
676+
api_version = kwargs.pop(
677+
"api_version", _params.pop("api-version", self._config.api_version)
678+
) # type: Literal["2018-06-01"]
662679
content_type = kwargs.pop("content_type", _headers.pop("Content-Type", None)) # type: Optional[str]
663680
cls = kwargs.pop("cls", None) # type: ClsType[Optional[_models.DataFlowDebugCommandResponse]]
664681

@@ -819,7 +836,9 @@ async def begin_execute_command(
819836
_headers = case_insensitive_dict(kwargs.pop("headers", {}) or {})
820837
_params = case_insensitive_dict(kwargs.pop("params", {}) or {})
821838

822-
api_version = kwargs.pop("api_version", _params.pop("api-version", self._config.api_version)) # type: str
839+
api_version = kwargs.pop(
840+
"api_version", _params.pop("api-version", self._config.api_version)
841+
) # type: Literal["2018-06-01"]
823842
content_type = kwargs.pop("content_type", _headers.pop("Content-Type", None)) # type: Optional[str]
824843
cls = kwargs.pop("cls", None) # type: ClsType[_models.DataFlowDebugCommandResponse]
825844
polling = kwargs.pop("polling", True) # type: Union[bool, AsyncPollingMethod]

sdk/datafactory/azure-mgmt-datafactory/azure/mgmt/datafactory/aio/operations/_data_flows_operations.py

Lines changed: 17 additions & 4 deletions
Original file line numberDiff line numberDiff line change
@@ -6,6 +6,7 @@
66
# Code generated by Microsoft (R) AutoRest Code Generator.
77
# Changes may cause incorrect behavior and will be lost if the code is regenerated.
88
# --------------------------------------------------------------------------
9+
import sys
910
from typing import Any, AsyncIterable, Callable, Dict, IO, Optional, TypeVar, Union, overload
1011
import urllib.parse
1112

@@ -35,6 +36,10 @@
3536
build_list_by_factory_request,
3637
)
3738

39+
if sys.version_info >= (3, 8):
40+
from typing import Literal # pylint: disable=no-name-in-module, ungrouped-imports
41+
else:
42+
from typing_extensions import Literal # type: ignore # pylint: disable=ungrouped-imports
3843
T = TypeVar("T")
3944
ClsType = Optional[Callable[[PipelineResponse[HttpRequest, AsyncHttpResponse], T, Dict[str, Any]], Any]]
4045

@@ -168,7 +173,9 @@ async def create_or_update(
168173
_headers = case_insensitive_dict(kwargs.pop("headers", {}) or {})
169174
_params = case_insensitive_dict(kwargs.pop("params", {}) or {})
170175

171-
api_version = kwargs.pop("api_version", _params.pop("api-version", self._config.api_version)) # type: str
176+
api_version = kwargs.pop(
177+
"api_version", _params.pop("api-version", self._config.api_version)
178+
) # type: Literal["2018-06-01"]
172179
content_type = kwargs.pop("content_type", _headers.pop("Content-Type", None)) # type: Optional[str]
173180
cls = kwargs.pop("cls", None) # type: ClsType[_models.DataFlowResource]
174181

@@ -253,7 +260,9 @@ async def get(
253260
_headers = kwargs.pop("headers", {}) or {}
254261
_params = case_insensitive_dict(kwargs.pop("params", {}) or {})
255262

256-
api_version = kwargs.pop("api_version", _params.pop("api-version", self._config.api_version)) # type: str
263+
api_version = kwargs.pop(
264+
"api_version", _params.pop("api-version", self._config.api_version)
265+
) # type: Literal["2018-06-01"]
257266
cls = kwargs.pop("cls", None) # type: ClsType[_models.DataFlowResource]
258267

259268
request = build_get_request(
@@ -317,7 +326,9 @@ async def delete( # pylint: disable=inconsistent-return-statements
317326
_headers = kwargs.pop("headers", {}) or {}
318327
_params = case_insensitive_dict(kwargs.pop("params", {}) or {})
319328

320-
api_version = kwargs.pop("api_version", _params.pop("api-version", self._config.api_version)) # type: str
329+
api_version = kwargs.pop(
330+
"api_version", _params.pop("api-version", self._config.api_version)
331+
) # type: Literal["2018-06-01"]
321332
cls = kwargs.pop("cls", None) # type: ClsType[None]
322333

323334
request = build_delete_request(
@@ -367,7 +378,9 @@ def list_by_factory(
367378
_headers = kwargs.pop("headers", {}) or {}
368379
_params = case_insensitive_dict(kwargs.pop("params", {}) or {})
369380

370-
api_version = kwargs.pop("api_version", _params.pop("api-version", self._config.api_version)) # type: str
381+
api_version = kwargs.pop(
382+
"api_version", _params.pop("api-version", self._config.api_version)
383+
) # type: Literal["2018-06-01"]
371384
cls = kwargs.pop("cls", None) # type: ClsType[_models.DataFlowListResponse]
372385

373386
error_map = {

0 commit comments

Comments
 (0)