diff --git a/metadata-ingestion/src/datahub/ingestion/source/dremio/dremio_api.py b/metadata-ingestion/src/datahub/ingestion/source/dremio/dremio_api.py index a7104c2936b7e..9a39b891eebbf 100644 --- a/metadata-ingestion/src/datahub/ingestion/source/dremio/dremio_api.py +++ b/metadata-ingestion/src/datahub/ingestion/source/dremio/dremio_api.py @@ -782,6 +782,6 @@ def get_context_for_vds(self, resource_id: str) -> str: url=f"/catalog/{resource_id}", ).get("sqlContext") - return '.'.join( + return ".".join( f'"{part}"' if "." in part else f"{part}" for part in context_array )