Revert "Setting max_size to a hard_limit if failed once (#297)"

This reverts commit 6ef7811.

digital_land/package/datasetparquet.py

@@ -2,7 +2,6 @@
 import logging
 import duckdb
 from .package import Package
-import resource
 
 logger = logging.getLogger(__name__)
 
@@ -65,15 +64,15 @@ def create_temp_table(self, input_paths):
 
         input_paths_str = ", ".join([f"'{path}'" for path in input_paths])
 
+        self.conn.execute("DROP TABLE IF EXISTS temp_table")
         # Initial max_line_size and increment step
         max_size = 40000000
-        # increment_step = 20000000
+        increment_step = 20000000
         # max_limit = 200000000  # Maximum allowable line size to attempt
 
-        # increment = False
+        increment = False
         while True:
             try:
-                self.conn.execute("DROP TABLE IF EXISTS temp_table")
                 query = f"""
                     CREATE TEMPORARY TABLE temp_table AS
                     SELECT *
@@ -86,19 +85,14 @@ def create_temp_table(self, input_paths):
                     )
                 """
                 self.conn.execute(query)
+                if increment:
+                    logging.info(f"Ended up needing a value of max_size = {max_size}")
                 break
             except duckdb.Error as e:  # Catch specific DuckDB error
                 if "Value with unterminated quote" in str(e):
-                    hard_limit = int(resource.getrlimit(resource.RLIMIT_AS)[1])
-                    if max_size < hard_limit / 3:
-                        logging.info(
-                            f"Initial max_size did not work, setting it to {hard_limit / 2}"
-                        )
-                        max_size = hard_limit / 2
-                    else:
-                        raise
+                    increment = True
+                    max_size += increment_step
                 else:
-                    logging.info(f"Failed to read in when max_size = {max_size}")
                     raise
 
     def load_facts(self):