Autogenerated documentation for github.

genindex.html

@@ -43,7 +43,7 @@
 
    <h1 id="index">Index</h1>
 
-   <a href="#Symbols"><strong>Symbols</strong></a> | <a href="#A"><strong>A</strong></a> | <a href="#B"><strong>B</strong></a> | <a href="#C"><strong>C</strong></a> | <a href="#D"><strong>D</strong></a> | <a href="#E"><strong>E</strong></a> | <a href="#F"><strong>F</strong></a> | <a href="#G"><strong>G</strong></a> | <a href="#I"><strong>I</strong></a> | <a href="#J"><strong>J</strong></a> | <a href="#L"><strong>L</strong></a> | <a href="#M"><strong>M</strong></a> | <a href="#N"><strong>N</strong></a> | <a href="#P"><strong>P</strong></a> | <a href="#Q"><strong>Q</strong></a> | <a href="#R"><strong>R</strong></a> | <a href="#S"><strong>S</strong></a> | <a href="#T"><strong>T</strong></a> | <a href="#U"><strong>U</strong></a> | <a href="#W"><strong>W</strong></a> 
+   <a href="#Symbols"><strong>Symbols</strong></a> | <a href="#A"><strong>A</strong></a> | <a href="#B"><strong>B</strong></a> | <a href="#C"><strong>C</strong></a> | <a href="#D"><strong>D</strong></a> | <a href="#E"><strong>E</strong></a> | <a href="#F"><strong>F</strong></a> | <a href="#G"><strong>G</strong></a> | <a href="#I"><strong>I</strong></a> | <a href="#J"><strong>J</strong></a> | <a href="#K"><strong>K</strong></a> | <a href="#L"><strong>L</strong></a> | <a href="#M"><strong>M</strong></a> | <a href="#N"><strong>N</strong></a> | <a href="#P"><strong>P</strong></a> | <a href="#Q"><strong>Q</strong></a> | <a href="#R"><strong>R</strong></a> | <a href="#S"><strong>S</strong></a> | <a href="#T"><strong>T</strong></a> | <a href="#U"><strong>U</strong></a> | <a href="#W"><strong>W</strong></a> 
 
    <hr />
 
@@ -85,9 +85,10 @@
 <dt><a href="reference/celery.datastructures.html#celery.datastructures.TaskProcessQueue.add">add() (celery.datastructures.TaskProcessQueue method)</a></dt>
 <dt><a href="reference/celery.registry.html#celery.registry.AlreadyRegistered">AlreadyRegistered</a></dt>
 <dt><a href="reference/celery.conf.html#celery.conf.AMQP_CONSUMER_QUEUE">AMQP_CONSUMER_QUEUE (in module celery.conf)</a></dt>
-<dt><a href="reference/celery.conf.html#celery.conf.AMQP_EXCHANGE">AMQP_EXCHANGE (in module celery.conf)</a></dt>
-<dt><a href="reference/celery.conf.html#celery.conf.AMQP_ROUTING_KEY">AMQP_ROUTING_KEY (in module celery.conf)</a></dt>
-<dt><a href="reference/celery.task.html#celery.task.TaskSet.arguments">arguments (celery.task.TaskSet attribute)</a></dt></dl></td><td width="33%" valign="top"><dl>
+<dt><a href="reference/celery.conf.html#celery.conf.AMQP_EXCHANGE">AMQP_EXCHANGE (in module celery.conf)</a>, <a href="reference/celery.conf.html#celery.conf.AMQP_EXCHANGE">[1]</a></dt>
+<dt><a href="reference/celery.conf.html#celery.conf.AMQP_ROUTING_KEY">AMQP_ROUTING_KEY (in module celery.conf)</a>, <a href="reference/celery.conf.html#celery.conf.AMQP_ROUTING_KEY">[1]</a></dt>
+<dt><a href="reference/celery.worker.html#celery.worker.TaskWrapper.args">args (celery.worker.TaskWrapper attribute)</a></dt></dl></td><td width="33%" valign="top"><dl>
+<dt><a href="reference/celery.task.html#celery.task.TaskSet.arguments">arguments (celery.task.TaskSet attribute)</a></dt>
 <dt><a href="reference/celery.task.html#celery.task.AsynchronousMapTask">AsynchronousMapTask (class in celery.task)</a></dt>
 <dt><a href="reference/celery.result.html#celery.result.AsyncResult">AsyncResult (class in celery.result)</a></dt>
 <dt><a href="reference/celery.registry.html#celery.registry.TaskRegistry.autodiscover">autodiscover() (celery.registry.TaskRegistry method)</a></dt>
@@ -158,21 +159,22 @@
 <table width="100%" class="indextable"><tr><td width="33%" valign="top">
 <dl>
 
-<dt><a href="reference/celery.conf.html#celery.conf.DAEMON_CONCURRENCY">DAEMON_CONCURRENCY (in module celery.conf)</a></dt>
-<dt><a href="reference/celery.conf.html#celery.conf.DAEMON_LOG_FILE">DAEMON_LOG_FILE (in module celery.conf)</a></dt>
-<dt><a href="reference/celery.conf.html#celery.conf.DAEMON_LOG_LEVEL">DAEMON_LOG_LEVEL (in module celery.conf)</a></dt>
-<dt><a href="reference/celery.conf.html#celery.conf.DAEMON_PID_FILE">DAEMON_PID_FILE (in module celery.conf)</a></dt>
+<dt><a href="reference/celery.conf.html#celery.conf.DAEMON_CONCURRENCY">DAEMON_CONCURRENCY (in module celery.conf)</a>, <a href="reference/celery.conf.html#celery.conf.DAEMON_CONCURRENCY">[1]</a></dt>
+<dt><a href="reference/celery.conf.html#celery.conf.DAEMON_LOG_FILE">DAEMON_LOG_FILE (in module celery.conf)</a>, <a href="reference/celery.conf.html#celery.conf.DAEMON_LOG_FILE">[1]</a></dt>
+<dt><a href="reference/celery.conf.html#celery.conf.DAEMON_LOG_LEVEL">DAEMON_LOG_LEVEL (in module celery.conf)</a>, <a href="reference/celery.conf.html#celery.conf.DAEMON_LOG_LEVEL">[1]</a></dt>
+<dt><a href="reference/celery.conf.html#celery.conf.DAEMON_PID_FILE">DAEMON_PID_FILE (in module celery.conf)</a>, <a href="reference/celery.conf.html#celery.conf.DAEMON_PID_FILE">[1]</a></dt>
 <dt><a href="reference/celery.platform.html#celery.platform.daemonize">daemonize() (in module celery.platform)</a></dt>
 <dt><a href="reference/celery.models.html#TaskMeta.date_done">date_done (TaskMeta attribute)</a></dt>
+<dt><a href="reference/celery.conf.html#celery.conf.DEFAULT_DAEMON_LOG_FILE">DEFAULT_DAEMON_LOG_FILE (in module celery.conf)</a></dt>
 <dt><a href="reference/celery.backends.html#celery.backends.DefaultBackend">DefaultBackend (class in celery.backends)</a></dt>
 <dt><a href="reference/celery.task.html#celery.task.Task.delay">delay() (celery.task.Task class method)</a></dt>
   <dd><dl>
     <dt><a href="reference/celery.models.html#PeriodicTaskMeta.delay">(PeriodicTaskMeta method)</a></dt>
-  </dl></dd>
+  </dl></dd></dl></td><td width="33%" valign="top"><dl>
 <dt><a href="reference/celery.messaging.html#celery.messaging.TaskPublisher.delay_task">delay_task() (celery.messaging.TaskPublisher method)</a></dt>
   <dd><dl>
     <dt><a href="reference/celery.task.html#celery.task.delay_task">(in module celery.task)</a></dt>
-  </dl></dd></dl></td><td width="33%" valign="top"><dl>
+  </dl></dd>
 <dt><a href="reference/celery.messaging.html#celery.messaging.TaskPublisher.delay_task_in_set">delay_task_in_set() (celery.messaging.TaskPublisher method)</a></dt>
 <dt><a href="reference/celery.managers.html#celery.managers.TaskManager.delete_expired">delete_expired() (celery.managers.TaskManager method)</a></dt>
 <dt><a href="reference/celery.task.html#celery.task.DeleteExpiredTaskMetaTask">DeleteExpiredTaskMetaTask (class in celery.task)</a></dt>
@@ -188,7 +190,7 @@
 
 <dt><a href="reference/celery.log.html#celery.log.emergency_error">emergency_error() (in module celery.log)</a></dt>
 <dt><a href="reference/celery.worker.html#celery.worker.TaskDaemon.empty_msg_emit_every">empty_msg_emit_every (celery.worker.TaskDaemon attribute)</a></dt>
