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

Fixed #11519 Support Usage queries contain \n characters (#12676)

Browse Source
This commit is contained in:
vanshika18 2023-08-17 11:21:12 +05:30 committed by GitHub
parent 3114ef9b5c
commit d6e4169faf
No known key found for this signature in database
GPG Key ID: 4AEE18F83AFDEB23
1 changed files with 4 additions and 1 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

5
ingestion/src/metadata/ingestion/source/database/usage_source.py
View File

@ -78,6 +78,9 @@ class UsageSource(QueryParserSource, ABC):
else: else:
yield from self.yield_table_queries() yield from self.yield_table_queries()
def format_query(self, query: str) -> str:
return query.replace("\\n", "\n")
def yield_table_queries(self): def yield_table_queries(self):
""" """
Given an Engine, iterate over the day range and Given an Engine, iterate over the day range and
@ -103,7 +106,7 @@ class UsageSource(QueryParserSource, ABC):
try: try:
queries.append( queries.append(
TableQuery( TableQuery(
query=row["query_text"], query=self.format_query(row["query_text"]),
userName=row["user_name"], userName=row["user_name"],
startTime=str(row["start_time"]), startTime=str(row["start_time"]),
endTime=str(row["end_time"]), endTime=str(row["end_time"]),