Script 'mail_helper' called by obssrc
Hello community,
here is the log from the commit of package python-azure-storage-file-datalake
for openSUSE:Factory checked in at 2026-05-15 23:56:10
++++++++++++++++++++++++++++++++++++++++++++++++++++++++++++++++++++++++
Comparing /work/SRC/openSUSE:Factory/python-azure-storage-file-datalake (Old)
and
/work/SRC/openSUSE:Factory/.python-azure-storage-file-datalake.new.1966 (New)
++++++++++++++++++++++++++++++++++++++++++++++++++++++++++++++++++++++++
Package is "python-azure-storage-file-datalake"
Fri May 15 23:56:10 2026 rev:34 rq:1353389 version:12.24.0
Changes:
--------
---
/work/SRC/openSUSE:Factory/python-azure-storage-file-datalake/python-azure-storage-file-datalake.changes
2026-05-05 17:58:13.802868234 +0200
+++
/work/SRC/openSUSE:Factory/.python-azure-storage-file-datalake.new.1966/python-azure-storage-file-datalake.changes
2026-05-15 23:58:12.152698437 +0200
@@ -1,0 +2,9 @@
+Fri May 15 09:34:46 UTC 2026 - John Paul Adrian Glaubitz
<[email protected]>
+
+- New upstream release
+ + Version 12.24.0
+ + For detailed information about changes see the
+ CHANGELOG.md file provided with this package
+- Remove temporary version override
+
+-------------------------------------------------------------------
Old:
----
azure_storage_file_datalake-12.24.0b1.tar.gz
New:
----
azure_storage_file_datalake-12.24.0.tar.gz
++++++++++++++++++++++++++++++++++++++++++++++++++++++++++++++++++++++++
Other differences:
------------------
++++++ python-azure-storage-file-datalake.spec ++++++
--- /var/tmp/diff_new_pack.cUkpsH/_old 2026-05-15 23:58:12.804725277 +0200
+++ /var/tmp/diff_new_pack.cUkpsH/_new 2026-05-15 23:58:12.808725442 +0200
@@ -16,17 +16,15 @@
#
-%define realversion 12.24.0b1
-
%{?sle15_python_module_pythons}
Name: python-azure-storage-file-datalake
-Version: 12.24.0~b1
+Version: 12.24.0
Release: 0
Summary: Azure DataLake service client library for Python
License: MIT
Group: Development/Languages/Python
URL: https://github.com/Azure/azure-sdk-for-python
-Source:
https://files.pythonhosted.org/packages/source/a/azure_storage_file_datalake/azure_storage_file_datalake-%{realversion}.tar.gz
+Source:
https://files.pythonhosted.org/packages/source/a/azure_storage_file_datalake/azure_storage_file_datalake-%{version}.tar.gz
BuildRequires: %{python_module azure-nspkg >= 3.0.0}
BuildRequires: %{python_module azure-storage-nspkg >= 3.0.0}
BuildRequires: %{python_module pip}
@@ -60,7 +58,7 @@
(HNS) accounts.
%prep
-%setup -q -n azure_storage_file_datalake-%{realversion}
+%setup -q -n azure_storage_file_datalake-%{version}
%build
%pyproject_wheel
++++++ azure_storage_file_datalake-12.24.0b1.tar.gz ->
azure_storage_file_datalake-12.24.0.tar.gz ++++++
diff -urN '--exclude=CVS' '--exclude=.cvsignore' '--exclude=.svn'
'--exclude=.svnignore' old/azure_storage_file_datalake-12.24.0b1/CHANGELOG.md
new/azure_storage_file_datalake-12.24.0/CHANGELOG.md
--- old/azure_storage_file_datalake-12.24.0b1/CHANGELOG.md 2026-01-27
15:11:20.000000000 +0100
+++ new/azure_storage_file_datalake-12.24.0/CHANGELOG.md 2026-05-15
02:57:20.000000000 +0200
@@ -1,5 +1,27 @@
# Release History
+## 12.24.0 (2026-05-14)
+
+### Features Added
+- Stable release of features from 12.24.0b1
+
+### Bugs Fixed
+- Fixed various issues with configuring logging via `logging_enable` and
`logging_body` keywords on a per-request
+basis and with retries. Prior to this fix logging may have not behaved as
expected, especially on retries.
+- Fix a potential memory leak caused by improper exception handling that could
occur under rare circumstances.
+
+## 12.25.0b1 (2026-04-01)
+
+### Features Added
+- Added support for service version 2026-06-06.
+- Added support for connection strings and `account_url`s to accept URLs with
`-ipv6` and `-dualstack` suffixes
+for `DataLakeServiceClient`, `FileSystemClient`, `DataLakeDirectoryClient`,
and `DataLakeFileClient`.
+- Added support for `DataLakeDirectoryClient` and `DataLakeFileClient`'s
`set_tags` and `get_tags` APIs
+to conditionally set and get tags associated with a directory or file client,
respectively.
+
+### Other Changes
+- Consolidated the behavior of `max_concurrency=None` by defaulting to the
shared `DEFAULT_MAX_CONCURRENCY` constant.
+
## 12.24.0b1 (2026-01-27)
### Features Added
diff -urN '--exclude=CVS' '--exclude=.cvsignore' '--exclude=.svn'
'--exclude=.svnignore' old/azure_storage_file_datalake-12.24.0b1/PKG-INFO
new/azure_storage_file_datalake-12.24.0/PKG-INFO
--- old/azure_storage_file_datalake-12.24.0b1/PKG-INFO 2026-01-27
15:36:08.942134900 +0100
+++ new/azure_storage_file_datalake-12.24.0/PKG-INFO 2026-05-15
03:20:29.486009100 +0200
@@ -1,13 +1,13 @@
Metadata-Version: 2.4
Name: azure-storage-file-datalake
-Version: 12.24.0b1
+Version: 12.24.0
Summary: Microsoft Azure File DataLake Storage Client Library for Python
Home-page: https://github.com/Azure/azure-sdk-for-python
Author: Microsoft Corporation
Author-email: [email protected]
License: MIT License
Keywords: azure,azure sdk
-Classifier: Development Status :: 4 - Beta
+Classifier: Development Status :: 5 - Production/Stable
Classifier: Programming Language :: Python
Classifier: Programming Language :: Python :: 3 :: Only
Classifier: Programming Language :: Python :: 3
@@ -22,7 +22,7 @@
Description-Content-Type: text/markdown
License-File: LICENSE
Requires-Dist: azure-core>=1.37.0
-Requires-Dist: azure-storage-blob>=12.29.0b1
+Requires-Dist: azure-storage-blob>=12.29.0
Requires-Dist: typing-extensions>=4.6.0
Requires-Dist: isodate>=0.6.1
Provides-Extra: aio
@@ -60,7 +60,7 @@
## Getting started
### Prerequisites
-* Python 3.9 or later is required to use this package. For more details,
please read our page on [Azure SDK for Python version support
policy](https://github.com/Azure/azure-sdk-for-python/wiki/Azure-SDKs-Python-version-support-policy).
+* Python 3.9 or later is required to use this package. For more details,
please read our page on [Azure SDK for Python version support
policy](https://github.com/Azure/azure-sdk-for-python/blob/main/doc/python_version_support_policy.md).
* You must have an [Azure subscription](https://azure.microsoft.com/free/) and
an
[Azure storage
account](https://learn.microsoft.com/azure/storage/blobs/data-lake-storage-quickstart-create-account)
to use this package.
@@ -122,7 +122,7 @@
* A directory under the file system
* A file in a the file system or under directory
-### Async Clients
+### Async Clients
This library includes a complete async API supported on Python 3.5+. To use
it, you must
first install an async transport, such as
[aiohttp](https://pypi.org/project/aiohttp/).
See
@@ -248,7 +248,7 @@
* __connection_timeout__ (int): The number of seconds the client will wait to
establish a connection to the server.
Defaults to 20 seconds.
* __read_timeout__ (int): The number of seconds the client will wait, between
consecutive read operations, for a
-response from the server. This is a socket level timeout and is not affected
by overall data size. Client-side read
+response from the server. This is a socket level timeout and is not affected
by overall data size. Client-side read
timeouts will be automatically retried. Defaults to 60 seconds.
* __transport__ (Any): User-provided transport to send the HTTP request.
diff -urN '--exclude=CVS' '--exclude=.cvsignore' '--exclude=.svn'
'--exclude=.svnignore' old/azure_storage_file_datalake-12.24.0b1/README.md
new/azure_storage_file_datalake-12.24.0/README.md
--- old/azure_storage_file_datalake-12.24.0b1/README.md 2026-01-27
15:11:20.000000000 +0100
+++ new/azure_storage_file_datalake-12.24.0/README.md 2026-05-15
02:57:20.000000000 +0200
@@ -17,7 +17,7 @@
## Getting started
### Prerequisites
-* Python 3.9 or later is required to use this package. For more details,
please read our page on [Azure SDK for Python version support
policy](https://github.com/Azure/azure-sdk-for-python/wiki/Azure-SDKs-Python-version-support-policy).
+* Python 3.9 or later is required to use this package. For more details,
please read our page on [Azure SDK for Python version support
policy](https://github.com/Azure/azure-sdk-for-python/blob/main/doc/python_version_support_policy.md).
* You must have an [Azure subscription](https://azure.microsoft.com/free/) and
an
[Azure storage
account](https://learn.microsoft.com/azure/storage/blobs/data-lake-storage-quickstart-create-account)
to use this package.
@@ -79,7 +79,7 @@
* A directory under the file system
* A file in a the file system or under directory
-### Async Clients
+### Async Clients
This library includes a complete async API supported on Python 3.5+. To use
it, you must
first install an async transport, such as
[aiohttp](https://pypi.org/project/aiohttp/).
See
@@ -205,7 +205,7 @@
* __connection_timeout__ (int): The number of seconds the client will wait to
establish a connection to the server.
Defaults to 20 seconds.
* __read_timeout__ (int): The number of seconds the client will wait, between
consecutive read operations, for a
-response from the server. This is a socket level timeout and is not affected
by overall data size. Client-side read
+response from the server. This is a socket level timeout and is not affected
by overall data size. Client-side read
timeouts will be automatically retried. Defaults to 60 seconds.
* __transport__ (Any): User-provided transport to send the HTTP request.
diff -urN '--exclude=CVS' '--exclude=.cvsignore' '--exclude=.svn'
'--exclude=.svnignore'
old/azure_storage_file_datalake-12.24.0b1/azure/storage/filedatalake/_data_lake_file_client_helpers.py
new/azure_storage_file_datalake-12.24.0/azure/storage/filedatalake/_data_lake_file_client_helpers.py
---
old/azure_storage_file_datalake-12.24.0b1/azure/storage/filedatalake/_data_lake_file_client_helpers.py
2026-01-27 15:11:20.000000000 +0100
+++
new/azure_storage_file_datalake-12.24.0/azure/storage/filedatalake/_data_lake_file_client_helpers.py
2026-05-15 02:57:20.000000000 +0200
@@ -19,6 +19,7 @@
get_mod_conditions,
get_path_http_headers
)
+from ._shared.constants import DEFAULT_MAX_CONCURRENCY
from ._shared.request_handlers import get_length, read_length
from ._shared.response_handlers import return_response_headers
from ._shared.uploads import IterStreamer
@@ -124,7 +125,9 @@
validate_content = kwargs.pop('validate_content', False)
content_settings = kwargs.pop('content_settings', None)
metadata = kwargs.pop('metadata', None)
- max_concurrency = kwargs.pop('max_concurrency', 1)
+ max_concurrency = kwargs.pop('max_concurrency', None)
+ if max_concurrency is None:
+ max_concurrency = DEFAULT_MAX_CONCURRENCY
kwargs['properties'] = add_metadata_headers(metadata)
kwargs['lease_access_conditions'] =
get_access_conditions(kwargs.pop('lease', None))
diff -urN '--exclude=CVS' '--exclude=.cvsignore' '--exclude=.svn'
'--exclude=.svnignore'
old/azure_storage_file_datalake-12.24.0b1/azure/storage/filedatalake/_shared/constants.py
new/azure_storage_file_datalake-12.24.0/azure/storage/filedatalake/_shared/constants.py
---
old/azure_storage_file_datalake-12.24.0b1/azure/storage/filedatalake/_shared/constants.py
2026-01-27 15:11:20.000000000 +0100
+++
new/azure_storage_file_datalake-12.24.0/azure/storage/filedatalake/_shared/constants.py
2026-05-15 02:57:20.000000000 +0200
@@ -17,4 +17,6 @@
DEFAULT_OAUTH_SCOPE = "/.default"
STORAGE_OAUTH_SCOPE = "https://storage.azure.com/.default";
+DEFAULT_MAX_CONCURRENCY = 1
+
SERVICE_HOST_BASE = "core.windows.net"
diff -urN '--exclude=CVS' '--exclude=.cvsignore' '--exclude=.svn'
'--exclude=.svnignore'
old/azure_storage_file_datalake-12.24.0b1/azure/storage/filedatalake/_shared/policies.py
new/azure_storage_file_datalake-12.24.0/azure/storage/filedatalake/_shared/policies.py
---
old/azure_storage_file_datalake-12.24.0b1/azure/storage/filedatalake/_shared/policies.py
2026-01-27 15:11:20.000000000 +0100
+++
new/azure_storage_file_datalake-12.24.0/azure/storage/filedatalake/_shared/policies.py
2026-05-15 02:57:20.000000000 +0200
@@ -188,7 +188,7 @@
class StorageLoggingPolicy(NetworkTraceLoggingPolicy):
"""A policy that logs HTTP request and response to the DEBUG logger.
- This accepts both global configuration, and per-request level with
"enable_http_logger"
+ This accepts both global configuration, and per-request level with
"logging_enable" and "logging_body"
"""
def __init__(self, logging_enable: bool = False, **kwargs) -> None:
@@ -198,9 +198,24 @@
def on_request(self, request: "PipelineRequest") -> None:
http_request = request.http_request
options = request.context.options
- self.logging_body = self.logging_body or options.pop("logging_body",
False)
- if options.pop("logging_enable", self.enable_http_logger):
- request.context["logging_enable"] = True
+
+ # Check if logging settings are already determined (from a previous
retry attempt)
+ if "logging_enable" not in request.context:
+ # First attempt - pop from options and store decision in context
+ # For logging_enable and logging_body, per-request setting will
override the global setting
+ logging_body = options.pop("logging_body", self.logging_body)
+ logging_enable = options.pop("logging_enable",
self.enable_http_logger)
+
+ # Only store in context if logging is enabled to avoid polluting
context
+ if logging_enable:
+ request.context["logging_enable"] = True
+ request.context["logging_body"] = logging_body
+ else:
+ # Retry attempt - use the settings stored in context from the
first attempt
+ logging_enable = request.context.get("logging_enable", False)
+ logging_body = request.context.get("logging_body", False)
+
+ if logging_enable:
if not _LOGGER.isEnabledFor(logging.DEBUG):
return
@@ -227,7 +242,7 @@
_LOGGER.debug(" %r: %r", header, value)
_LOGGER.debug("Request body:")
- if self.logging_body:
+ if logging_body:
_LOGGER.debug(str(http_request.body))
else:
# We don't want to log the binary data of a file upload.
@@ -236,7 +251,10 @@
_LOGGER.debug("Failed to log request: %r", err)
def on_response(self, request: "PipelineRequest", response:
"PipelineResponse") -> None:
- if response.context.pop("logging_enable", self.enable_http_logger):
+ # Logging settings should always be present in context if logging is
enabled
+ # Use .get() instead of .pop() to preserve context values for
potential retries
+ if response.context.get("logging_enable", False):
+ logging_body = response.context.get("logging_body", False)
if not _LOGGER.isEnabledFor(logging.DEBUG):
return
@@ -260,9 +278,9 @@
elif resp_content_type.startswith("image"):
_LOGGER.debug("Body contains image data.")
- if self.logging_body and resp_content_type.startswith("text"):
+ if logging_body and resp_content_type.startswith("text"):
_LOGGER.debug(response.http_response.text())
- elif self.logging_body:
+ elif logging_body:
try:
_LOGGER.debug(response.http_response.body())
except ValueError:
diff -urN '--exclude=CVS' '--exclude=.cvsignore' '--exclude=.svn'
'--exclude=.svnignore'
old/azure_storage_file_datalake-12.24.0b1/azure/storage/filedatalake/_shared/response_handlers.py
new/azure_storage_file_datalake-12.24.0/azure/storage/filedatalake/_shared/response_handlers.py
---
old/azure_storage_file_datalake-12.24.0b1/azure/storage/filedatalake/_shared/response_handlers.py
2026-01-27 15:11:20.000000000 +0100
+++
new/azure_storage_file_datalake-12.24.0/azure/storage/filedatalake/_shared/response_handlers.py
2026-05-15 02:57:20.000000000 +0200
@@ -190,11 +190,15 @@
error.additional_info = additional_data
# error.args is what's surfaced on the traceback - show error message in
all cases
error.args = (error.message,)
+
try:
- # `from None` prevents us from double printing the exception
(suppresses generated layer error context)
- exec("raise error from None") # pylint: disable=exec-used # nosec
- except SyntaxError as exc:
- raise error from exc
+ # `from None` suppresses exception chaining to prevent double printing
the exception.
+ raise error from None
+ finally:
+ # Explicitly clears exception references to break circular references
+ # and allow immediate garbage collection.
+ error = None
+ storage_error = None
def parse_to_internal_user_delegation_key(service_user_delegation_key):
diff -urN '--exclude=CVS' '--exclude=.cvsignore' '--exclude=.svn'
'--exclude=.svnignore'
old/azure_storage_file_datalake-12.24.0b1/azure/storage/filedatalake/_version.py
new/azure_storage_file_datalake-12.24.0/azure/storage/filedatalake/_version.py
---
old/azure_storage_file_datalake-12.24.0b1/azure/storage/filedatalake/_version.py
2026-01-27 15:11:20.000000000 +0100
+++
new/azure_storage_file_datalake-12.24.0/azure/storage/filedatalake/_version.py
2026-05-15 02:57:20.000000000 +0200
@@ -4,4 +4,4 @@
# license information.
# --------------------------------------------------------------------------
-VERSION = "12.24.0b1"
+VERSION = "12.24.0"
diff -urN '--exclude=CVS' '--exclude=.cvsignore' '--exclude=.svn'
'--exclude=.svnignore'
old/azure_storage_file_datalake-12.24.0b1/azure_storage_file_datalake.egg-info/PKG-INFO
new/azure_storage_file_datalake-12.24.0/azure_storage_file_datalake.egg-info/PKG-INFO
---
old/azure_storage_file_datalake-12.24.0b1/azure_storage_file_datalake.egg-info/PKG-INFO
2026-01-27 15:36:08.000000000 +0100
+++
new/azure_storage_file_datalake-12.24.0/azure_storage_file_datalake.egg-info/PKG-INFO
2026-05-15 03:20:29.000000000 +0200
@@ -1,13 +1,13 @@
Metadata-Version: 2.4
Name: azure-storage-file-datalake
-Version: 12.24.0b1
+Version: 12.24.0
Summary: Microsoft Azure File DataLake Storage Client Library for Python
Home-page: https://github.com/Azure/azure-sdk-for-python
Author: Microsoft Corporation
Author-email: [email protected]
License: MIT License
Keywords: azure,azure sdk
-Classifier: Development Status :: 4 - Beta
+Classifier: Development Status :: 5 - Production/Stable
Classifier: Programming Language :: Python
Classifier: Programming Language :: Python :: 3 :: Only
Classifier: Programming Language :: Python :: 3
@@ -22,7 +22,7 @@
Description-Content-Type: text/markdown
License-File: LICENSE
Requires-Dist: azure-core>=1.37.0
-Requires-Dist: azure-storage-blob>=12.29.0b1
+Requires-Dist: azure-storage-blob>=12.29.0
Requires-Dist: typing-extensions>=4.6.0
Requires-Dist: isodate>=0.6.1
Provides-Extra: aio
@@ -60,7 +60,7 @@
## Getting started
### Prerequisites
-* Python 3.9 or later is required to use this package. For more details,
please read our page on [Azure SDK for Python version support
policy](https://github.com/Azure/azure-sdk-for-python/wiki/Azure-SDKs-Python-version-support-policy).
+* Python 3.9 or later is required to use this package. For more details,
please read our page on [Azure SDK for Python version support
policy](https://github.com/Azure/azure-sdk-for-python/blob/main/doc/python_version_support_policy.md).
* You must have an [Azure subscription](https://azure.microsoft.com/free/) and
an
[Azure storage
account](https://learn.microsoft.com/azure/storage/blobs/data-lake-storage-quickstart-create-account)
to use this package.
@@ -122,7 +122,7 @@
* A directory under the file system
* A file in a the file system or under directory
-### Async Clients
+### Async Clients
This library includes a complete async API supported on Python 3.5+. To use
it, you must
first install an async transport, such as
[aiohttp](https://pypi.org/project/aiohttp/).
See
@@ -248,7 +248,7 @@
* __connection_timeout__ (int): The number of seconds the client will wait to
establish a connection to the server.
Defaults to 20 seconds.
* __read_timeout__ (int): The number of seconds the client will wait, between
consecutive read operations, for a
-response from the server. This is a socket level timeout and is not affected
by overall data size. Client-side read
+response from the server. This is a socket level timeout and is not affected
by overall data size. Client-side read
timeouts will be automatically retried. Defaults to 60 seconds.
* __transport__ (Any): User-provided transport to send the HTTP request.
diff -urN '--exclude=CVS' '--exclude=.cvsignore' '--exclude=.svn'
'--exclude=.svnignore'
old/azure_storage_file_datalake-12.24.0b1/azure_storage_file_datalake.egg-info/requires.txt
new/azure_storage_file_datalake-12.24.0/azure_storage_file_datalake.egg-info/requires.txt
---
old/azure_storage_file_datalake-12.24.0b1/azure_storage_file_datalake.egg-info/requires.txt
2026-01-27 15:36:08.000000000 +0100
+++
new/azure_storage_file_datalake-12.24.0/azure_storage_file_datalake.egg-info/requires.txt
2026-05-15 03:20:29.000000000 +0200
@@ -1,5 +1,5 @@
azure-core>=1.37.0
-azure-storage-blob>=12.29.0b1
+azure-storage-blob>=12.29.0
typing-extensions>=4.6.0
isodate>=0.6.1
diff -urN '--exclude=CVS' '--exclude=.cvsignore' '--exclude=.svn'
'--exclude=.svnignore' old/azure_storage_file_datalake-12.24.0b1/pyproject.toml
new/azure_storage_file_datalake-12.24.0/pyproject.toml
--- old/azure_storage_file_datalake-12.24.0b1/pyproject.toml 2026-01-27
15:11:20.000000000 +0100
+++ new/azure_storage_file_datalake-12.24.0/pyproject.toml 2026-05-15
02:57:20.000000000 +0200
@@ -4,3 +4,7 @@
type_check_samples = true
verifytypes = false
black = false
+
+[tool.azure-sdk-conda]
+in_bundle = true
+bundle_name = "azure-storage"
diff -urN '--exclude=CVS' '--exclude=.cvsignore' '--exclude=.svn'
'--exclude=.svnignore' old/azure_storage_file_datalake-12.24.0b1/setup.py
new/azure_storage_file_datalake-12.24.0/setup.py
--- old/azure_storage_file_datalake-12.24.0b1/setup.py 2026-01-27
15:11:20.000000000 +0100
+++ new/azure_storage_file_datalake-12.24.0/setup.py 2026-05-15
02:57:20.000000000 +0200
@@ -57,7 +57,7 @@
url='https://github.com/Azure/azure-sdk-for-python',
keywords="azure, azure sdk",
classifiers=[
- 'Development Status :: 4 - Beta',
+ 'Development Status :: 5 - Production/Stable',
'Programming Language :: Python',
'Programming Language :: Python :: 3 :: Only',
'Programming Language :: Python :: 3',
@@ -79,7 +79,7 @@
python_requires=">=3.9",
install_requires=[
"azure-core>=1.37.0",
- "azure-storage-blob>=12.29.0b1",
+ "azure-storage-blob>=12.29.0",
"typing-extensions>=4.6.0",
"isodate>=0.6.1"
],
diff -urN '--exclude=CVS' '--exclude=.cvsignore' '--exclude=.svn'
'--exclude=.svnignore'
old/azure_storage_file_datalake-12.24.0b1/tests/test_file.py
new/azure_storage_file_datalake-12.24.0/tests/test_file.py
--- old/azure_storage_file_datalake-12.24.0b1/tests/test_file.py
2026-01-27 15:11:20.000000000 +0100
+++ new/azure_storage_file_datalake-12.24.0/tests/test_file.py 2026-05-15
02:57:20.000000000 +0200
@@ -694,6 +694,27 @@
@DataLakePreparer()
@recorded_by_proxy
+ def test_upload_data_with_none_max_concurrency(self, **kwargs):
+ datalake_storage_account_name =
kwargs.pop("datalake_storage_account_name")
+ datalake_storage_account_key =
kwargs.pop("datalake_storage_account_key")
+
+ self._setUp(datalake_storage_account_name,
datalake_storage_account_key)
+ directory_name = self._get_directory_reference()
+
+ # Create a directory to put the file under that
+ directory_client =
self.dsc.get_directory_client(self.file_system_name, directory_name)
+ directory_client.create_directory()
+
+ file_client = directory_client.get_file_client('filename')
+ data = self.get_random_bytes(100)
+ # max_concurrency=None should not raise TypeError
+ file_client.upload_data(data, overwrite=True, max_concurrency=None)
+
+ downloaded_data = file_client.download_file().readall()
+ assert data == downloaded_data
+
+ @DataLakePreparer()
+ @recorded_by_proxy
def test_read_file(self, **kwargs):
datalake_storage_account_name =
kwargs.pop("datalake_storage_account_name")
datalake_storage_account_key =
kwargs.pop("datalake_storage_account_key")
@@ -710,6 +731,24 @@
downloaded_data = file_client.download_file().readall()
assert data == downloaded_data
+ @DataLakePreparer()
+ @recorded_by_proxy
+ def test_read_file_with_none_max_concurrency(self, **kwargs):
+ datalake_storage_account_name =
kwargs.pop("datalake_storage_account_name")
+ datalake_storage_account_key =
kwargs.pop("datalake_storage_account_key")
+
+ self._setUp(datalake_storage_account_name,
datalake_storage_account_key)
+ file_client = self._create_file_and_return_client()
+ data = self.get_random_bytes(1024)
+
+ # upload data to file
+ file_client.append_data(data, 0, len(data))
+ file_client.flush_data(len(data))
+
+ # max_concurrency=None should not raise TypeError
+ downloaded_data =
file_client.download_file(max_concurrency=None).readall()
+ assert data == downloaded_data
+
@pytest.mark.live_test_only
@DataLakePreparer()
def test_read_file_with_user_delegation_key(self, **kwargs):
diff -urN '--exclude=CVS' '--exclude=.cvsignore' '--exclude=.svn'
'--exclude=.svnignore'
old/azure_storage_file_datalake-12.24.0b1/tests/test_file_async.py
new/azure_storage_file_datalake-12.24.0/tests/test_file_async.py
--- old/azure_storage_file_datalake-12.24.0b1/tests/test_file_async.py
2026-01-27 15:11:20.000000000 +0100
+++ new/azure_storage_file_datalake-12.24.0/tests/test_file_async.py
2026-05-15 02:57:20.000000000 +0200
@@ -729,6 +729,27 @@
@DataLakePreparer()
@recorded_by_proxy_async
+ async def test_upload_data_with_none_max_concurrency(self, **kwargs):
+ datalake_storage_account_name =
kwargs.pop("datalake_storage_account_name")
+ datalake_storage_account_key =
kwargs.pop("datalake_storage_account_key")
+
+ await self._setUp(datalake_storage_account_name,
datalake_storage_account_key)
+
+ # Create a directory to put the file under
+ directory_name = self._get_directory_reference()
+ directory_client =
self.dsc.get_directory_client(self.file_system_name, directory_name)
+ await directory_client.create_directory()
+
+ file_client = directory_client.get_file_client('filename')
+ data = self.get_random_bytes(100)
+ # max_concurrency=None should not raise TypeError
+ await file_client.upload_data(data, overwrite=True,
max_concurrency=None)
+
+ downloaded_data = await (await file_client.download_file()).readall()
+ assert data == downloaded_data
+
+ @DataLakePreparer()
+ @recorded_by_proxy_async
async def test_read_file(self, **kwargs):
datalake_storage_account_name =
kwargs.pop("datalake_storage_account_name")
datalake_storage_account_key =
kwargs.pop("datalake_storage_account_key")
@@ -745,6 +766,24 @@
downloaded_data = await (await file_client.download_file()).readall()
assert data == downloaded_data
+ @DataLakePreparer()
+ @recorded_by_proxy_async
+ async def test_read_file_with_none_max_concurrency(self, **kwargs):
+ datalake_storage_account_name =
kwargs.pop("datalake_storage_account_name")
+ datalake_storage_account_key =
kwargs.pop("datalake_storage_account_key")
+
+ await self._setUp(datalake_storage_account_name,
datalake_storage_account_key)
+ file_client = await self._create_file_and_return_client()
+ data = self.get_random_bytes(1024)
+
+ # upload data to file
+ await file_client.append_data(data, 0, len(data))
+ await file_client.flush_data(len(data))
+
+ # max_concurrency=None should not raise TypeError
+ downloaded_data = await (await
file_client.download_file(max_concurrency=None)).readall()
+ assert data == downloaded_data
+
@pytest.mark.live_test_only
@DataLakePreparer()
async def test_read_file_with_user_delegation_key(self, **kwargs):
