assert that the worker is still alive until stopped

Author: mredolatti

tests/push/test_segment_worker.py

@@ -35,6 +35,13 @@ def handler_sync(change_number):
         with pytest.raises(Exception):
             segment_worker._handler()
 
+        assert segment_worker.is_running()
+        assert segment_worker._worker.is_alive()
+        segment_worker.stop()
+        time.sleep(1)
+        assert not segment_worker.is_running()
+        assert not segment_worker._worker.is_alive()
+
     def test_handler(self):
         q = queue.Queue()
         segment_worker = SegmentWorker(handler_sync, q)

tests/push/test_split_worker.py

@@ -32,6 +32,13 @@ def handler_sync(change_number):
         with pytest.raises(Exception):
             split_worker._handler()
 
+        assert split_worker.is_running()
+        assert split_worker._worker.is_alive()
+        split_worker.stop()
+        time.sleep(1)
+        assert not split_worker.is_running()
+        assert not split_worker._worker.is_alive()
+
     def test_handler(self):
         q = queue.Queue()
         split_worker = SplitWorker(handler_sync, q)