Autogenerated documentation for github.

genindex.html

@@ -94,8 +94,8 @@
 <dt><a href="reference/celery.discovery.html#module-celery.discovery">celery.discovery (module)</a></dt>
 <dt><a href="reference/celery.log.html#module-celery.log">celery.log (module)</a></dt>
 <dt><a href="reference/celery.managers.html#module-celery.managers">celery.managers (module)</a></dt>
-<dt><a href="reference/celery.messaging.html#module-celery.messaging">celery.messaging (module)</a></dt></dl></td><td width="33%" valign="top"><dl>
-<dt><a href="reference/celery.platform.html#module-celery.platform">celery.platform (module)</a></dt>
+<dt><a href="reference/celery.messaging.html#module-celery.messaging">celery.messaging (module)</a></dt>
+<dt><a href="reference/celery.platform.html#module-celery.platform">celery.platform (module)</a></dt></dl></td><td width="33%" valign="top"><dl>
 <dt><a href="reference/celery.registry.html#module-celery.registry">celery.registry (module)</a></dt>
 <dt><a href="reference/celery.result.html#module-celery.result">celery.result (module)</a></dt>
 <dt><a href="reference/celery.task.html#module-celery.task">celery.task (module)</a></dt>
@@ -106,6 +106,8 @@
   <dd><dl>
     <dt><a href="reference/celery.backends.database.html#celery.backends.database.Backend.cleanup">(celery.backends.database.Backend method)</a></dt>
   </dl></dd>
+<dt><a href="reference/celery.worker.html#celery.worker.TaskDaemon.concurrency">concurrency (celery.worker.TaskDaemon attribute)</a></dt>
+<dt><a href="reference/celery.worker.html#celery.worker.TaskDaemon.connection_diagnostics">connection_diagnostics() (celery.worker.TaskDaemon method)</a></dt>
 </dl></td></tr></table>
 
 <h2 id="D">D</h2>
@@ -141,10 +143,13 @@
 <dl>
 
 <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.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>
 <dt><a href="reference/celery.worker.html#celery.worker.TaskWrapper.execute">execute() (celery.worker.TaskWrapper method)</a></dt></dl></td><td width="33%" valign="top"><dl>
+<dt><a href="reference/celery.worker.html#celery.worker.TaskDaemon.execute_next_task">execute_next_task() (celery.worker.TaskDaemon method)</a></dt>
 <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>
@@ -155,6 +160,7 @@
 <table width="100%" class="indextable"><tr><td width="33%" valign="top">
 <dl>
 
+<dt><a href="reference/celery.worker.html#celery.worker.TaskDaemon.fetch_next_task">fetch_next_task() (celery.worker.TaskDaemon method)</a></dt>
 <dt><a href="reference/celery.registry.html#celery.registry.TaskRegistry.filter_types">filter_types() (celery.registry.TaskRegistry method)</a></dt>
 <dt><a href="reference/celery.discovery.html#celery.discovery.find_related_module">find_related_module() (in module celery.discovery)</a></dt></dl></td><td width="33%" valign="top"><dl>
 <dt><a href="reference/celery.worker.html#celery.worker.TaskWrapper.from_message">from_message() (celery.worker.TaskWrapper class method)</a></dt>
@@ -181,6 +187,7 @@
     <dt><a href="reference/celery.backends.database.html#celery.backends.database.Backend.get_result">(celery.backends.database.Backend method)</a></dt>
     <dt><a href="reference/celery.backends.tyrant.html#celery.backends.tyrant.Backend.get_result">(celery.backends.tyrant.Backend method)</a></dt>
   </dl></dd></dl></td><td width="33%" valign="top"><dl>
+<dt><a href="reference/celery.backends.tyrant.html#celery.backends.tyrant.Backend.get_server">get_server() (celery.backends.tyrant.Backend method)</a></dt>
 <dt><a href="reference/celery.backends.base.html#celery.backends.base.BaseBackend.get_status">get_status() (celery.backends.base.BaseBackend method)</a></dt>
   <dd><dl>
     <dt><a href="reference/celery.backends.cache.html#celery.backends.cache.Backend.get_status">(celery.backends.cache.Backend method)</a></dt>
@@ -198,6 +205,7 @@
 <table width="100%" class="indextable"><tr><td width="33%" valign="top">
 <dl>
 
