Skip to content

Commit d48629e

Browse files
[Storage] [STG93] STG93 Feature Branch -> Main (Azure#34921)
* [Storage] [STG93] Prepare for STG93 Feature Work (Azure#33869) * Bump sv=, F+R recordings, add changelog entry * Bump changefeed blobs dep to lastest GA release * Add changelog entry for changefeed's blob dependency * [Storage] [STG93] Return `client_name` field on ListHandles API (Azure#33878) * [Storage] [STG93] Rename Support for List Ranges Diff API (Azure#33893) * [Storage] [STG93] Support owner/group/permission/acl on put APIs and `x-ms-upn` header (Azure#33925) * Missed upn hint here (Azure#33998) * [Storage] [STG93] Archboard Feedback STG93 (Azure#34083) * Target right place * Correction * Fighting the assets.json * [Storage] [STG93] Update changelogs to prep for beta release (Azure#34312) * Add changelogs * Nit * [Storage] [STG93] Fix Blob Recordings (`sv=` F&R) (Azure#34928) * Fix Blob failing CI, F+R recordings sv= * Fix missing recordings * Bring back F+R recordings * Add missing recordings for feature added to main b/w this times recordings * Generated code all packages, adjust changelogs to merge before release * Update file-share reference for swagger
1 parent 54682bc commit d48629e

File tree

94 files changed

+2486
-4817
lines changed

Some content is hidden

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

94 files changed

+2486
-4817
lines changed

.vscode/cspell.json

Lines changed: 2 additions & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -1356,7 +1356,8 @@
13561356
"Ffile",
13571357
"Fsubdir",
13581358
"Fdir",
1359-
"adal"
1359+
"adal",
1360+
"mytestshare"
13601361
]
13611362
},
13621363
{

sdk/storage/azure-storage-blob-changefeed/CHANGELOG.md

Lines changed: 2 additions & 3 deletions
Original file line numberDiff line numberDiff line change
@@ -4,9 +4,8 @@
44

55
This version and all future versions will require Python 3.8+. Python 3.6 and 3.7 are no longer supported.
66

7-
### Features Added
8-
9-
### Bugs Fixed
7+
### Other Changes
8+
- Bumped dependency of `azure-storage-blob` to the latest stable release (12.19.0).
109

1110
### 12.0.0b4 (2022-06-15)
1211

sdk/storage/azure-storage-blob-changefeed/setup.py

Lines changed: 1 addition & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -77,6 +77,6 @@
7777
},
7878
python_requires=">=3.8",
7979
install_requires=[
80-
"azure-storage-blob>=12.14.1,<13.0.0"
80+
"azure-storage-blob>=12.19.1,<13.0.0"
8181
],
8282
)

sdk/storage/azure-storage-blob/CHANGELOG.md

Lines changed: 1 addition & 0 deletions
Original file line numberDiff line numberDiff line change
@@ -5,6 +5,7 @@
55
This version and all future versions will require Python 3.8+. Python 3.7 is no longer supported.
66

77
### Features Added
8+
- Added support for service version 2024-05-04.
89
- The `services` parameter has been added to the `generate_account_sas` API, which enables the ability to generate SAS
910
tokens to be used with multiple services. By default, the SAS token service scope will default to the current service.
1011

sdk/storage/azure-storage-blob/assets.json

Lines changed: 1 addition & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -2,5 +2,5 @@
22
"AssetsRepo": "Azure/azure-sdk-assets",
33
"AssetsRepoPrefixPath": "python",
44
"TagPrefix": "python/storage/azure-storage-blob",
5-
"Tag": "python/storage/azure-storage-blob_20d52f0450"
5+
"Tag": "python/storage/azure-storage-blob_fa839739c1"
66
}

sdk/storage/azure-storage-blob/azure/storage/blob/_generated/_azure_blob_storage.py

Lines changed: 21 additions & 3 deletions
Original file line numberDiff line numberDiff line change
@@ -10,6 +10,7 @@
1010
from typing import Any
1111

1212
from azure.core import PipelineClient
13+
from azure.core.pipeline import policies
1314
from azure.core.rest import HttpRequest, HttpResponse
1415

