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

Simap Connector component: 

- Reduced log messages
parent ab49481a

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

+1 −1
Original line number Diff line number Diff line
@@ -78,7 +78,7 @@ class AggregatorWorker(_Worker): 


        try:

            while not self._stop_event.is_set() and not self._terminate.is_set():

                self._logger.info('[run] Aggregating...')

                #self._logger.debug('[run] Aggregating...')



                link_sample = self._aggregation_cache.aggregate()

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

+2 −2
Original line number Diff line number Diff line
@@ -89,8 +89,8 @@ class CollectorWorker(_Worker): 
                    if line is None: continue

                    if len(line) == 0: continue



                    MSG = '[underlay_subscription_stream] ==> {:s}'

                    self._logger.info(MSG.format(str(line)))

                    #MSG = '[underlay_subscription_stream] ==> {:s}'

                    #self._logger.debug(MSG.format(str(line)))

                    if not line.startswith('data:'): continue

                    data = json.loads(line[5:])

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

+1 −1
Original line number Diff line number Diff line
@@ -45,7 +45,7 @@ class SynthesizerWorker(_Worker): 


        try:

            while not self._stop_event.is_set() and not self._terminate.is_set():

                self._logger.info('[run] Sampling...')

                #self._logger.debug('[run] Sampling...')



                with self._lock:

                    self._resources.generate_samples(self._simap_client)