+<dt><a href="reference/celery.timer.html#celery.timer.EventTimer.interval">interval (celery.timer.EventTimer attribute)</a></dt>
 <dt><a href="reference/celery.backends.base.html#celery.backends.base.BaseBackend.is_done">is_done() (celery.backends.base.BaseBackend method)</a></dt>
   <dd><dl>
     <dt><a href="reference/celery.backends.cache.html#celery.backends.cache.Backend.is_done">(celery.backends.cache.Backend method)</a></dt>
@@ -223,8 +231,12 @@
 <dl>
 
 <dt><a href="reference/celery.models.html#PeriodicTaskMeta.last_run_at">last_run_at (PeriodicTaskMeta attribute)</a></dt>
-<dt><a href="reference/celery.conf.html#celery.conf.LOG_FORMAT">LOG_FORMAT (in module celery.conf)</a></dt></dl></td><td width="33%" valign="top"><dl>
-<dt><a href="reference/celery.conf.html#celery.conf.LOG_LEVELS">LOG_LEVELS (in module celery.conf)</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.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.worker.html#celery.worker.TaskDaemon.logfile">logfile (celery.worker.TaskDaemon attribute)</a></dt>
+<dt><a href="reference/celery.worker.html#celery.worker.TaskDaemon.logger">logger (celery.worker.TaskDaemon attribute)</a></dt>
+<dt><a href="reference/celery.worker.html#celery.worker.TaskDaemon.loglevel">loglevel (celery.worker.TaskDaemon attribute)</a></dt>
 </dl></td></tr></table>
 
 <h2 id="M">M</h2>
@@ -259,8 +271,9 @@
 
 <dt><a href="reference/celery.task.html#celery.task.PeriodicTask">PeriodicTask (class in celery.task)</a></dt>
 <dt><a href="reference/celery.managers.html#celery.managers.PeriodicTaskManager">PeriodicTaskManager (class in celery.managers)</a></dt>
-<dt><a href="reference/celery.models.html#PeriodicTaskMeta">PeriodicTaskMeta (built-in class)</a></dt></dl></td><td width="33%" valign="top"><dl>
-<dt><a href="reference/celery.platform.html#celery.platform.PIDFile">PIDFile (class in celery.platform)</a></dt>
+<dt><a href="reference/celery.models.html#PeriodicTaskMeta">PeriodicTaskMeta (built-in class)</a></dt>
+<dt><a href="reference/celery.platform.html#celery.platform.PIDFile">PIDFile (class in celery.platform)</a></dt></dl></td><td width="33%" valign="top"><dl>
+<dt><a href="reference/celery.worker.html#celery.worker.TaskDaemon.pool">pool (celery.worker.TaskDaemon attribute)</a></dt>
 <dt><a href="reference/celery.backends.base.html#celery.backends.base.BaseBackend.prepare_result">prepare_result() (celery.backends.base.BaseBackend method)</a></dt>
 </dl></td></tr></table>
 
@@ -268,6 +281,7 @@
 <table width="100%" class="indextable"><tr><td width="33%" valign="top">
 <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>
 </dl></td></tr></table>
 
@@ -276,15 +290,18 @@
 <dl>
 
 <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.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></td><td width="33%" valign="top"><dl>
+  </dl></dd>
 <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>
@@ -320,6 +337,7 @@
 
 <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.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>
@@ -334,9 +352,9 @@
 <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></dl></td><td width="33%" valign="top"><dl>
+<dt><a href="reference/celery.models.html#TaskMeta">TaskMeta (built-in class)</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">TaskRegistry (class in celery.registry)</a></dt></dl></td><td width="33%" valign="top"><dl>
 <dt><a href="reference/celery.registry.html#celery.registry.TaskRegistry.AlreadyRegistered">TaskRegistry.AlreadyRegistered</a></dt>
 <dt><a href="reference/celery.registry.html#celery.registry.TaskRegistry.NotRegistered">TaskRegistry.NotRegistered</a></dt>
 <dt><a href="reference/celery.registry.html#celery.registry.tasks">tasks (in module celery.registry)</a></dt>
@@ -346,11 +364,15 @@
   <dd><dl>
     <dt><a href="reference/celery.timer.html#celery.timer.TimeoutTimer.tick">(celery.timer.TimeoutTimer method)</a></dt>
   </dl></dd>
