diff --git a/ingestion/src/metadata/ingestion/source/sample_usage.py b/ingestion/src/metadata/ingestion/source/sample_usage.py index 18d1a6e45a5..318ccef1ae0 100644 --- a/ingestion/src/metadata/ingestion/source/sample_usage.py +++ b/ingestion/src/metadata/ingestion/source/sample_usage.py @@ -48,18 +48,14 @@ class SampleUsageSource(Source): def next_record(self) -> Iterable[TableQuery]: for row in self.query_logs: tq = TableQuery( - row["query"], - "", - 100, - 0, - 0, - "", - "", - datetime.today().strftime("%Y-%m-%d %H:%M:%S"), - 100, - "shopify", - False, - row["query"], + query=row["query"], + user_name="", + starttime="", + endtime="", + analysis_date=datetime.today().strftime("%Y-%m-%d %H:%M:%S"), + database="shopify", + aborted=False, + sql=row["query"], ) yield tq