Explorar o código

celery.bin main functions now supports app argument

Ask Solem %!s(int64=11) %!d(string=hai) anos
pai
achega
460a5bd16a
Modificáronse 3 ficheiros con 6 adicións e 6 borrados
  1. 2 2
      celery/bin/beat.py
  2. 2 2
      celery/bin/celeryd_detach.py
  3. 2 2
      celery/bin/worker.py

+ 2 - 2
celery/bin/beat.py

@@ -91,8 +91,8 @@ class beat(Command):
         )
 
 
-def main():
-    beat().execute_from_commandline()
+def main(app=None):
+    beat(app=app).execute_from_commandline()
 
 if __name__ == '__main__':      # pragma: no cover
     main()

+ 2 - 2
celery/bin/celeryd_detach.py

@@ -151,8 +151,8 @@ class detached_celeryd(object):
                  **vars(options)))
 
 
-def main():
-    detached_celeryd().execute_from_commandline()
+def main(app=None):
+    detached_celeryd(app).execute_from_commandline()
 
 if __name__ == '__main__':  # pragma: no cover
     main()

+ 2 - 2
celery/bin/worker.py

@@ -222,7 +222,7 @@ class worker(Command):
         ) + daemon_options() + tuple(self.app.user_options['worker'])
 
 
-def main():
+def main(app=None):
     # Fix for setuptools generated scripts, so that it will
     # work with multiprocessing fork emulation.
     # (see multiprocessing.forking.get_preparation_data())
@@ -230,7 +230,7 @@ def main():
         sys.modules['__main__'] = sys.modules[__name__]
     from billiard import freeze_support
     freeze_support()
-    worker().execute_from_commandline()
+    worker(app=app).execute_from_commandline()
 
 
 if __name__ == '__main__':          # pragma: no cover