Fix AsyncioTelemetryManager to avoid creating a task every second

.pubnub.yml

@@ -1,5 +1,5 @@
 name: python
-version: 7.4.0
+version: 7.4.1
 schema: 1
 scm: github.com/pubnub/python
 sdks:
@@ -18,7 +18,7 @@ sdks:
         distributions:
           - distribution-type: library
             distribution-repository: package
-            package-name: pubnub-7.4.0
+            package-name: pubnub-7.4.1
             location: https://pypi.org/project/pubnub/
             supported-platforms:
               supported-operating-systems:
@@ -97,8 +97,8 @@ sdks:
           -
             distribution-type: library
             distribution-repository: git release
-            package-name: pubnub-7.4.0
-            location: https://github.com/pubnub/python/releases/download/v7.4.0/pubnub-7.4.0.tar.gz
+            package-name: pubnub-7.4.1
+            location: https://github.com/pubnub/python/releases/download/v7.4.1/pubnub-7.4.1.tar.gz
             supported-platforms:
               supported-operating-systems:
                 Linux:
@@ -169,6 +169,11 @@ sdks:
                 license-url: https://github.com/aio-libs/aiohttp/blob/master/LICENSE.txt
                 is-required: Required
 changelog:
+  - date: 2024-02-26
+    version: v7.4.1
+    changes:
+      - type: bug
+        text: "Fixes AsyncioTelemetryManager to avoid creating a task every second."
   - date: 2024-02-08
     version: v7.4.0
     changes:

CHANGELOG.md

@@ -1,3 +1,9 @@
+## v7.4.1
+February 26 2024
+
+#### Fixed
+- Fixes AsyncioTelemetryManager to avoid creating a task every second.
+
 ## v7.4.0
 February 08 2024
 

pubnub/pubnub_asyncio.py

@@ -794,14 +794,18 @@ async def wait_for_presence_on(self, *channel_names):
 class AsyncioTelemetryManager(TelemetryManager):
     def __init__(self):
         TelemetryManager.__init__(self)
-        self._timer = AsyncioPeriodicCallback(
-            self._start_clean_up_timer,
-            self.CLEAN_UP_INTERVAL * self.CLEAN_UP_INTERVAL_MULTIPLIER,
-            asyncio.get_event_loop())
-        self._timer.start()
+        self.loop = asyncio.get_event_loop()
+        self._schedule_next_cleanup()
 
-    async def _start_clean_up_timer(self):
+    def _schedule_next_cleanup(self):
+        self._timer = self.loop.call_later(
+            self.CLEAN_UP_INTERVAL * self.CLEAN_UP_INTERVAL_MULTIPLIER / 1000,
+            self._clean_up_schedule_next
+        )
+
+    def _clean_up_schedule_next(self):
         self.clean_up_telemetry_data()
+        self._schedule_next_cleanup()
 
     def _stop_clean_up_timer(self):
-        self._timer.stop()
+        self._timer.cancel()

pubnub/pubnub_core.py

@@ -85,7 +85,7 @@
 
 class PubNubCore:
     """A base class for PubNub Python API implementations"""
-    SDK_VERSION = "7.4.0"
+    SDK_VERSION = "7.4.1"
     SDK_NAME = "PubNub-Python"
 
     TIMESTAMP_DIVIDER = 1000

setup.py

@@ -2,7 +2,7 @@
 
 setup(
     name='pubnub',
-    version='7.4.0',
+    version='7.4.1',
     description='PubNub Real-time push service in the cloud',
     author='PubNub',
     author_email='[email protected]',