wip on mqtt test bug

Author: CamDavidsonPilon

pioreactor/tests/test_mqtt_to_db_streaming.py

@@ -5,6 +5,8 @@
 import sqlite3
 from time import sleep
 
+import pytest
+
 import pioreactor.background_jobs.leader.mqtt_to_db_streaming as m2db
 from pioreactor import mureq
 from pioreactor import structs
@@ -143,6 +145,7 @@ def test_dosing_events_land_in_db() -> None:
     assert len(results) == 1
 
 
+@pytest.mark.xfail(reason="we stopped adding to kalman filter table in 25.1.x release")
 def test_kalman_filter_entries() -> None:
     config["storage"]["database"] = "test.sqlite"
     config["od_reading.config"]["samples_per_second"] = "0.2"

pioreactor/utils/sqlite_worker.py

@@ -61,11 +61,9 @@ def __init__(self, file_name: str, max_queue_size: int = 100, raise_on_error: bo
         self._sqlite3_cursor = self._sqlite3_conn.cursor()
         self._sqlite3_cursor.executescript(
             """
-            PRAGMA journal_mode=WAL;
             PRAGMA synchronous = 1; -- aka NORMAL, recommended when using WAL
             PRAGMA temp_store = 2;  -- stop writing small files to disk, use mem
             PRAGMA busy_timeout = 15000;
-            PRAGMA foreign_keys = ON;
             PRAGMA synchronous = NORMAL;
             PRAGMA auto_vacuum = INCREMENTAL;
             PRAGMA cache_size = -20000;