fixup! In KafkaConsumer class, implement throttling of telemetry data.

lsst-ts · Feb 14, 2025 · 735b8fe · 735b8fe
1 parent b78b8b7
commit 735b8fe
Showing 1 changed file with 3 additions and 1 deletion.
diff --git a/python/lsst/ts/salobj/kafka_consumer.py b/python/lsst/ts/salobj/kafka_consumer.py
@@ -480,7 +480,9 @@ def _handle_throttle(self) -> None:
                         self.log.info(
                             f"{kafka_name}: {index=} throutput={n_read/dt} messages/s ({throttle=})."
                         )
-                        old_throttle = self.throttle_telemetry[kafka_name].get(index, 0)
+                        old_throttle = self.throttle_telemetry[kafka_name].get(
+                            index, throttle
+                        )
                         self.throttle_telemetry[kafka_name][index] = int(
                             (old_throttle + throttle) / 2.0
                         )