Ver código fonte

Python2.6 does not support pkg/__main__.py

Ask Solem 11 anos atrás
pai
commit
312f6cbc0d
2 arquivos alterados com 6 adições e 1 exclusões
  1. 2 0
      celery/bin/celery.py
  2. 4 1
      celery/bin/celeryd_detach.py

+ 2 - 0
celery/bin/celery.py

@@ -780,4 +780,6 @@ def command(*args, **kwargs):
 
 
 if __name__ == '__main__':          # pragma: no cover
+    from celery.platforms import maybe_patch_concurrency
+    maybe_patch_concurrency(sys.argv, ['-P'], ['--pool'])
     main()

+ 4 - 1
celery/bin/celeryd_detach.py

@@ -109,7 +109,10 @@ class detached_celeryd(object):
                    'for the list of supported worker arguments.')
     command = sys.executable
     execv_path = sys.executable
-    execv_argv = ['-m', 'celery', 'worker']
+    if sys.version_info < (2, 7):  # does not support pkg/__main__.py
+        execv_argv = ['-m', 'celery.bin.celery', 'worker']
+    else:
+        execv_argv = ['-m', 'celery', 'worker']
 
     def Parser(self, prog_name):
         return PartialOptionParser(prog=prog_name,