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

pankajastro · web-flow · commit 0e2f2bc0ffb1 · 2024-03-14T16:34:43.000+05:30
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),
