Commit 006ff10d authored by Lluis Gifre Renom's avatar Lluis Gifre Renom
Browse files

Simap Connector: 

- Corrected update_counter in aggregator worker
parent 78440a42

src/simap_connector/service/telemetry/worker/AggregatorWorker.py

+2 −0
Original line number Diff line number Diff line
@@ -100,6 +100,8 @@ class AggregatorWorker(_Worker): 
                )

                kafka_producer.flush()



                update_counter += 1



                # Make wait responsible to terminations

                iterations = int(math.ceil(self._sampling_interval / WAIT_LOOP_GRANULARITY))

                for _ in range(iterations):