fix open-metadata#2869: snowflake-usage processor fixed

ulixius9 · Feb 21, 2022 · d03e11a · d03e11a
1 parent 9e4d8d7
commit d03e11a
Showing 1 changed file with 5 additions and 3 deletions.
diff --git a/ingestion/src/metadata/ingestion/processor/query_parser.py b/ingestion/src/metadata/ingestion/processor/query_parser.py
@@ -75,9 +75,11 @@ def create(
 
     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(