fix deprecation of Event.isSet call (#138)

* Additional deprecation fixes

* PubNub SDK 7.0.1 release.

Co-authored-by: Client Engineering Bot <[email protected]>

Author: seba-aln

.pubnub.yml

@@ -1,5 +1,5 @@
 name: python
-version: 7.0.0
+version: 7.0.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.0.0
+            package-name: pubnub-7.0.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.0.0
-            location: https://github.com/pubnub/python/releases/download/7.0.0/pubnub-7.0.0.tar.gz
+            package-name: pubnub-7.0.1
+            location: https://github.com/pubnub/python/releases/download/7.0.1/pubnub-7.0.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: 2022-10-05
+    version: 7.0.1
+    changes:
+      - type: bug
+        text: "Remove deprecation warning of Event.is_set and Thread.deamon."
   - date: 2022-08-23
     version: 7.0.0
     changes:

CHANGELOG.md

@@ -1,3 +1,9 @@
+## 7.0.1
+October 05 2022
+
+#### Fixed
+- Remove deprecation warning of Event.is_set and Thread.deamon.
+
 ## 7.0.0
 August 23 2022
 

pubnub/pubnub.py

@@ -102,7 +102,7 @@ def _register_heartbeat_timer(self):
         self._recalculate_interval()
 
         self._timer = threading.Timer(self._timer_interval, self._call_time)
-        self._timer.setDaemon(True)
+        self._timer.daemon = True
         self._timer.start()
 
     def _call_time(self):
@@ -265,7 +265,7 @@ def _start_worker(self):
             target=consumer.run,
             name="SubscribeMessageWorker"
         )
-        self._consumer_thread.setDaemon(True)
+        self._consumer_thread.daemon = True
         self._consumer_thread.start()
 
     def _start_subscribe_loop(self):
@@ -349,13 +349,13 @@ def _run(self):
 
     def _schedule_next(self):
         self._timeout = threading.Timer(self._callback_time, self._run)
-        self._timeout.setDaemon(True)
+        self._timer.daemon = True
         self._timeout.start()
 
 
 class NativeSubscribeMessageWorker(SubscribeMessageWorker):
     def _take_message(self):
-        while not self._event.isSet():
+        while not self._event.is_set():
             try:
                 # TODO: get rid of 1s timeout
                 msg = self._queue.get(True, 1)

pubnub/pubnub_core.py

@@ -83,7 +83,7 @@
 
 class PubNubCore:
     """A base class for PubNub Python API implementations"""
-    SDK_VERSION = "7.0.0"
+    SDK_VERSION = "7.0.1"
     SDK_NAME = "PubNub-Python"
 
     TIMESTAMP_DIVIDER = 1000

pubnub/request_handlers/requests_handler.py

@@ -51,7 +51,7 @@ def async_request(self, endpoint_name, platform_options, endpoint_call_options,
         def callback_to_invoke_in_separate_thread():
             try:
                 envelope = self._build_envelope(platform_options, endpoint_call_options)
-                if cancellation_event is not None and cancellation_event.isSet():
+                if cancellation_event is not None and cancellation_event.is_set():
                     # Since there are no way to affect on ongoing request it's response will
                     # be just ignored on cancel call
                     return
@@ -94,7 +94,7 @@ def execute_callback_in_separate_thread(
             target=client.run,
             name="Thread-%s-%d" % (operation_name, ++RequestsRequestHandler.ENDPOINT_THREAD_COUNTER)
         )
-        thread.setDaemon(self.pubnub.config.daemon)
+        thread.daemon = self.pubnub.config.daemon
         thread.start()
 
         call_obj.thread = thread

setup.py

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