+<dt><a href="reference/celery.timer.html#celery.timer.TimeoutTimer.time_start">time_start (celery.timer.TimeoutTimer attribute)</a></dt>
+<dt><a href="reference/celery.timer.html#celery.timer.TimeoutTimer.timeout">timeout (celery.timer.TimeoutTimer attribute)</a></dt>
 <dt><a href="reference/celery.timer.html#celery.timer.TimeoutError">TimeoutError</a></dt>
 <dt><a href="reference/celery.timer.html#celery.timer.TimeoutTimer">TimeoutTimer (class in celery.timer)</a></dt>
 <dt><a href="reference/celery.models.html#PeriodicTaskMeta.total_run_count">total_run_count (PeriodicTaskMeta attribute)</a></dt>
 <dt><a href="reference/celery.backends.tyrant.html#celery.backends.tyrant.TT_HOST">TT_HOST (in module celery.backends.tyrant)</a></dt>
 <dt><a href="reference/celery.backends.tyrant.html#celery.backends.tyrant.TT_PORT">TT_PORT (in module celery.backends.tyrant)</a></dt>
+<dt><a href="reference/celery.backends.tyrant.html#celery.backends.tyrant.Backend.tyrant_host">tyrant_host (celery.backends.tyrant.Backend attribute)</a></dt>
+<dt><a href="reference/celery.backends.tyrant.html#celery.backends.tyrant.Backend.tyrant_port">tyrant_port (celery.backends.tyrant.Backend attribute)</a></dt>
 </dl></td></tr></table>
 
 <h2 id="U">U</h2>

objects.inv

@@ -24,7 +24,7 @@ celery.messaging.NoProcessConsumer class reference/celery.messaging.html
 celery.task.mark_as_done function reference/celery.task.html
 celery.result.BaseAsyncResult.is_done method reference/celery.result.html
 celery.worker.TaskWrapper.execute method reference/celery.worker.html
-celery.backends.base.BaseBackend.mark_as_done method reference/celery.backends.base.html
+celery.backends.tyrant.Backend.tyrant_port attribute reference/celery.backends.tyrant.html
 celery.task.delay_task function reference/celery.task.html
 celery.registry.AlreadyRegistered exception reference/celery.registry.html
 TASK_STATUS_FAILURE data reference/celery.models.html
@@ -34,11 +34,14 @@ celery.discovery.find_related_module function reference/celery.discovery.html
 celery.backends.tyrant.TT_PORT data reference/celery.backends.tyrant.html
 celery.result.BaseAsyncResult.ready method reference/celery.result.html
 celery.worker.EmptyQueue exception reference/celery.worker.html
+celery.worker.TaskDaemon.fetch_next_task method reference/celery.worker.html
 celery.registry.TaskRegistry.AlreadyRegistered exception reference/celery.registry.html
 celery.managers.TaskManager.delete_expired method reference/celery.managers.html
 celery.registry.TaskRegistry.filter_types method reference/celery.registry.html
+celery.worker.TaskDaemon.receive_message method reference/celery.worker.html
 celery.conf.AMQP_CONSUMER_QUEUE data reference/celery.conf.html
 celery.task.DeleteExpiredTaskMetaTask class reference/celery.task.html
+celery.worker.TaskDaemon.connection_diagnostics method reference/celery.worker.html
 celery.managers.TaskManager.get_all_expired method reference/celery.managers.html
 TaskMeta.task_id attribute reference/celery.models.html
 celery.platform.PIDFile.get_pid method reference/celery.platform.html
@@ -46,8 +49,10 @@ celery.worker.TaskDaemon class reference/celery.worker.html
 celery.backends.get_default_backend_cls function reference/celery.backends.html
 celery.backends.tyrant.Backend.get_result method reference/celery.backends.tyrant.html
 celery.task.TaskSet class reference/celery.task.html
+celery.worker.TaskDaemon.loglevel attribute reference/celery.worker.html
 celery.task.AsynchronousMapTask class reference/celery.task.html
 celery.managers.PeriodicTaskManager class reference/celery.managers.html
+celery.timer.EventTimer.event attribute reference/celery.timer.html
 TaskMeta class reference/celery.models.html
 celery.worker.TaskWrapper.from_message classmethod reference/celery.worker.html
 celery.timer.TimeoutError exception reference/celery.timer.html
@@ -60,7 +65,7 @@ celery.platform.PIDFile.remove method reference/celery.platform.html
 PeriodicTaskMeta.task attribute reference/celery.models.html
 celery.log.setup_logger function reference/celery.log.html
 celery.backends.base.BaseBackend.wait_for method reference/celery.backends.base.html
