removed deprecated setDaemon method

Author: chillaq

splitio/client/factory.py

@@ -136,7 +136,7 @@ def _start_status_updater(self):
             # add a listener that updates the status to READY once the flag is set.
             ready_updater = threading.Thread(target=self._update_status_when_ready,
                                              name='SDKReadyFlagUpdater')
-            ready_updater.setDaemon(True)
+            ready_updater.daemon = True
             ready_updater.start()
         else:
             self._status = Status.READY
@@ -226,7 +226,7 @@ def _wait_for_tasks_to_stop():
                         destroyed_event.set()
 
                     wait_thread = threading.Thread(target=_wait_for_tasks_to_stop)
-                    wait_thread.setDaemon(True)
+                    wait_thread.daemon = True
                     wait_thread.start()
                 else:
                     self._sync_manager.stop(False)
@@ -273,7 +273,7 @@ def resume(self):
             target=self._sync_manager.start,
             name="SDKInitializer",
         )
-        initialization_thread.setDaemon(True)
+        initialization_thread.daemon = True
         initialization_thread.start()
         self._preforked_initialization = False  # reset for status updater
         self._start_status_updater()
@@ -386,7 +386,7 @@ def _build_in_memory_factory(api_key, cfg, sdk_url=None, events_url=None,  # pyl
                             recorder, manager, preforked_initialization=preforked_initialization)
 
     initialization_thread = threading.Thread(target=manager.start, name="SDKInitializer")
-    initialization_thread.setDaemon(True)
+    initialization_thread.daemon = True
     initialization_thread.start()
 
     return SplitFactory(api_key, storages, cfg['labelsEnabled'],
@@ -441,7 +441,7 @@ def _build_redis_factory(api_key, cfg):
 
     manager = RedisManager(synchronizer)
     initialization_thread = threading.Thread(target=manager.start, name="SDKInitializer")
-    initialization_thread.setDaemon(True)
+    initialization_thread.daemon = True
     initialization_thread.start()
 
     return SplitFactory(

splitio/push/segmentworker.py

@@ -55,7 +55,7 @@ def start(self):
 
         _LOGGER.debug('Starting Segment Worker')
         self._worker = threading.Thread(target=self._run, name='PushSegmentWorker')
-        self._worker.setDaemon(True)
+        self._worker.daemon = True
         self._worker.start()
 
     def stop(self):

splitio/push/splitsse.py

@@ -135,7 +135,7 @@ def connect(url):
 
         url = self._build_url(token)
         task = threading.Thread(target=connect, name='SSEConnection', args=(url,))
-        task.setDaemon(True)
+        task.daemon = True
         task.start()
         event_group.wait()
         return self._status == SplitSSEClient._Status.CONNECTED

splitio/push/splitworker.py

@@ -54,7 +54,7 @@ def start(self):
 
         _LOGGER.debug('Starting Split Worker')
         self._worker = threading.Thread(target=self._run, name='PushSplitWorker')
-        self._worker.setDaemon(True)
+        self._worker.daemon = True
         self._worker.start()
 
     def stop(self):

splitio/sync/manager.py

@@ -52,7 +52,7 @@ def __init__(self, ready_flag, synchronizer, auth_api, streaming_enabled, sdk_me
             self._push = PushManager(auth_api, synchronizer, self._queue, sdk_metadata, sse_url, client_key)
             self._push_status_handler = Thread(target=self._streaming_feedback_handler,
                                                name='PushStatusHandler')
-            self._push_status_handler.setDaemon(True)
+            self._push_status_handler.daemon = True
 
     def recreate(self):
         """Recreate poolers for forked processes."""

splitio/tasks/util/asynctask.py

@@ -129,7 +129,7 @@ def start(self):
         # Start execution
         self._thread = threading.Thread(target=self._execution_wrapper,
                                         name='AsyncTask::' + getattr(self._main, '__name__', 'N/S'))
-        self._thread.setDaemon(True)
+        self._thread.daemon = True
         try:
             self._thread.start()
 

splitio/tasks/util/workerpool.py

@@ -27,7 +27,7 @@ def __init__(self, worker_count, worker_func):
             for i in range(0, worker_count)
         ]
         for thread in self._threads:
-            thread.setDaemon(True)
+            thread.daemon = True
 
     def start(self):
         """Start the workers."""
@@ -117,7 +117,7 @@ def wait_for_completion(self):
     def stop(self, event=None):
         """Stop all worker nodes."""
         async_stop = Thread(target=self._wait_workers_shutdown, args=(event,))
-        async_stop.setDaemon(True)
+        async_stop.daemon = True
         async_stop.start()
 
     def _wait_workers_shutdown(self, event):

tests/helpers/mockserver.py

@@ -24,7 +24,7 @@ def __init__(self, req_queue=None):
         self._server = HTTPServer(('localhost', 0),
                                   lambda *xs: SSEHandler(self._queue, *xs, req_queue=req_queue))
         self._server_thread = threading.Thread(target=self._blocking_run)
-        self._server_thread.setDaemon(True)
+        self._server_thread.daemon = True
         self._done_event = threading.Event()
 
     def _blocking_run(self):
@@ -117,7 +117,7 @@ def __init__(self, split_changes=None, segment_changes=None, req_queue=None,
                                                          req_queue=req_queue,
                                                          auth_response=auth_response))
         self._server_thread = threading.Thread(target=self._blocking_run, name="SplitMockServer")
-        self._server_thread.setDaemon(True)
+        self._server_thread.daemon = True
         self._done_event = threading.Event()
 
     def _blocking_run(self):

tests/push/test_manager.py

@@ -39,7 +39,7 @@ def test_connection_success(self, mocker):
         def new_start(*args, **kwargs):  # pylint: disable=unused-argument
             """splitsse.start mock."""
             thread = Thread(target=manager._handle_connection_ready)
-            thread.setDaemon(True)
+            thread.daemon = True
             thread.start()
             return True
 
@@ -72,7 +72,7 @@ def test_connection_failure(self, mocker):
         def new_start(*args, **kwargs):  # pylint: disable=unused-argument
             """splitsse.start mock."""
             thread = Thread(target=manager._handle_connection_end)
-            thread.setDaemon(True)
+            thread.daemon = True
             thread.start()
             return False
 

tests/push/test_sse.py

@@ -26,7 +26,7 @@ def runner():
             """SSE client runner thread."""
             assert client.start('http://127.0.0.1:' + str(server.port()))
         client_task = threading.Thread(target=runner)
-        client_task.setDaemon(True)
+        client_task.daemon = True
         client_task.setName('client')
         client_task.start()
         with pytest.raises(RuntimeError):
@@ -67,7 +67,7 @@ def runner():
             """SSE client runner thread."""
             assert client.start('http://127.0.0.1:' + str(server.port()))
         client_task = threading.Thread(target=runner)
-        client_task.setDaemon(True)
+        client_task.daemon = True
         client_task.setName('client')
         client_task.start()
 
@@ -93,7 +93,7 @@ def test_sse_server_disconnects_abruptly(self):
         """Test correct initialization. Server ends connection."""
         server = SSEMockServer()
         server.start()
- 
+
         events = []
         def callback(event):
             """Callback."""
@@ -105,7 +105,7 @@ def runner():
             """SSE client runner thread."""
             assert client.start('http://127.0.0.1:' + str(server.port()))
         client_task = threading.Thread(target=runner)
-        client_task.setDaemon(True)
+        client_task.daemon = True
         client_task.setName('client')
         client_task.start()