diff --git a/target_snowflake/db_sync.py b/target_snowflake/db_sync.py index 64efcac9..ffac46c5 100644 --- a/target_snowflake/db_sync.py +++ b/target_snowflake/db_sync.py @@ -688,7 +688,7 @@ def get_table_columns(self, table_schemas=None): # Run everything in one transaction try: - columns = self.query(queries, max_records=9999) + columns = self.query(queries, max_records=99999) if not columns: self.logger.warning('No columns discovered in the schema "%s"',