Apache Airflow: SnowflakeOperator
If you run into this problem after downloading snowflake-sqlalchemy
for Apache Airflow:
That means you probably encountered this error while downloading snowflake-sqlalchemy
:
A quick Google search will push you to this Stackoverflow question.
This question is pretty helpful and it should give you the idea that you need to downgrade your SQLAlchmey package. Luckly, the Airflow community is aware of the problem and is working to solve it, here.
For me, what fixed the issue was downgraing both sqlalchemy
and snowflake-sqlalchemy
:
pip3 install snowflake-sqlalchemy==1.2.4 sqlalchemy==1.3.24
Comments