|
@@ -116,10 +116,6 @@ The :program:`celery worker` command (previously known as ``celeryd``)
|
|
|
from __future__ import absolute_import
|
|
|
|
|
|
import sys
|
|
|
-from celery.platforms import maybe_patch_concurrency
|
|
|
-maybe_patch_concurrency(sys.argv, ['-P'], ['--pool'])
|
|
|
-
|
|
|
-from billiard import freeze_support
|
|
|
|
|
|
from celery import concurrency
|
|
|
from celery.bin.base import Command, Option
|
|
@@ -200,6 +196,7 @@ def main():
|
|
|
# (see multiprocessing.forking.get_preparation_data())
|
|
|
if __name__ != '__main__': # pragma: no cover
|
|
|
sys.modules['__main__'] = sys.modules[__name__]
|
|
|
+ from billiard import freeze_support
|
|
|
freeze_support()
|
|
|
worker = WorkerCommand()
|
|
|
worker.execute_from_commandline()
|