-
Notifications
You must be signed in to change notification settings - Fork 14.7k
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
Implement AthenaSQLHook #36171
Implement AthenaSQLHook #36171
Conversation
a8baa4d
to
2de24b6
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.
Please add docs for using the operator.
We probably will need also index added to explain the difference between the two options and then point to the specific doc of the relevant option.
You can see example of how we do it for Redshift
https://airflow.apache.org/docs/apache-airflow-providers-amazon/stable/operators/redshift/index.html
Should be easy to be done. If you need help with it let me know
70207e8
to
a9f651f
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.
LGTM. Thanks for addressing the feedbacks, I'd like to have the other opinions before merging though
a9f651f
to
93dae69
Compare
071fa23
to
37e80f9
Compare
a32133a
to
5736fd2
Compare
@eladkal could you help me with the spellcheck test? can't find what's wrong. thx! |
|
Interesting, I have a very similar error message in one of my open PRs and cannot figure out why. I am very interested if someone knows the reason |
It seems, Sphinx has some issues referencing a document not built yet. See https://apache-airflow.slack.com/archives/CJ1LVREHX/p1702929226260749. In other words, here you are creating a new file (renaming a file is like creating a new file for Sphinx) and are referring this file. It seems Sphinx does not like it. One way to solve it would be to keep the old file for now and delete it in another PR |
5736fd2
to
e87f135
Compare
e443580
to
e5dcfd1
Compare
Will this work with AWS credentials provider chain? I'm thinking about mwaa environments where the aws_default conn_id is used for most aws hooks. |
@flolas what is the status of this PR? I'm hoping to get it to the next provider release. |
2aed8f6
to
25fffe0
Compare
@eladkal Ummh, I can't figure out why spellcheck test fails with errors like this:
After resolving this issue (if you could give me a hand, that would be great), I need to fix some hook tests due to some changes I made in response to @Taragolis' comments/suggestions (but that's the easy part). |
I can see:
Adding |
Yeah sounds good, but why is this showing up in my PR when I'm only changing the Amazon provider and nothing else? Is this a expected behaviour of the spellcheck test? |
a43268e
to
fadd899
Compare
Co-authored-by: Vincent <[email protected]> Co-authored-by: Josh Fell <[email protected]> Co-authored-by: Andrey Anshin <[email protected]>
fadd899
to
28cc91f
Compare
@eladkal Tests seems good now 👍 , can you review again the code? I made some changes to address @Taragolis comments. thanks! |
🎉 🎉🎉 |
Co-authored-by: Vincent <[email protected]> Co-authored-by: Josh Fell <[email protected]> Co-authored-by: Andrey Anshin <[email protected]> (cherry picked from commit 6661272)
Co-authored-by: Vincent <[email protected]> Co-authored-by: Josh Fell <[email protected]> Co-authored-by: Andrey Anshin <[email protected]> (cherry picked from commit 6661272)
In this Pull Request, we're introducing the
AthenaSQLHook
, an implementation leveraging PyAthena. This development opens doors for us to interact with Athena using the familiar DBApiHook operators.Close: #34823
^ 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.rst
or{issue_number}.significant.rst
, in newsfragments.