rename mtk task calls

Author: chillaq

splitio/client/factory.py

@@ -335,8 +335,8 @@ def _build_in_memory_factory(api_key, cfg, sdk_url=None, events_url=None,  # pyl
         imp_strategy = StrategyNoneMode(imp_counter)
         clear_filter_sync = ClearFilterSynchronizer(imp_strategy._unique_keys_tracker)
         unique_keys_synchronizer = UniqueKeysSynchronizer(InMemorySenderAdapter(apis['telemetry']), imp_strategy._unique_keys_tracker)
-        unique_keys_task = UniqueKeysSyncTask(unique_keys_synchronizer.SendAll)
-        clear_filter_task = ClearFilterSyncTask(clear_filter_sync.clearAll)
+        unique_keys_task = UniqueKeysSyncTask(unique_keys_synchronizer.send_all)
+        clear_filter_task = ClearFilterSyncTask(clear_filter_sync.clear_all)
         imp_strategy._unique_keys_tracker.set_queue_full_hook(unique_keys_task.flush)
     elif cfg['impressionsMode'] == ImpressionsMode.DEBUG:
         imp_strategy = StrategyDebugMode()

splitio/sync/unique_keys.py

@@ -20,7 +20,7 @@ def __init__(self, impressions_sender_adapter, uniqe_keys_tracker):
         self._max_bulk_size = _UNIQUE_KEYS_MAX_BULK_SIZE
         self._impressions_sender_adapter = impressions_sender_adapter
 
-    def SendAll(self):
+    def send_all(self):
         """
         Flush the unique keys dictionary to split back end.
         Limit each post to the max_bulk_size value.
@@ -81,7 +81,7 @@ def __init__(self, unique_keys_tracker):
         """
         self._unique_keys_tracker = unique_keys_tracker
 
-    def clearAll(self):
+    def clear_all(self):
         """
         Clear the bloom filter cache
 

tests/sync/test_unique_keys_sync.py

@@ -37,7 +37,7 @@ def test_sync_unique_keys_send_all(self, mtk_mocker):
             unique_keys_tracker.track('key'+str(i)+'', 'feature1')
         sender_adapter = InMemorySenderAdapter(mock.Mock())
         unique_keys_synchronizer = UniqueKeysSynchronizer(sender_adapter, unique_keys_tracker)
-        unique_keys_synchronizer.SendAll()
+        unique_keys_synchronizer.send_all()
         assert(mtk_mocker.call_count == int(total_mtks / unique_keys_synchronizer._max_bulk_size) + 1)
 
     def mocked_record_unique_keys(self, cache):
@@ -50,6 +50,6 @@ def test_clear_all_filter(self, mocker):
             unique_keys_tracker.track('key'+str(i)+'', 'feature1')
 
         clear_filter_sync = ClearFilterSynchronizer(unique_keys_tracker)
-        clear_filter_sync.clearAll()
+        clear_filter_sync.clear_all()
         for i in range(0 , total_mtks):
             assert(not unique_keys_tracker._filter.contains('feature1key'+str(i)))

tests/tasks/test_unique_keys_sync.py

@@ -23,7 +23,7 @@ def test_normal_operation(self, mocker):
         unique_keys_tracker.track("key2", "split1")
 
         unique_keys_sync = UniqueKeysSynchronizer(mocker.Mock(), unique_keys_tracker)
-        task = UniqueKeysSyncTask(unique_keys_sync.SendAll, 1)
+        task = UniqueKeysSyncTask(unique_keys_sync.send_all, 1)
         task.start()
         time.sleep(2)
         assert task.is_running()
@@ -44,7 +44,7 @@ def test_normal_operation(self, mocker):
         unique_keys_tracker.track("key2", "split1")
 
         clear_filter_sync = ClearFilterSynchronizer(unique_keys_tracker)
-        task = ClearFilterSyncTask(clear_filter_sync.clearAll, 1)
+        task = ClearFilterSyncTask(clear_filter_sync.clear_all, 1)
         task.start()
         time.sleep(2)
         assert task.is_running()