From d1a3fa4928abe7d273e5ced461884cd6b3bb5b08 Mon Sep 17 00:00:00 2001 From: Milan Bariya <52292922+MilanBariya@users.noreply.github.com> Date: Thu, 22 Sep 2022 18:10:17 +0530 Subject: [PATCH] Fix: Remove min duration limit (#7627) --- .../ingestion/source/database/snowflake_query_parser.py | 4 +--- 1 file changed, 1 insertion(+), 3 deletions(-) diff --git a/ingestion/src/metadata/ingestion/source/database/snowflake_query_parser.py b/ingestion/src/metadata/ingestion/source/database/snowflake_query_parser.py index 6dd3846af07..e5fde42de99 100644 --- a/ingestion/src/metadata/ingestion/source/database/snowflake_query_parser.py +++ b/ingestion/src/metadata/ingestion/source/database/snowflake_query_parser.py @@ -44,9 +44,7 @@ class SnowflakeQueryParserSource(QueryParserSource, ABC): def __init__(self, config: WorkflowSource, metadata_config: OpenMetadataConnection): super().__init__(config, metadata_config) - # Snowflake does not allow retrieval of data older than 7 days - # Update start and end based on this - duration = min(self.source_config.queryLogDuration, 6) + duration = self.source_config.queryLogDuration self.start, self.end = get_start_and_end(duration) @classmethod