Skip to content

Commit

Permalink
fix: Remove bad snowflake offline store method (#3204)
Browse files Browse the repository at this point in the history
Signed-off-by: Miles Adkins <miles.adkins@snowflake.com>

Signed-off-by: Miles Adkins <miles.adkins@snowflake.com>
  • Loading branch information
sfc-gh-madkins committed Sep 12, 2022
1 parent c19d640 commit dfdd0ca
Showing 1 changed file with 0 additions and 9 deletions.
9 changes: 0 additions & 9 deletions sdk/python/feast/infra/offline_stores/snowflake.py
Expand Up @@ -447,15 +447,6 @@ def to_sql(self) -> str:
with self._query_generator() as query:
return query

def to_arrow_chunks(self, arrow_options: Optional[Dict] = None) -> Optional[List]:
with self._query_generator() as query:

arrow_batches = execute_snowflake_statement(
self.snowflake_conn, query
).get_result_batches()

return arrow_batches

def persist(self, storage: SavedDatasetStorage, allow_overwrite: bool = False):
assert isinstance(storage, SavedDatasetSnowflakeStorage)
self.to_snowflake(table_name=storage.snowflake_options.table)
Expand Down

0 comments on commit dfdd0ca

Please sign in to comment.