ref: thread timing (re #14)

Author: paulmueller

dcoraid/upload/job.py

@@ -37,7 +37,7 @@
 VALID_RESOURCE_REGEXP = r"^[a-zA-Z0-9\.,\-_\+\(\)\[\]]+$"
 
 
-class UploadJob(object):
+class UploadJob:
     def __init__(self, api, dataset_id, resource_paths,
                  resource_names=None, resource_supplements=None,
                  task_id=None, cache_dir=None):

dcoraid/worker/daemon.py

@@ -36,7 +36,7 @@ def run(self):
                         break
                 else:
                     # Nothing to do, sleep a little to avoid 100% CPU
-                    time.sleep(.1)
+                    time.sleep(.05)
                     continue
                 # Perform daemon task
                 task = getattr(job, self.job_function_name)

dcoraid/worker/kthread.py

@@ -61,4 +61,4 @@ def terminate(self):
         atexit.unregister(self.terminate)
         while self.is_alive():
             self.raise_exc(KThreadExit)
-            time.sleep(.05)
+            time.sleep(.1)

tests/test_gui.py

@@ -1,6 +1,7 @@
 import pathlib
 import shutil
 import tempfile
+import time
 from unittest import mock
 
 import uuid
@@ -38,6 +39,8 @@ def mw(qtbot):
     yield mw
     # Make sure that all daemons are gone
     mw.close()
+    # It is extremely weird, but this seems to be important to avoid segfaults!
+    time.sleep(1)
     QtTest.QTest.qWait(100)
     QtWidgets.QApplication.processEvents(QtCore.QEventLoop.AllEvents, 5000)
 
@@ -81,6 +84,7 @@ def test_gui_anonymous(qtbot):
         spath.unlink()
         shutil.copy2(stmp, spath)
     mw.close()
+    time.sleep(1)
     QtTest.QTest.qWait(500)
     QtWidgets.QApplication.processEvents(QtCore.QEventLoop.AllEvents, 500)