need to restart mqtt to db since we are changing a struct defintion

Author: CamDavidsonPilon

CHANGELOG.md

@@ -16,6 +16,7 @@ rate_std=0.25
  - New image installs only:
    - updated base OS to the latest 25-05-06 Raspberry Pi OS. The big change is using Linux kernel 6.12.
  - Added the column `hours_since_experiment_created` to dataset exports that details hours since experiment was created.
+ - A running pump now fires off an incremental dosing event every N seconds (N=0.5 currently) to tell the software its progress. Previously, we would fire off a single event that represented the total amount moved. This is most noticeable when watching the vial volume change over time (looks more accurate over a short period).
  - When a pump runs, it _first_ fires off a dosing_event, which stores information about how much liquid is moved. However, if the pump is stopped early, there was no correction issued to the amount of liquid actually moved. Now, when a pump is stopped early, a _negative_ volume is sent s.t. the delta between the initial amount and new amount is equal to the dosed amount (so when you sum up the volume changes, you get the actual change, as expected).
  - Performance optimizations
 

pioreactor/actions/pump.py

@@ -310,7 +310,7 @@ def _get_pump_action(pump_device: PumpCalibrationDevices) -> str:
         with PWMPump(
             unit, experiment, pin, calibration=calibration, mqtt_client=mqtt_client, logger=logger
         ) as pump:
-            sub_duration = 1.0
+            sub_duration = 0.5
             volume_moved_ml = 0.0
 
             pump_start_time = time.monotonic()

pioreactor/background_jobs/dosing_automation.py

@@ -264,12 +264,6 @@ def __init__(
                 "It's recommended to have stirring on to improve mixing during dosing events."
             )
 
-        if self.max_volume >= self.MAX_VIAL_VOLUME_TO_STOP:
-            # possibly the user messed up their configuration. We warn them.
-            self.logger.warning(
-                "The parameter max_volume_ml should be less than max_volume_to_stop (otherwise your pumping will stop too soon)."
-            )
-
     def set_duration(self, duration: Optional[float]) -> None:
         if duration:
             self.duration = float(duration)

update_scripts/upcoming/post_update.sh

@@ -0,0 +1,15 @@
+#!/bin/bash
+
+set -xeu
+
+
+export LC_ALL=C
+
+LEADER_HOSTNAME=$(crudini --get /home/pioreactor/.pioreactor/config.ini cluster.topology leader_hostname)
+
+# if leader
+if [ "$HOSTNAME" = "$LEADER_HOSTNAME" ]; then
+
+    # restart mqtt to db
+    sudo systemctl restart pioreactor_startup_run@mqtt_to_db_streaming.service || :
+fi

update_scripts/upcoming/pre_update.sh

@@ -0,0 +1,23 @@
+#!/bin/bash
+
+set -xeu
+
+
+export LC_ALL=C
+
+# Lower bound version
+min_version="25.4.11"
+
+# Get the current version of pio
+current_version=$(sudo -u pioreactor pio version)
+
+# Use sorting to determine if the current version is less than the minimum version
+is_valid=$(printf "%s\n%s" "$current_version" "$min_version" | sort -V | head -n1)
+
+# If the smallest version isn't the minimum version, then current version is too low
+if [ "$is_valid" != "$min_version" ]; then
+    sudo -u pioreactor pio log -l ERROR -m "Version error: installed version $current_version is lower than the minimum required version $min_version."
+    exit 1
+fi
+
+echo "Version check passed: $current_version"