Refactor ObjectStorage into a Path (apache#35612)

TiDeane · Nov 18, 2023 · 2fc8d2a · 2fc8d2a
1 parent f30d5b8
commit 2fc8d2a
Show file tree

Hide file tree

Showing 11 changed files with 564 additions and 843 deletions.
diff --git a/airflow/example_dags/tutorial_objectstorage.py b/airflow/example_dags/tutorial_objectstorage.py
@@ -23,7 +23,7 @@
 import requests
 
 from airflow.decorators import dag, task
-from airflow.io.store.path import ObjectStoragePath
+from airflow.io.path import ObjectStoragePath
 
 # [END import_module]
 
@@ -93,7 +93,7 @@ def get_air_quality_data(**kwargs) -> ObjectStoragePath:
         response.raise_for_status()
 
         # ensure the bucket exists
-        base.mkdir(exists_ok=True)
+        base.mkdir(exist_ok=True)
 
         formatted_date = execution_date.format("YYYYMMDD")
         path = base / f"air_quality_{formatted_date}.parquet"