-celery.result.AsyncResult class reference/celery.result.html
+celery.backends.base.BaseBackend.mark_as_done method reference/celery.backends.base.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
@@ -81,17 +86,22 @@ celery.backends.base.BaseBackend.prepare_result method reference/celery.backends
 celery.task.execute_remote function reference/celery.task.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.worker.jail function reference/celery.worker.html
 celery.result.AsyncResult.task_id attribute reference/celery.result.html
+celery.timer.EventTimer.interval attribute reference/celery.timer.html
 celery.result.BaseAsyncResult.successful method reference/celery.result.html
+celery.backends.tyrant.Backend.get_server method reference/celery.backends.tyrant.html
 celery.conf.LOG_FORMAT data reference/celery.conf.html
 TASK_STATUSES data reference/celery.models.html
 celery.managers.TaskManager.get_task method reference/celery.managers.html
 celery.conf.AMQP_EXCHANGE data reference/celery.conf.html
 celery.registry.tasks data reference/celery.registry.html
+celery.worker.TaskDaemon.task_consumer attribute reference/celery.worker.html
 celery.conf.AMQP_ROUTING_KEY data reference/celery.conf.html
+celery.timer.TimeoutTimer.timeout attribute reference/celery.timer.html
 celery.result.AsyncResult.backend attribute reference/celery.result.html
 celery.backends.database.Backend.cleanup method reference/celery.backends.database.html
 celery.conf.DAEMON_LOG_LEVEL data reference/celery.conf.html
@@ -111,10 +121,13 @@ celery.task.PeriodicTask class reference/celery.task.html
 celery.registry.TaskRegistry.unregister method reference/celery.registry.html
 celery.task.TaskSet.remote_execute classmethod reference/celery.task.html
 TaskMeta.date_done attribute reference/celery.models.html
+celery.worker.TaskDaemon.execute_next_task method reference/celery.worker.html
+celery.result.AsyncResult class reference/celery.result.html
 PeriodicTaskMeta.name attribute reference/celery.models.html
 celery.task.mark_as_failure function reference/celery.task.html
 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.result.BaseAsyncResult.task_id attribute reference/celery.result.html
 celery.backends.cache.Backend.is_done method reference/celery.backends.cache.html
@@ -128,6 +141,7 @@ celery.managers.PeriodicTaskManager.get_waiting_tasks method reference/celery.ma
 celery.messaging.TaskPublisher.delay_task method reference/celery.messaging.html
 celery.task.TaskSet.join method reference/celery.task.html
 celery.registry.TaskRegistry.get_all_regular method reference/celery.registry.html
+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
 PeriodicTaskMeta.total_run_count attribute reference/celery.models.html
@@ -135,16 +149,21 @@ 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
 celery.task.TaskSet.run method reference/celery.task.html
+celery.worker.TaskDaemon.reset_connection method reference/celery.worker.html
 PeriodicTaskMeta.delay method reference/celery.models.html
 celery.worker.TaskDaemon.run_periodic_tasks method reference/celery.worker.html
 celery.result.BaseAsyncResult.result attribute reference/celery.result.html
+celery.worker.TaskDaemon.queue_wakeup_after attribute reference/celery.worker.html
 celery.backends.cache.Backend.store_result method reference/celery.backends.cache.html
 TaskMeta.status attribute reference/celery.models.html
 celery.backends.database.Backend.is_done method reference/celery.backends.database.html
+celery.backends.tyrant.Backend.tyrant_host attribute reference/celery.backends.tyrant.html
 celery.backends.tyrant.Backend class reference/celery.backends.tyrant.html
 TASK_STATUSES_CHOICES data reference/celery.models.html
 celery.backends.base.BaseBackend.mark_as_retry method reference/celery.backends.base.html
+celery.timer.EventTimer.last_triggered attribute reference/celery.timer.html
 TASK_STATUS_DONE data reference/celery.models.html
+celery.worker.TaskDaemon.concurrency attribute reference/celery.worker.html
 celery.backends.cache.Backend class reference/celery.backends.cache.html
 celery.task.is_done function reference/celery.task.html
 celery.conf.LOG_LEVELS data reference/celery.conf.html
@@ -155,11 +174,13 @@ celery.backends.cache.Backend.get_status method reference/celery.backends.cache.
 celery.conf.EMPTY_MSG_EMIT_EVERY data reference/celery.conf.html
 celery.registry.NotRegistered exception reference/celery.registry.html
 celery.conf.DAEMON_CONCURRENCY data reference/celery.conf.html
