React to both yz and toz stop commands

2026-02-25 16:30:57 +01:00
parent 493095331f
commit 7c951a2f14
1 changed files with 1 additions and 1 deletions
--- a/eos/kafka_serializer.py
+++ b/eos/kafka_serializer.py
@@ -160,7 +160,7 @@ class ESSSerializer:
                    )
            self.producer.flush()
            if isinstance(command, Stop):
-                if command.hist_id == self._active_histogram_yz:
+                if command.hist_id in [self._active_histogram_yz, self._active_histogram_tofz]:
                    self.count_stopped.set()
                else:
                    return