Skip to content
Merged
Changes from 1 commit
Commits
File filter

Filter by extension

Filter by extension

Conversations
Failed to load comments.
Loading
Jump to
Jump to file
Failed to load files.
Loading
Diff view
Diff view
5 changes: 5 additions & 0 deletions sdk/python/feast/infra/offline_stores/snowflake_source.py
Original file line number Diff line number Diff line change
Expand Up @@ -263,6 +263,11 @@ def get_table_column_names_and_types(
result.dtypes[column].name
]
else:
if len(result) > 0:
max_value = result.iloc[0][0]
if max_value is not None and len(str(max_value)) <= 18:
row["snowflake_type"] = "NUMBER"
continue
Comment thread
sfc-gh-madkins marked this conversation as resolved.
raise NotImplementedError(
"NaNs or Numbers larger than INT64 are not supported"
)
Expand Down