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-6521]: add project param to bigQuery hook .getSchema method #7118
Conversation
Codecov Report
@@ Coverage Diff @@
## master #7118 +/- ##
==========================================
- Coverage 85.17% 84.96% -0.22%
==========================================
Files 683 683
Lines 39155 39155
==========================================
- Hits 33352 33267 -85
- Misses 5803 5888 +85
Continue to review full report at Codecov.
|
112dd04
to
6dc5ad3
Compare
6dc5ad3
to
2d38b38
Compare
@@ -1453,17 +1453,21 @@ def get_dataset_tables(self, dataset_id: str, project_id: Optional[str] = None, | |||
**optional_params).execute(num_retries=self.num_retries)) | |||
|
|||
@CloudBaseHook.catch_http_exception | |||
def get_schema(self, dataset_id: str, table_id: str) -> Dict: |
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.
Can you use @CloudBaseHook.fallback_to_default_project_id
?
…pache#7118) BigQuery hook can now take project_id as a parameter, so that operators may specify project_ids other than the default specified in connection.
Issue link: AIRFLOW-6521
[AIRFLOW-NNNN]
. AIRFLOW-NNNN = JIRA ID** For document-only changes commit message can start with
[AIRFLOW-XXXX]
.In case of fundamental code change, 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 UPDATING.md.
Read the Pull Request Guidelines for more information.