-
Notifications
You must be signed in to change notification settings - Fork 1k
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.
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
Fix timezone issue in materialize & materialize_incremental #1439
Conversation
fed5c36
to
8939ab9
Compare
/ok-to-test |
5ca0e94
to
415ee45
Compare
415ee45
to
3e44b15
Compare
There was a problem hiding this comment.
Choose a reason for hiding this comment
The reason will be displayed to describe this comment to others. Learn more.
Mostly looks good, just some comments on the test structure
38cf31a
to
77c2e70
Compare
Signed-off-by: Tsotne Tabidze <[email protected]>
77c2e70
to
293d973
Compare
[APPROVALNOTIFIER] This PR is APPROVED This pull-request has been approved by: tsotnet, woop The full list of commands accepted by this bot can be found here. The pull request process is described here
Needs approval from an approver in each of these files:
Approvers can indicate their approval by writing |
/lgtm |
Signed-off-by: Tsotne Tabidze [email protected]
What this PR does / why we need it: Fixes an issue of mixing tz-aware and tz-naive timestamps. This was happening in fs.materialize & fs.materialize_incremental (both call _materialize_single_feature_view where I applied the fix), in FeatureView where the time zones aren't persisted between to_proto & from_proto, and in LocalSqlite:pull_latest_from_table_or_query where the source dataframe could have some tz-naive timestamps.
I also refactored
test_materialize_from_bigquery_to_datastore.py
intotest_materialize.py
where I maintain both existing test cases but also add a unit test that runs in the local mode. Lastly, I made sure to mix in tz-naive and tz-aware timestamps so that we make sure this bug is now well-tested.Which issue(s) this PR fixes:
Fixes #
Does this PR introduce a user-facing change?: