Pārlūkot izejas kodu

Adds App.WorkController for embedded workers

Ask Solem 13 gadi atpakaļ
vecāks
revīzija
d7d3ead49e
1 mainītis faili ar 3 papildinājumiem un 0 dzēšanām
  1. 3 0
      celery/app/__init__.py

+ 3 - 0
celery/app/__init__.py

@@ -117,6 +117,9 @@ class App(base.BaseApp):
         """Create new :class:`~celery.apps.worker.Worker` instance."""
         return instantiate("celery.apps.worker.Worker", app=self, **kwargs)
 
+    def WorkController(self, **kwargs):
+        return instantiate("celery.worker.WorkController", app=self, **kwargs)
+
     def Beat(self, **kwargs):
         """Create new :class:`~celery.apps.beat.Beat` instance."""
         return instantiate("celery.apps.beat.Beat", app=self, **kwargs)