try this

Pioreactor · Dec 28, 2024 · f8d09fc · f8d09fc
1 parent 6025268
commit f8d09fc
Show file tree

Hide file tree

Showing 3 changed files with 2 additions and 2 deletions.
diff --git a/pioreactor/actions/leader/export_experiment_data.py b/pioreactor/actions/leader/export_experiment_data.py
@@ -246,7 +246,7 @@ def export_experiment_data(
 
                     parition_to_writer_map[rows_partition].writerow(row)
 
-                    if count % 1000 == 0:
+                    if count % 10_000 == 0:
                         logger.debug(f"Exported {count} rows...")
 
             logger.debug(f"Exported {count} rows from {dataset_name}.")

diff --git a/pioreactor/cli/pio.py b/pioreactor/cli/pio.py
@@ -124,6 +124,7 @@ def log(message: str, level: str, name: str, local_only: bool):
     except Exception as e:
         # don't let a logging error bring down a script...
         print(e)
+        sys.exit(1)
 
 
 @pio.command(name="blink", short_help="blink LED")

diff --git a/pioreactor/utils/__init__.py b/pioreactor/utils/__init__.py
@@ -601,7 +601,6 @@ class JobManager:
     def __init__(self) -> None:
         db_path = f"{tempfile.gettempdir()}/local_intermittent_pioreactor_metadata.sqlite"
         self.conn = sqlite3.connect(db_path, isolation_level=None)
-        self.conn.execute("pragma journal_mode=wal")
         self.cursor = self.conn.cursor()
         self._create_tables()