polish

Author: Bilal Al

splitio/models/telemetry.py

@@ -255,9 +255,10 @@ class MethodLatenciesAsync(MethodLatenciesBase):
     Method async Latency class
 
     """
-    async def create():
+    @classmethod
+    async def create(cls):
         """Constructor"""
-        self = MethodLatenciesAsync()
+        self = cls()
         self._lock = asyncio.Lock()
         async with self._lock:
             self._reset_all()
@@ -406,9 +407,10 @@ class HTTPLatenciesAsync(HTTPLatenciesBase):
     HTTP Latency async class
 
     """
-    async def create():
+    @classmethod
+    async def create(cls):
         """Constructor"""
-        self = HTTPLatenciesAsync()
+        self = cls()
         self._lock = asyncio.Lock()
         async with self._lock:
             self._reset_all()
@@ -557,9 +559,10 @@ class MethodExceptionsAsync(MethodExceptionsBase):
     Method async exceptions class
 
     """
-    async def create():
+    @classmethod
+    async def create(cls):
         """Constructor"""
-        self = MethodExceptionsAsync()
+        self = cls()
         self._lock = asyncio.Lock()
         async with self._lock:
             self._reset_all()
@@ -707,9 +710,10 @@ class LastSynchronizationAsync(LastSynchronizationBase):
     Last Synchronization async info class
 
     """
-    async def create():
+    @classmethod
+    async def create(cls):
         """Constructor"""
-        self = LastSynchronizationAsync()
+        self = cls()
         self._lock = asyncio.Lock()
         async with self._lock:
             self._reset_all()
@@ -869,9 +873,10 @@ class HTTPErrorsAsync(HTTPErrorsBase):
     Http error async class
 
     """
-    async def create():
+    @classmethod
+    async def create(cls):
         """Constructor"""
-        self = HTTPErrorsAsync()
+        self = cls()
         self._lock = asyncio.Lock()
         async with self._lock:
             self._reset_all()
@@ -1177,9 +1182,10 @@ class TelemetryCountersAsync(TelemetryCountersBase):
     Counters async class
 
     """
-    async def create():
+    @classmethod
+    async def create(cls):
         """Constructor"""
-        self = TelemetryCountersAsync()
+        self = cls()
         self._lock = asyncio.Lock()
         async with self._lock:
             self._reset_all()
@@ -1385,9 +1391,10 @@ class StreamingEventsAsync(object):
     Streaming events async class
 
     """
-    async def create():
+    @classmethod
+    async def create(cls):
         """Constructor"""
-        self = StreamingEventsAsync()
+        self = cls()
         self._lock = asyncio.Lock()
         async with self._lock:
             self._streaming_events = []
@@ -1803,9 +1810,10 @@ class TelemetryConfigAsync(TelemetryConfigBase):
     Telemetry init config async class
 
     """
-    async def create():
+    @classmethod
+    async def create(cls):
         """Constructor"""
-        self = TelemetryConfigAsync()
+        self = cls()
         self._lock = asyncio.Lock()
         async with self._lock:
             self._reset_all()

splitio/optional/loaders.py

@@ -18,6 +18,4 @@ async def _anext(it):
     return await it.__anext__()
 
 if sys.version_info.major < 3 or sys.version_info.minor < 10:
-    anext = _anext
-else:
-    anext = anext
+    anext = _anext

splitio/storage/inmemmory.py

@@ -1672,9 +1672,10 @@ def pop_update_from_sse(self, event):
 class InMemoryTelemetryStorageAsync(InMemoryTelemetryStorageBase):
     """In-memory telemetry async storage."""
 
-    async def create():
+    @classmethod
+    async def create(cls):
         """Constructor"""
-        self = InMemoryTelemetryStorageAsync()
+        self = cls()
         self._lock = asyncio.Lock()
         self._method_exceptions = await MethodExceptionsAsync.create()
         self._last_synchronization = await LastSynchronizationAsync.create()

splitio/storage/pluggable.py

@@ -1539,7 +1539,8 @@ def record_ready_time(self, ready_time):
 class PluggableTelemetryStorageAsync(PluggableTelemetryStorageBase):
     """Pluggable telemetry storage class."""
 
-    async def create(pluggable_adapter, sdk_metadata, prefix=None):
+    @classmethod
+    async def create(cls, pluggable_adapter, sdk_metadata, prefix=None):
         """
         Class constructor.
 
@@ -1550,7 +1551,7 @@ async def create(pluggable_adapter, sdk_metadata, prefix=None):
         :param prefix: optional, prefix to storage keys
         :type prefix: str
         """
-        self = PluggableTelemetryStorageAsync()
+        self = cls()
         self._pluggable_adapter = pluggable_adapter
         self._sdk_metadata = sdk_metadata.sdk_version + '/' + sdk_metadata.instance_name + '/' + sdk_metadata.instance_ip
         self._telemetry_config_key = 'SPLITIO.telemetry.init'

splitio/storage/redis.py

@@ -1367,7 +1367,8 @@ def record_ready_time(self, ready_time):
 class RedisTelemetryStorageAsync(RedisTelemetryStorageBase):
     """Redis based telemetry async storage class."""
 
-    async def create(redis_client, sdk_metadata):
+    @classmethod
+    async def create(cls, redis_client, sdk_metadata):
         """
         Create instance and reset tags
 
@@ -1379,7 +1380,7 @@ async def create(redis_client, sdk_metadata):
         :return: self instance.
         :rtype: splitio.storage.redis.RedisTelemetryStorageAsync
         """
-        self = RedisTelemetryStorageAsync()
+        self = cls()
         await self._reset_config_tags()
         self._redis_client = redis_client
         self._sdk_metadata = sdk_metadata