yujunjun/OpenMetadata
1
0
Fork 0
mirror of https://github.com/open-metadata/OpenMetadata.git synced 2026-01-06 04:26:57 +00:00
Code Issues Packages Projects Releases Wiki Activity

Don't overwrite query to execute (#20069)

Browse Source
This commit is contained in:
olof-nn 2025-03-05 06:41:20 +01:00 committed by GitHub
parent fb1283b8a7
commit c46ed2aa56
No known key found for this signature in database
GPG Key ID: B5690EEEBB952194
1 changed files with 4 additions and 4 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

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

@ -122,15 +122,15 @@ class UsageSource(QueryParserSource, ABC):
row = dict(row)
try:
row.update({k.lower(): v for k, v in row.items()})
logger.debug(f"Processing row: {query}")
logger.debug(f"Processing row: {row}")
query_type = row.get("query_type")
query = self.format_query(row["query_text"])
query_text = self.format_query(row["query_text"])
queries.append(
TableQuery(
query=query,
query=query_text,
query_type=query_type,
exclude_usage=self.check_life_cycle_query(
query_type=query_type, query_text=query
query_type=query_type, query_text=query_text
),
dialect=self.dialect.value,
userName=row["user_name"],