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

lsst-ts · Feb 14, 2025 · 5a4d74e · 5a4d74e
1 parent b9e92c2
commit 5a4d74e
Showing 1 changed file with 3 additions and 3 deletions.
diff --git a/python/lsst/ts/salobj/kafka_consumer.py b/python/lsst/ts/salobj/kafka_consumer.py
@@ -478,16 +478,16 @@ def _handle_throttle(self) -> None:
                                 self.max_throttle,
                             ]
                         )
-                        self.log.info(
-                            f"{kafka_name}: {index=} throutput={n_read/dt} messages/s ({throttle=})."
-                        )
                         old_throttle = self.throttle_telemetry[kafka_name].get(
                             index, throttle
                         )
                         if throttle > old_throttle + self.max_throttle_change:
                             throttle = old_throttle + self.max_throttle_change
                         elif throttle < old_throttle - self.max_throttle_change:
                             throttle = old_throttle - self.max_throttle_change
+                        self.log.info(
+                            f"{kafka_name}: {index=} throutput={n_read/dt} messages/s ({throttle=})."
+                        )
                         self.throttle_telemetry[kafka_name][index] = throttle
                         self.telemetry_n_reads[kafka_name][index] = 1
             self.throutput_measurement_n_reads = 0