decoupled tasks and util modules

splitio/client/__init__.py

@@ -2,10 +2,10 @@
 from harness_commons.engine.impressions.strategies import StrategyNoneMode, StrategyDebugMode, StrategyOptimizedMode
 from harness_commons.engine.impressions.adapters import InMemorySenderAdapter, RedisSenderAdapter, PluggableSenderAdapter, RedisSenderAdapterAsync, \
     InMemorySenderAdapterAsync, PluggableSenderAdapterAsync
-from splitio.tasks.unique_keys_sync import UniqueKeysSyncTask, ClearFilterSyncTask, UniqueKeysSyncTaskAsync, ClearFilterSyncTaskAsync
+from harness_commons.tasks.unique_keys_sync import UniqueKeysSyncTask, ClearFilterSyncTask, UniqueKeysSyncTaskAsync, ClearFilterSyncTaskAsync
 from harness_commons.sync.unique_keys import UniqueKeysSynchronizer, ClearFilterSynchronizer, UniqueKeysSynchronizerAsync, ClearFilterSynchronizerAsync
 from harness_commons.sync.impression import ImpressionsCountSynchronizer, ImpressionsCountSynchronizerAsync
-from splitio.tasks.impressions_sync import ImpressionsCountSyncTask, ImpressionsCountSyncTaskAsync
+from harness_commons.tasks.impressions_sync import ImpressionsCountSyncTask, ImpressionsCountSyncTaskAsync
 
 def set_classes(storage_mode, impressions_mode, api_adapter, imp_counter, unique_keys_tracker, prefix=None):
     """
@@ -27,10 +27,10 @@ def set_classes(storage_mode, impressions_mode, api_adapter, imp_counter, unique
     :return: tuple of classes instances.
     :rtype: (harness_commons.sync.unique_keys.UniqueKeysSynchronizer,
             harness_commons.sync.unique_keys.ClearFilterSynchronizer,
-            splitio.tasks.unique_keys_sync.UniqueKeysTask,
-            splitio.tasks.unique_keys_sync.ClearFilterTask,
+            harness_commons.tasks.unique_keys_sync.UniqueKeysTask,
+            harness_commons.tasks.unique_keys_sync.ClearFilterTask,
             harness_commons.sync.impressions_sync.ImpressionsCountSynchronizer,
-            splitio.tasks.impressions_sync.ImpressionsCountSyncTask,
+            harness_commons.tasks.impressions_sync.ImpressionsCountSyncTask,
             splitio.engine.impressions.strategies.StrategyNoneMode/splitio.engine.impressions.strategies.StrategyDebugMode/splitio.engine.impressions.strategies.StrategyOptimizedMode)
     """
     unique_keys_synchronizer = None
@@ -92,10 +92,10 @@ def set_classes_async(storage_mode, impressions_mode, api_adapter, imp_counter,
     :return: tuple of classes instances.
     :rtype: (harness_commons.sync.unique_keys.UniqueKeysSynchronizerAsync,
             harness_commons.sync.unique_keys.ClearFilterSynchronizerAsync,
-            splitio.tasks.unique_keys_sync.UniqueKeysTaskAsync,
-            splitio.tasks.unique_keys_sync.ClearFilterTaskAsync,
+            harness_commons.tasks.unique_keys_sync.UniqueKeysTaskAsync,
+            harness_commons.tasks.unique_keys_sync.ClearFilterTaskAsync,
             harness_commons.sync.impressions_sync.ImpressionsCountSynchronizerAsync,
-            splitio.tasks.impressions_sync.ImpressionsCountSyncTaskAsync,
+            harness_commons.tasks.impressions_sync.ImpressionsCountSyncTaskAsync,
             splitio.engine.impressions.strategies.StrategyNoneMode/splitio.engine.impressions.strategies.StrategyDebugMode/splitio.engine.impressions.strategies.StrategyOptimizedMode)
     """
     unique_keys_synchronizer = None

splitio/client/client.py

@@ -12,7 +12,7 @@
 from harness_commons.models.events import Event, EventWrapper, SdkEvent
 from harness_commons.models.telemetry import get_latency_bucket_index, MethodExceptionsAndLatencies
 from splitio.optional.loaders import asyncio
-from splitio.util.time import get_current_epoch_time_ms, utctime_ms
+from harness_commons.util.time import get_current_epoch_time_ms, utctime_ms
 
 
 _LOGGER = logging.getLogger(__name__)

splitio/client/factory.py

@@ -59,15 +59,15 @@
 from harness_commons.api.events import EventsAPI, EventsAPIAsync
 from harness_commons.api.auth import AuthAPI, AuthAPIAsync
 from harness_commons.api.telemetry import TelemetryAPI, TelemetryAPIAsync
-from splitio.util.time import get_current_epoch_time_ms
+from harness_commons.util.time import get_current_epoch_time_ms
 from splitio.spec import SPEC_VERSION
 
 # Tasks
 from splitio.tasks.split_sync import SplitSynchronizationTask, SplitSynchronizationTaskAsync
-from splitio.tasks.segment_sync import SegmentSynchronizationTask, SegmentSynchronizationTaskAsync
-from splitio.tasks.impressions_sync import ImpressionsSyncTask, ImpressionsCountSyncTask,\
+from harness_commons.tasks.segment_sync import SegmentSynchronizationTask, SegmentSynchronizationTaskAsync
+from harness_commons.tasks.impressions_sync import ImpressionsSyncTask, ImpressionsCountSyncTask,\
     ImpressionsCountSyncTaskAsync, ImpressionsSyncTaskAsync
-from splitio.tasks.events_sync import EventsSyncTask, EventsSyncTaskAsync
+from harness_commons.tasks.events_sync import EventsSyncTask, EventsSyncTaskAsync
 from harness_commons.tasks.telemetry_sync import TelemetrySyncTask, TelemetrySyncTaskAsync
 
 # Synchronizer