Merge branch 'feature/telemetryv2' into telemetry-attach-services

Author: chillaq

splitio/api/impressions.py

@@ -6,7 +6,7 @@
 from splitio.api import APIException
 from splitio.api.client import HttpClientException
 from splitio.api.commons import headers_from_metadata
-from splitio.engine.impressions import ImpressionsMode
+from splitio.engine.impressions.impressions import ImpressionsMode
 
 
 _LOGGER = logging.getLogger(__name__)

splitio/client/config.py

@@ -2,7 +2,7 @@
 import os.path
 import logging
 
-from splitio.engine.impressions import ImpressionsMode
+from splitio.engine.impressions.impressions import ImpressionsMode
 
 
 _LOGGER = logging.getLogger(__name__)

splitio/client/factory.py

@@ -204,7 +204,7 @@ def block_until_ready(self, timeout=None):
                 self._telemetry_init_producer.record_bur_time_out()
                 raise TimeoutException('SDK Initialization: time of %d exceeded' % timeout)
             else:
-                redundant_factory_count, active_factory_count = _get_active_and_derundant_count()
+                redundant_factory_count, active_factory_count = _get_active_and_redundant_count()
                 self._telemetry_init_producer.record_active_and_redundant_factories(active_factory_count, redundant_factory_count)
 
                 config_post_thread = threading.Thread(target=self._telemetry_api.record_init(self._telemetry_init_consumer.get_config_stats()), name="PostConfigData")
@@ -576,7 +576,7 @@ def get_factory(api_key, **kwargs):
         _INSTANTIATED_FACTORIES.update([api_key])
         _INSTANTIATED_FACTORIES_LOCK.release()
 
-def _get_active_and_derundant_count():
+def _get_active_and_redundant_count():
     redundant_factory_count = 0
     active_factory_count = 0
     _INSTANTIATED_FACTORIES_LOCK.acquire()

splitio/models/telemetry.py

@@ -2,13 +2,9 @@
 from bisect import bisect_left
 import threading
 import os
-import logging
 
 from splitio.engine.impressions import ImpressionsMode
 
-_LOGGER = logging.getLogger(__name__)
-
-
 BUCKETS = (
     1000, 1500, 2250, 3375, 5063,
     7594, 11391, 17086, 25629, 38443,
@@ -270,7 +266,6 @@ def add_exception(self, method):
                 self._track = self._track + 1
             else:
                 return
-        _LOGGER.debug(self._treatment)
 
     def pop_all(self):
         """
@@ -745,7 +740,6 @@ def record_active_and_redundant_factories(self, active_factory_count, redundant_
             self._active_factory_count = active_factory_count
             self._redundant_factory_count = redundant_factory_count
 
-
     def record_ready_time(self, ready_time):
         """
         Record ready time.

splitio/sync/telemetry.py

@@ -49,4 +49,4 @@ def _build_stats(self):
         }
         merged_dict.update(self._telemetry_runtime_consumer.pop_formatted_stats())
         merged_dict.update(self._telemetry_evaluation_consumer.pop_formatted_stats())
-        return merged_dict
+        return merged_dict

tests/api/test_impressions_api.py

@@ -3,7 +3,7 @@
 import pytest
 from splitio.api import impressions, client, APIException
 from splitio.models.impressions import Impression
-from splitio.engine.impressions import ImpressionsMode
+from splitio.engine.impressions.impressions import ImpressionsMode
 from splitio.engine.impressions.manager import Counter
 from splitio.client.util import get_metadata
 from splitio.client.config import DEFAULT_CONFIG

tests/client/test_config.py

@@ -2,7 +2,7 @@
 # pylint: disable=protected-access,no-self-use,line-too-long
 
 from splitio.client import config
-from splitio.engine.impressions import ImpressionsMode
+from splitio.engine.impressions.impressions import ImpressionsMode
 
 
 class ConfigSanitizationTests(object):