Skip to content

Commit 1288aba

Browse files
authored
Bumping min version of azure-storage-blob to 12.26.0 (apache#53440)
1 parent dc63c25 commit 1288aba

File tree

3 files changed

+4
-4
lines changed

3 files changed

+4
-4
lines changed

providers/celery/src/airflow/providers/celery/executors/celery_executor.py

Lines changed: 0 additions & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -473,7 +473,6 @@ def try_adopt_task_instances(self, tis: Sequence[TaskInstance]) -> Sequence[Task
473473

474474
celery_tasks = {}
475475
not_adopted_tis = []
476-
477476
for ti in tis:
478477
if ti.external_executor_id is not None:
479478
celery_tasks[ti.external_executor_id] = (AsyncResult(ti.external_executor_id), ti)

providers/microsoft/azure/pyproject.toml

Lines changed: 1 addition & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -66,7 +66,7 @@ dependencies = [
6666
"azure-keyvault-secrets>=4.1.0",
6767
"azure-mgmt-datalake-store>=0.5.0",
6868
"azure-mgmt-resource>=2.2.0",
69-
"azure-storage-blob>=12.14.0",
69+
"azure-storage-blob>=12.26.0",
7070
"azure-mgmt-storage>=16.0.0",
7171
"azure-storage-file-share>=12.7.0",
7272
"azure-servicebus>=7.12.1",

providers/microsoft/azure/src/airflow/providers/microsoft/azure/hooks/wasb.py

Lines changed: 3 additions & 2 deletions
Original file line numberDiff line numberDiff line change
@@ -57,6 +57,7 @@
5757
if TYPE_CHECKING:
5858
from azure.core.credentials import TokenCredential
5959
from azure.storage.blob._models import BlobProperties
60+
from azure.storage.blob.aio._list_blobs_helper import BlobPrefix
6061

6162
AsyncCredentials = AsyncClientSecretCredential | AsyncDefaultAzureCredential
6263

@@ -712,7 +713,7 @@ async def get_blobs_list_async(
712713
include: list[str] | None = None,
713714
delimiter: str = "/",
714715
**kwargs: Any,
715-
) -> list[BlobProperties]:
716+
) -> list[BlobProperties | BlobPrefix]:
716717
"""
717718
List blobs in a given container.
718719
@@ -725,7 +726,7 @@ async def get_blobs_list_async(
725726
:param delimiter: filters objects based on the delimiter (for e.g '.csv')
726727
"""
727728
container = self._get_container_client(container_name)
728-
blob_list: list[BlobProperties] = []
729+
blob_list: list[BlobProperties | BlobPrefix] = []
729730
blobs = container.walk_blobs(name_starts_with=prefix, include=include, delimiter=delimiter, **kwargs)
730731
async for blob in blobs:
731732
blob_list.append(blob)

0 commit comments

Comments
 (0)