-<dt><a href="reference/celery.conf.html#celery.conf.EMPTY_MSG_EMIT_EVERY">EMPTY_MSG_EMIT_EVERY (in module celery.conf)</a></dt>
+<dt><a href="reference/celery.conf.html#celery.conf.EMPTY_MSG_EMIT_EVERY">EMPTY_MSG_EMIT_EVERY (in module celery.conf)</a>, <a href="reference/celery.conf.html#celery.conf.EMPTY_MSG_EMIT_EVERY">[1]</a></dt>
 <dt><a href="reference/celery.worker.html#celery.worker.EmptyQueue">EmptyQueue</a></dt>
 <dt><a href="reference/celery.timer.html#celery.timer.EventTimer.event">event (celery.timer.EventTimer attribute)</a></dt>
 <dt><a href="reference/celery.timer.html#celery.timer.EventTimer">EventTimer (class in celery.timer)</a></dt>
@@ -209,7 +211,7 @@
 <dt><a href="reference/celery.task.html#celery.task.execute_remote">execute_remote() (in module celery.task)</a></dt>
 <dt><a href="reference/celery.worker.html#celery.worker.TaskWrapper.execute_using_pool">execute_using_pool() (celery.worker.TaskWrapper method)</a></dt>
 <dt><a href="reference/celery.task.html#celery.task.ExecuteRemoteTask">ExecuteRemoteTask (class in celery.task)</a></dt>
-<dt><a href="reference/celery.worker.html#celery.worker.TaskWrapper.extend_kwargs_with_logging">extend_kwargs_with_logging() (celery.worker.TaskWrapper method)</a></dt>
+<dt><a href="reference/celery.worker.html#celery.worker.TaskWrapper.extend_with_default_kwargs">extend_with_default_kwargs() (celery.worker.TaskWrapper method)</a></dt>
 </dl></td></tr></table>
 
 <h2 id="F">F</h2>
@@ -285,15 +287,23 @@
 <dt><a href="reference/celery.task.html#celery.task.TaskSet.join">join() (celery.task.TaskSet method)</a></dt></dl></td><td width="33%" valign="top"><dl>
 </dl></td></tr></table>
 
+<h2 id="K">K</h2>
+<table width="100%" class="indextable"><tr><td width="33%" valign="top">
+<dl>
+
+<dt><a href="reference/celery.worker.html#celery.worker.TaskWrapper.kwargs">kwargs (celery.worker.TaskWrapper attribute)</a></dt></dl></td><td width="33%" valign="top"><dl>
+</dl></td></tr></table>
+
 <h2 id="L">L</h2>
 <table width="100%" class="indextable"><tr><td width="33%" valign="top">
 <dl>
 
 <dt><a href="reference/celery.models.html#PeriodicTaskMeta.last_run_at">last_run_at (PeriodicTaskMeta attribute)</a></dt>
 <dt><a href="reference/celery.timer.html#celery.timer.EventTimer.last_triggered">last_triggered (celery.timer.EventTimer attribute)</a></dt>
+<dt><a href="reference/celery.datastructures.html#celery.datastructures.PositionQueue.length">length (celery.datastructures.PositionQueue attribute)</a></dt>
 <dt><a href="reference/celery.datastructures.html#celery.datastructures.TaskProcessQueue.limit">limit (celery.datastructures.TaskProcessQueue attribute)</a></dt>
-<dt><a href="reference/celery.conf.html#celery.conf.LOG_FORMAT">LOG_FORMAT (in module celery.conf)</a></dt>
-<dt><a href="reference/celery.conf.html#celery.conf.LOG_LEVELS">LOG_LEVELS (in module celery.conf)</a></dt></dl></td><td width="33%" valign="top"><dl>
+<dt><a href="reference/celery.conf.html#celery.conf.LOG_FORMAT">LOG_FORMAT (in module celery.conf)</a>, <a href="reference/celery.conf.html#celery.conf.LOG_FORMAT">[1]</a></dt>
+<dt><a href="reference/celery.conf.html#celery.conf.LOG_LEVELS">LOG_LEVELS (in module celery.conf)</a>, <a href="reference/celery.conf.html#celery.conf.LOG_LEVELS">[1]</a></dt></dl></td><td width="33%" valign="top"><dl>
 <dt><a href="reference/celery.worker.html#celery.worker.TaskDaemon.logfile">logfile (celery.worker.TaskDaemon attribute)</a></dt>
 <dt><a href="reference/celery.datastructures.html#celery.datastructures.TaskProcessQueue.logger">logger (celery.datastructures.TaskProcessQueue attribute)</a></dt>
   <dd><dl>
@@ -344,7 +354,7 @@
 <dl>
 
 <dt><a href="reference/celery.worker.html#celery.worker.TaskDaemon.queue_wakeup_after">queue_wakeup_after (celery.worker.TaskDaemon attribute)</a></dt>
-<dt><a href="reference/celery.conf.html#celery.conf.QUEUE_WAKEUP_AFTER">QUEUE_WAKEUP_AFTER (in module celery.conf)</a></dt></dl></td><td width="33%" valign="top"><dl>
+<dt><a href="reference/celery.conf.html#celery.conf.QUEUE_WAKEUP_AFTER">QUEUE_WAKEUP_AFTER (in module celery.conf)</a>, <a href="reference/celery.conf.html#celery.conf.QUEUE_WAKEUP_AFTER">[1]</a></dt></dl></td><td width="33%" valign="top"><dl>
 </dl></td></tr></table>
 
 <h2 id="R">R</h2>
@@ -353,17 +363,16 @@
 
 <dt><a href="reference/celery.result.html#celery.result.BaseAsyncResult.ready">ready() (celery.result.BaseAsyncResult method)</a></dt>
 <dt><a href="reference/celery.worker.html#celery.worker.TaskDaemon.receive_message">receive_message() (celery.worker.TaskDaemon method)</a></dt>
-<dt><a href="reference/celery.worker.html#celery.worker.TaskDaemon.receive_message_cc">receive_message_cc() (celery.worker.TaskDaemon method)</a></dt>
 <dt><a href="reference/celery.registry.html#celery.registry.TaskRegistry.register">register() (celery.registry.TaskRegistry method)</a></dt>
 <dt><a href="reference/celery.task.html#celery.task.TaskSet.remote_execute">remote_execute() (celery.task.TaskSet class method)</a></dt>
 <dt><a href="reference/celery.platform.html#celery.platform.PIDFile.remove">remove() (celery.platform.PIDFile method)</a></dt>
 <dt><a href="reference/celery.platform.html#celery.platform.remove_pidfile">remove_pidfile() (in module celery.platform)</a></dt>
 <dt><a href="reference/celery.messaging.html#celery.messaging.TaskPublisher.requeue_task">requeue_task() (celery.messaging.TaskPublisher method)</a></dt>
-<dt><a href="reference/celery.worker.html#celery.worker.TaskDaemon.reset_connection">reset_connection() (celery.worker.TaskDaemon method)</a></dt></dl></td><td width="33%" valign="top"><dl>
+<dt><a href="reference/celery.worker.html#celery.worker.TaskDaemon.reset_connection">reset_connection() (celery.worker.TaskDaemon method)</a></dt>
 <dt><a href="reference/celery.result.html#celery.result.BaseAsyncResult.result">result (celery.result.BaseAsyncResult attribute)</a></dt>
   <dd><dl>
     <dt><a href="reference/celery.models.html#TaskMeta.result">(TaskMeta attribute)</a></dt>
-  </dl></dd>
+  </dl></dd></dl></td><td width="33%" valign="top"><dl>
 <dt><a href="reference/celery.task.html#celery.task.ExecuteRemoteTask.run">run() (celery.task.ExecuteRemoteTask method)</a></dt>
   <dd><dl>
     <dt><a href="reference/celery.task.html#celery.task.Task.run">(celery.task.Task method)</a></dt>
@@ -401,12 +410,17 @@
 <dt><a href="reference/celery.task.html#celery.task.Task">Task (class in celery.task)</a></dt>
 <dt><a href="reference/celery.models.html#PeriodicTaskMeta.task">task (PeriodicTaskMeta attribute)</a></dt>
 <dt><a href="reference/celery.worker.html#celery.worker.TaskDaemon.task_consumer">task_consumer (celery.worker.TaskDaemon attribute)</a></dt>
+<dt><a href="reference/celery.worker.html#celery.worker.TaskWrapper.task_func">task_func (celery.worker.TaskWrapper attribute)</a></dt>
 <dt><a href="reference/celery.result.html#celery.result.AsyncResult.task_id">task_id (celery.result.AsyncResult attribute)</a></dt>
   <dd><dl>
     <dt><a href="reference/celery.models.html#TaskMeta.task_id">(TaskMeta attribute)</a></dt>
     <dt><a href="reference/celery.result.html#celery.result.BaseAsyncResult.task_id">(celery.result.BaseAsyncResult attribute)</a></dt>