1516
from . import models as _models
@@ -54,7 +55,24 @@ def __init__( # pylint: disable=missing-client-constructor-parameter-credential
5455
self, url: str, base_url: str = "", **kwargs: Any
5556
) -> None:
5657
self._config = AzureBlobStorageConfiguration(url=url, **kwargs)
57-
self._client: PipelineClient = PipelineClient(base_url=base_url, config=self._config, **kwargs)
58+
_policies = kwargs.pop("policies", None)
59+
if _policies is None:
60+
_policies = [
61+
policies.RequestIdPolicy(**kwargs),
62+
self._config.headers_policy,
63+
self._config.user_agent_policy,
64+
self._config.proxy_policy,
65+
policies.ContentDecodePolicy(**kwargs),
66+
self._config.redirect_policy,
67+
self._config.retry_policy,
68+
self._config.authentication_policy,
69+
self._config.custom_hook_policy,
70+
self._config.logging_policy,
71+
policies.DistributedTracingPolicy(**kwargs),
72+
policies.SensitiveHeaderCleanupPolicy(**kwargs) if self._config.redirect_policy else None,
73+
self._config.http_logging_policy,
74+
]
75+
self._client: PipelineClient = PipelineClient(base_url=base_url, policies=_policies, **kwargs)
5876

5977
client_models = {k: v for k, v in _models.__dict__.items() if isinstance(v, type)}
6078
self._serialize = Serializer(client_models)
@@ -67,7 +85,7 @@ def __init__( # pylint: disable=missing-client-constructor-parameter-credential
6785
self.append_blob = AppendBlobOperations(self._client, self._config, self._serialize, self._deserialize)
6886
self.block_blob = BlockBlobOperations(self._client, self._config, self._serialize, self._deserialize)
6987

70-
def _send_request(self, request: HttpRequest, **kwargs: Any) -> HttpResponse:
88+
def _send_request(self, request: HttpRequest, *, stream: bool = False, **kwargs: Any) -> HttpResponse:
7189
"""Runs the network request through the client's chained policies.
7290
7391
>>> from azure.core.rest import HttpRequest
@@ -87,7 +105,7 @@ def _send_request(self, request: HttpRequest, **kwargs: Any) -> HttpResponse:
87105

88106
request_copy = deepcopy(request)
89107
request_copy.url = self._client.format_url(request_copy.url)
90-
return self._client.send_request(request_copy, **kwargs)
108+
return self._client.send_request(request_copy, stream=stream, **kwargs) # type: ignore
91109

92110
def close(self) -> None:
93111
self._client.close()

sdk/storage/azure-storage-blob/azure/storage/blob/_generated/_configuration.py

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

9-
import sys
10-
from typing import Any
9+
from typing import Any, Literal
1110

12-
from azure.core.configuration import Configuration
1311
from azure.core.pipeline import policies
1412

15-
if sys.version_info >= (3, 8):
16-
from typing import Literal # pylint: disable=no-name-in-module, ungrouped-imports
17-
else:
18-
from typing_extensions import Literal # type: ignore # pylint: disable=ungrouped-imports
19-
2013
VERSION = "unknown"
2114

2215

23-
class AzureBlobStorageConfiguration(Configuration): # pylint: disable=too-many-instance-attributes
16+
class AzureBlobStorageConfiguration: # pylint: disable=too-many-instance-attributes,name-too-long
2417
"""Configuration for AzureBlobStorage.
2518
2619
Note that all parameters used to create this instance are saved as instance
@@ -35,7 +28,6 @@ class AzureBlobStorageConfiguration(Configuration): # pylint: disable=too-many-
3528
"""
3629

3730
def __init__(self, url: str, **kwargs: Any) -> None:
38-
super(AzureBlobStorageConfiguration, self).__init__(**kwargs)
3931
version: Literal["2021-12-02"] = kwargs.pop("version", "2021-12-02")
4032

4133
if url is None:
@@ -44,6 +36,7 @@ def __init__(self, url: str, **kwargs: Any) -> None:
4436
self.url = url
4537
self.version = version
4638
kwargs.setdefault("sdk_moniker", "azureblobstorage/{}".format(VERSION))
39+
self.polling_interval = kwargs.get("polling_interval", 30)
4740
self._configure(**kwargs)
4841

4942
def _configure(self, **kwargs: Any) -> None:
@@ -52,7 +45,7 @@ def _configure(self, **kwargs: Any) -> None:
5245
self.proxy_policy = kwargs.get("proxy_policy") or policies.ProxyPolicy(**kwargs)
5346
self.logging_policy = kwargs.get("logging_policy") or policies.NetworkTraceLoggingPolicy(**kwargs)
5447
self.http_logging_policy = kwargs.get("http_logging_policy") or policies.HttpLoggingPolicy(**kwargs)
55-
self.retry_policy = kwargs.get("retry_policy") or policies.RetryPolicy(**kwargs)
5648
self.custom_hook_policy = kwargs.get("custom_hook_policy") or policies.CustomHookPolicy(**kwargs)
5749
self.redirect_policy = kwargs.get("redirect_policy") or policies.RedirectPolicy(**kwargs)
50+
self.retry_policy = kwargs.get("retry_policy") or policies.RetryPolicy(**kwargs)
5851
self.authentication_policy = kwargs.get("authentication_policy")

0 commit comments

Comments
 (0)