Set qos=1 for buffering messages

equinor · May 29, 2024 · c9ae4a8 · c9ae4a8
1 parent e52f5dc
commit c9ae4a8
Show file tree

Hide file tree

Showing 2 changed files with 5 additions and 0 deletions.
diff --git a/src/isar/state_machine/state_machine.py b/src/isar/state_machine/state_machine.py
@@ -516,6 +516,7 @@ def publish_mission_status(self) -> None:
         self.mqtt_publisher.publish(
             topic=settings.TOPIC_ISAR_MISSION,
             payload=payload,
+            qos=1,
             retain=True,
         )
 
@@ -548,6 +549,7 @@ def publish_task_status(self, task: Task) -> None:
         self.mqtt_publisher.publish(
             topic=settings.TOPIC_ISAR_TASK,
             payload=payload,
+            qos=1,
             retain=True,
         )
 
@@ -582,6 +584,7 @@ def publish_step_status(self, step: Step) -> None:
         self.mqtt_publisher.publish(
             topic=settings.TOPIC_ISAR_STEP,
             payload=payload,
+            qos=1,
             retain=True,
         )
 
@@ -601,6 +604,7 @@ def publish_status(self) -> None:
         self.mqtt_publisher.publish(
             topic=settings.TOPIC_ISAR_STATUS,
             payload=payload,
+            qos=1,
             retain=True,
         )
 

diff --git a/src/isar/storage/uploader.py b/src/isar/storage/uploader.py
@@ -161,5 +161,6 @@ def _publish_inspection_result(
         self.mqtt_publisher.publish(
             topic=settings.TOPIC_ISAR_INSPECTION_RESULT,
             payload=payload,
+            qos=1,
             retain=True,
         )