+    <dt><a href="reference/celery.worker.html#celery.worker.TaskWrapper.task_id">(celery.worker.TaskWrapper attribute)</a></dt>
   </dl></dd>
 <dt><a href="reference/celery.task.html#celery.task.TaskSet.task_name">task_name (celery.task.TaskSet attribute)</a></dt>
+  <dd><dl>
+    <dt><a href="reference/celery.worker.html#celery.worker.TaskWrapper.task_name">(celery.worker.TaskWrapper attribute)</a></dt>
+  </dl></dd>
 <dt><a href="reference/celery.models.html#TASK_STATUS_DONE">TASK_STATUS_DONE (built-in variable)</a></dt>
 <dt><a href="reference/celery.models.html#TASK_STATUS_FAILURE">TASK_STATUS_FAILURE (built-in variable)</a></dt>
 <dt><a href="reference/celery.models.html#TASK_STATUS_PENDING">TASK_STATUS_PENDING (built-in variable)</a></dt>
@@ -416,8 +430,8 @@
 <dt><a href="reference/celery.messaging.html#celery.messaging.TaskConsumer">TaskConsumer (class in celery.messaging)</a></dt>
 <dt><a href="reference/celery.worker.html#celery.worker.TaskDaemon">TaskDaemon (class in celery.worker)</a></dt>
 <dt><a href="reference/celery.managers.html#celery.managers.TaskManager">TaskManager (class in celery.managers)</a></dt>
-<dt><a href="reference/celery.models.html#TaskMeta">TaskMeta (built-in class)</a></dt>
-<dt><a href="reference/celery.datastructures.html#celery.datastructures.TaskProcessQueue">TaskProcessQueue (class in celery.datastructures)</a></dt></dl></td><td width="33%" valign="top"><dl>
+<dt><a href="reference/celery.models.html#TaskMeta">TaskMeta (built-in class)</a></dt></dl></td><td width="33%" valign="top"><dl>
+<dt><a href="reference/celery.datastructures.html#celery.datastructures.TaskProcessQueue">TaskProcessQueue (class in celery.datastructures)</a></dt>
 <dt><a href="reference/celery.messaging.html#celery.messaging.TaskPublisher">TaskPublisher (class in celery.messaging)</a></dt>
 <dt><a href="reference/celery.registry.html#celery.registry.TaskRegistry">TaskRegistry (class in celery.registry)</a></dt>
 <dt><a href="reference/celery.registry.html#celery.registry.TaskRegistry.AlreadyRegistered">TaskRegistry.AlreadyRegistered</a></dt>

objects.inv

@@ -75,8 +75,8 @@ celery.log.setup_logger function reference/celery.log.html
 celery.backends.base.BaseBackend.wait_for method reference/celery.backends.base.html
 celery.task.Task.name attribute reference/celery.task.html
 celery.backends.base.BaseBackend.mark_as_done method reference/celery.backends.base.html
+celery.conf.DEFAULT_DAEMON_LOG_FILE data reference/celery.conf.html
 celery.registry.TaskRegistry.get_all_periodic method reference/celery.registry.html
-celery.worker.TaskWrapper.extend_kwargs_with_logging method reference/celery.worker.html
 PeriodicTaskMeta.last_run_at attribute reference/celery.models.html
 celery.task.Task.get_publisher method reference/celery.task.html
 celery.worker.TaskDaemon.run method reference/celery.worker.html
@@ -86,17 +86,18 @@ celery.backends.database.Backend.get_status method reference/celery.backends.dat
 PeriodicTaskMeta class reference/celery.models.html
 celery.messaging.TaskPublisher.requeue_task method reference/celery.messaging.html
 celery.messaging.TaskPublisher class reference/celery.messaging.html
+celery.worker.TaskWrapper.task_name attribute reference/celery.worker.html
 celery.backends.base.BaseBackend class reference/celery.backends.base.html
 celery.backends.base.BaseBackend.mark_as_failure method reference/celery.backends.base.html
 celery.backends.tyrant.Backend.get_status method reference/celery.backends.tyrant.html
 celery.registry.TaskRegistry.NotRegistered exception reference/celery.registry.html
+celery.datastructures.PositionQueue.length attribute reference/celery.datastructures.html
 celery.datastructures.PositionQueue class reference/celery.datastructures.html
 celery.backends.base.BaseBackend.prepare_result method reference/celery.backends.base.html
 celery.datastructures.TaskProcessQueue class reference/celery.datastructures.html
 celery.backends.base.BaseBackend.UnpickleableExceptionWrapper.exc_module attribute reference/celery.backends.base.html
 celery.task.ExecuteRemoteTask class reference/celery.task.html
 celery.task.dmap_async function reference/celery.task.html
-celery.worker.TaskDaemon.receive_message_cc method reference/celery.worker.html
 celery.managers.TaskManager class reference/celery.managers.html
 celery.backends.base.BaseBackend.store_result method reference/celery.backends.base.html
 celery.datastructures.TaskProcessQueue.logger attribute reference/celery.datastructures.html
@@ -118,13 +119,15 @@ celery.task.TaskSet.total attribute reference/celery.task.html
 celery.conf.DAEMON_LOG_LEVEL data reference/celery.conf.html
 celery.backends.database.Backend class reference/celery.backends.database.html
 celery.result.BaseAsyncResult.status attribute reference/celery.result.html
+celery.worker.TaskWrapper.kwargs attribute reference/celery.worker.html
 celery.datastructures.TaskProcessQueue.limit attribute reference/celery.datastructures.html
 celery.conf.QUEUE_WAKEUP_AFTER data reference/celery.conf.html
 celery.backends.database.Backend.get_result method reference/celery.backends.database.html
 celery.backends.get_backend_cls function reference/celery.backends.html
 celery.registry.TaskRegistry.register method reference/celery.registry.html
 celery.worker.TaskDaemon.schedule_retry_tasks method reference/celery.worker.html
-celery.worker.UnknownTask exception reference/celery.worker.html
+celery.worker.TaskWrapper.args attribute reference/celery.worker.html
+celery.worker.TaskWrapper.task_func attribute reference/celery.worker.html
 celery.task.TaskSet.map classmethod reference/celery.task.html
 celery.backends.cache.Backend.get_result method reference/celery.backends.cache.html
 celery.task.Task.get_logger method reference/celery.task.html
@@ -142,6 +145,7 @@ celery.worker.TaskWrapper.execute_using_pool method reference/celery.worker.html
 celery.backends.base.BaseBackend.is_done method reference/celery.backends.base.html
 celery.worker.TaskDaemon.pool attribute reference/celery.worker.html
 celery.backends.tyrant.Backend.is_done method reference/celery.backends.tyrant.html
+celery.worker.TaskWrapper.extend_with_default_kwargs method reference/celery.worker.html
 celery.result.BaseAsyncResult.task_id attribute reference/celery.result.html
 celery.backends.cache.Backend.is_done method reference/celery.backends.cache.html
 celery.task.Task.get_consumer method reference/celery.task.html
@@ -150,6 +154,7 @@ celery.backends.base.BaseBackend.UnpickleableExceptionWrapper exception referenc
 celery.platform.PIDFile.write method reference/celery.platform.html
 celery.platform.remove_pidfile function reference/celery.platform.html
 celery.platform.PIDFile class reference/celery.platform.html
+celery.worker.TaskWrapper.task_id attribute reference/celery.worker.html
 celery.managers.PeriodicTaskManager.get_waiting_tasks method reference/celery.managers.html
 celery.messaging.TaskPublisher.delay_task method reference/celery.messaging.html
 celery.datastructures.TaskProcessQueue.done_msg attribute reference/celery.datastructures.html
@@ -157,6 +162,7 @@ celery.registry.TaskRegistry.get_all_regular method reference/celery.registry.ht
 celery.worker.TaskDaemon.logger attribute reference/celery.worker.html
 celery.registry.TaskRegistry class reference/celery.registry.html
 celery.backends.DefaultBackend class reference/celery.backends.html
+celery.worker.UnknownTask exception reference/celery.worker.html
 celery.timer.TimeoutTimer class reference/celery.timer.html
 celery.task.Task.run method reference/celery.task.html
 celery.result.BaseAsyncResult.wait method reference/celery.result.html

reference/celery.conf.html

@@ -54,63 +54,119 @@
 <dl class="data">
 <dt id="celery.conf.AMQP_EXCHANGE">
 <tt class="descclassname">celery.conf.</tt><tt class="descname">AMQP_EXCHANGE</tt><a class="headerlink" href="#celery.conf.AMQP_EXCHANGE" title="Permalink to this definition">¶</a></dt>