+celery.worker.TaskDaemon.empty_msg_emit_every attribute reference/celery.worker.html
 celery.registry.TaskRegistry.get_all method reference/celery.registry.html
 celery.backends.tyrant.Backend.store_result method reference/celery.backends.tyrant.html
 celery.timer.TimeoutTimer.tick method reference/celery.timer.html
 TASK_STATUS_PENDING data reference/celery.models.html
 celery.result.BaseAsyncResult.get method reference/celery.result.html
+celery.worker.TaskDaemon.logfile attribute reference/celery.worker.html
 celery.conf.DAEMON_PID_FILE data reference/celery.conf.html
 celery.task.Task class reference/celery.task.html
 celery.backends.base.BaseBackend.get_status method reference/celery.backends.base.html
@@ -173,3 +194,4 @@ celery.messaging.TaskConsumer class reference/celery.messaging.html
 celery.platform.daemonize function reference/celery.platform.html
 celery.managers.TaskManager.store_result method reference/celery.managers.html
 TaskMeta.result attribute reference/celery.models.html
+celery.timer.TimeoutTimer.time_start attribute reference/celery.timer.html

reference/celery.backends.tyrant.html

@@ -68,13 +68,29 @@
 <dl class="class">
 <dt id="celery.backends.tyrant.Backend">
 <em class="property">
-class </em><tt class="descclassname">celery.backends.tyrant.</tt><tt class="descname">Backend</tt><big>(</big><em>*args</em>, <em>**kwargs</em><big>)</big><a class="headerlink" href="#celery.backends.tyrant.Backend" title="Permalink to this definition">¶</a></dt>
+class </em><tt class="descclassname">celery.backends.tyrant.</tt><tt class="descname">Backend</tt><big>(</big><em>tyrant_host=None</em>, <em>tyrant_port=None</em><big>)</big><a class="headerlink" href="#celery.backends.tyrant.Backend" title="Permalink to this definition">¶</a></dt>
 <dd><p>Tokyo Cabinet based task backend store.</p>
+<dl class="attribute">
+<dt id="celery.backends.tyrant.Backend.tyrant_host">
+<tt class="descname">tyrant_host</tt><a class="headerlink" href="#celery.backends.tyrant.Backend.tyrant_host" title="Permalink to this definition">¶</a></dt>
+<dd>The hostname to the Tokyo Tyrant server.</dd></dl>
+
+<dl class="attribute">
+<dt id="celery.backends.tyrant.Backend.tyrant_port">
+<tt class="descname">tyrant_port</tt><a class="headerlink" href="#celery.backends.tyrant.Backend.tyrant_port" title="Permalink to this definition">¶</a></dt>
+<dd>The port to the Tokyo Tyrant server.</dd></dl>
+
 <dl class="method">
 <dt id="celery.backends.tyrant.Backend.get_result">
 <tt class="descname">get_result</tt><big>(</big><em>task_id</em><big>)</big><a class="headerlink" href="#celery.backends.tyrant.Backend.get_result" title="Permalink to this definition">¶</a></dt>
 <dd>Get the result of a task.</dd></dl>
 
