code: def get_fs(
      conn_id: str | None, storage_options: dict[str, str] | None = None
  ) -> AbstractFileSystem:
      # https://gcsfs.readthedocs.io/en/latest/api.html#gcsfs.core.GCSFileSystem
      from gcsfs import GCSFileSystem
  
      if conn_id is 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,
          "consistency": g.extras.get(GCS_CONSISTENCY, "none"),
          "cache_timeout": g.extras.get(GCS_CACHE_TIMEOUT),
          "requester_pays": g.extras.get(GCS_REQUESTER_PAYS, False),
          "session_kwargs": g.extras.get(GCS_SESSION_KWARGS, {}),
          "endpoint_url": g.extras.get(GCS_ENDPOINT),
          "default_location": g.extras.get(GCS_DEFAULT_LOCATION),
          "version_aware": g.extras.get(
              GCS_VERSION_AWARE, "false"
          ).lower()
          == "true",
      }
      options.update(storage_options or {})
  
      return GCSFileSystem(**options)
  
imports: from __future__ import annotations
  from typing import TYPE_CHECKING
  from airflow.providers.google.common.hooks.base_google import GoogleBaseHook
label_desc: Use image node_id 1 for calling a global function with example usage: get_fs(conn_id, storage_options) and returns: GCSFileSystem, GCSFileSystem