yujunjun/OpenMetadata
1
0
Fork 0
mirror of https://github.com/open-metadata/OpenMetadata.git synced 2025-09-09 09:02:12 +00:00
Code Issues Packages Projects Releases Wiki Activity

Fixes: GetTags-403 Permission denied on resource project None. (#14521)

Browse Source 
* Fix "GetTags-403 Permission denied on resource project None."

Signed-off-by: Takahiro Nakayama <civitaspo@gmail.com>
This commit is contained in:
Takahiro Nakayama 2023-12-29 18:39:59 +09:00 committed by GitHub
parent e4ea06834f
commit 7d05d9f50a
No known key found for this signature in database
GPG Key ID: 4AEE18F83AFDEB23
1 changed files with 24 additions and 3 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

27
ingestion/src/metadata/ingestion/source/database/bigquery/connection.py
View File

@ -44,6 +44,9 @@ from metadata.ingestion.connections.test_connections import (
from metadata.ingestion.ometa.ometa_api import OpenMetadata
from metadata.ingestion.source.database.bigquery.queries import BIGQUERY_TEST_STATEMENT
from metadata.utils.credentials import set_google_credentials
from metadata.utils.logger import ingestion_logger
logger = ingestion_logger()
def get_connection_url(connection: BigQueryConnection) -> str:
@ -107,9 +110,27 @@ def test_connection(
return policy_tags
def test_tags():
taxonomies = PolicyTagManagerClient().list_taxonomies(
parent=f"projects/{engine.url.host}/locations/{service_connection.taxonomyLocation}"
)
taxonomy_project_ids = []
if engine.url.host:
taxonomy_project_ids.append(engine.url.host)
if service_connection.taxonomyProjectId:
taxonomy_project_ids.extend(service_connection.taxonomyProjectId)
if not taxonomy_project_ids:
logger.info("'taxonomyProjectID' is not set, so skipping this test.")
return None
taxonomy_location = service_connection.taxonomyLocation
if not taxonomy_location:
logger.info("'taxonomyLocation' is not set, so skipping this test.")
return None
taxonomies = []
for project_id in taxonomy_project_ids:
taxonomies.extend(
PolicyTagManagerClient().list_taxonomies(
parent=f"projects/{project_id}/locations/{taxonomy_location}"
)
)
return get_tags(taxonomies)
def test_connection_inner(engine):