-<dd>The AMQP exchange.</dd></dl>
-
-<dl class="data">
+<dd><dl class="data">
 <dt id="celery.conf.AMQP_ROUTING_KEY">
 <tt class="descclassname">celery.conf.</tt><tt class="descname">AMQP_ROUTING_KEY</tt><a class="headerlink" href="#celery.conf.AMQP_ROUTING_KEY" title="Permalink to this definition">¶</a></dt>
 <dd>The AMQP routing key.</dd></dl>
 
+</dd></dl>
+
 <dl class="data">
+<dt>
+<tt class="descclassname">celery.conf.</tt><tt class="descname">AMQP_ROUTING_KEY</tt></dt>
+<dd><dl class="data">
 <dt id="celery.conf.AMQP_CONSUMER_QUEUE">
 <tt class="descclassname">celery.conf.</tt><tt class="descname">AMQP_CONSUMER_QUEUE</tt><a class="headerlink" href="#celery.conf.AMQP_CONSUMER_QUEUE" title="Permalink to this definition">¶</a></dt>
 <dd>The name of the AMQP queue.</dd></dl>
 
+</dd></dl>
+
 <dl class="data">
 <dt id="celery.conf.DAEMON_CONCURRENCY">
 <tt class="descclassname">celery.conf.</tt><tt class="descname">DAEMON_CONCURRENCY</tt><a class="headerlink" href="#celery.conf.DAEMON_CONCURRENCY" title="Permalink to this definition">¶</a></dt>
-<dd>The number of worker processes, that should work simultaenously.</dd></dl>
+<dd><dl class="data">
+<dt>
+<tt class="descclassname">celery.conf.</tt><tt class="descname">AMQP_EXCHANGE</tt></dt>
+<dd>Name of the AMQP exchange.</dd></dl>
 
-<dl class="data">
-<dt id="celery.conf.DAEMON_PID_FILE">
-<tt class="descclassname">celery.conf.</tt><tt class="descname">DAEMON_PID_FILE</tt><a class="headerlink" href="#celery.conf.DAEMON_PID_FILE" title="Permalink to this definition">¶</a></dt>
-<dd>Full path to the daemon pid file.</dd></dl>
+</dd></dl>
 
 <dl class="data">
-<dt id="celery.conf.EMPTY_MSG_EMIT_EVERY">
-<tt class="descclassname">celery.conf.</tt><tt class="descname">EMPTY_MSG_EMIT_EVERY</tt><a class="headerlink" href="#celery.conf.EMPTY_MSG_EMIT_EVERY" title="Permalink to this definition">¶</a></dt>
-<dd>How often the celery daemon should write a log message saying there are no
-messages in the queue. If this is <tt class="xref docutils literal"><span class="pre">None</span></tt> or <tt class="docutils literal"><span class="pre">0</span></tt>, it will never print
-this message.</dd></dl>
+<dt id="celery.conf.DAEMON_LOG_FILE">
+<tt class="descclassname">celery.conf.</tt><tt class="descname">DAEMON_LOG_FILE</tt><a class="headerlink" href="#celery.conf.DAEMON_LOG_FILE" title="Permalink to this definition">¶</a></dt>
+<dd><dl class="data">
+<dt id="celery.conf.DAEMON_LOG_LEVEL">
+<tt class="descclassname">celery.conf.</tt><tt class="descname">DAEMON_LOG_LEVEL</tt><a class="headerlink" href="#celery.conf.DAEMON_LOG_LEVEL" title="Permalink to this definition">¶</a></dt>
+<dd>Celery daemon log level, can be any of <tt class="docutils literal"><span class="pre">DEBUG</span></tt>, <tt class="docutils literal"><span class="pre">INFO</span></tt>, <tt class="docutils literal"><span class="pre">WARNING</span></tt>,
+<tt class="docutils literal"><span class="pre">ERROR</span></tt>, <tt class="docutils literal"><span class="pre">CRITICAL</span></tt>, or <tt class="docutils literal"><span class="pre">FATAL</span></tt>. See the <tt class="xref docutils literal"><span class="pre">logging</span></tt> module
+for more information.</dd></dl>
+
+</dd></dl>
 
 <dl class="data">
+<dt>
+<tt class="descclassname">celery.conf.</tt><tt class="descname">DAEMON_LOG_LEVEL</tt></dt>
+<dd><dl class="data">
 <dt id="celery.conf.QUEUE_WAKEUP_AFTER">
 <tt class="descclassname">celery.conf.</tt><tt class="descname">QUEUE_WAKEUP_AFTER</tt><a class="headerlink" href="#celery.conf.QUEUE_WAKEUP_AFTER" title="Permalink to this definition">¶</a></dt>
-<dd>The time (in seconds) the celery daemon should sleep when there are no messages
-left on the queue. After the time is slept, the worker wakes up and
-checks the queue again.</dd></dl>
+<dd>The time (in seconds) the celery worker should sleep when there&#8217;s
+no messages left on the queue. After the time is slept, the worker
+wakes up and checks the queue again.</dd></dl>
+
+</dd></dl>
 
 <dl class="data">
-<dt id="celery.conf.DAEMON_LOG_LEVEL">
-<tt class="descclassname">celery.conf.</tt><tt class="descname">DAEMON_LOG_LEVEL</tt><a class="headerlink" href="#celery.conf.DAEMON_LOG_LEVEL" title="Permalink to this definition">¶</a></dt>
-<dd>Celery daemon log level, could be any of <tt class="docutils literal"><span class="pre">DEBUG</span></tt>, <tt class="docutils literal"><span class="pre">INFO</span></tt>, <tt class="docutils literal"><span class="pre">WARNING</span></tt>,
-<tt class="docutils literal"><span class="pre">ERROR</span></tt>, <tt class="docutils literal"><span class="pre">CRITICAL</span></tt>, or <tt class="docutils literal"><span class="pre">FATAL</span></tt>.</dd></dl>
+<dt id="celery.conf.DAEMON_PID_FILE">
+<tt class="descclassname">celery.conf.</tt><tt class="descname">DAEMON_PID_FILE</tt><a class="headerlink" href="#celery.conf.DAEMON_PID_FILE" title="Permalink to this definition">¶</a></dt>
+<dd><dl class="data">
+<dt>
+<tt class="descclassname">celery.conf.</tt><tt class="descname">DAEMON_CONCURRENCY</tt></dt>
+<dd>The number of concurrent worker processes, executing tasks simultaneously.</dd></dl>
+
+</dd></dl>
 
 <dl class="data">
-<dt id="celery.conf.DAEMON_LOG_FILE">
-<tt class="descclassname">celery.conf.</tt><tt class="descname">DAEMON_LOG_FILE</tt><a class="headerlink" href="#celery.conf.DAEMON_LOG_FILE" title="Permalink to this definition">¶</a></dt>
-<dd>The path to the deamon log file (if not set, <tt class="docutils literal"><span class="pre">stderr</span></tt> is used).</dd></dl>
+<dt id="celery.conf.DEFAULT_DAEMON_LOG_FILE">
+<tt class="descclassname">celery.conf.</tt><tt class="descname">DEFAULT_DAEMON_LOG_FILE</tt><a class="headerlink" href="#celery.conf.DEFAULT_DAEMON_LOG_FILE" title="Permalink to this definition">¶</a></dt>
+<dd><dl class="data">
+<dt id="celery.conf.LOG_LEVELS">
+<tt class="descclassname">celery.conf.</tt><tt class="descname">LOG_LEVELS</tt><a class="headerlink" href="#celery.conf.LOG_LEVELS" title="Permalink to this definition">¶</a></dt>
+<dd>Mapping of log level names to <tt class="xref docutils literal"><span class="pre">logging</span></tt> module constants.</dd></dl>
+
+</dd></dl>
+
+<dl class="data">
+<dt id="celery.conf.EMPTY_MSG_EMIT_EVERY">
+<tt class="descclassname">celery.conf.</tt><tt class="descname">EMPTY_MSG_EMIT_EVERY</tt><a class="headerlink" href="#celery.conf.EMPTY_MSG_EMIT_EVERY" title="Permalink to this definition">¶</a></dt>
+<dd><dl class="data">
+<dt>
+<tt class="descclassname">celery.conf.</tt><tt class="descname">DAEMON_PID_FILE</tt></dt>
+<dd>Full path to the daemon pidfile.</dd></dl>
+
+</dd></dl>
 
 <dl class="data">
 <dt id="celery.conf.LOG_FORMAT">
 <tt class="descclassname">celery.conf.</tt><tt class="descname">LOG_FORMAT</tt><a class="headerlink" href="#celery.conf.LOG_FORMAT" title="Permalink to this definition">¶</a></dt>
