diff --git a/metadata-ingestion/src/datahub/ingestion/source/tableau.py b/metadata-ingestion/src/datahub/ingestion/source/tableau.py index a2e46cd0c8..0c2010f56e 100644 --- a/metadata-ingestion/src/datahub/ingestion/source/tableau.py +++ b/metadata-ingestion/src/datahub/ingestion/source/tableau.py @@ -920,7 +920,7 @@ class TableauSource(StatefulIngestionSourceBase): view_properties = ViewPropertiesClass( materialized=False, viewLanguage="SQL", - viewLogic=clean_query(csql.get("query", "")), + viewLogic=clean_query(csql.get("query") or ""), ) dataset_snapshot.aspects.append(view_properties) diff --git a/metadata-ingestion/src/datahub/ingestion/source/tableau_common.py b/metadata-ingestion/src/datahub/ingestion/source/tableau_common.py index 3a33da17e1..1363207bd1 100644 --- a/metadata-ingestion/src/datahub/ingestion/source/tableau_common.py +++ b/metadata-ingestion/src/datahub/ingestion/source/tableau_common.py @@ -616,7 +616,7 @@ def get_unique_custom_sql(custom_sql_list: List[dict]) -> List[dict]: return unique_custom_sql -def clean_query(query): +def clean_query(query: str) -> str: """ Clean special chars in query """