Fixed telemetry init format and applied latest patch code

Author: chillaq

CHANGES.txt

@@ -1,3 +1,14 @@
+9.2.2 (Dec 13, 2022)
+- Fixed RedisSenderAdapter instantiation to store mtk keys.
+
+9.2.1 (Dec 2, 2022)
+- Changed redis record type for impressions counts from list using rpush to hashed key using hincrby.
+- Apply Timeout Exception when incorrect SDK API Key is used.
+- Changed potential initial fetching segment Warning to Debug in logging.
+
+9.2.0 (Oct 14, 2022)
+- Added a new impressions mode for the SDK called NONE , to be used in factory when there is no desire to capture impressions on an SDK factory to feed Split's analytics engine. Running NONE mode, the SDK will only capture unique keys evaluated for a particular feature flag instead of full blown impressions
+
 9.1.3 (July 25, 2022)
 - Fixed synching missed segment(s) after receiving split update
 

splitio/client/factory.py

@@ -152,9 +152,15 @@ def _start_status_updater(self):
             ready_updater.start()
         else:
             self._status = Status.READY
-            #Push Config Telemetry into redis storage
-            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)
+            init_updater = threading.Thread(target=self._update_redis_init,
+                                             name='RedisInitUpdater')
+            init_updater.setDaemon(True)
+            init_updater.start()
+
+    def _update_redis_init(self):
+        """Push Config Telemetry into redis storage"""
+        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)
 
     def _update_status_when_ready(self):
         """Wait until the sdk is ready and update the status."""

splitio/storage/redis.py

@@ -617,7 +617,16 @@ def record_config(self, config, extra_config):
     def record_active_and_redundant_factories(self, active_factory_count, redundant_factory_count):
         """Record active and redundant factories."""
         self._tel_config.record_active_and_redundant_factories(active_factory_count, redundant_factory_count)
-        self._redis_client.record_init(self._tel_config.get_stats())
+        self._redis_client.record_init(self._format_config_stats())
+
+    def _format_config_stats(self):
+        config_stats = self._tel_config.get_stats()
+        return json.dumps({
+            'aF': config_stats['aF'],
+            'rF': config_stats['rF'],
+            'sT': config_stats['sT'],
+            'oM': config_stats['oM']
+        })
 
     def add_latency_to_pipe(self, method, latency, pipe):
         """

splitio/version.py

@@ -1 +1 @@
-__version__ = '9.2.1'
+__version__ = '9.2.3-rc1'