+<dd><dl class="data">
+<dt>
+<tt class="descclassname">celery.conf.</tt><tt class="descname">DAEMON_LOG_FILE</tt></dt>
+<dd>The path to the deamon log file (if not set, <tt class="docutils literal"><span class="pre">stderr</span></tt> is used).</dd></dl>
+
+</dd></dl>
+
+<dl class="data">
+<dt>
+<tt class="descclassname">celery.conf.</tt><tt class="descname">LOG_LEVELS</tt></dt>
+<dd><dl class="data">
+<dt>
+<tt class="descclassname">celery.conf.</tt><tt class="descname">LOG_FORMAT</tt></dt>
 <dd>The format to use for log messages.
 Default is <tt class="docutils literal"><span class="pre">[%(asctime)s:</span> <span class="pre">%(levelname)s/%(processName)s]</span> <span class="pre">%(message)s</span></tt></dd></dl>
 
+</dd></dl>
+
 <dl class="data">
-<dt id="celery.conf.LOG_LEVELS">
-<tt class="descclassname">celery.conf.</tt><tt class="descname">LOG_LEVELS</tt><a class="headerlink" href="#celery.conf.LOG_LEVELS" title="Permalink to this definition">¶</a></dt>
-<dd>Mapping of log level names to <tt class="docutils literal"><span class="pre">logging</span></tt> module constants.</dd></dl>
+<dt>
+<tt class="descclassname">celery.conf.</tt><tt class="descname">QUEUE_WAKEUP_AFTER</tt></dt>
+<dd><dl class="data">
+<dt>
+<tt class="descclassname">celery.conf.</tt><tt class="descname">EMPTY_MSG_EMIT_EVERY</tt></dt>
+<dd>How often the celery daemon should write a log message saying there are no
+messages in the queue. If this is <tt class="xref docutils literal"><span class="pre">None</span></tt> or <tt class="docutils literal"><span class="pre">0</span></tt>, it will never print
+this message.</dd></dl>
+
+</dd></dl>
 
 </div>
 

reference/celery.datastructures.html

@@ -62,10 +62,15 @@ is considered <a title="celery.datastructures.PositionQueue.full" class="referen
 <col class="field-name" />
 <col class="field-body" />
 <tbody valign="top">
-<tr class="field"><th class="field-name">Parameter:</th><td class="field-body"><em>length</em> &#8211; The number of items required for the queue to be filled.</td>
+<tr class="field"><th class="field-name">Parameter:</th><td class="field-body"><em>length</em> &#8211; see <a title="celery.datastructures.PositionQueue.length" class="reference internal" href="#celery.datastructures.PositionQueue.length"><tt class="xref docutils literal"><span class="pre">length</span></tt></a>.</td>
 </tr>
 </tbody>
 </table>
+<dl class="attribute">
+<dt id="celery.datastructures.PositionQueue.length">
+<tt class="descname">length</tt><a class="headerlink" href="#celery.datastructures.PositionQueue.length" title="Permalink to this definition">¶</a></dt>
+<dd>The number of items required for the queue to be considered full.</dd></dl>
+
 <dl class="class">
 <dt id="celery.datastructures.PositionQueue.UnfilledPosition">
 <em class="property">
@@ -89,7 +94,7 @@ class </em><tt class="descname">UnfilledPosition</tt><big>(</big><em>position</e
 <em class="property">
 class </em><tt class="descclassname">celery.datastructures.</tt><tt class="descname">TaskProcessQueue</tt><big>(</big><em>limit</em>, <em>logger=None</em>, <em>done_msg=None</em><big>)</big><a class="headerlink" href="#celery.datastructures.TaskProcessQueue" title="Permalink to this definition">¶</a></dt>
 <dd><p>Queue of running child processes, which starts waiting for the
-processes to finish when the queue limit is reached.</p>
+processes to finish when the queue limit has been reached.</p>
 <table class="docutils field-list" frame="void" rules="none">
 <col class="field-name" />
 <col class="field-body" />

reference/celery.result.html

@@ -56,6 +56,14 @@
 <em class="property">
 class </em><tt class="descclassname">celery.result.</tt><tt class="descname">AsyncResult</tt><big>(</big><em>task_id</em><big>)</big><a class="headerlink" href="#celery.result.AsyncResult" title="Permalink to this definition">¶</a></dt>
 <dd><p>Pending task result using the default backend.</p>
+<table class="docutils field-list" frame="void" rules="none">
+<col class="field-name" />
+<col class="field-body" />
+<tbody valign="top">
+<tr class="field"><th class="field-name">Parameter:</th><td class="field-body"><em>task_id</em> &#8211; see <a title="celery.result.AsyncResult.task_id" class="reference internal" href="#celery.result.AsyncResult.task_id"><tt class="xref docutils literal"><span class="pre">task_id</span></tt></a>.</td>
+</tr>
+</tbody>
+</table>
 <dl class="attribute">
 <dt id="celery.result.AsyncResult.task_id">
 <tt class="descname">task_id</tt><a class="headerlink" href="#celery.result.AsyncResult.task_id" title="Permalink to this definition">¶</a></dt>
@@ -72,7 +80,20 @@ class </em><tt class="descclassname">celery.result.</tt><tt class="descname">Asy
 <dt id="celery.result.BaseAsyncResult">
 <em class="property">
 class </em><tt class="descclassname">celery.result.</tt><tt class="descname">BaseAsyncResult</tt><big>(</big><em>task_id</em>, <em>backend</em><big>)</big><a class="headerlink" href="#celery.result.BaseAsyncResult" title="Permalink to this definition">¶</a></dt>
-<dd><p>Base class for pending result, takes <tt class="docutils literal"><span class="pre">backend</span></tt> argument.</p>
+<dd><p>Base class for pending result, supports custom
+task meta <a title="celery.result.BaseAsyncResult.backend" class="reference internal" href="#celery.result.BaseAsyncResult.backend"><tt class="xref docutils literal"><span class="pre">backend</span></tt></a></p>
+<table class="docutils field-list" frame="void" rules="none">
+<col class="field-name" />
+<col class="field-body" />
+<tbody valign="top">
+<tr class="field"><th class="field-name">Parameters:</th><td class="field-body"><ul class="first last simple">
+<li><em>task_id</em> &#8211; see <a title="celery.result.BaseAsyncResult.task_id" class="reference internal" href="#celery.result.BaseAsyncResult.task_id"><tt class="xref docutils literal"><span class="pre">task_id</span></tt></a>.</li>
+<li><em>backend</em> &#8211; see <a title="celery.result.BaseAsyncResult.backend" class="reference internal" href="#celery.result.BaseAsyncResult.backend"><tt class="xref docutils literal"><span class="pre">backend</span></tt></a>.</li>
+</ul>
+</td>
+</tr>
+</tbody>
+</table>
 <dl class="attribute">
 <dt id="celery.result.BaseAsyncResult.task_id">
 <tt class="descname">task_id</tt><a class="headerlink" href="#celery.result.BaseAsyncResult.task_id" title="Permalink to this definition">¶</a></dt>
@@ -121,9 +142,8 @@ then <tt class="xref docutils literal"><span class="pre">False</span></tt> is re
 <dl class="attribute">
 <dt id="celery.result.BaseAsyncResult.result">
 <tt class="descname">result</tt><a class="headerlink" href="#celery.result.BaseAsyncResult.result" title="Permalink to this definition">¶</a></dt>
-<dd><p>When the task is executed, this contains the return value.</p>
-<p>If the task resulted in failure, this will be the exception instance
-raised.</p>
+<dd><p>When the task has been executed, this contains the return value.</p>
+<p>If the task raised an exception, this will be the exception instance.</p>
 </dd></dl>
 
 <dl class="attribute">

reference/celery.worker.html

@@ -62,36 +62,50 @@ exception </em><tt class="descclassname">celery.worker.</tt><tt class="descname"
 <em class="property">
 class </em><tt class="descclassname">celery.worker.</tt><tt class="descname">TaskDaemon</tt><big>(</big><em>concurrency=None</em>, <em>logfile=None</em>, <em>loglevel=None</em>, <em>queue_wakeup_after=None</em><big>)</big><a class="headerlink" href="#celery.worker.TaskDaemon" title="Permalink to this definition">¶</a></dt>
 <dd><p>Executes tasks waiting in the task queue.</p>
+<table class="docutils field-list" frame="void" rules="none">
+<col class="field-name" />
+<col class="field-body" />
+<tbody valign="top">
+<tr class="field"><th class="field-name">Parameters:</th><td class="field-body"><ul class="first last simple">
+<li><em>concurrency</em> &#8211; see <a title="celery.worker.TaskDaemon.concurrency" class="reference internal" href="#celery.worker.TaskDaemon.concurrency"><tt class="xref docutils literal"><span class="pre">concurrency</span></tt></a>.</li>
+<li><em>logfile</em> &#8211; see <a title="celery.worker.TaskDaemon.logfile" class="reference internal" href="#celery.worker.TaskDaemon.logfile"><tt class="xref docutils literal"><span class="pre">logfile</span></tt></a>.</li>
+<li><em>loglevel</em> &#8211; see <a title="celery.worker.TaskDaemon.loglevel" class="reference internal" href="#celery.worker.TaskDaemon.loglevel"><tt class="xref docutils literal"><span class="pre">loglevel</span></tt></a>.</li>
+<li><em>queue_wakeup_after</em> &#8211; see <a title="celery.worker.TaskDaemon.queue_wakeup_after" class="reference internal" href="#celery.worker.TaskDaemon.queue_wakeup_after"><tt class="xref docutils literal"><span class="pre">queue_wakeup_after</span></tt></a>.</li>
+</ul>
+</td>
+</tr>
+</tbody>
+</table>
 <dl class="attribute">
 <dt id="celery.worker.TaskDaemon.concurrency">
 <tt class="descname">concurrency</tt><a class="headerlink" href="#celery.worker.TaskDaemon.concurrency" title="Permalink to this definition">¶</a></dt>
 <dd>The number of simultaneous processes doing work (default:
-<tt class="docutils literal"><span class="pre">celery.conf.DAEMON_CONCURRENCY</span></tt>)</dd></dl>
+<a title="celery.conf.DAEMON_CONCURRENCY" class="reference external" href="celery.conf.html#celery.conf.DAEMON_CONCURRENCY"><tt class="xref docutils literal"><span class="pre">celery.conf.DAEMON_CONCURRENCY</span></tt></a>)</dd></dl>
 
 <dl class="attribute">
 <dt id="celery.worker.TaskDaemon.loglevel">
 <tt class="descname">loglevel</tt><a class="headerlink" href="#celery.worker.TaskDaemon.loglevel" title="Permalink to this definition">¶</a></dt>
