Browse Source

celeryd: Use multiprocesing.freeze_support()

Ask Solem 14 years ago
parent
commit
c863769ee2
2 changed files with 3 additions and 0 deletions
  1. 2 0
      bin/celeryd
  2. 1 0
      celery/bin/celeryd.py

+ 2 - 0
bin/celeryd

@@ -26,4 +26,6 @@ def main():
     celeryd.run_worker(**vars(options))
 
 if __name__ == "__main__":
+    import multiprocessing
+    multiprocessing.freeze_support()
     main()

+ 1 - 0
celery/bin/celeryd.py

@@ -420,6 +420,7 @@ def run_worker(**options):
 
 
 def main():
+    multiprocessing.freeze_support()
     options = parse_options(sys.argv[1:])
     return run_worker(**vars(options))