-
Notifications
You must be signed in to change notification settings - Fork 16.3k
Fix: Handle SQLAlchemy_URI for Apache Impala #57153
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
Conversation
56ae464 to
aa08162
Compare
|
@jason810496 @Lee-W can you please review this PR |
providers/apache/impala/src/airflow/providers/apache/impala/hooks/impala.py
Show resolved
Hide resolved
providers/apache/impala/src/airflow/providers/apache/impala/hooks/impala.py
Outdated
Show resolved
Hide resolved
Lee-W
left a comment
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.
a few nits. not major issue. great job!
providers/apache/impala/src/airflow/providers/apache/impala/hooks/impala.py
Outdated
Show resolved
Hide resolved
providers/apache/impala/src/airflow/providers/apache/impala/hooks/impala.py
Show resolved
Hide resolved
25092ae to
ba216a6
Compare
ba216a6 to
7ff55da
Compare
|
Hey @jason810496 can you review this PR? |
eladkal
left a comment
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.
happy to merge if no other concerns
Implemented a SQLAlchemy-compatible sqlalchemy_url property in ImpalaHook.
Added get_uri() method to return a fully formatted URI for Impala connections.
Added unit tests to verify correctness of the sqlalchemy_url property and get_uri() output.
Ran prek pre-commit checks to ensure code quality and formatting.
Related : #38195
^ Add meaningful description above
Read the Pull Request Guidelines for more information.
In case of fundamental code changes, an Airflow Improvement Proposal (AIP) is needed.
In case of a new dependency, check compliance with the ASF 3rd Party License Policy.
In case of backwards incompatible changes please leave a note in a newsfragment file, named
{pr_number}.significant.rstor{issue_number}.significant.rst, in airflow-core/newsfragments.