-<dd>The loglevel used (default: <tt class="docutils literal"><span class="pre">logging.INFO</span></tt>)</dd></dl>
+<dd>The loglevel used (default: <tt class="xref docutils literal"><span class="pre">logging.INFO</span></tt>)</dd></dl>
 
 <dl class="attribute">
 <dt id="celery.worker.TaskDaemon.logfile">
 <tt class="descname">logfile</tt><a class="headerlink" href="#celery.worker.TaskDaemon.logfile" title="Permalink to this definition">¶</a></dt>
 <dd>The logfile used, if no logfile is specified it uses <tt class="docutils literal"><span class="pre">stderr</span></tt>
-(default: <tt class="docutils literal"><span class="pre">celery.conf.DAEMON_LOG_FILE</span></tt>).</dd></dl>
+(default: <a title="celery.conf.DAEMON_LOG_FILE" class="reference external" href="celery.conf.html#celery.conf.DAEMON_LOG_FILE"><tt class="xref docutils literal"><span class="pre">celery.conf.DAEMON_LOG_FILE</span></tt></a>).</dd></dl>
 
 <dl class="attribute">
 <dt id="celery.worker.TaskDaemon.queue_wakeup_after">
 <tt class="descname">queue_wakeup_after</tt><a class="headerlink" href="#celery.worker.TaskDaemon.queue_wakeup_after" title="Permalink to this definition">¶</a></dt>
 <dd>The time it takes for the daemon to wake up after the queue is empty,
 so it can check for more work
-(default: <tt class="docutils literal"><span class="pre">celery.conf.QUEUE_WAKEUP_AFTER</span></tt>).</dd></dl>
+(default: <a title="celery.conf.QUEUE_WAKEUP_AFTER" class="reference external" href="celery.conf.html#celery.conf.QUEUE_WAKEUP_AFTER"><tt class="xref docutils literal"><span class="pre">celery.conf.QUEUE_WAKEUP_AFTER</span></tt></a>).</dd></dl>
 
 <dl class="attribute">
 <dt id="celery.worker.TaskDaemon.empty_msg_emit_every">
 <tt class="descname">empty_msg_emit_every</tt><a class="headerlink" href="#celery.worker.TaskDaemon.empty_msg_emit_every" title="Permalink to this definition">¶</a></dt>
-<dd>How often the daemon emits the <tt class="docutils literal"><span class="pre">Waiting</span> <span class="pre">for</span> <span class="pre">queue</span></tt> message.
+<dd>How often the daemon emits the <tt class="docutils literal"><span class="pre">&quot;Waiting</span> <span class="pre">for</span> <span class="pre">queue...&quot;</span></tt> message.
 If this is <tt class="xref docutils literal"><span class="pre">None</span></tt>, the message will never be logged.
-(default: <tt class="docutils literal"><span class="pre">celery.conf.EMPTY_MSG_EMIT_EVERY</span></tt>)</dd></dl>
+(default: <a title="celery.conf.EMPTY_MSG_EMIT_EVERY" class="reference external" href="celery.conf.html#celery.conf.EMPTY_MSG_EMIT_EVERY"><tt class="xref docutils literal"><span class="pre">celery.conf.EMPTY_MSG_EMIT_EVERY</span></tt></a>)</dd></dl>
 
 <dl class="attribute">
 <dt id="celery.worker.TaskDaemon.logger">
@@ -111,27 +125,28 @@ If this is <tt class="xref docutils literal"><span class="pre">None</span></tt>,
 <dl class="method">
 <dt id="celery.worker.TaskDaemon.connection_diagnostics">
 <tt class="descname">connection_diagnostics</tt><big>(</big><big>)</big><a class="headerlink" href="#celery.worker.TaskDaemon.connection_diagnostics" title="Permalink to this definition">¶</a></dt>
-<dd>Diagnose the AMQP connection, and reset if necessary.</dd></dl>
+<dd>Diagnose the AMQP connection, and reset connection if
+necessary.</dd></dl>
 
 <dl class="method">
 <dt id="celery.worker.TaskDaemon.execute_next_task">
 <tt class="descname">execute_next_task</tt><big>(</big><big>)</big><a class="headerlink" href="#celery.worker.TaskDaemon.execute_next_task" title="Permalink to this definition">¶</a></dt>
-<dd><p>Execute the next task on the queue using the multiprocessing
-pool.</p>
-<p>Catches all exceptions and logs them with level <tt class="docutils literal"><span class="pre">logging.CRITICAL</span></tt>.</p>
+<dd><p>Execute the next task on the queue using the multiprocessing pool.</p>
+<p>Catches all exceptions and logs them with level
+<tt class="xref docutils literal"><span class="pre">logging.CRITICAL</span></tt>.</p>
 </dd></dl>
 
 <dl class="method">
 <dt id="celery.worker.TaskDaemon.fetch_next_task">
 <tt class="descname">fetch_next_task</tt><big>(</big><big>)</big><a class="headerlink" href="#celery.worker.TaskDaemon.fetch_next_task" title="Permalink to this definition">¶</a></dt>
 <dd><p>Fetch the next task from the AMQP broker.</p>
-<p>Raises <a title="celery.worker.EmptyQueue" class="reference internal" href="#celery.worker.EmptyQueue"><tt class="xref docutils literal"><span class="pre">EmptyQueue</span></tt></a> exception if there is no messages
+<p>Raises <a title="celery.worker.EmptyQueue" class="reference internal" href="#celery.worker.EmptyQueue"><tt class="xref docutils literal"><span class="pre">EmptyQueue</span></tt></a> exception if there is no message
 waiting on the queue.</p>
 <table class="docutils field-list" frame="void" rules="none">
 <col class="field-name" />
 <col class="field-body" />
 <tbody valign="top">
-<tr class="field"><th class="field-name">Return type:</th><td class="field-body"><a title="celery.worker.TaskWrapper" class="reference internal" href="#celery.worker.TaskWrapper"><tt class="xref docutils literal"><span class="pre">TaskWrapper</span></tt></a> instance.</td>
+<tr class="field"><th class="field-name">Returns:</th><td class="field-body"><a title="celery.worker.TaskWrapper" class="reference internal" href="#celery.worker.TaskWrapper"><tt class="xref docutils literal"><span class="pre">TaskWrapper</span></tt></a> instance.</td>
 </tr>
 </tbody>
 </table>
@@ -140,7 +155,7 @@ waiting on the queue.</p>
 <dl class="method">
 <dt id="celery.worker.TaskDaemon.receive_message">
 <tt class="descname">receive_message</tt><big>(</big><big>)</big><a class="headerlink" href="#celery.worker.TaskDaemon.receive_message" title="Permalink to this definition">¶</a></dt>
-<dd><p>Receive the next message from the Task consumer queue.</p>
+<dd><p>Receive the next message from the message broker.</p>
 <p>Tries to reset the AMQP connection if not available.
 Returns <tt class="xref docutils literal"><span class="pre">None</span></tt> if no message is waiting on the queue.</p>
 <table class="docutils field-list" frame="void" rules="none">
