From f8d09fc208b08e20729136813ddd5b0228038be7 Mon Sep 17 00:00:00 2001 From: CamDavidsonPilon Date: Fri, 27 Dec 2024 19:51:38 -0500 Subject: [PATCH] try this --- pioreactor/actions/leader/export_experiment_data.py | 2 +- pioreactor/cli/pio.py | 1 + pioreactor/utils/__init__.py | 1 - 3 files changed, 2 insertions(+), 2 deletions(-) diff --git a/pioreactor/actions/leader/export_experiment_data.py b/pioreactor/actions/leader/export_experiment_data.py index 6e509200..7e833cd3 100644 --- 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 index 4da9551e..6225387b 100644 --- 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 index c1761cd6..d8a280a9 100644 --- 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()