From 1e556d2ac1d4176efceee5848c59d9e7209cc1c0 Mon Sep 17 00:00:00 2001 From: Mayur Singal <39544459+ulixius9@users.noreply.github.com> Date: Mon, 21 Feb 2022 22:35:24 +0530 Subject: [PATCH] fix #2869: snowflake-usage processor fixed (#2896) --- .../src/metadata/ingestion/processor/query_parser.py | 8 +++++--- 1 file changed, 5 insertions(+), 3 deletions(-) diff --git a/ingestion/src/metadata/ingestion/processor/query_parser.py b/ingestion/src/metadata/ingestion/processor/query_parser.py index 45b09b781ba..f087156ba9e 100644 --- a/ingestion/src/metadata/ingestion/processor/query_parser.py +++ b/ingestion/src/metadata/ingestion/processor/query_parser.py @@ -75,9 +75,11 @@ class QueryParserProcessor(Processor): def process(self, record: TableQuery) -> QueryParserData: try: - start_date = datetime.datetime.strptime( - record.analysis_date, "%Y-%m-%d %H:%M:%S" - ).date() + start_date = record.analysis_date + if isinstance(record.analysis_date, str): + start_date = datetime.datetime.strptime( + record.analysis_date, "%Y-%m-%d %H:%M:%S" + ).date() parser = Parser(record.sql) columns_dict = {} if parser.columns_dict is None else parser.columns_dict query_parser_data = QueryParserData(