Fix gcs Anonymous user issue because none token (#38102)

apache · Mar 14, 2024 · 0e2f2bc · 0e2f2bc
1 parent 3c5bcaa
commit 0e2f2bc
Showing 1 changed file with 1 addition and 2 deletions.
diff --git a/airflow/providers/google/cloud/fs/gcs.py b/airflow/providers/google/cloud/fs/gcs.py
@@ -47,12 +47,11 @@ def get_fs(conn_id: str | None, storage_options: dict[str, str] | None = None) -
         return GCSFileSystem()
 
     g = GoogleBaseHook(gcp_conn_id=conn_id)
-    creds = g.get_credentials()
 
     options = {
         "project": g.project_id,
         "access": g.extras.get(GCS_ACCESS, "full_control"),
-        "token": creds.token,
+        "token": g._get_access_token(),
         "consistency": g.extras.get(GCS_CONSISTENCY, "none"),
         "cache_timeout": g.extras.get(GCS_CACHE_TIMEOUT),
         "requester_pays": g.extras.get(GCS_REQUESTER_PAYS, False),