see if I can get more logs about why log-buckets fail often

Author: CamDavidsonPilon

.github/workflows/ci.yaml

@@ -70,7 +70,7 @@ jobs:
 
       - name: Run tests
         run:  |
-          pytest pioreactor/tests/ -vv --timeout 600 --random-order --durations 15
+          pytest pioreactor/tests/ -vv --timeout 600 --random-order --durations 15 --log-level DEBUG
           pytest pioreactor/tests/test_automation_imports.py
         env:
           TESTING: 1

pioreactor/background_jobs/leader/mqtt_to_db_streaming.py

@@ -349,13 +349,13 @@ def parse_kalman_filter_outputs(topic: str, payload: pt.MQTTMessagePayload) -> d
         "timestamp": kf_output.timestamp,
         "state_0": kf_output.state[0],
         "state_1": kf_output.state[1],
-        "state_2": kf_output.state[2],
+        "state_2": 0.0,  # prev acc
         "cov_00": kf_output.covariance_matrix[0][0],
         "cov_01": kf_output.covariance_matrix[0][1],
-        "cov_02": kf_output.covariance_matrix[0][2],
+        "cov_02": 0.0,
         "cov_11": kf_output.covariance_matrix[1][1],
-        "cov_12": kf_output.covariance_matrix[1][2],
-        "cov_22": kf_output.covariance_matrix[2][2],
+        "cov_12": 0.0,
+        "cov_22": 0.0,
     }
 
 

pioreactor/pubsub.py

@@ -331,7 +331,9 @@ def __init__(self, log_level: str, unit: str, experiment: str) -> None:
         self.client: Client = subscribe_and_callback(
             self._collect_logs_into_bucket,
             f"pioreactor/{self.unit}/{self.experiment}/logs/app/{self.log_level.lower()}",
+            allow_retained=False,
         )
+        assert self.client.is_connected
 
     def _collect_logs_into_bucket(self, message):
         # load the message