Ver Fonte

Use freeze_support from billiard

Ask Solem há 13 anos atrás
pai
commit
291d39bc46
1 ficheiros alterados com 5 adições e 2 exclusões
  1. 5 2
      celery/bin/celeryd.py

+ 5 - 2
celery/bin/celeryd.py

@@ -76,9 +76,12 @@ from __future__ import absolute_import
 import sys
 
 try:
-    from celery.concurrency.processes.forking import freeze_support
+    import multiprocessing  # noqa
 except ImportError:  # pragma: no cover
-    freeze_support = lambda: True  # noqa
+    freeze_support = lambda: True
+else:
+    # patch with freeze_support from billiard
+    from billiard import freeze_support  # noqa
 
 from celery.bin.base import Command, Option