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(