We read every piece of feedback, and take your input very seriously.
To see all available qualifiers, see our documentation.
1 parent d829dad commit c809bc7Copy full SHA for c809bc7
sdk/python/feast/infra/offline_stores/contrib/trino_offline_store/trino.py
@@ -207,9 +207,7 @@ def _to_df_internal(self, timeout: Optional[int] = None) -> pd.DataFrame:
207
208
def _to_arrow_internal(self, timeout: Optional[int] = None) -> pyarrow.Table:
209
"""Return payrrow dataset as synchronously including on demand transforms"""
210
- return pyarrow.Table.from_pandas(
211
- self._to_df_internal(timeout=timeout)
212
- )
+ return pyarrow.Table.from_pandas(self._to_df_internal(timeout=timeout))
213
214
def to_sql(self) -> str:
215
"""Returns the SQL query that will be executed in Trino to build the historical feature table"""
0 commit comments