code: def create_client(self) -> "google.cloud.storage.Client":
          
          # Client should be imported here because grpc starts threads during import
          # and if you call fork after that, a child process will be hang during exit
          from google.cloud.storage import Client
          if self.credentials:
              client = Client.from_service_account_json(self.credentials)
          else:
              client = Client()
          return client
docs: Construct GCS API client.