This is an automated email from the ASF dual-hosted git repository.
amoghdesai pushed a commit to branch main
in repository https://gitbox.apache.org/repos/asf/airflow.git
The following commit(s) were added to refs/heads/main by this push:
new 1288aba2b6f Bumping min version of azure-storage-blob to 12.26.0
(#53440)
1288aba2b6f is described below
commit 1288aba2b6fed385140f64811d42298b632476b1
Author: Amogh Desai <[email protected]>
AuthorDate: Thu Jul 17 14:53:53 2025 +0530
Bumping min version of azure-storage-blob to 12.26.0 (#53440)
---
.../celery/src/airflow/providers/celery/executors/celery_executor.py | 1 -
providers/microsoft/azure/pyproject.toml | 2 +-
.../azure/src/airflow/providers/microsoft/azure/hooks/wasb.py | 5 +++--
3 files changed, 4 insertions(+), 4 deletions(-)
diff --git
a/providers/celery/src/airflow/providers/celery/executors/celery_executor.py
b/providers/celery/src/airflow/providers/celery/executors/celery_executor.py
index 6160b055a3e..95c4c97f12c 100644
--- a/providers/celery/src/airflow/providers/celery/executors/celery_executor.py
+++ b/providers/celery/src/airflow/providers/celery/executors/celery_executor.py
@@ -473,7 +473,6 @@ class CeleryExecutor(BaseExecutor):
celery_tasks = {}
not_adopted_tis = []
-
for ti in tis:
if ti.external_executor_id is not None:
celery_tasks[ti.external_executor_id] =
(AsyncResult(ti.external_executor_id), ti)
diff --git a/providers/microsoft/azure/pyproject.toml
b/providers/microsoft/azure/pyproject.toml
index 81381a1f7d6..fb7610834bc 100644
--- a/providers/microsoft/azure/pyproject.toml
+++ b/providers/microsoft/azure/pyproject.toml
@@ -66,7 +66,7 @@ dependencies = [
"azure-keyvault-secrets>=4.1.0",
"azure-mgmt-datalake-store>=0.5.0",
"azure-mgmt-resource>=2.2.0",
- "azure-storage-blob>=12.14.0",
+ "azure-storage-blob>=12.26.0",
"azure-mgmt-storage>=16.0.0",
"azure-storage-file-share>=12.7.0",
"azure-servicebus>=7.12.1",
diff --git
a/providers/microsoft/azure/src/airflow/providers/microsoft/azure/hooks/wasb.py
b/providers/microsoft/azure/src/airflow/providers/microsoft/azure/hooks/wasb.py
index a87f00a571c..c0709afecfe 100644
---
a/providers/microsoft/azure/src/airflow/providers/microsoft/azure/hooks/wasb.py
+++
b/providers/microsoft/azure/src/airflow/providers/microsoft/azure/hooks/wasb.py
@@ -57,6 +57,7 @@ from airflow.providers.microsoft.azure.version_compat import
BaseHook
if TYPE_CHECKING:
from azure.core.credentials import TokenCredential
from azure.storage.blob._models import BlobProperties
+ from azure.storage.blob.aio._list_blobs_helper import BlobPrefix
AsyncCredentials = AsyncClientSecretCredential | AsyncDefaultAzureCredential
@@ -712,7 +713,7 @@ class WasbAsyncHook(WasbHook):
include: list[str] | None = None,
delimiter: str = "/",
**kwargs: Any,
- ) -> list[BlobProperties]:
+ ) -> list[BlobProperties | BlobPrefix]:
"""
List blobs in a given container.
@@ -725,7 +726,7 @@ class WasbAsyncHook(WasbHook):
:param delimiter: filters objects based on the delimiter (for e.g
'.csv')
"""
container = self._get_container_client(container_name)
- blob_list: list[BlobProperties] = []
+ blob_list: list[BlobProperties | BlobPrefix] = []
blobs = container.walk_blobs(name_starts_with=prefix, include=include,
delimiter=delimiter, **kwargs)
async for blob in blobs:
blob_list.append(blob)