@@ -153,21 +168,18 @@ Returns <tt class="xref docutils literal"><span class="pre">None</span></tt> if
 </table>
 </dd></dl>
 
-<dl class="method">
-<dt id="celery.worker.TaskDaemon.receive_message_cc">
-<tt class="descname">receive_message_cc</tt><big>(</big><big>)</big><a class="headerlink" href="#celery.worker.TaskDaemon.receive_message_cc" title="Permalink to this definition">¶</a></dt>
-<dd>UNUSED.</dd></dl>
-
 <dl class="method">
 <dt id="celery.worker.TaskDaemon.reset_connection">
 <tt class="descname">reset_connection</tt><big>(</big><big>)</big><a class="headerlink" href="#celery.worker.TaskDaemon.reset_connection" title="Permalink to this definition">¶</a></dt>
-<dd>Reset the AMQP connection, and reinitialize the
-<a title="celery.messaging.TaskConsumer" class="reference external" href="celery.messaging.html#celery.messaging.TaskConsumer"><tt class="xref docutils literal"><span class="pre">celery.messaging.TaskConsumer</span></tt></a> instance.</dd></dl>
+<dd><p>Reset the AMQP connection, and reinitialize the
+<a title="celery.messaging.TaskConsumer" class="reference external" href="celery.messaging.html#celery.messaging.TaskConsumer"><tt class="xref docutils literal"><span class="pre">celery.messaging.TaskConsumer</span></tt></a> instance.</p>
+<p>Resets the task consumer in <a title="celery.worker.TaskDaemon.task_consumer" class="reference internal" href="#celery.worker.TaskDaemon.task_consumer"><tt class="xref docutils literal"><span class="pre">task_consumer</span></tt></a>.</p>
+</dd></dl>
 
 <dl class="method">
 <dt id="celery.worker.TaskDaemon.run">
 <tt class="descname">run</tt><big>(</big><big>)</big><a class="headerlink" href="#celery.worker.TaskDaemon.run" title="Permalink to this definition">¶</a></dt>
-<dd>The worker server&#8217;s main loop.</dd></dl>
+<dd>Starts the workers main loop.</dd></dl>
 
 <dl class="method">
 <dt id="celery.worker.TaskDaemon.run_periodic_tasks">
@@ -194,30 +206,89 @@ Returns <tt class="xref docutils literal"><span class="pre">None</span></tt> if
 <dt id="celery.worker.TaskWrapper">
 <em class="property">
 class </em><tt class="descclassname">celery.worker.</tt><tt class="descname">TaskWrapper</tt><big>(</big><em>task_name</em>, <em>task_id</em>, <em>task_func</em>, <em>args</em>, <em>kwargs</em><big>)</big><a class="headerlink" href="#celery.worker.TaskWrapper" title="Permalink to this definition">¶</a></dt>
-<dd><p>Class defining a task to be run.</p>
+<dd><p>Class wrapping a task to be run.</p>
+<table class="docutils field-list" frame="void" rules="none">
+<col class="field-name" />
+<col class="field-body" />
+<tbody valign="top">
+<tr class="field"><th class="field-name">Parameters:</th><td class="field-body"><ul class="first last simple">
+<li><em>task_name</em> &#8211; see <a title="celery.worker.TaskWrapper.task_name" class="reference internal" href="#celery.worker.TaskWrapper.task_name"><tt class="xref docutils literal"><span class="pre">task_name</span></tt></a>.</li>
+<li><em>task_id</em> &#8211; see <a title="celery.worker.TaskWrapper.task_id" class="reference internal" href="#celery.worker.TaskWrapper.task_id"><tt class="xref docutils literal"><span class="pre">task_id</span></tt></a>.</li>
+<li><em>task_func</em> &#8211; see <a title="celery.worker.TaskWrapper.task_func" class="reference internal" href="#celery.worker.TaskWrapper.task_func"><tt class="xref docutils literal"><span class="pre">task_func</span></tt></a></li>
+<li><em>args</em> &#8211; see <a title="celery.worker.TaskWrapper.args" class="reference internal" href="#celery.worker.TaskWrapper.args"><tt class="xref docutils literal"><span class="pre">args</span></tt></a></li>
+<li><em>kwargs</em> &#8211; see <a title="celery.worker.TaskWrapper.kwargs" class="reference internal" href="#celery.worker.TaskWrapper.kwargs"><tt class="xref docutils literal"><span class="pre">kwargs</span></tt></a>.</li>
+</ul>
+</td>
+</tr>
+</tbody>
+</table>
+<dl class="attribute">
+<dt id="celery.worker.TaskWrapper.task_name">
+<tt class="descname">task_name</tt><a class="headerlink" href="#celery.worker.TaskWrapper.task_name" title="Permalink to this definition">¶</a></dt>
+<dd>Kind of task. Must be a name registered in the task registry.</dd></dl>
+
+<dl class="attribute">
+<dt id="celery.worker.TaskWrapper.task_id">
+<tt class="descname">task_id</tt><a class="headerlink" href="#celery.worker.TaskWrapper.task_id" title="Permalink to this definition">¶</a></dt>
+<dd>UUID of the task.</dd></dl>
+
+<dl class="attribute">
+<dt id="celery.worker.TaskWrapper.task_func">
+<tt class="descname">task_func</tt><a class="headerlink" href="#celery.worker.TaskWrapper.task_func" title="Permalink to this definition">¶</a></dt>
+<dd>The tasks callable object.</dd></dl>
+
+<dl class="attribute">
+<dt id="celery.worker.TaskWrapper.args">
+<tt class="descname">args</tt><a class="headerlink" href="#celery.worker.TaskWrapper.args" title="Permalink to this definition">¶</a></dt>
+<dd>List of positional arguments to apply to the task.</dd></dl>
+
+<dl class="attribute">
+<dt id="celery.worker.TaskWrapper.kwargs">
+<tt class="descname">kwargs</tt><a class="headerlink" href="#celery.worker.TaskWrapper.kwargs" title="Permalink to this definition">¶</a></dt>
+<dd>Mapping of keyword arguments to apply to the task.</dd></dl>
+
 <dl class="method">
 <dt id="celery.worker.TaskWrapper.execute">
-<tt class="descname">execute</tt><big>(</big><em>loglevel</em>, <em>logfile</em><big>)</big><a class="headerlink" href="#celery.worker.TaskWrapper.execute" title="Permalink to this definition">¶</a></dt>
-<dd>Execute the task in a <tt class="docutils literal"><span class="pre">jail()</span></tt> and store its result and status
-in the task meta backend.</dd></dl>
+<tt class="descname">execute</tt><big>(</big><em>loglevel=None</em>, <em>logfile=None</em><big>)</big><a class="headerlink" href="#celery.worker.TaskWrapper.execute" title="Permalink to this definition">¶</a></dt>
+<dd><p>Execute the task in a <a title="celery.worker.jail" class="reference internal" href="#celery.worker.jail"><tt class="xref docutils literal"><span class="pre">jail()</span></tt></a> and store return value
+and status in the task meta backend.</p>
+<table class="docutils field-list" frame="void" rules="none">
+<col class="field-name" />
+<col class="field-body" />
+<tbody valign="top">
+<tr class="field"><th class="field-name">Parameters:</th><td class="field-body"><ul class="first last simple">
+<li><em>loglevel</em> &#8211; The loglevel used by the task.</li>
+<li><em>logfile</em> &#8211; The logfile used by the task.</li>
+</ul>
+</td>
+</tr>
+</tbody>
+</table>
+</dd></dl>
 
 <dl class="method">
 <dt id="celery.worker.TaskWrapper.execute_using_pool">
-<tt class="descname">execute_using_pool</tt><big>(</big><em>pool</em>, <em>loglevel</em>, <em>logfile</em><big>)</big><a class="headerlink" href="#celery.worker.TaskWrapper.execute_using_pool" title="Permalink to this definition">¶</a></dt>
-<dd><p>Like <tt class="docutils literal"><span class="pre">execute</span></tt>, but using the <tt class="docutils literal"><span class="pre">multiprocessing</span></tt> pool.</p>
+<tt class="descname">execute_using_pool</tt><big>(</big><em>pool</em>, <em>loglevel=None</em>, <em>logfile=None</em><big>)</big><a class="headerlink" href="#celery.worker.TaskWrapper.execute_using_pool" title="Permalink to this definition">¶</a></dt>
+<dd><p>Like <a title="celery.worker.TaskWrapper.execute" class="reference internal" href="#celery.worker.TaskWrapper.execute"><tt class="xref docutils literal"><span class="pre">execute()</span></tt></a>, but using the <tt class="xref docutils literal"><span class="pre">multiprocessing</span></tt> pool.</p>
 <table class="docutils field-list" frame="void" rules="none">
 <col class="field-name" />
 <col class="field-body" />
 <tbody valign="top">
