def METHOD_NAME(self, **kwargs):
    api_key = self.api_key or get_secret_by_name("CALITP_AIRTABLE_API_KEY")
    self.extract.fetch_from_airtable(api_key)
    fs = get_fs()
    # inserts into xcoms
    return self.extract.save_to_gcs(fs, self.bucket)