Autogenerated documentation for github.

celery/conf.py

@@ -142,11 +142,12 @@ AMQP_CONSUMER_QUEUE = getattr(settings, "CELERY_AMQP_CONSUMER_QUEUE",
 """
 AMQP_CONNECTION_TIMEOUT = getattr(settings, "CELERY_AMQP_CONNECTION_TIMEOUT",
                                   DEFAULT_AMQP_CONNECTION_TIMEOUT)
+
 """
 .. data:: SEND_CELERY_TASK_ERROR_EMAILS
 
     If set to ``True``, errors in tasks will be sent to admins by e-mail.
-    If unset, it will send the e-mails if DEBUG is False.
+    If unset, it will send the e-mails if ``settings.DEBUG`` is False.
 
 """
 SEND_CELERY_TASK_ERROR_EMAILS = getattr(settings,
@@ -155,6 +156,7 @@ SEND_CELERY_TASK_ERROR_EMAILS = getattr(settings,
 
 """
 .. data:: STATISTICS_COLLECT_INTERVAL
+
     The interval in seconds of which the
     :class:`celery.task.CollectStatisticsTask`` is run.
 

celery/monitoring.py

@@ -163,7 +163,7 @@ class StatsCollector(object):
 
     def collect(self):
         """Collect any new statistics available since the last time
-        :methd:`collect` was executed."""
+        :method:`collect` was executed."""
         connection = DjangoAMQPConnection()
         consumer = StatsConsumer(connection=connection)
         it = consumer.iterqueue(infinite=False)

celery/pool.py

@@ -17,7 +17,6 @@ class TaskPool(object):
     processes to finish when the queue limit has been reached.
 
     :param limit: see :attr:`limit` attribute.
-
     :param logger: see :attr:`logger` attribute.
 
 
@@ -44,8 +43,7 @@ class TaskPool(object):
     def run(self):
         """Run the task pool.
 
-        Will launch all worker processes so they are ready
-        for processing tasks.
+        Will pre-fork all workers so they're ready to accept tasks.
 
         """
         self._start()