+<dl class="method">
+<dt id="celery.backends.tyrant.Backend.get_server">
+<tt class="descname">get_server</tt><big>(</big><big>)</big><a class="headerlink" href="#celery.backends.tyrant.Backend.get_server" title="Permalink to this definition">¶</a></dt>
+<dd>Get <tt class="xref docutils literal"><span class="pre">pytyrant.PyTyrant`</span></tt> instance with the current
+server configuration.</dd></dl>
+
 <dl class="method">
 <dt id="celery.backends.tyrant.Backend.get_status">
 <tt class="descname">get_status</tt><big>(</big><em>task_id</em><big>)</big><a class="headerlink" href="#celery.backends.tyrant.Backend.get_status" title="Permalink to this definition">¶</a></dt>

reference/celery.result.html

@@ -91,14 +91,32 @@ class </em><tt class="descclassname">celery.result.</tt><tt class="descname">Bas
 <dl class="method">
 <dt id="celery.result.BaseAsyncResult.is_done">
 <tt class="descname">is_done</tt><big>(</big><big>)</big><a class="headerlink" href="#celery.result.BaseAsyncResult.is_done" title="Permalink to this definition">¶</a></dt>
-<dd>Returns <tt class="xref docutils literal"><span class="pre">True</span></tt> if the task executed successfully.</dd></dl>
+<dd><p>Returns <tt class="xref docutils literal"><span class="pre">True</span></tt> if the task executed successfully.</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">bool</td>
+</tr>
+</tbody>
+</table>
+</dd></dl>
 
 <dl class="method">
 <dt id="celery.result.BaseAsyncResult.ready">
 <tt class="descname">ready</tt><big>(</big><big>)</big><a class="headerlink" href="#celery.result.BaseAsyncResult.ready" title="Permalink to this definition">¶</a></dt>
-<dd>Returns <tt class="xref docutils literal"><span class="pre">True</span></tt> if the task executed successfully, or raised
+<dd><p>Returns <tt class="xref docutils literal"><span class="pre">True</span></tt> if the task executed successfully, or raised
 an exception. If the task is still pending, or is waiting for retry
-then <tt class="xref docutils literal"><span class="pre">False</span></tt> is returned.</dd></dl>
+then <tt class="xref docutils literal"><span class="pre">False</span></tt> is returned.</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">bool</td>
+</tr>
+</tbody>
+</table>
+</dd></dl>
 
 <dl class="attribute">
 <dt id="celery.result.BaseAsyncResult.result">

reference/celery.task.html

@@ -142,7 +142,16 @@ name of the task.</p>
 <dt id="celery.task.Task.delay">
 <em class="property">
 classmethod </em><tt class="descname">delay</tt><big>(</big><em>*args</em>, <em>**kwargs</em><big>)</big><a class="headerlink" href="#celery.task.Task.delay" title="Permalink to this definition">¶</a></dt>
-<dd>Delay this task for execution by the <tt class="docutils literal"><span class="pre">celery</span></tt> daemon(s).</dd></dl>
+<dd><p>Delay this task for execution by the <tt class="docutils literal"><span class="pre">celery</span></tt> daemon(s).</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.result.AsyncResult" class="reference external" href="celery.result.html#celery.result.AsyncResult"><tt class="xref docutils literal"><span class="pre">celery.result.AsyncResult</span></tt></a></td>
+</tr>
+</tbody>
+</table>
+</dd></dl>
 
 <dl class="method">
 <dt id="celery.task.Task.get_consumer">
@@ -256,9 +265,23 @@ celery server(s).</dd></dl>
 <dt id="celery.task.delay_task">
 <tt class="descclassname">celery.task.</tt><tt class="descname">delay_task</tt><big>(</big><em>task_name</em>, <em>*args</em>, <em>**kwargs</em><big>)</big><a class="headerlink" href="#celery.task.delay_task" title="Permalink to this definition">¶</a></dt>
 <dd><p>Delay a task for execution by the <tt class="docutils literal"><span class="pre">celery</span></tt> daemon.</p>
-<div class="highlight-python"><div class="highlight"><pre><span class="gp">&gt;&gt;&gt; </span><span class="n">delay_task</span><span class="p">(</span><span class="s">&quot;update_record&quot;</span><span class="p">,</span> <span class="n">name</span><span class="o">=</span><span class="s">&quot;George Constanza&quot;</span><span class="p">,</span> <span class="n">age</span><span class="o">=</span><span class="mf">32</span><span class="p">)</span>
+<div class="highlight-python"><div class="highlight"><pre><span class="gp">&gt;&gt;&gt; </span><span class="n">r</span> <span class="o">=</span> <span class="n">delay_task</span><span class="p">(</span><span class="s">&quot;update_record&quot;</span><span class="p">,</span> <span class="n">name</span><span class="o">=</span><span class="s">&quot;George Constanza&quot;</span><span class="p">,</span> <span class="n">age</span><span class="o">=</span><span class="mf">32</span><span class="p">)</span>
+<span class="gp">&gt;&gt;&gt; </span><span class="n">r</span><span class="o">.</span><span class="n">ready</span><span class="p">()</span>
+<span class="go">True</span>
+<span class="gp">&gt;&gt;&gt; </span><span class="n">r</span><span class="o">.</span><span class="n">result</span>
+<span class="go">&quot;Record was updated&quot;</span>
 </pre></div>
 </div>
+<p>Raises <a title="celery.registry.NotRegistered" class="reference external" href="celery.registry.html#celery.registry.NotRegistered"><tt class="xref docutils literal"><span class="pre">celery.registry.NotRegistered</span></tt></a> exception if no such task 
+has been registered in the task registry.</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.result.AsyncResult" class="reference external" href="celery.result.html#celery.result.AsyncResult"><tt class="xref docutils literal"><span class="pre">celery.result.AsyncResult</span></tt></a>.</td>
+</tr>
+</tbody>
+</table>
 </dd></dl>
 
 <dl class="function">
@@ -268,6 +291,14 @@ celery server(s).</dd></dl>
 <p>This will ignore all tasks waiting for execution, and they will
 be deleted from the messaging server.</p>
 <p>Returns the number of tasks discarded.</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">int</td>
+</tr>
+</tbody>
+</table>
 </dd></dl>
 
 <dl class="function">
@@ -307,12 +338,29 @@ asynchronously.</p>
 <dd><p>Execute arbitrary function/object remotely.</p>
 <p>The object must be picklable, so you can&#8217;t use lambdas or functions
 defined in the REPL (the objects must have an associated module).</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.result.AsyncResult" class="reference external" href="celery.result.html#celery.result.AsyncResult"><tt class="xref docutils literal"><span class="pre">celery.result.AsyncResult</span></tt></a></td>
+</tr>
+</tbody>
+</table>
 </dd></dl>
 
 <dl class="function">
 <dt id="celery.task.is_done">
 <tt class="descclassname">celery.task.</tt><tt class="descname">is_done</tt><big>(</big><em>task_id</em><big>)</big><a class="headerlink" href="#celery.task.is_done" title="Permalink to this definition">¶</a></dt>
-<dd>Returns <tt class="xref docutils literal"><span class="pre">True</span></tt> if task with <tt class="docutils literal"><span class="pre">task_id</span></tt> has been executed.</dd></dl>
+<dd><p>Returns <tt class="xref docutils literal"><span class="pre">True</span></tt> if task with <tt class="docutils literal"><span class="pre">task_id</span></tt> has been executed.</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">bool</td>
+</tr>
+</tbody>
+</table>
+</dd></dl>
 
 <dl class="function">
 <dt id="celery.task.mark_as_done">

reference/celery.timer.html

@@ -56,6 +56,21 @@
 <em class="property">
 class </em><tt class="descclassname">celery.timer.</tt><tt class="descname">EventTimer</tt><big>(</big><em>event</em>, <em>interval=None</em><big>)</big><a class="headerlink" href="#celery.timer.EventTimer" title="Permalink to this definition">¶</a></dt>
 <dd><p>Do something at an interval.</p>
+<dl class="attribute">
+<dt id="celery.timer.EventTimer.interval">
+<tt class="descname">interval</tt><a class="headerlink" href="#celery.timer.EventTimer.interval" title="Permalink to this definition">¶</a></dt>
+<dd>How often we call the event (in seconds).</dd></dl>
+
+<dl class="attribute">
+<dt id="celery.timer.EventTimer.event">
+<tt class="descname">event</tt><a class="headerlink" href="#celery.timer.EventTimer.event" title="Permalink to this definition">¶</a></dt>
+<dd>The event callable to run every <tt class="docutils literal"><span class="pre">interval</span></tt> seconds.</dd></dl>
+
+<dl class="attribute">
+<dt id="celery.timer.EventTimer.last_triggered">
+<tt class="descname">last_triggered</tt><a class="headerlink" href="#celery.timer.EventTimer.last_triggered" title="Permalink to this definition">¶</a></dt>
+<dd>The last time, in unix timestamp format, the event was executed.</dd></dl>
+
 <dl class="method">
 <dt id="celery.timer.EventTimer.tick">
 <tt class="descname">tick</tt><big>(</big><big>)</big><a class="headerlink" href="#celery.timer.EventTimer.tick" title="Permalink to this definition">¶</a></dt>
@@ -76,7 +91,18 @@ exception </em><tt class="descclassname">celery.timer.</tt><tt class="descname">
 <dt id="celery.timer.TimeoutTimer">
 <em class="property">
 class </em><tt class="descclassname">celery.timer.</tt><tt class="descname">TimeoutTimer</tt><big>(</big><em>timeout</em><big>)</big><a class="headerlink" href="#celery.timer.TimeoutTimer" title="Permalink to this definition">¶</a></dt>
-<dd><p>A timer that raises <tt class="docutils literal"><span class="pre">TimeoutError</span></tt> when the time has run out.</p>
+<dd><p>A timer that raises <a title="celery.timer.TimeoutError" class="reference internal" href="#celery.timer.TimeoutError"><tt class="xref docutils literal"><span class="pre">TimeoutError</span></tt></a> exception when the
+time has run out.</p>
+<dl class="attribute">
+<dt id="celery.timer.TimeoutTimer.timeout">
+<tt class="descname">timeout</tt><a class="headerlink" href="#celery.timer.TimeoutTimer.timeout" title="Permalink to this definition">¶</a></dt>
+<dd>The timeout in seconds.</dd></dl>
+
+<dl class="attribute">
+<dt id="celery.timer.TimeoutTimer.time_start">
+<tt class="descname">time_start</tt><a class="headerlink" href="#celery.timer.TimeoutTimer.time_start" title="Permalink to this definition">¶</a></dt>
+<dd>The time when the timeout timer instance was constructed.</dd></dl>
+
 <dl class="method">
 <dt id="celery.timer.TimeoutTimer.tick">
 <tt class="descname">tick</tt><big>(</big><big>)</big><a class="headerlink" href="#celery.timer.TimeoutTimer.tick" title="Permalink to this definition">¶</a></dt>

reference/celery.worker.html

@@ -62,7 +62,110 @@ 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>
-<p><tt class="docutils literal"><span class="pre">concurrency</span></tt> is the number of simultaneous processes.</p>
+<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>
+
+<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>
+
+<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>
+
+<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>
+
+<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.
+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>
+
+<dl class="attribute">
+<dt id="celery.worker.TaskDaemon.logger">
+<tt class="descname">logger</tt><a class="headerlink" href="#celery.worker.TaskDaemon.logger" title="Permalink to this definition">¶</a></dt>
+<dd>The <tt class="xref docutils literal"><span class="pre">logging.Logger</span></tt> instance used for logging.</dd></dl>
+
+<dl class="attribute">
+<dt id="celery.worker.TaskDaemon.pool">
+<tt class="descname">pool</tt><a class="headerlink" href="#celery.worker.TaskDaemon.pool" title="Permalink to this definition">¶</a></dt>
+<dt>
+<tt class="descname">The :class:`multiprocessing.Pool` instance used.</tt></dt>
+<dd></dd></dl>
+
+<dl class="attribute">
+<dt id="celery.worker.TaskDaemon.task_consumer">
+<tt class="descname">task_consumer</tt><a class="headerlink" href="#celery.worker.TaskDaemon.task_consumer" title="Permalink to this definition">¶</a></dt>
+<dd>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 used.</dd></dl>
+
+<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>
+
+<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></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 :class`EmptyQueue` exception if there is no messages
+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>
+</tbody>
+</table>
+</dd></dl>
+
+<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>
+<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">
+<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">carrot.messaging.Message</span></tt> instance.</td>
+</tr>
+</tbody>
+</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>
+
 <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>
@@ -72,7 +175,14 @@ class </em><tt class="descclassname">celery.worker.</tt><tt class="descname">Tas
 <dt id="celery.worker.TaskDaemon.run_periodic_tasks">
 <tt class="descname">run_periodic_tasks</tt><big>(</big><big>)</big><a class="headerlink" href="#celery.worker.TaskDaemon.run_periodic_tasks" title="Permalink to this definition">¶</a></dt>
 <dd><p>Schedule all waiting periodic tasks for execution.</p>
-<p>Returns list of <tt class="xref docutils literal"><span class="pre">celery.models.PeriodicTaskMeta</span></tt> objects.</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">list of <tt class="xref docutils literal"><span class="pre">celery.models.PeriodicTaskMeta</span></tt> objects.</td>
+</tr>
+</tbody>
+</table>
 </dd></dl>
 
 <dl class="method">
@@ -96,7 +206,16 @@ in the task meta backend.</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>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.</dd></dl>
+<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>
+<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>
+</tbody>
+</table>
+</dd></dl>
 
 <dl class="method">
 <dt id="celery.worker.TaskWrapper.extend_kwargs_with_logging">
@@ -109,8 +228,19 @@ 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>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>.</dd></dl>
+<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>
+<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>
+</tbody>
+</table>
+</dd></dl>
 
 </dd></dl>
 
@@ -124,8 +254,13 @@ 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>Wraps the task in a jail which saves the status and result
-of the task execution to the task meta backend.</dd></dl>
+<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>
+<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>
+</dd></dl>
 
 </div>