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
[AIRFLOW-5200] Move GCP PubSub to core #5803
Conversation
Depends on #5791 |
Pylint is sad :-/ |
d722a26
to
ada3585
Compare
super().__init__(gcp_conn_id, delegate_to=delegate_to) | ||
self.num_retries = self._get_field('num_retries', 5) # type: int | ||
|
||
def get_conn(self): |
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.
nit: there are type annotations in public methods, do we need type hints as well?
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.
The Google API Client library (discovery API) does not have valid annotations, because types are automatically generated at runtime.
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 PR is not intended to make changes to the code. There are no annotations in many places related to GCP, but this month we will try to prepare PR.
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.
Got it. Thanks!
This commit moves GCP PubSub from contrib to core. For more information check AIP-21.
Make sure you have checked all steps below.
Jira
Description
This commit moves GCP PubSub from contrib to core. For more information check AIP-21.
Tests
Commits
Documentation
Code Quality
flake8