-
Notifications
You must be signed in to change notification settings - Fork 646
fix(databricks/pyspark): unify timestamp/timestamp_ntz behavior #11142
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
base: main
Are you sure you want to change the base?
Conversation
3e06c79
to
e0beb04
Compare
e0beb04
to
479f888
Compare
479f888
to
8558f8b
Compare
39f33fa
to
64c5194
Compare
39a1e8d
to
0ead096
Compare
0ead096
to
98df77b
Compare
@@ -559,7 +559,7 @@ def _read_in_memory(source: Any, table_name: str, _conn: Backend, **kwargs: Any) | |||
|
|||
@_read_in_memory.register("ibis.expr.types.Table") | |||
def _table(source, table_name, _conn, **kwargs: Any): | |||
_conn._add_table(table_name, source.to_polars()) | |||
_conn._add_table(table_name, _conn.to_polars(source)) |
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.
This was a hidden use of the default backend.
@@ -525,6 +525,7 @@ def test_roundtrip_delta(backend, con, alltypes, tmp_path, monkeypatch): | |||
["databricks"], raises=AssertionError, reason="Only the devil knows" | |||
) | |||
@pytest.mark.notyet(["athena"], raises=PyAthenaOperationalError) | |||
@pytest.mark.xfail_version(pyspark=["pyspark<3.4"], raises=AssertionError) |
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.
This indicates the biggest behavior change here which is that timestamps in PySpark 3.3 are now always without a timezone, because that's all that was supported in that version of PySpark. PySpark >=3.4 supports timestamps with and without timezones.
I'm going to consider this a breaking change and merge it in for 11.0. I'll release 10.6.0 this week as the last release of the 10.x series, and I'll start to merge the breakages after that. |
Closes #11137.
Closes #11062.