File tree Expand file tree Collapse file tree 2 files changed +3
-7
lines changed
Expand file tree Collapse file tree 2 files changed +3
-7
lines changed Original file line number Diff line number Diff line change 55import pytest
66import snowflake .connector
77from snowflake .sqlalchemy import URL
8- from sqlalchemy import create_engine
8+ from sqlalchemy import create_engine , text
99
1010import dask
1111import dask .dataframe as dd
@@ -29,7 +29,8 @@ def table(connection_kwargs):
2929 yield name
3030
3131 engine = create_engine (URL (** connection_kwargs ))
32- engine .execute (f"DROP TABLE IF EXISTS { name } " )
32+ with engine .connect () as conn :
33+ conn .execute (text (f"DROP TABLE IF EXISTS { name } " ))
3334
3435
3536@pytest .fixture (scope = "module" )
Original file line number Diff line number Diff line change @@ -2,8 +2,3 @@ dask>=2024.3.0
22distributed
33snowflake-connector-python [pandas ]>= 2.6.0
44snowflake-sqlalchemy
5- # `pandas=2.2` dropped support for `sqlalchemy<2`, but `snowflake-sqlalchemy`
6- # doesn't support `sqlalchemy>=2` yet. Temporarily pinning `pandas<2.2` for now.
7- # xref https://github.com/pandas-dev/pandas/issues/57049
8- # xref https://github.com/snowflakedb/snowflake-sqlalchemy/issues/380
9- pandas < 2.2
You can’t perform that action at this time.
0 commit comments