Commit 79781190 authored by Lluis Gifre Renom's avatar Lluis Gifre Renom
Browse files

Simap Connector: 

- Fixed composition of name for aggregator worker
parent 336a6bc5

src/simap_connector/service/SimapConnectorServiceServicerImpl.py

+1 −3
Original line number Diff line number Diff line
@@ -102,9 +102,7 @@ class SimapConnectorServiceServicerImpl(SimapConnectorServiceServicer): 
        topic = 'subscription.{:d}'.format(parent_subscription_id)

        create_kafka_topic(topic)



        aggregator_name = '{:s}:{:s}'.format(

            controller_id, str(parent_subscription_id)

        )

        aggregator_name = str(parent_subscription_id)

        self._telemetry_pool.start_aggregator(

            aggregator_name, parent_subscription_id, aggregation_cache, topic, period

        )