uncomment inserts

algo.py

@@ -341,11 +341,11 @@ class Algo:
                 results.append(mapping)
 
             if len(result_batch) >= 500:
-                # store_batch_results_to_db(self.db_conn, self.db_cursor, self.run_key, result_batch)
+                store_batch_results_to_db(self.db_conn, self.db_cursor, self.run_key, result_batch)
                 result_batch = []
 
         if len(result_batch) > 0:
-            # store_batch_results_to_db(self.db_conn, self.db_cursor, self.run_key, result_batch)
+            store_batch_results_to_db(self.db_conn, self.db_cursor, self.run_key, result_batch)
             result_batch = []
 
 

rq_settings.py

@@ -20,14 +20,14 @@ LOGGING = {
     },
     'handlers': {
         'console': {
-            'level': 'DEBUG',
+            'level': 'WARNING',
             'class': 'logging.StreamHandler',
             'formatter': 'verbose'
         },
     },
     'root': {
         'handlers': ['console'],
-        'level': 'DEBUG',
+        'level': 'WARNING',
     },
     'rq.worker': {
         'handlers': ['console'],

run.py

@@ -37,11 +37,7 @@ if __name__ == "__main__":
         run_key = raw_file_name.split('.')[0]
         csv_complete, _ = file_is_complete(raw_file_name, run_key, db_cursor)
         if not csv_complete:
-            job = q.enqueue(process_file, raw_file_name, timeout=WORKER_TIMEOUT)
+            job = q.enqueue(process_file, raw_file_name, job_timeout=WORKER_TIMEOUT)
             print(f"Task enqueued with job ID: {job.id}")
 
-        # process_file.delay(raw_file_name)
-        
-        # algo.match_words([['bananas']])
-
-    # db_conn.close()
+    db_conn.close()