-<tr class="field"><th class="field-name">Return type:</th><td class="field-body"><tt class="xref docutils literal"><span class="pre">multiprocessing.AsyncResult</span></tt> instance.</td>
+<tr class="field"><th class="field-name">Parameters:</th><td class="field-body"><ul class="first last simple">
+<li><em>pool</em> &#8211; A <a href="#id1"><span class="problematic" id="id2">:cls:`multiprocessing.Pool`</span></a> instance.</li>
+<li><em>loglevel</em> &#8211; The loglevel used by the task.</li>
+<li><em>logfile</em> &#8211; The logfile used by the task.</li>
+</ul>
+</td>
 </tr>
 </tbody>
 </table>
+<p>:returns <tt class="xref docutils literal"><span class="pre">multiprocessing.AsyncResult</span></tt> instance.</p>
 </dd></dl>
 
 <dl class="method">
-<dt id="celery.worker.TaskWrapper.extend_kwargs_with_logging">
-<tt class="descname">extend_kwargs_with_logging</tt><big>(</big><em>loglevel</em>, <em>logfile</em><big>)</big><a class="headerlink" href="#celery.worker.TaskWrapper.extend_kwargs_with_logging" title="Permalink to this definition">¶</a></dt>
+<dt id="celery.worker.TaskWrapper.extend_with_default_kwargs">
+<tt class="descname">extend_with_default_kwargs</tt><big>(</big><em>loglevel</em>, <em>logfile</em><big>)</big><a class="headerlink" href="#celery.worker.TaskWrapper.extend_with_default_kwargs" title="Permalink to this definition">¶</a></dt>
 <dd><p>Extend the tasks keyword arguments with standard task arguments.</p>
 <p>These are <tt class="docutils literal"><span class="pre">logfile</span></tt>, <tt class="docutils literal"><span class="pre">loglevel</span></tt>, <tt class="docutils literal"><span class="pre">task_id</span></tt> and <tt class="docutils literal"><span class="pre">task_name</span></tt>.</p>
 </dd></dl>
@@ -226,15 +297,17 @@ in the task meta backend.</dd></dl>
 <dt id="celery.worker.TaskWrapper.from_message">
 <em class="property">
 classmethod </em><tt class="descname">from_message</tt><big>(</big><em>message</em><big>)</big><a class="headerlink" href="#celery.worker.TaskWrapper.from_message" title="Permalink to this definition">¶</a></dt>
-<dd><p>Create a TaskWrapper from a message returned by
-<a title="celery.messaging.TaskConsumer" class="reference external" href="celery.messaging.html#celery.messaging.TaskConsumer"><tt class="xref docutils literal"><span class="pre">celery.messaging.TaskConsumer</span></tt></a>.</p>
-<p>If the message is not a proper task it raises
-<a title="celery.worker.UnknownTask" class="reference internal" href="#celery.worker.UnknownTask"><tt class="xref docutils literal"><span class="pre">UnknownTask</span></tt></a> exception.</p>
+<dd><p>Create a <a title="celery.worker.TaskWrapper" class="reference internal" href="#celery.worker.TaskWrapper"><tt class="xref docutils literal"><span class="pre">TaskWrapper</span></tt></a> from a task message sent by
+<a title="celery.messaging.TaskPublisher" class="reference external" href="celery.messaging.html#celery.messaging.TaskPublisher"><tt class="xref docutils literal"><span class="pre">celery.messaging.TaskPublisher</span></tt></a>.</p>
 <table class="docutils field-list" frame="void" rules="none">
 <col class="field-name" />
 <col class="field-body" />
 <tbody valign="top">
-<tr class="field"><th class="field-name">Return type:</th><td class="field-body"><a title="celery.worker.TaskWrapper" class="reference internal" href="#celery.worker.TaskWrapper"><tt class="xref docutils literal"><span class="pre">TaskWrapper</span></tt></a> instance.</td>
+<tr class="field"><th class="field-name" colspan="2">Raises <a title="celery.worker.UnknownTask" class="reference internal" href="#celery.worker.UnknownTask">UnknownTask</a>:</th></tr>
+<tr><td>&nbsp;</td><td class="field-body">if the message does not describe a task,
+the message is also rejected.</td>
+</tr>
+<tr class="field"><th class="field-name">Returns:</th><td class="field-body"><a title="celery.worker.TaskWrapper" class="reference internal" href="#celery.worker.TaskWrapper"><tt class="xref docutils literal"><span class="pre">TaskWrapper</span></tt></a> instance.</td>
 </tr>
 </tbody>
 </table>
@@ -251,13 +324,34 @@ ignored.</dd></dl>
 
 <dl class="function">
 <dt id="celery.worker.jail">
-<tt class="descclassname">celery.worker.</tt><tt class="descname">jail</tt><big>(</big><em>task_id</em>, <em>callable_</em>, <em>args</em>, <em>kwargs</em><big>)</big><a class="headerlink" href="#celery.worker.jail" title="Permalink to this definition">¶</a></dt>
-<dd><p>Wraps the task in a jail which saves the status and result
-of the task execution to the task meta backend.</p>
-<p>If the call results in an exception, it saves the exception as the task
-result, and sets the task status to <tt class="docutils literal"><span class="pre">FAILURE</span></tt>.</p>
+<tt class="descclassname">celery.worker.</tt><tt class="descname">jail</tt><big>(</big><em>task_id</em>, <em>func</em>, <em>args</em>, <em>kwargs</em><big>)</big><a class="headerlink" href="#celery.worker.jail" title="Permalink to this definition">¶</a></dt>
+<dd><p>Wraps the task in a jail, which catches all exceptions, and 
+saves the status and result of the task execution to the task
+meta backend.</p>
 <p>If the call was successful, it saves the result to the task result
-backend, and sets the task status to <tt class="docutils literal"><span class="pre">DONE</span></tt>.</p>
+backend, and sets the task status to <tt class="docutils literal"><span class="pre">&quot;DONE&quot;</span></tt>.</p>
+<p>If the call results in an exception, it saves the exception as the task
+result, and sets the task status to <tt class="docutils literal"><span class="pre">&quot;FAILURE&quot;</span></tt>.</p>
+<table class="docutils field-list" frame="void" rules="none">
+<col class="field-name" />
+<col class="field-body" />
+<tbody valign="top">
+<tr class="field"><th class="field-name">Parameters:</th><td class="field-body"><ul class="first simple">
+<li><em>task_id</em> &#8211; The id of the task.</li>
+<li><em>func</em> &#8211; Callable object to execute.</li>
+<li><em>args</em> &#8211; List of positional args to pass on to the function.</li>
+<li><em>kwargs</em> &#8211; Keyword arguments mapping to pass on to the function.</li>
+</ul>
+</td>
+</tr>
+<tr class="field"><th class="field-name">Returns:</th><td class="field-body"><p class="first">the function return value on success.</p>
+</td>
+</tr>
+<tr class="field"><th class="field-name">Returns:</th><td class="field-body"><p class="first last">the exception instance on failure.</p>
+</td>
+</tr>
+</tbody>
+</table>
 </dd></dl>
 
 </div>

sources/reference/celery.conf.txt

@@ -6,53 +6,3 @@ Configuration - celery.conf
 
 .. automodule:: celery.conf
     :members:
-
-.. data:: AMQP_EXCHANGE
-
-    The AMQP exchange.
-
-.. data:: AMQP_ROUTING_KEY
-   
-    The AMQP routing key.
-
-.. data:: AMQP_CONSUMER_QUEUE
-   
-    The name of the AMQP queue.
-
-.. data:: DAEMON_CONCURRENCY
-   
-    The number of worker processes, that should work simultaenously.
-
-.. data:: DAEMON_PID_FILE
-   
-    Full path to the daemon pid file.
-
-.. data:: EMPTY_MSG_EMIT_EVERY
-   
-    How often the celery daemon should write a log message saying there are no
-    messages in the queue. If this is ``None`` or ``0``, it will never print
-    this message.
-
-.. data:: QUEUE_WAKEUP_AFTER
-   
-    The time (in seconds) the celery daemon should sleep when there are no messages
-    left on the queue. After the time is slept, the worker wakes up and
-    checks the queue again.
-
-.. data:: DAEMON_LOG_LEVEL
-   
-    Celery daemon log level, could be any of ``DEBUG``, ``INFO``, ``WARNING``,
-    ``ERROR``, ``CRITICAL``, or ``FATAL``.
-
-.. data:: DAEMON_LOG_FILE
-   
-    The path to the deamon log file (if not set, ``stderr`` is used).
-
-.. data:: LOG_FORMAT
-   
-    The format to use for log messages.
-    Default is ``[%(asctime)s: %(levelname)s/%(processName)s] %(message)s``
-
-.. data:: LOG_LEVELS
-   
-    Mapping of log level names to ``logging`` module constants.