Merge pull request #293 from splitio/development

Release patch 9.2.2

Author: chillaq

.github/workflows/ci.yml

@@ -10,20 +10,20 @@ on:
 
 jobs:
   test:
-    runs-on: ubuntu-latest
+    runs-on: ubuntu-20.04
     services:
       redis:
         image: redis
         ports:
           - 6379:6379
     steps:
       - name: Checkout code
-        uses: actions/checkout@v2
+        uses: actions/checkout@v3
         with:
           fetch-depth: 0
 
       - name: Set up Python
-        uses: actions/setup-python@v2
+        uses: actions/setup-python@v3
         with:
           python-version: '3.6'
 

CHANGES.txt

@@ -1,3 +1,6 @@
+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.

splitio/engine/impressions/__init__.py

@@ -15,19 +15,21 @@ def set_classes(storage_mode, impressions_mode, api_adapter):
     clear_filter_task = None
     impressions_count_sync = None
     impressions_count_task = None
+    sender_adapter = None
     if storage_mode == 'REDIS':
-        redis_sender_adapter = RedisSenderAdapter(api_adapter)
-        api_telemetry_adapter = redis_sender_adapter
-        api_impressions_adapter = redis_sender_adapter
+        sender_adapter = RedisSenderAdapter(api_adapter)
+        api_telemetry_adapter = sender_adapter
+        api_impressions_adapter = sender_adapter
     else:
         api_telemetry_adapter = api_adapter['telemetry']
         api_impressions_adapter = api_adapter['impressions']
+        sender_adapter = InMemorySenderAdapter(api_telemetry_adapter)
 
     if impressions_mode == ImpressionsMode.NONE:
         imp_counter = ImpressionsCounter()
         imp_strategy = StrategyNoneMode(imp_counter)
         clear_filter_sync = ClearFilterSynchronizer(imp_strategy.get_unique_keys_tracker())
-        unique_keys_synchronizer = UniqueKeysSynchronizer(InMemorySenderAdapter(api_telemetry_adapter), imp_strategy.get_unique_keys_tracker())
+        unique_keys_synchronizer = UniqueKeysSynchronizer(sender_adapter, imp_strategy.get_unique_keys_tracker())
         unique_keys_task = UniqueKeysSyncTask(unique_keys_synchronizer.send_all)
         clear_filter_task = ClearFilterSyncTask(clear_filter_sync.clear_all)
         imp_strategy.get_unique_keys_tracker().set_queue_full_hook(unique_keys_task.flush)

splitio/version.py

@@ -1 +1 @@
-__version__ = '9.2.1'
+__version__ = '9.2.2'