Преглед на файлове

joining of threads broke the tests

Ask Solem преди 15 години
родител
ревизия
f2911e4a5d
променени са 1 файла, в които са добавени 2 реда и са изтрити 1 реда
  1. 2 1
      celery/worker/heartbeat.py

+ 2 - 1
celery/worker/heartbeat.py

@@ -58,4 +58,5 @@ class Heart(threading.Thread):
         self._state = "CLOSE"
         self._shutdown.set()
         self._stopped.wait() # block until this thread is done
-        self.join(1e100)
+        if self.isAlive():
+            self.join(1e100)