Skip to content

feat: Offline store update pull_all_from_table_or_query to make timestampfield optional #5281

New issue

Have a question about this project? Sign up for a free GitHub account to open an issue and contact its maintainers and the community.

Sign up for GitHub

By clicking “Sign up for GitHub”, you agree to our terms of service and privacy statement. We’ll occasionally send you account related emails.

Already on GitHub? Sign in to your account

Merged
franciscojavierarceo merged 20 commits into from
Apr 20, 2025
Merged

feat: Offline store update pull_all_from_table_or_query to make timestampfield optional #5281

Changes from 1 commit
Commits
Show all changes
20 commits
Select commit Hold shift + click to select a range
112014e
Update offline store pull all API date field optional
HaoXuAI Apr 18, 2025
c75c264
Update offline store pull all API date field optional
HaoXuAI Apr 18, 2025
b62fd1a
update
HaoXuAI Apr 18, 2025
8b5bdae
update
HaoXuAI Apr 18, 2025
e92d015
update
HaoXuAI Apr 18, 2025
4765d8f
fix test
HaoXuAI Apr 18, 2025
0bbdbbc
update source read node
HaoXuAI Apr 18, 2025
0336318
fix linting
HaoXuAI Apr 18, 2025
ac03a75
fix linting
HaoXuAI Apr 18, 2025
0033b9c
fix linting
HaoXuAI Apr 18, 2025
743a490
fix linting
HaoXuAI Apr 18, 2025
4285b5f
fix linting
HaoXuAI Apr 18, 2025
618c4b8
fix test
HaoXuAI Apr 18, 2025
afcaf9c
fix test
HaoXuAI Apr 18, 2025
8e02747
fix test
HaoXuAI Apr 18, 2025
71daec2
fix test
HaoXuAI Apr 18, 2025
23a0fb4
fix test
HaoXuAI Apr 18, 2025
bcf1d7a
fix test
HaoXuAI Apr 18, 2025
89ad0da
fix test
HaoXuAI Apr 18, 2025
cdae95b
fix test
HaoXuAI Apr 18, 2025
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
Prev Previous commit
Next Next commit
fix test 
Signed-off-by: HaoXuAI <sduxuhao@gmail.com>
  • Loading branch information
@HaoXuAI
HaoXuAI committed Apr 18, 2025
commit 4765d8fd544bf475b71c536b3e72e6734bd9aec8
14 changes: 5 additions & 9 deletions sdk/python/feast/infra/offline_stores/offline_utils.py
View file
Open in desktop
Original file line number Diff line number Diff line change
Expand Up @@ -298,16 +298,12 @@ def format_casted_ts(val: Union[str, datetime]) -> str:
if isinstance(val, datetime):
if tz:
val = val.astimezone(tz)
val_str = val.isoformat()
else:
val_str = val

if cast_style == "timestamp_func":
return f"TIMESTAMP('{val_str}')"
return f"TIMESTAMP('{val}')"
elif cast_style == "timestamptz":
return f"'{val_str}'::timestamptz"
else: # raw
return f"'{val_str}'"
return f"'{val}'::timestamptz"
else:
return f"'{val}'"

def format_date(val: Union[str, datetime]) -> str:
if isinstance(val, datetime):
Expand All @@ -321,7 +317,7 @@ def format_date(val: Union[str, datetime]) -> str:
# Timestamp filters
if start_date and end_date:
filters.append(
f"{timestamp_field} BETWEEN {format_casted_ts(start_date)} AND {format_casted_ts(end_date)}"
f'"{timestamp_field}" BETWEEN {format_casted_ts(start_date)} AND {format_casted_ts(end_date)}'
)
elif start_date:
filters.append(f"{timestamp_field} >= {format_casted_ts(start_date)}")
Expand Down
Loading