From a5a0e1b3dca95b78b2e83c4858df6763404b86e9 Mon Sep 17 00:00:00 2001 From: Miles Adkins Date: Sat, 10 Sep 2022 16:06:20 -0500 Subject: [PATCH] fix: Remove bad snowflake offline store method Signed-off-by: Miles Adkins --- sdk/python/feast/infra/offline_stores/snowflake.py | 9 --------- 1 file changed, 9 deletions(-) diff --git a/sdk/python/feast/infra/offline_stores/snowflake.py b/sdk/python/feast/infra/offline_stores/snowflake.py index 2395979702..c835eb939f 100644 --- a/sdk/python/feast/infra/offline_stores/snowflake.py +++ b/sdk/python/feast/infra/offline_stores/snowflake.py @@ -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)