Переглянути джерело

Autogenerated documentation for github.

Ask Solem 15 роки тому
батько
коміт
16b711b1c6

+ 5 - 5
changelog.html

@@ -21,7 +21,7 @@
     <script type="text/javascript" src="static/doctools.js"></script>
     <link rel="top" title="Celery v0.7.0 (unstable) documentation" href="index.html" />
     <link rel="next" title="Interesting Links" href="links.html" />
-    <link rel="prev" title="Celery Worker Daemon - celery.bin.celeryd" href="reference/celery.bin.celeryd.html" /> 
+    <link rel="prev" title="Celery Initialize - celery.bin.celeryinit" href="reference/celery.bin.celeryinit.html" /> 
   </head>
   <body>
     <div class="related">
@@ -37,7 +37,7 @@
           <a href="links.html" title="Interesting Links"
              accesskey="N">next</a> |</li>
         <li class="right" >
-          <a href="reference/celery.bin.celeryd.html" title="Celery Worker Daemon - celery.bin.celeryd"
+          <a href="reference/celery.bin.celeryinit.html" title="Celery Initialize - celery.bin.celeryinit"
              accesskey="P">previous</a> |</li>
         <li><a href="index.html">Celery v0.7.0 (unstable) documentation</a> &raquo;</li> 
       </ul>
@@ -660,8 +660,8 @@ the name change request is in <tt class="docutils literal"><span class="pre">doc
 </ul>
 
             <h4>Previous topic</h4>
-            <p class="topless"><a href="reference/celery.bin.celeryd.html"
-                                  title="previous chapter">Celery Worker Daemon - celery.bin.celeryd</a></p>
+            <p class="topless"><a href="reference/celery.bin.celeryinit.html"
+                                  title="previous chapter">Celery Initialize - celery.bin.celeryinit</a></p>
             <h4>Next topic</h4>
             <p class="topless"><a href="links.html"
                                   title="next chapter">Interesting Links</a></p>
@@ -700,7 +700,7 @@ the name change request is in <tt class="docutils literal"><span class="pre">doc
           <a href="links.html" title="Interesting Links"
              >next</a> |</li>
         <li class="right" >
-          <a href="reference/celery.bin.celeryd.html" title="Celery Worker Daemon - celery.bin.celeryd"
+          <a href="reference/celery.bin.celeryinit.html" title="Celery Initialize - celery.bin.celeryinit"
              >previous</a> |</li>
         <li><a href="index.html">Celery v0.7.0 (unstable) documentation</a> &raquo;</li> 
       </ul>

+ 1 - 1
cookbook/task-retries.html

@@ -71,7 +71,7 @@ attribute.</p>
 is available as the tombstone (result) of the task, when
 <a title="celery.task.base.Task.max_retries" class="reference external" href="../reference/celery.task.base.html#celery.task.base.Task.max_retries"><tt class="xref docutils literal"><span class="pre">celery.task.base.Task.max_retries</span></tt></a> has been exceeded this is the exception
 raised. However, if an <tt class="docutils literal"><span class="pre">exc</span></tt> argument is not provided the
-<a title="celery.task.base.RetryTaskError" class="reference external" href="../reference/celery.task.base.html#celery.task.base.RetryTaskError"><tt class="xref docutils literal"><span class="pre">celery.task.base.RetryTaskError</span></tt></a> exception is raised instead.</p>
+<tt class="xref docutils literal"><span class="pre">celery.task.base.RetryTaskError</span></tt> exception is raised instead.</p>
 </div>
 <div class="section" id="setting-a-custom-delay-for-retries">
 <h2>Setting a custom delay for retries.<a class="headerlink" href="#setting-a-custom-delay-for-retries" title="Permalink to this headline">¶</a></h2>

+ 43 - 41
genindex.html

@@ -113,7 +113,7 @@
 <dt><a href="reference/celery.managers.html#celery.managers.TableLock.acquire">acquire() (celery.managers.TableLock class method)</a></dt>
 <dt><a href="reference/celery.bin.celeryd.html#celery.bin.celeryd.acquire_pidlock">acquire_pidlock() (in module celery.bin.celeryd)</a></dt>
 <dt><a href="reference/celery.pool.html#celery.pool.DynamicPool.add_worker">add_worker() (celery.pool.DynamicPool method)</a></dt>
-<dt><a href="reference/celery.registry.html#celery.registry.AlreadyRegistered">AlreadyRegistered</a></dt>
+<dt><a href="reference/celery.exceptions.html#celery.exceptions.AlreadyRegistered">AlreadyRegistered</a></dt>
 <dt><a href="reference/celery.conf.html#celery.conf.ALWAYS_EAGER">ALWAYS_EAGER (in module celery.conf)</a>, <a href="reference/celery.conf.html#celery.conf.ALWAYS_EAGER">[1]</a></dt>
 <dt><a href="reference/celery.conf.html#celery.conf.AMQP_CONNECTION_MAX_RETRIES">AMQP_CONNECTION_MAX_RETRIES (in module celery.conf)</a></dt>
 <dt><a href="reference/celery.conf.html#celery.conf.AMQP_CONNECTION_RETRY">AMQP_CONNECTION_RETRY (in module celery.conf)</a></dt>
@@ -157,17 +157,17 @@
   <dd><dl>
     <dt><a href="reference/celery.result.html#celery.result.BaseAsyncResult.backend">(celery.result.BaseAsyncResult attribute)</a></dt>
   </dl></dd>
-<dt><a href="reference/celery.backends.cache.html#celery.backends.cache.Backend">Backend (class in celery.backends.cache)</a></dt>
+<dt><a href="reference/celery.backends.amqp.html#celery.backends.amqp.Backend">Backend (class in celery.backends.amqp)</a></dt>
   <dd><dl>
+    <dt><a href="reference/celery.backends.cache.html#celery.backends.cache.Backend">(class in celery.backends.cache)</a></dt>
     <dt><a href="reference/celery.backends.database.html#celery.backends.database.Backend">(class in celery.backends.database)</a></dt>
     <dt><a href="reference/celery.backends.tyrant.html#celery.backends.tyrant.Backend">(class in celery.backends.tyrant)</a></dt>
   </dl></dd>
 <dt><a href="reference/celery.worker.controllers.html#celery.worker.controllers.BackgroundThread">BackgroundThread (class in celery.worker.controllers)</a></dt>
-<dt><a href="reference/celery.result.html#celery.result.BaseAsyncResult">BaseAsyncResult (class in celery.result)</a></dt>
-<dt><a href="reference/celery.result.html#celery.result.BaseAsyncResult.TimeoutError">BaseAsyncResult.TimeoutError</a></dt></dl></td><td width="33%" valign="top"><dl>
+<dt><a href="reference/celery.result.html#celery.result.BaseAsyncResult">BaseAsyncResult (class in celery.result)</a></dt></dl></td><td width="33%" valign="top"><dl>
+<dt><a href="reference/celery.result.html#celery.result.BaseAsyncResult.TimeoutError">BaseAsyncResult.TimeoutError</a></dt>
 <dt><a href="reference/celery.backends.base.html#celery.backends.base.BaseBackend">BaseBackend (class in celery.backends.base)</a></dt>
 <dt><a href="reference/celery.backends.base.html#celery.backends.base.BaseBackend.TimeoutError">BaseBackend.TimeoutError</a></dt>
-<dt><a href="reference/celery.backends.base.html#celery.backends.base.BaseBackend.UnpickleableExceptionWrapper">BaseBackend.UnpickleableExceptionWrapper</a></dt>
 <dt><a href="reference/celery.loaders.base.html#celery.loaders.base.BaseLoader">BaseLoader (class in celery.loaders.base)</a></dt>
 <dt><a href="reference/celery.worker.html#celery.worker.AMQPListener.bucket_queue">bucket_queue (celery.worker.AMQPListener attribute)</a></dt>
   <dd><dl>
@@ -182,14 +182,17 @@
 
 <dt><a href="reference/celery.worker.controllers.html#celery.worker.controllers.Mediator.callback">callback (celery.worker.controllers.Mediator attribute)</a></dt>
 <dt><a href="reference/celery.backends.html#module-celery.backends">celery.backends (module)</a></dt>
+<dt><a href="reference/celery.backends.amqp.html#module-celery.backends.amqp">celery.backends.amqp (module)</a></dt>
 <dt><a href="reference/celery.backends.base.html#module-celery.backends.base">celery.backends.base (module)</a></dt>
 <dt><a href="reference/celery.backends.cache.html#module-celery.backends.cache">celery.backends.cache (module)</a></dt>
 <dt><a href="reference/celery.backends.database.html#module-celery.backends.database">celery.backends.database (module)</a></dt>
 <dt><a href="reference/celery.backends.tyrant.html#module-celery.backends.tyrant">celery.backends.tyrant (module)</a></dt>
 <dt><a href="reference/celery.bin.celeryd.html#module-celery.bin.celeryd">celery.bin.celeryd (module)</a></dt>
+<dt><a href="reference/celery.bin.celeryinit.html#module-celery.bin.celeryinit">celery.bin.celeryinit (module)</a></dt>
 <dt><a href="reference/celery.conf.html#module-celery.conf">celery.conf (module)</a></dt>
 <dt><a href="reference/celery.datastructures.html#module-celery.datastructures">celery.datastructures (module)</a></dt>
 <dt><a href="reference/celery.discovery.html#module-celery.discovery">celery.discovery (module)</a></dt>
+<dt><a href="reference/celery.exceptions.html#module-celery.exceptions">celery.exceptions (module)</a></dt>
 <dt><a href="reference/celery.execute.html#module-celery.execute">celery.execute (module)</a></dt>
 <dt><a href="reference/celery.fields.html#module-celery.fields">celery.fields (module)</a></dt>
 <dt><a href="reference/celery.loaders.html#module-celery.loaders">celery.loaders (module)</a></dt>
@@ -208,9 +211,9 @@
 <dt><a href="reference/celery.task.html#module-celery.task">celery.task (module)</a></dt>
 <dt><a href="reference/celery.task.base.html#module-celery.task.base">celery.task.base (module)</a></dt>
 <dt><a href="reference/celery.task.builtins.html#module-celery.task.builtins">celery.task.builtins (module)</a></dt>
-<dt><a href="reference/celery.task.strategy.html#module-celery.task.strategy">celery.task.strategy (module)</a></dt>
+<dt><a href="reference/celery.task.strategy.html#module-celery.task.strategy">celery.task.strategy (module)</a></dt></dl></td><td width="33%" valign="top"><dl>
 <dt><a href="reference/celery.utils.html#module-celery.utils">celery.utils (module)</a></dt>
-<dt><a href="reference/celery.views.html#module-celery.views">celery.views (module)</a></dt></dl></td><td width="33%" valign="top"><dl>
+<dt><a href="reference/celery.views.html#module-celery.views">celery.views (module)</a></dt>
 <dt><a href="reference/celery.worker.html#module-celery.worker">celery.worker (module)</a></dt>
 <dt><a href="reference/celery.worker.controllers.html#module-celery.worker.controllers">celery.worker.controllers (module)</a></dt>
 <dt><a href="reference/celery.worker.job.html#module-celery.worker.job">celery.worker.job (module)</a></dt>
@@ -243,7 +246,6 @@
 <dt><a href="reference/celery.worker.html#celery.worker.WorkController.concurrency">concurrency (celery.worker.WorkController attribute)</a></dt>
 <dt><a href="reference/celery.loaders.base.html#celery.loaders.base.BaseLoader.conf">conf (celery.loaders.base.BaseLoader attribute)</a></dt>
 <dt><a href="reference/celery.worker.html#celery.worker.AMQPListener.consume_messages">consume_messages() (celery.worker.AMQPListener method)</a></dt>
-<dt><a href="reference/celery.backends.base.html#celery.backends.base.BaseBackend.create_exception_cls">create_exception_cls() (celery.backends.base.BaseBackend method)</a></dt>
 </dl></td></tr></table>
 
 <h2 id="D">D</h2>
@@ -289,26 +291,15 @@
 <dt><a href="reference/celery.log.html#celery.log.emergency_error">emergency_error() (in module celery.log)</a></dt>
 <dt><a href="reference/celery.messaging.html#celery.messaging.TaskPublisher.encoder">encoder() (celery.messaging.TaskPublisher method)</a></dt>
 <dt><a href="reference/celery.task.strategy.html#celery.task.strategy.even_time_distribution">even_time_distribution() (in module celery.task.strategy)</a></dt>
-<dt><a href="reference/celery.backends.base.html#celery.backends.base.BaseBackend.UnpickleableExceptionWrapper.exc_args">exc_args (celery.backends.base.BaseBackend.UnpickleableExceptionWrapper attribute)</a></dt>
-  <dd><dl>
-    <dt><a href="reference/celery.backends.base.html#celery.backends.base.UnpickleableExceptionWrapper.exc_args">(celery.backends.base.UnpickleableExceptionWrapper attribute)</a></dt>
-  </dl></dd>
-<dt><a href="reference/celery.backends.base.html#celery.backends.base.BaseBackend.UnpickleableExceptionWrapper.exc_cls_name">exc_cls_name (celery.backends.base.BaseBackend.UnpickleableExceptionWrapper attribute)</a></dt>
-  <dd><dl>
-    <dt><a href="reference/celery.backends.base.html#celery.backends.base.UnpickleableExceptionWrapper.exc_cls_name">(celery.backends.base.UnpickleableExceptionWrapper attribute)</a></dt>
-  </dl></dd>
-<dt><a href="reference/celery.backends.base.html#celery.backends.base.BaseBackend.UnpickleableExceptionWrapper.exc_module">exc_module (celery.backends.base.BaseBackend.UnpickleableExceptionWrapper attribute)</a></dt>
-  <dd><dl>
-    <dt><a href="reference/celery.backends.base.html#celery.backends.base.UnpickleableExceptionWrapper.exc_module">(celery.backends.base.UnpickleableExceptionWrapper attribute)</a></dt>
-  </dl></dd></dl></td><td width="33%" valign="top"><dl>
 <dt><a href="reference/celery.datastructures.html#celery.datastructures.ExceptionInfo.exception">exception (celery.datastructures.ExceptionInfo attribute)</a></dt>
 <dt><a href="reference/celery.backends.base.html#celery.backends.base.BaseBackend.exception_to_python">exception_to_python() (celery.backends.base.BaseBackend method)</a></dt>
 <dt><a href="reference/celery.datastructures.html#celery.datastructures.ExceptionInfo">ExceptionInfo (class in celery.datastructures)</a></dt>
-<dt><a href="reference/celery.task.base.html#celery.task.base.Task.exchange">exchange (celery.task.base.Task attribute)</a></dt>
+<dt><a href="reference/celery.task.base.html#celery.task.base.Task.exchange">exchange (celery.task.base.Task attribute)</a></dt></dl></td><td width="33%" valign="top"><dl>
 <dt><a href="reference/celery.worker.job.html#celery.worker.job.TaskWrapper.execute">execute() (celery.worker.job.TaskWrapper 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.job.html#celery.worker.job.TaskWrapper.execute_using_pool">execute_using_pool() (celery.worker.job.TaskWrapper method)</a></dt>
 <dt><a href="reference/celery.task.base.html#celery.task.base.ExecuteRemoteTask">ExecuteRemoteTask (class in celery.task.base)</a></dt>
+<dt><a href="reference/celery.execute.html#celery.execute.ExecuteWrapper">ExecuteWrapper (class in celery.execute)</a></dt>
 <dt><a href="reference/celery.supervisor.html#celery.supervisor.OFASupervisor.Process.exitcode">exitcode (celery.supervisor.OFASupervisor.Process attribute)</a></dt>
 <dt><a href="reference/celery.worker.job.html#celery.worker.job.TaskWrapper.extend_with_default_kwargs">extend_with_default_kwargs() (celery.worker.job.TaskWrapper method)</a></dt>
 </dl></td></tr></table>
@@ -320,8 +311,7 @@
 <dt><a href="reference/celery.result.html#celery.result.TaskSetResult.failed">failed() (celery.result.TaskSetResult method)</a></dt>
 <dt><a href="reference/celery.datastructures.html#celery.datastructures.PositionQueue.filled">filled (celery.datastructures.PositionQueue attribute)</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.backends.base.html#celery.backends.base.find_nearest_pickleable_exception">find_nearest_pickleable_exception() (in module celery.backends.base)</a></dt></dl></td><td width="33%" valign="top"><dl>
-<dt><a href="reference/celery.discovery.html#celery.discovery.find_related_module">find_related_module() (in module celery.discovery)</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.job.html#celery.worker.job.TaskWrapper.from_message">from_message() (celery.worker.job.TaskWrapper class method)</a></dt>
 <dt><a href="reference/celery.datastructures.html#celery.datastructures.PositionQueue.full">full() (celery.datastructures.PositionQueue method)</a></dt>
 </dl></td></tr></table>
@@ -343,24 +333,27 @@
 <dt><a href="reference/celery.backends.html#celery.backends.get_default_backend_cls">get_default_backend_cls (in module celery.backends)</a></dt>
 <dt><a href="reference/celery.backends.html#celery.backends.get_default_periodicstatus_backend_cls">get_default_periodicstatus_backend_cls (in module celery.backends)</a></dt>
 <dt><a href="reference/celery.backends.html#celery.backends.get_default_periodicstatus_backend_cls">get_default_periodicstatus_backend_cls() (in module celery.backends)</a></dt>
-<dt><a href="reference/celery.utils.html#celery.utils.get_full_cls_name">get_full_cls_name() (in module celery.utils)</a></dt></dl></td><td width="33%" valign="top"><dl>
+<dt><a href="reference/celery.utils.html#celery.utils.get_full_cls_name">get_full_cls_name() (in module celery.utils)</a></dt>
 <dt><a href="reference/celery.fields.html#celery.fields.PickledObjectField.get_internal_type">get_internal_type() (celery.fields.PickledObjectField method)</a></dt>
-<dt><a href="reference/celery.task.base.html#celery.task.base.Task.get_logger">get_logger() (celery.task.base.Task method)</a></dt>
+<dt><a href="reference/celery.task.base.html#celery.task.base.Task.get_logger">get_logger() (celery.task.base.Task method)</a></dt></dl></td><td width="33%" valign="top"><dl>
 <dt><a href="reference/celery.task.base.html#celery.task.base.Task.get_publisher">get_publisher() (celery.task.base.Task method)</a></dt>
-<dt><a href="reference/celery.backends.base.html#celery.backends.base.BaseBackend.get_result">get_result() (celery.backends.base.BaseBackend method)</a></dt>
+<dt><a href="reference/celery.backends.amqp.html#celery.backends.amqp.Backend.get_result">get_result() (celery.backends.amqp.Backend method)</a></dt>
   <dd><dl>
+    <dt><a href="reference/celery.backends.base.html#celery.backends.base.BaseBackend.get_result">(celery.backends.base.BaseBackend method)</a></dt>
     <dt><a href="reference/celery.backends.database.html#celery.backends.database.Backend.get_result">(celery.backends.database.Backend method)</a></dt>
   </dl></dd>
-<dt><a href="reference/celery.backends.base.html#celery.backends.base.BaseBackend.get_status">get_status() (celery.backends.base.BaseBackend method)</a></dt>
+<dt><a href="reference/celery.backends.amqp.html#celery.backends.amqp.Backend.get_status">get_status() (celery.backends.amqp.Backend method)</a></dt>
   <dd><dl>
+    <dt><a href="reference/celery.backends.base.html#celery.backends.base.BaseBackend.get_status">(celery.backends.base.BaseBackend method)</a></dt>
     <dt><a href="reference/celery.backends.database.html#celery.backends.database.Backend.get_status">(celery.backends.database.Backend method)</a></dt>
   </dl></dd>
 <dt><a href="reference/celery.managers.html#celery.managers.TaskManager.get_task">get_task() (celery.managers.TaskManager method)</a></dt>
   <dd><dl>
     <dt><a href="reference/celery.registry.html#celery.registry.TaskRegistry.get_task">(celery.registry.TaskRegistry method)</a></dt>
   </dl></dd>
-<dt><a href="reference/celery.backends.base.html#celery.backends.base.BaseBackend.get_traceback">get_traceback() (celery.backends.base.BaseBackend method)</a></dt>
+<dt><a href="reference/celery.backends.amqp.html#celery.backends.amqp.Backend.get_traceback">get_traceback() (celery.backends.amqp.Backend method)</a></dt>
   <dd><dl>
+    <dt><a href="reference/celery.backends.base.html#celery.backends.base.BaseBackend.get_traceback">(celery.backends.base.BaseBackend method)</a></dt>
     <dt><a href="reference/celery.backends.database.html#celery.backends.database.Backend.get_traceback">(celery.backends.database.Backend method)</a></dt>
   </dl></dd>
 <dt><a href="reference/celery.managers.html#celery.managers.PeriodicTaskManager.get_waiting_tasks">get_waiting_tasks() (celery.managers.PeriodicTaskManager method)</a></dt>
@@ -371,10 +364,13 @@
 <table width="100%" class="indextable"><tr><td width="33%" valign="top">
 <dl>
 
+<dt><a href="reference/celery.execute.html#celery.execute.ExecuteWrapper.handle_failure">handle_failure() (celery.execute.ExecuteWrapper method)</a></dt>
+<dt><a href="reference/celery.execute.html#celery.execute.ExecuteWrapper.handle_retry">handle_retry() (celery.execute.ExecuteWrapper method)</a></dt>
+<dt><a href="reference/celery.execute.html#celery.execute.ExecuteWrapper.handle_success">handle_success() (celery.execute.ExecuteWrapper method)</a></dt></dl></td><td width="33%" valign="top"><dl>
 <dt><a href="reference/celery.worker.html#celery.worker.AMQPListener.hold_queue">hold_queue (celery.worker.AMQPListener attribute)</a></dt>
   <dd><dl>
     <dt><a href="reference/celery.worker.html#celery.worker.WorkController.hold_queue">(celery.worker.WorkController attribute)</a></dt>
-  </dl></dd></dl></td><td width="33%" valign="top"><dl>
+  </dl></dd>
 </dl></td></tr></table>
 
 <h2 id="I">I</h2>
@@ -389,8 +385,9 @@
 <dt><a href="reference/celery.bin.celeryd.html#celery.bin.celeryd.install_restart_signal_handler">install_restart_signal_handler() (in module celery.bin.celeryd)</a></dt>
 <dt><a href="reference/celery.supervisor.html#celery.supervisor.OFASupervisor.Process.is_alive">is_alive() (celery.supervisor.OFASupervisor.Process method)</a></dt>
 <dt><a href="reference/celery.worker.html#celery.worker.WorkController.is_detached">is_detached (celery.worker.WorkController 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>
+<dt><a href="reference/celery.backends.amqp.html#celery.backends.amqp.Backend.is_done">is_done() (celery.backends.amqp.Backend method)</a></dt>
   <dd><dl>
+    <dt><a href="reference/celery.backends.base.html#celery.backends.base.BaseBackend.is_done">(celery.backends.base.BaseBackend method)</a></dt>
     <dt><a href="reference/celery.backends.database.html#celery.backends.database.Backend.is_done">(celery.backends.database.Backend method)</a></dt>
     <dt><a href="reference/celery.managers.html#celery.managers.TaskManager.is_done">(celery.managers.TaskManager method)</a></dt>
     <dt><a href="reference/celery.result.html#celery.result.BaseAsyncResult.is_done">(celery.result.BaseAsyncResult method)</a></dt>
@@ -408,7 +405,6 @@
 <table width="100%" class="indextable"><tr><td width="33%" valign="top">
 <dl>
 
-<dt><a href="reference/celery.worker.job.html#celery.worker.job.jail">jail() (in module celery.worker.job)</a></dt>
 <dt><a href="reference/celery.result.html#celery.result.TaskSetResult.join">join() (celery.result.TaskSetResult method)</a></dt>
   <dd><dl>
     <dt><a href="reference/celery.supervisor.html#celery.supervisor.OFASupervisor.Process.join">(celery.supervisor.OFASupervisor.Process method)</a></dt>
@@ -466,7 +462,7 @@
 <dt><a href="reference/celery.supervisor.html#celery.supervisor.OFASupervisor.max_restart_freq_time">max_restart_freq_time (celery.supervisor.OFASupervisor attribute)</a></dt>
 <dt><a href="reference/celery.task.base.html#celery.task.base.Task.max_retries">max_retries (celery.task.base.Task attribute)</a></dt></dl></td><td width="33%" valign="top"><dl>
 <dt><a href="reference/celery.supervisor.html#celery.supervisor.MaxRestartsExceededError">MaxRestartsExceededError</a></dt>
-<dt><a href="reference/celery.task.base.html#celery.task.base.MaxRetriesExceededError">MaxRetriesExceededError</a></dt>
+<dt><a href="reference/celery.exceptions.html#celery.exceptions.MaxRetriesExceededError">MaxRetriesExceededError</a></dt>
 <dt><a href="reference/celery.worker.html#celery.worker.WorkController.mediator">mediator (celery.worker.WorkController attribute)</a></dt>
 <dt><a href="reference/celery.worker.controllers.html#celery.worker.controllers.Mediator">Mediator (class in celery.worker.controllers)</a></dt>
 <dt><a href="reference/celery.worker.job.html#celery.worker.job.TaskWrapper.message">message (celery.worker.job.TaskWrapper attribute)</a></dt>
@@ -482,7 +478,7 @@
   <dd><dl>
     <dt><a href="reference/celery.models.html#PeriodicTaskMeta.name">(PeriodicTaskMeta attribute)</a></dt>
   </dl></dd></dl></td><td width="33%" valign="top"><dl>
-<dt><a href="reference/celery.registry.html#celery.registry.NotRegistered">NotRegistered</a></dt>
+<dt><a href="reference/celery.exceptions.html#celery.exceptions.NotRegistered">NotRegistered</a></dt>
 </dl></td></tr></table>
 
 <h2 id="O">O</h2>
@@ -491,11 +487,14 @@
 
 <dt><a href="reference/celery.supervisor.html#celery.supervisor.OFASupervisor">OFASupervisor (class in celery.supervisor)</a></dt>
 <dt><a href="reference/celery.supervisor.html#celery.supervisor.OFASupervisor.Process">OFASupervisor.Process (class in celery.supervisor)</a></dt>
-<dt><a href="reference/celery.worker.job.html#celery.worker.job.TaskWrapper.on_failure">on_failure() (celery.worker.job.TaskWrapper method)</a></dt>
+<dt><a href="reference/celery.task.base.html#celery.task.base.Task.on_failure">on_failure() (celery.task.base.Task method)</a></dt>
+  <dd><dl>
+    <dt><a href="reference/celery.worker.job.html#celery.worker.job.TaskWrapper.on_failure">(celery.worker.job.TaskWrapper method)</a></dt>
+  </dl></dd>
 <dt><a href="reference/celery.monitoring.html#celery.monitoring.TimerStats.on_finish">on_finish() (celery.monitoring.TimerStats method)</a></dt>
 <dt><a href="reference/celery.worker.controllers.html#celery.worker.controllers.BackgroundThread.on_iteration">on_iteration() (celery.worker.controllers.BackgroundThread method)</a></dt>
 <dt><a href="reference/celery.pool.html#celery.pool.TaskPool.on_ready">on_ready() (celery.pool.TaskPool method)</a></dt>
-<dt><a href="reference/celery.pool.html#celery.pool.TaskPool.on_return">on_return() (celery.pool.TaskPool method)</a></dt>
+<dt><a href="reference/celery.task.base.html#celery.task.base.Task.on_retry">on_retry() (celery.task.base.Task method)</a></dt>
 <dt><a href="reference/celery.monitoring.html#celery.monitoring.Statistics.on_start">on_start() (celery.monitoring.Statistics method)</a></dt>
   <dd><dl>
     <dt><a href="reference/celery.monitoring.html#celery.monitoring.TimerStats.on_start">(celery.monitoring.TimerStats method)</a></dt>
@@ -506,7 +505,10 @@
   <dd><dl>
     <dt><a href="reference/celery.worker.controllers.html#celery.worker.controllers.BackgroundThread.on_stop">(celery.worker.controllers.BackgroundThread method)</a></dt>
   </dl></dd>
-<dt><a href="reference/celery.worker.job.html#celery.worker.job.TaskWrapper.on_success">on_success() (celery.worker.job.TaskWrapper method)</a></dt>
+<dt><a href="reference/celery.task.base.html#celery.task.base.Task.on_success">on_success() (celery.task.base.Task method)</a></dt>
+  <dd><dl>
+    <dt><a href="reference/celery.worker.job.html#celery.worker.job.TaskWrapper.on_success">(celery.worker.job.TaskWrapper method)</a></dt>
+  </dl></dd>
 <dt><a href="reference/celery.loaders.base.html#celery.loaders.base.BaseLoader.on_task_init">on_task_init() (celery.loaders.base.BaseLoader method)</a></dt>
   <dd><dl>
     <dt><a href="reference/celery.loaders.djangoapp.html#celery.loaders.djangoapp.Loader.on_task_init">(celery.loaders.djangoapp.Loader method)</a></dt>
@@ -575,7 +577,7 @@
   </dl></dd>
 <dt><a href="reference/celery.task.base.html#celery.task.base.Task.retry">retry() (celery.task.base.Task method)</a></dt></dl></td><td width="33%" valign="top"><dl>
 <dt><a href="reference/celery.utils.html#celery.utils.retry_over_time">retry_over_time() (in module celery.utils)</a></dt>
-<dt><a href="reference/celery.task.base.html#celery.task.base.RetryTaskError">RetryTaskError</a></dt>
+<dt><a href="reference/celery.exceptions.html#celery.exceptions.RetryTaskError">RetryTaskError</a></dt>
 <dt><a href="reference/celery.task.base.html#celery.task.base.Task.routing_key">routing_key (celery.task.base.Task attribute)</a></dt>
 <dt><a href="reference/celery.monitoring.html#celery.monitoring.Statistics.run">run() (celery.monitoring.Statistics method)</a></dt>
   <dd><dl>
@@ -624,8 +626,9 @@
     <dt><a href="reference/celery.worker.html#celery.worker.WorkController.stop">(celery.worker.WorkController method)</a></dt>
     <dt><a href="reference/celery.worker.controllers.html#celery.worker.controllers.BackgroundThread.stop">(celery.worker.controllers.BackgroundThread method)</a></dt>
   </dl></dd>
-<dt><a href="reference/celery.backends.base.html#celery.backends.base.BaseBackend.store_result">store_result() (celery.backends.base.BaseBackend method)</a></dt>
+<dt><a href="reference/celery.backends.amqp.html#celery.backends.amqp.Backend.store_result">store_result() (celery.backends.amqp.Backend method)</a></dt>
   <dd><dl>
+    <dt><a href="reference/celery.backends.base.html#celery.backends.base.BaseBackend.store_result">(celery.backends.base.BaseBackend method)</a></dt>
     <dt><a href="reference/celery.backends.database.html#celery.backends.database.Backend.store_result">(celery.backends.database.Backend method)</a></dt>
     <dt><a href="reference/celery.managers.html#celery.managers.TaskManager.store_result">(celery.managers.TaskManager method)</a></dt>
   </dl></dd>
@@ -680,7 +683,7 @@
 <dt><a href="reference/celery.worker.job.html#celery.worker.job.TaskWrapper">TaskWrapper (class in celery.worker.job)</a></dt>
 <dt><a href="reference/celery.supervisor.html#celery.supervisor.OFASupervisor.Process.terminate">terminate() (celery.supervisor.OFASupervisor.Process method)</a></dt>
 <dt><a href="reference/celery.monitoring.html#celery.monitoring.TimerStats.time_start">time_start (celery.monitoring.TimerStats attribute)</a></dt>
-<dt><a href="reference/celery.backends.base.html#celery.backends.base.TimeoutError">TimeoutError</a>, <a href="reference/celery.result.html#celery.result.TimeoutError">[1]</a></dt>
+<dt><a href="reference/celery.exceptions.html#celery.exceptions.TimeoutError">TimeoutError</a></dt>
 <dt><a href="reference/celery.monitoring.html#celery.monitoring.TimerStats">TimerStats (class in celery.monitoring)</a></dt>
 <dt><a href="reference/celery.fields.html#celery.fields.PickledObjectField.to_python">to_python() (celery.fields.PickledObjectField method)</a></dt>
 <dt><a href="reference/celery.result.html#celery.result.TaskSetResult.total">total (celery.result.TaskSetResult attribute)</a></dt>
@@ -712,8 +715,7 @@
 <dt><a href="reference/celery.managers.html#celery.managers.MySQLTableLock.unlock_table">unlock_table() (celery.managers.MySQLTableLock method)</a></dt>
   <dd><dl>
     <dt><a href="reference/celery.managers.html#celery.managers.TableLock.unlock_table">(celery.managers.TableLock method)</a></dt>
-  </dl></dd>
-<dt><a href="reference/celery.backends.base.html#celery.backends.base.UnpickleableExceptionWrapper">UnpickleableExceptionWrapper</a></dt></dl></td><td width="33%" valign="top"><dl>
+  </dl></dd></dl></td><td width="33%" valign="top"><dl>
 <dt><a href="reference/celery.registry.html#celery.registry.TaskRegistry.unregister">unregister() (celery.registry.TaskRegistry method)</a></dt>
 </dl></td></tr></table>
 

+ 3 - 0
index.html

@@ -93,6 +93,7 @@
 <li class="toctree-l2"><a class="reference external" href="reference/celery.task.html">Task Information and Utilities - celery.task</a></li>
 <li class="toctree-l2"><a class="reference external" href="reference/celery.registry.html">Task Registry - celery.registry</a></li>
 <li class="toctree-l2"><a class="reference external" href="reference/celery.signals.html">Signals - celery.signals</a></li>
+<li class="toctree-l2"><a class="reference external" href="reference/celery.exceptions.html">Exceptions - celery.exceptions</a></li>
 <li class="toctree-l2"><a class="reference external" href="reference/celery.task.builtins.html">Built-in Task Classes - celery.task.builtins</a></li>
 <li class="toctree-l2"><a class="reference external" href="reference/celery.task.strategy.html">Common Task Strategies - celery.task.strategy</a></li>
 <li class="toctree-l2"><a class="reference external" href="reference/celery.loaders.html">Loaders - celery.loaders</a></li>
@@ -111,6 +112,7 @@
 <li class="toctree-l2"><a class="reference external" href="reference/celery.backends.base.html">Backend: Base - celery.backends.base</a></li>
 <li class="toctree-l2"><a class="reference external" href="reference/celery.backends.database.html">Backend: Database - celery.backends.database</a></li>
 <li class="toctree-l2"><a class="reference external" href="reference/celery.backends.cache.html">Backend: Cache - celery.backends.cache</a></li>
+<li class="toctree-l2"><a class="reference external" href="reference/celery.backends.amqp.html">Backend: AMQP - celery.backends.amqp</a></li>
 <li class="toctree-l2"><a class="reference external" href="reference/celery.backends.tyrant.html">Backend: Tokyo Tyrant - celery.backends.tyrant</a></li>
 <li class="toctree-l2"><a class="reference external" href="reference/celery.conf.html">Configuration - celery.conf</a></li>
 <li class="toctree-l2"><a class="reference external" href="reference/celery.datastructures.html">Datastructures - celery.datastructures</a></li>
@@ -121,6 +123,7 @@
 <li class="toctree-l2"><a class="reference external" href="reference/celery.models.html">Django Models - celery.models</a></li>
 <li class="toctree-l2"><a class="reference external" href="reference/celery.fields.html">Django Fields - celery.fields</a></li>
 <li class="toctree-l2"><a class="reference external" href="reference/celery.bin.celeryd.html">Celery Worker Daemon - celery.bin.celeryd</a></li>
+<li class="toctree-l2"><a class="reference external" href="reference/celery.bin.celeryinit.html">Celery Initialize - celery.bin.celeryinit</a></li>
 </ul>
 </li>
 <li class="toctree-l1"><a class="reference external" href="changelog.html">Change history</a><ul>

+ 12 - 0
modindex.html

@@ -61,6 +61,10 @@
      <em></em></td></tr><tr class="cg-1">
      <td></td>
      <td>&nbsp;&nbsp;&nbsp;
+     <a href="reference/celery.backends.amqp.html#module-celery.backends.amqp"><tt class="xref">celery.backends.amqp</tt></a></td><td>
+     <em></em></td></tr><tr class="cg-1">
+     <td></td>
+     <td>&nbsp;&nbsp;&nbsp;
      <a href="reference/celery.backends.base.html#module-celery.backends.base"><tt class="xref">celery.backends.base</tt></a></td><td>
      <em></em></td></tr><tr class="cg-1">
      <td></td>
@@ -81,6 +85,10 @@
      <em></em></td></tr><tr class="cg-1">
      <td></td>
      <td>&nbsp;&nbsp;&nbsp;
+     <a href="reference/celery.bin.celeryinit.html#module-celery.bin.celeryinit"><tt class="xref">celery.bin.celeryinit</tt></a></td><td>
+     <em></em></td></tr><tr class="cg-1">
+     <td></td>
+     <td>&nbsp;&nbsp;&nbsp;
      <a href="reference/celery.conf.html#module-celery.conf"><tt class="xref">celery.conf</tt></a></td><td>
      <em></em></td></tr><tr class="cg-1">
      <td></td>
@@ -93,6 +101,10 @@
      <em></em></td></tr><tr class="cg-1">
      <td></td>
      <td>&nbsp;&nbsp;&nbsp;
+     <a href="reference/celery.exceptions.html#module-celery.exceptions"><tt class="xref">celery.exceptions</tt></a></td><td>
+     <em></em></td></tr><tr class="cg-1">
+     <td></td>
+     <td>&nbsp;&nbsp;&nbsp;
      <a href="reference/celery.execute.html#module-celery.execute"><tt class="xref">celery.execute</tt></a></td><td>
      <em></em></td></tr><tr class="cg-1">
      <td></td>

+ 31 - 28
objects.inv

@@ -2,6 +2,7 @@
 # Project: Celery
 # Version: 0.7
 celery.backends.base mod reference/celery.backends.base.html
+celery.exceptions mod reference/celery.exceptions.html
 celery.execute mod reference/celery.execute.html
 celery.task.strategy mod reference/celery.task.strategy.html
 celery.loaders.djangoapp mod reference/celery.loaders.djangoapp.html
@@ -20,10 +21,11 @@ celery.supervisor mod reference/celery.supervisor.html
 celery.backends mod reference/celery.backends.html
 celery.loaders.base mod reference/celery.loaders.base.html
 celery.worker mod reference/celery.worker.html
-celery.worker.controllers mod reference/celery.worker.controllers.html
+celery.bin.celeryinit mod reference/celery.bin.celeryinit.html
 celery.backends.cache mod reference/celery.backends.cache.html
 celery.datastructures mod reference/celery.datastructures.html
 celery.messaging mod reference/celery.messaging.html
+celery.backends.amqp mod reference/celery.backends.amqp.html
 celery.task.base mod reference/celery.task.base.html
 celery.loaders mod reference/celery.loaders.html
 celery.loaders.default mod reference/celery.loaders.default.html
@@ -34,15 +36,16 @@ celery.conf mod reference/celery.conf.html
 celery.registry mod reference/celery.registry.html
 celery.result mod reference/celery.result.html
 celery.fields mod reference/celery.fields.html
+celery.worker.controllers mod reference/celery.worker.controllers.html
 celery.supervisor.OFASupervisor.Process.exitcode attribute reference/celery.supervisor.html
-celery.backends.tyrant.Backend.tyrant_port attribute reference/celery.backends.tyrant.html
+celery.backends.base.BaseBackend.mark_as_done method reference/celery.backends.base.html
 celery.worker.controllers.BackgroundThread.on_stop method reference/celery.worker.controllers.html
 celery.result.TaskSetResult.iterate method reference/celery.result.html
 celery.supervisor.OFASupervisor.Process.run method reference/celery.supervisor.html
-celery.registry.AlreadyRegistered exception reference/celery.registry.html
 celery.task.base.AsynchronousMapTask class reference/celery.task.base.html
 celery.result.BaseAsyncResult.backend attribute reference/celery.result.html
 celery.fields.PickledObjectField.get_internal_type method reference/celery.fields.html
+celery.worker.WorkController class reference/celery.worker.html
 celery.worker.WorkController.logfile attribute reference/celery.worker.html
 celery.result.BaseAsyncResult.ready method reference/celery.result.html
 celery.managers.TaskManager.delete_expired method reference/celery.managers.html
@@ -50,7 +53,7 @@ celery.datastructures.ExceptionInfo.traceback attribute reference/celery.datastr
 celery.managers.TaskManager.get_all_expired method reference/celery.managers.html
 celery.managers.table_lock attribute reference/celery.managers.html
 celery.task.strategy.even_time_distribution function reference/celery.task.strategy.html
-celery.worker.controllers.PeriodicWorkController.process_hold_queue method reference/celery.worker.controllers.html
+celery.execute.ExecuteWrapper.handle_success method reference/celery.execute.html
 celery.task.base.ExecuteRemoteTask.run method reference/celery.task.base.html
 celery.task.base.Task.retry method reference/celery.task.base.html
 celery.supervisor.OFASupervisor.start method reference/celery.supervisor.html
@@ -82,19 +85,18 @@ celery.task.base.PeriodicTask class reference/celery.task.base.html
 celery.managers.TaskManager.get_task method reference/celery.managers.html
 celery.loaders.djangoapp.Loader.read_configuration method reference/celery.loaders.djangoapp.html
 celery.conf.DAEMON_LOG_LEVEL data reference/celery.conf.html
-celery.task.base.MaxRetriesExceededError exception reference/celery.task.base.html
 celery.task.builtins.PingTask.run method reference/celery.task.builtins.html
 celery.result.BaseAsyncResult.status attribute reference/celery.result.html
 celery.conf.DEFAULT_AMQP_CONNECTION_MAX_RETRIES data reference/celery.conf.html
 celery.monitoring.StatsCollector.total_task_time_running attribute reference/celery.monitoring.html
-celery.backends.base.BaseBackend.UnpickleableExceptionWrapper.exc_args attribute reference/celery.backends.base.html
 TaskMeta.date_done attribute reference/celery.models.html
 celery.monitoring.StatsCollector.collect method reference/celery.monitoring.html
 celery.monitoring.StatsCollector.total_task_time_running_by_type attribute reference/celery.monitoring.html
 celery.backends.base.BaseBackend.is_done method reference/celery.backends.base.html
 celery.loaders.base.BaseLoader.on_task_init method reference/celery.loaders.base.html
 celery.task.base.TaskSet.map classmethod reference/celery.task.base.html
-celery.backends.base.BaseBackend.UnpickleableExceptionWrapper exception reference/celery.backends.base.html
+celery.exceptions.MaxRetriesExceededError exception reference/celery.exceptions.html
+celery.backends.amqp.Backend.store_result method reference/celery.backends.amqp.html
 celery.worker.job.TaskWrapper.kwargs attribute reference/celery.worker.job.html
 celery.messaging.TaskPublisher.delay_task method reference/celery.messaging.html
 celery.worker.WorkController.is_detached attribute reference/celery.worker.html
@@ -102,8 +104,8 @@ celery.result.BaseAsyncResult.traceback attribute reference/celery.result.html
 celery.task.base.TaskSet.map_async classmethod reference/celery.task.base.html
 celery.worker.AMQPListener.reset_connection method reference/celery.worker.html
 celery.loaders.djangoapp.Loader.on_task_init method reference/celery.loaders.djangoapp.html
+celery.execute.ExecuteWrapper.handle_retry method reference/celery.execute.html
 celery.fields.PickledObjectField.get_db_prep_save method reference/celery.fields.html
-celery.backends.base.BaseBackend.UnpickleableExceptionWrapper.exc_cls_name attribute reference/celery.backends.base.html
 celery.task.base.Task.exchange attribute reference/celery.task.base.html
 celery.worker.job.TaskWrapper class reference/celery.worker.job.html
 celery.worker.WorkController.concurrency attribute reference/celery.worker.html
@@ -134,24 +136,25 @@ celery.result.EagerResult.wait method reference/celery.result.html
 celery.result.BaseAsyncResult.is_done method reference/celery.result.html
 celery.conf.LOG_LEVELS data reference/celery.conf.html
 celery.result.TaskSetResult.successful method reference/celery.result.html
-celery.backends.base.UnpickleableExceptionWrapper exception reference/celery.backends.base.html
+celery.result.TaskSetResult class reference/celery.result.html
 celery.result.EagerResult.is_done method reference/celery.result.html
 celery.monitoring.TimerStats.time_start attribute reference/celery.monitoring.html
 celery.worker.job.TaskWrapper.task_func attribute reference/celery.worker.job.html
-celery.backends.base.BaseBackend.mark_as_done method reference/celery.backends.base.html
 celery.pool.TaskPool class reference/celery.pool.html
 celery.discovery.autodiscover function reference/celery.discovery.html
+celery.backends.amqp.Backend.is_done method reference/celery.backends.amqp.html
 celery.result.EagerResult class reference/celery.result.html
+celery.worker.controllers.PeriodicWorkController.process_hold_queue method reference/celery.worker.controllers.html
 celery.result.TaskSetResult.total attribute reference/celery.result.html
 celery.task.ping function reference/celery.task.html
 celery.supervisor.OFASupervisor.target attribute reference/celery.supervisor.html
 celery.fields.PickledObject class reference/celery.fields.html
 celery.utils.mitemgetter function reference/celery.utils.html
-celery.pool.TaskPool.on_return method reference/celery.pool.html
 celery.worker.WorkController.process_task method reference/celery.worker.html
 celery.monitoring.StatsCollector class reference/celery.monitoring.html
 celery.supervisor.OFASupervisor.Process class reference/celery.supervisor.html
 celery.registry.TaskRegistry.get_all_periodic method reference/celery.registry.html
+celery.task.base.Task.on_success method reference/celery.task.base.html
 celery.utils.repeatlast function reference/celery.utils.html
 celery.loaders.default.Loader.on_worker_init method reference/celery.loaders.default.html
 celery.worker.job.TaskWrapper.on_success method reference/celery.worker.job.html
@@ -160,10 +163,10 @@ celery.task.base.AsynchronousMapTask.run method reference/celery.task.base.html
 celery.pool.DynamicPool.grow method reference/celery.pool.html
 celery.backends.base.BaseBackend class reference/celery.backends.base.html
 celery.conf.AMQP_EXCHANGE_TYPE data reference/celery.conf.html
-celery.worker.WorkController class reference/celery.worker.html
+celery.exceptions.AlreadyRegistered exception reference/celery.exceptions.html
 celery.backends.base.BaseBackend.prepare_exception method reference/celery.backends.base.html
 celery.task.base.Task.run method reference/celery.task.base.html
-celery.backends.base.BaseBackend.UnpickleableExceptionWrapper.exc_module attribute reference/celery.backends.base.html
+celery.backends.amqp.Backend class reference/celery.backends.amqp.html
 celery.managers.TaskManager class reference/celery.managers.html
 celery.worker.job.TaskWrapper.task_id attribute reference/celery.worker.job.html
 celery.utils.chunks function reference/celery.utils.html
@@ -175,22 +178,20 @@ celery.backends.database.Backend class reference/celery.backends.database.html
 celery.task.builtins.PingTask class reference/celery.task.builtins.html
 celery.bin.celeryd.install_restart_signal_handler function reference/celery.bin.celeryd.html
 celery.conf.DAEMON_LOG_FILE data reference/celery.conf.html
-celery.backends.base.find_nearest_pickleable_exception function reference/celery.backends.base.html
 celery.worker.AMQPListener.consume_messages method reference/celery.worker.html
 celery.worker.job.TaskWrapper.message attribute reference/celery.worker.job.html
-celery.backends.base.TimeoutError exception reference/celery.backends.base.html
 celery.managers.TableLock.lock_table method reference/celery.managers.html
 celery.worker.controllers.BackgroundThread.run method reference/celery.worker.controllers.html
 celery.conf.STATISTICS_COLLECT_INTERVAL data reference/celery.conf.html
+celery.backends.tyrant.Backend.tyrant_port attribute reference/celery.backends.tyrant.html
 celery.result.BaseAsyncResult.task_id attribute reference/celery.result.html
 celery.fields.PickledObjectField class reference/celery.fields.html
 celery.pool.TaskPool.logger attribute reference/celery.pool.html
 celery.worker.AMQPListener.start method reference/celery.worker.html
-celery.loaders.default.Loader.read_configuration method reference/celery.loaders.default.html
 celery.worker.AMQPListener.close_connection method reference/celery.worker.html
 celery.worker.AMQPListener.receive_message method reference/celery.worker.html
 celery.task.base.Task.type attribute reference/celery.task.base.html
-celery.backends.get_default_periodicstatus_backend_cls function reference/celery.backends.html
+celery.exceptions.RetryTaskError exception reference/celery.exceptions.html
 celery.worker.WorkController.bucket_queue attribute reference/celery.worker.html
 celery.task.base.Task class reference/celery.task.base.html
 TaskMeta.status attribute reference/celery.models.html
@@ -200,12 +201,11 @@ celery.result.EagerResult.is_ready method reference/celery.result.html
 celery.backends.base.BaseBackend.mark_as_retry method reference/celery.backends.base.html
 celery.datastructures.PositionQueue.filled attribute reference/celery.datastructures.html
 TASK_STATUS_DONE data reference/celery.models.html
-celery.backends.base.UnpickleableExceptionWrapper.exc_cls_name attribute reference/celery.backends.base.html
 celery.conf.AMQP_PUBLISHER_ROUTING_KEY data reference/celery.conf.html
 celery.backends.cache.Backend class reference/celery.backends.cache.html
 celery.worker.controllers.PeriodicWorkController class reference/celery.worker.controllers.html
+celery.execute.ExecuteWrapper.handle_failure method reference/celery.execute.html
 celery.supervisor.OFASupervisor.Process.daemon attribute reference/celery.supervisor.html
-celery.registry.NotRegistered exception reference/celery.registry.html
 celery.conf.DAEMON_CONCURRENCY data reference/celery.conf.html
 celery.registry.TaskRegistry.get_all method reference/celery.registry.html
 celery.managers.MySQLTableLock class reference/celery.managers.html
@@ -226,7 +226,6 @@ celery.messaging.TaskPublisher.encoder method reference/celery.messaging.html
 celery.task.base.TaskSet.join method reference/celery.task.base.html
 celery.datastructures.PositionQueue.full method reference/celery.datastructures.html
 celery.registry.TaskRegistry.AlreadyRegistered exception reference/celery.registry.html
-celery.backends.base.UnpickleableExceptionWrapper.exc_args attribute reference/celery.backends.base.html
 celery.conf.AMQP_CONSUMER_QUEUE data reference/celery.conf.html
 celery.monitoring.StatsCollector.task_time_running method reference/celery.monitoring.html
 PeriodicTaskMeta.total_run_count attribute reference/celery.models.html
@@ -234,7 +233,7 @@ celery.result.TaskSetResult.ready method reference/celery.result.html
 celery.backends.get_default_backend_cls data reference/celery.backends.html
 celery.worker.job.TaskWrapper.args attribute reference/celery.worker.job.html
 celery.conf.AMQP_CONSUMER_QUEUES data reference/celery.conf.html
-celery.result.TimeoutError exception reference/celery.result.html
+celery.backends.get_default_periodicstatus_backend_cls function reference/celery.backends.html
 celery.backends.database.Backend.store_result method reference/celery.backends.database.html
 celery.monitoring.TaskTimerStats class reference/celery.monitoring.html
 PeriodicTaskMeta.task attribute reference/celery.models.html
@@ -244,7 +243,6 @@ PeriodicTaskMeta class reference/celery.models.html
 celery.utils.get_full_cls_name function reference/celery.utils.html
 celery.worker.job.TaskWrapper.extend_with_default_kwargs method reference/celery.worker.job.html
 celery.result.AsyncResult class reference/celery.result.html
-celery.result.TaskSetResult class reference/celery.result.html
 celery.datastructures.SharedCounter class reference/celery.datastructures.html
 celery.task.dmap_async function reference/celery.task.html
 celery.result.TaskSetResult.waiting method reference/celery.result.html
@@ -261,20 +259,18 @@ celery.backends.database.Backend.get_result method reference/celery.backends.dat
 celery.supervisor.OFASupervisor.max_restart_freq_time attribute reference/celery.supervisor.html
 celery.backends.get_backend_cls function reference/celery.backends.html
 celery.conf.AMQP_CONNECTION_MAX_RETRIES data reference/celery.conf.html
-celery.backends.base.BaseBackend.create_exception_cls method reference/celery.backends.base.html
 celery.monitoring.Statistics.stop method reference/celery.monitoring.html
 celery.registry.TaskRegistry.unregister method reference/celery.registry.html
 celery.pool.TaskPool.stop method reference/celery.pool.html
 celery.result.TaskSetResult.failed method reference/celery.result.html
 celery.worker.job.TaskWrapper.execute method reference/celery.worker.job.html
-celery.worker.job.jail function reference/celery.worker.job.html
 celery.monitoring.Statistics.start classmethod reference/celery.monitoring.html
 celery.backends.base.BaseBackend.TimeoutError exception reference/celery.backends.base.html
 celery.managers.MySQLTableLock.unlock_table method reference/celery.managers.html
 celery.loaders.base.BaseLoader.on_worker_init method reference/celery.loaders.base.html
 celery.managers.PeriodicTaskManager.get_waiting_tasks method reference/celery.managers.html
 celery.pool.DynamicPool.replace_dead_workers method reference/celery.pool.html
-celery.result.TaskSetResult.itersubtasks method reference/celery.result.html
+celery.registry.TaskRegistry.register method reference/celery.registry.html
 celery.registry.TaskRegistry class reference/celery.registry.html
 celery.backends.DefaultBackend class reference/celery.backends.html
 celery.task.base.Task.MaxRetriesExceededError exception reference/celery.task.base.html
@@ -284,8 +280,8 @@ celery.monitoring.Statistics.type attribute reference/celery.monitoring.html
 celery.bin.celeryd.run_worker function reference/celery.bin.celeryd.html
 celery.result.AsyncResult.backend attribute reference/celery.result.html
 celery.result.BaseAsyncResult.result attribute reference/celery.result.html
+celery.task.base.Task.on_failure method reference/celery.task.base.html
 celery.backends.tyrant.Backend.tyrant_host attribute reference/celery.backends.tyrant.html
-celery.backends.base.UnpickleableExceptionWrapper.exc_module attribute reference/celery.backends.base.html
 celery.pool.TaskPool.start method reference/celery.pool.html
 celery.monitoring.TimerStats.on_start method reference/celery.monitoring.html
 celery.task.is_done function reference/celery.task.html
@@ -300,20 +296,22 @@ celery.fields.PickledObjectField.get_db_prep_lookup method reference/celery.fiel
 TASK_STATUS_PENDING data reference/celery.models.html
 celery.result.EagerResult.TimeoutError exception reference/celery.result.html
 celery.managers.TableLock.unlock_table method reference/celery.managers.html
-celery.task.base.RetryTaskError exception reference/celery.task.base.html
+celery.loaders.default.Loader.read_configuration method reference/celery.loaders.default.html
 celery.result.TaskSetResult.completed_count method reference/celery.result.html
+celery.exceptions.TimeoutError exception reference/celery.exceptions.html
 celery.messaging.TaskConsumer class reference/celery.messaging.html
 celery.worker.WorkController.safe_process_task method reference/celery.worker.html
 celery.result.TaskSetResult.taskset_id attribute reference/celery.result.html
 celery.supervisor.OFASupervisor.Process.join method reference/celery.supervisor.html
+celery.backends.amqp.Backend.get_traceback method reference/celery.backends.amqp.html
 celery.log.emergency_error function reference/celery.log.html
 celery.monitoring.Statistics.on_start method reference/celery.monitoring.html
 celery.supervisor.OFASupervisor.args attribute reference/celery.supervisor.html
 celery.task.base.Task.routing_key attribute reference/celery.task.base.html
-celery.registry.TaskRegistry.register method reference/celery.registry.html
 celery.task.base.PeriodicTask.run_every attribute reference/celery.task.base.html
 celery.managers.TaskManager.is_done method reference/celery.managers.html
 celery.task.base.Task.get_consumer method reference/celery.task.base.html
+celery.execute.ExecuteWrapper class reference/celery.execute.html
 celery.discovery.find_related_module function reference/celery.discovery.html
 celery.registry.TaskRegistry.filter_types method reference/celery.registry.html
 celery.worker.controllers.Mediator class reference/celery.worker.controllers.html
@@ -324,6 +322,7 @@ TaskMeta.task_id attribute reference/celery.models.html
 celery.task.base.TaskSet.task_name attribute reference/celery.task.base.html
 celery.supervisor.OFASupervisor.Process.ident attribute reference/celery.supervisor.html
 celery.datastructures.ExceptionInfo class reference/celery.datastructures.html
+celery.backends.amqp.Backend.get_result method reference/celery.backends.amqp.html
 celery.task.base.Task.ignore_result attribute reference/celery.task.base.html
 celery.managers.PeriodicTaskManager class reference/celery.managers.html
 TaskMeta class reference/celery.models.html
@@ -333,6 +332,8 @@ celery.pool.DynamicPool class reference/celery.pool.html
 celery.backends.tyrant.Backend.close method reference/celery.backends.tyrant.html
 celery.backends.base.BaseBackend.wait_for method reference/celery.backends.base.html
 PeriodicTaskMeta.last_run_at attribute reference/celery.models.html
+celery.exceptions.NotRegistered exception reference/celery.exceptions.html
+celery.result.TaskSetResult.itersubtasks method reference/celery.result.html
 celery.bin.celeryd.acquire_pidlock function reference/celery.bin.celeryd.html
 celery.task.base.TaskSet.remote_execute classmethod reference/celery.task.base.html
 celery.backends.database.Backend.get_status method reference/celery.backends.database.html
@@ -357,6 +358,7 @@ celery.task.builtins.DeleteExpiredTaskMetaTask.run method reference/celery.task.
 celery.task.base.Task.delay classmethod reference/celery.task.base.html
 celery.pool.TaskPool.apply_async method reference/celery.pool.html
 PeriodicTaskMeta.name attribute reference/celery.models.html
+celery.task.base.Task.on_retry method reference/celery.task.base.html
 celery.monitoring.Statistics.run method reference/celery.monitoring.html
 celery.task.base.Task.apply classmethod reference/celery.task.base.html
 celery.registry.TaskRegistry.get_task method reference/celery.registry.html
@@ -370,6 +372,7 @@ celery.result.TaskSetResult.join method reference/celery.result.html
 celery.task.builtins.DeleteExpiredTaskMetaTask class reference/celery.task.builtins.html
 celery.worker.job.TaskWrapper.task_name attribute reference/celery.worker.job.html
 celery.pool.process_is_dead function reference/celery.pool.html
+celery.backends.amqp.Backend.get_status method reference/celery.backends.amqp.html
 celery.worker.WorkController.amqp_listener attribute reference/celery.worker.html
 celery.backends.database.Backend.is_done method reference/celery.backends.database.html
 TASK_STATUSES_CHOICES data reference/celery.models.html

+ 2 - 126
reference/celery.backends.base.html

@@ -64,62 +64,12 @@ class </em><tt class="descclassname">celery.backends.base.</tt><tt class="descna
 exception </em><tt class="descname">TimeoutError</tt><a class="headerlink" href="#celery.backends.base.BaseBackend.TimeoutError" title="Permalink to this definition">¶</a></dt>
 <dd>The operation timed out.</dd></dl>
 
-<dl class="exception">
-<dt id="celery.backends.base.BaseBackend.UnpickleableExceptionWrapper">
-<em class="property">
-exception </em><tt class="descclassname">BaseBackend.</tt><tt class="descname">UnpickleableExceptionWrapper</tt><big>(</big><em>exc_module</em>, <em>exc_cls_name</em>, <em>exc_args</em><big>)</big><a class="headerlink" href="#celery.backends.base.BaseBackend.UnpickleableExceptionWrapper" title="Permalink to this definition">¶</a></dt>
-<dd><p>Wraps unpickleable exceptions.</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>exc_module</em> &#8211; see <a title="celery.backends.base.BaseBackend.UnpickleableExceptionWrapper.exc_module" class="reference internal" href="#celery.backends.base.BaseBackend.UnpickleableExceptionWrapper.exc_module"><tt class="xref docutils literal"><span class="pre">exc_module</span></tt></a>.</li>
-<li><em>exc_cls_name</em> &#8211; see <a title="celery.backends.base.BaseBackend.UnpickleableExceptionWrapper.exc_cls_name" class="reference internal" href="#celery.backends.base.BaseBackend.UnpickleableExceptionWrapper.exc_cls_name"><tt class="xref docutils literal"><span class="pre">exc_cls_name</span></tt></a>.</li>
-<li><em>exc_args</em> &#8211; see <a title="celery.backends.base.BaseBackend.UnpickleableExceptionWrapper.exc_args" class="reference internal" href="#celery.backends.base.BaseBackend.UnpickleableExceptionWrapper.exc_args"><tt class="xref docutils literal"><span class="pre">exc_args</span></tt></a></li>
-</ul>
-</td>
-</tr>
-</tbody>
-</table>
-<dl class="attribute">
-<dt id="celery.backends.base.BaseBackend.UnpickleableExceptionWrapper.exc_module">
-<tt class="descname">exc_module</tt><a class="headerlink" href="#celery.backends.base.BaseBackend.UnpickleableExceptionWrapper.exc_module" title="Permalink to this definition">¶</a></dt>
-<dd>The module of the original exception.</dd></dl>
-
-<dl class="attribute">
-<dt id="celery.backends.base.BaseBackend.UnpickleableExceptionWrapper.exc_cls_name">
-<tt class="descname">exc_cls_name</tt><a class="headerlink" href="#celery.backends.base.BaseBackend.UnpickleableExceptionWrapper.exc_cls_name" title="Permalink to this definition">¶</a></dt>
-<dd>The name of the original exception class.</dd></dl>
-
-<dl class="attribute">
-<dt id="celery.backends.base.BaseBackend.UnpickleableExceptionWrapper.exc_args">
-<tt class="descname">exc_args</tt><a class="headerlink" href="#celery.backends.base.BaseBackend.UnpickleableExceptionWrapper.exc_args" title="Permalink to this definition">¶</a></dt>
-<dd>The arguments for the original exception.</dd></dl>
-
-<p>Example</p>
-<div class="highlight-python"><div class="highlight"><pre><span class="gp">&gt;&gt;&gt; </span><span class="k">try</span><span class="p">:</span>
-<span class="gp">... </span>    <span class="n">something_raising_unpickleable_exc</span><span class="p">()</span>
-<span class="gp">&gt;&gt;&gt; </span><span class="k">except</span> <span class="ne">Exception</span><span class="p">,</span> <span class="n">e</span><span class="p">:</span>
-<span class="gp">... </span>    <span class="n">exc</span> <span class="o">=</span> <span class="n">UnpickleableException</span><span class="p">(</span><span class="n">e</span><span class="o">.</span><span class="n">__class__</span><span class="o">.</span><span class="n">__module__</span><span class="p">,</span>
-<span class="gp">... </span>                                <span class="n">e</span><span class="o">.</span><span class="n">__class__</span><span class="o">.</span><span class="n">__name__</span><span class="p">,</span>
-<span class="gp">... </span>                                <span class="n">e</span><span class="o">.</span><span class="n">args</span><span class="p">)</span>
-<span class="gp">... </span>    <span class="n">pickle</span><span class="o">.</span><span class="n">dumps</span><span class="p">(</span><span class="n">exc</span><span class="p">)</span> <span class="c"># Works fine.</span>
-</pre></div>
-</div>
-</dd></dl>
-
 <dl class="method">
 <dt id="celery.backends.base.BaseBackend.cleanup">
 <tt class="descclassname">BaseBackend.</tt><tt class="descname">cleanup</tt><big>(</big><big>)</big><a class="headerlink" href="#celery.backends.base.BaseBackend.cleanup" title="Permalink to this definition">¶</a></dt>
 <dd>Backend cleanup. Is run by
 <tt class="xref docutils literal"><span class="pre">celery.task.DeleteExpiredTaskMetaTask</span></tt>.</dd></dl>
 
-<dl class="method">
-<dt id="celery.backends.base.BaseBackend.create_exception_cls">
-<tt class="descclassname">BaseBackend.</tt><tt class="descname">create_exception_cls</tt><big>(</big><em>name</em>, <em>module</em>, <em>parent=None</em><big>)</big><a class="headerlink" href="#celery.backends.base.BaseBackend.create_exception_cls" title="Permalink to this definition">¶</a></dt>
-<dd>Dynamically create an exception class.</dd></dl>
-
 <dl class="method">
 <dt id="celery.backends.base.BaseBackend.exception_to_python">
 <tt class="descclassname">BaseBackend.</tt><tt class="descname">exception_to_python</tt><big>(</big><em>exc</em><big>)</big><a class="headerlink" href="#celery.backends.base.BaseBackend.exception_to_python" title="Permalink to this definition">¶</a></dt>
@@ -190,84 +140,10 @@ exception (if any).</dd></dl>
 <p>If the task raises an exception, this exception
 will be re-raised by <a title="celery.backends.base.BaseBackend.wait_for" class="reference internal" href="#celery.backends.base.BaseBackend.wait_for"><tt class="xref docutils literal"><span class="pre">wait_for()</span></tt></a>.</p>
 <p>If <tt class="docutils literal"><span class="pre">timeout</span></tt> is not <tt class="xref docutils literal"><span class="pre">None</span></tt>, this raises the
-<tt class="xref docutils literal"><span class="pre">celery.timer.TimeoutError</span></tt> exception if the operation takes
-longer than <tt class="docutils literal"><span class="pre">timeout</span></tt> seconds.</p>
-</dd></dl>
-
-</dd></dl>
-
-<dl class="exception">
-<dt id="celery.backends.base.TimeoutError">
-<em class="property">
-exception </em><tt class="descclassname">celery.backends.base.</tt><tt class="descname">TimeoutError</tt><a class="headerlink" href="#celery.backends.base.TimeoutError" title="Permalink to this definition">¶</a></dt>
-<dd>The operation timed out.</dd></dl>
-
-<dl class="exception">
-<dt id="celery.backends.base.UnpickleableExceptionWrapper">
-<em class="property">
-exception </em><tt class="descclassname">celery.backends.base.</tt><tt class="descname">UnpickleableExceptionWrapper</tt><big>(</big><em>exc_module</em>, <em>exc_cls_name</em>, <em>exc_args</em><big>)</big><a class="headerlink" href="#celery.backends.base.UnpickleableExceptionWrapper" title="Permalink to this definition">¶</a></dt>
-<dd><p>Wraps unpickleable exceptions.</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>exc_module</em> &#8211; see <a title="celery.backends.base.UnpickleableExceptionWrapper.exc_module" class="reference internal" href="#celery.backends.base.UnpickleableExceptionWrapper.exc_module"><tt class="xref docutils literal"><span class="pre">exc_module</span></tt></a>.</li>
-<li><em>exc_cls_name</em> &#8211; see <a title="celery.backends.base.UnpickleableExceptionWrapper.exc_cls_name" class="reference internal" href="#celery.backends.base.UnpickleableExceptionWrapper.exc_cls_name"><tt class="xref docutils literal"><span class="pre">exc_cls_name</span></tt></a>.</li>
-<li><em>exc_args</em> &#8211; see <a title="celery.backends.base.UnpickleableExceptionWrapper.exc_args" class="reference internal" href="#celery.backends.base.UnpickleableExceptionWrapper.exc_args"><tt class="xref docutils literal"><span class="pre">exc_args</span></tt></a></li>
-</ul>
-</td>
-</tr>
-</tbody>
-</table>
-<dl class="attribute">
-<dt id="celery.backends.base.UnpickleableExceptionWrapper.exc_module">
-<tt class="descname">exc_module</tt><a class="headerlink" href="#celery.backends.base.UnpickleableExceptionWrapper.exc_module" title="Permalink to this definition">¶</a></dt>
-<dd>The module of the original exception.</dd></dl>
-
-<dl class="attribute">
-<dt id="celery.backends.base.UnpickleableExceptionWrapper.exc_cls_name">
-<tt class="descname">exc_cls_name</tt><a class="headerlink" href="#celery.backends.base.UnpickleableExceptionWrapper.exc_cls_name" title="Permalink to this definition">¶</a></dt>
-<dd>The name of the original exception class.</dd></dl>
-
-<dl class="attribute">
-<dt id="celery.backends.base.UnpickleableExceptionWrapper.exc_args">
-<tt class="descname">exc_args</tt><a class="headerlink" href="#celery.backends.base.UnpickleableExceptionWrapper.exc_args" title="Permalink to this definition">¶</a></dt>
-<dd>The arguments for the original exception.</dd></dl>
-
-<p>Example</p>
-<div class="highlight-python"><div class="highlight"><pre><span class="gp">&gt;&gt;&gt; </span><span class="k">try</span><span class="p">:</span>
-<span class="gp">... </span>    <span class="n">something_raising_unpickleable_exc</span><span class="p">()</span>
-<span class="gp">&gt;&gt;&gt; </span><span class="k">except</span> <span class="ne">Exception</span><span class="p">,</span> <span class="n">e</span><span class="p">:</span>
-<span class="gp">... </span>    <span class="n">exc</span> <span class="o">=</span> <span class="n">UnpickleableException</span><span class="p">(</span><span class="n">e</span><span class="o">.</span><span class="n">__class__</span><span class="o">.</span><span class="n">__module__</span><span class="p">,</span>
-<span class="gp">... </span>                                <span class="n">e</span><span class="o">.</span><span class="n">__class__</span><span class="o">.</span><span class="n">__name__</span><span class="p">,</span>
-<span class="gp">... </span>                                <span class="n">e</span><span class="o">.</span><span class="n">args</span><span class="p">)</span>
-<span class="gp">... </span>    <span class="n">pickle</span><span class="o">.</span><span class="n">dumps</span><span class="p">(</span><span class="n">exc</span><span class="p">)</span> <span class="c"># Works fine.</span>
-</pre></div>
-</div>
+<a title="celery.exceptions.TimeoutError" class="reference external" href="celery.exceptions.html#celery.exceptions.TimeoutError"><tt class="xref docutils literal"><span class="pre">celery.exceptions.TimeoutError</span></tt></a> exception if the operation
+takes longer than <tt class="docutils literal"><span class="pre">timeout</span></tt> seconds.</p>
 </dd></dl>
 
-<dl class="function">
-<dt id="celery.backends.base.find_nearest_pickleable_exception">
-<tt class="descclassname">celery.backends.base.</tt><tt class="descname">find_nearest_pickleable_exception</tt><big>(</big><em>exc</em><big>)</big><a class="headerlink" href="#celery.backends.base.find_nearest_pickleable_exception" title="Permalink to this definition">¶</a></dt>
-<dd><p>With an exception instance, iterate over its super classes (by mro)
-and find the first super exception that is pickleable. It does
-not go below <tt class="xref docutils literal"><span class="pre">Exception</span></tt> (i.e. it skips <tt class="xref docutils literal"><span class="pre">Exception</span></tt>,
-<tt class="xref docutils literal"><span class="pre">BaseException</span></tt> and <tt class="xref docutils literal"><span class="pre">object</span></tt>). If that happens
-you should use <tt class="xref docutils literal"><span class="pre">UnpickleableException</span></tt> instead.</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>exc</em> &#8211; An exception instance.</td>
-</tr>
-<tr class="field"><th class="field-name">Returns:</th><td class="field-body">the nearest exception if it&#8217;s not <tt class="xref docutils literal"><span class="pre">Exception</span></tt> or below,
-if it is it returns <tt class="xref docutils literal"><span class="pre">None</span></tt>.</td>
-</tr>
-<tr class="field"><th class="field-name">Return type:</th><td class="field-body"><tt class="xref docutils literal"><span class="pre">Exception</span></tt></td>
-</tr>
-</tbody>
-</table>
 </dd></dl>
 
 </div>

+ 5 - 5
reference/celery.backends.cache.html

@@ -21,7 +21,7 @@
     <script type="text/javascript" src="../static/doctools.js"></script>
     <link rel="top" title="Celery v0.7.0 (unstable) documentation" href="../index.html" />
     <link rel="up" title="Module API Reference" href="index.html" />
-    <link rel="next" title="Backend: Tokyo Tyrant - celery.backends.tyrant" href="celery.backends.tyrant.html" />
+    <link rel="next" title="Backend: AMQP - celery.backends.amqp" href="celery.backends.amqp.html" />
     <link rel="prev" title="Backend: Database - celery.backends.database" href="celery.backends.database.html" /> 
   </head>
   <body>
@@ -35,7 +35,7 @@
           <a href="../modindex.html" title="Global Module Index"
              accesskey="M">modules</a> |</li>
         <li class="right" >
-          <a href="celery.backends.tyrant.html" title="Backend: Tokyo Tyrant - celery.backends.tyrant"
+          <a href="celery.backends.amqp.html" title="Backend: AMQP - celery.backends.amqp"
              accesskey="N">next</a> |</li>
         <li class="right" >
           <a href="celery.backends.database.html" title="Backend: Database - celery.backends.database"
@@ -71,8 +71,8 @@ class </em><tt class="descclassname">celery.backends.cache.</tt><tt class="descn
             <p class="topless"><a href="celery.backends.database.html"
                                   title="previous chapter">Backend: Database - celery.backends.database</a></p>
             <h4>Next topic</h4>
-            <p class="topless"><a href="celery.backends.tyrant.html"
-                                  title="next chapter">Backend: Tokyo Tyrant - celery.backends.tyrant</a></p>
+            <p class="topless"><a href="celery.backends.amqp.html"
+                                  title="next chapter">Backend: AMQP - celery.backends.amqp</a></p>
             <h3>This Page</h3>
             <ul class="this-page-menu">
               <li><a href="../sources/reference/celery.backends.cache.txt"
@@ -105,7 +105,7 @@ class </em><tt class="descclassname">celery.backends.cache.</tt><tt class="descn
           <a href="../modindex.html" title="Global Module Index"
              >modules</a> |</li>
         <li class="right" >
-          <a href="celery.backends.tyrant.html" title="Backend: Tokyo Tyrant - celery.backends.tyrant"
+          <a href="celery.backends.amqp.html" title="Backend: AMQP - celery.backends.amqp"
              >next</a> |</li>
         <li class="right" >
           <a href="celery.backends.database.html" title="Backend: Database - celery.backends.database"

+ 5 - 5
reference/celery.backends.tyrant.html

@@ -22,7 +22,7 @@
     <link rel="top" title="Celery v0.7.0 (unstable) documentation" href="../index.html" />
     <link rel="up" title="Module API Reference" href="index.html" />
     <link rel="next" title="Configuration - celery.conf" href="celery.conf.html" />
-    <link rel="prev" title="Backend: Cache - celery.backends.cache" href="celery.backends.cache.html" /> 
+    <link rel="prev" title="Backend: AMQP - celery.backends.amqp" href="celery.backends.amqp.html" /> 
   </head>
   <body>
     <div class="related">
@@ -38,7 +38,7 @@
           <a href="celery.conf.html" title="Configuration - celery.conf"
              accesskey="N">next</a> |</li>
         <li class="right" >
-          <a href="celery.backends.cache.html" title="Backend: Cache - celery.backends.cache"
+          <a href="celery.backends.amqp.html" title="Backend: AMQP - celery.backends.amqp"
              accesskey="P">previous</a> |</li>
         <li><a href="../index.html">Celery v0.7.0 (unstable) documentation</a> &raquo;</li>
           <li><a href="index.html" accesskey="U">Module API Reference</a> &raquo;</li> 
@@ -93,8 +93,8 @@ explicit <a title="celery.backends.tyrant.Backend.close" class="reference intern
       <div class="sphinxsidebar">
         <div class="sphinxsidebarwrapper">
             <h4>Previous topic</h4>
-            <p class="topless"><a href="celery.backends.cache.html"
-                                  title="previous chapter">Backend: Cache - celery.backends.cache</a></p>
+            <p class="topless"><a href="celery.backends.amqp.html"
+                                  title="previous chapter">Backend: AMQP - celery.backends.amqp</a></p>
             <h4>Next topic</h4>
             <p class="topless"><a href="celery.conf.html"
                                   title="next chapter">Configuration - celery.conf</a></p>
@@ -133,7 +133,7 @@ explicit <a title="celery.backends.tyrant.Backend.close" class="reference intern
           <a href="celery.conf.html" title="Configuration - celery.conf"
              >next</a> |</li>
         <li class="right" >
-          <a href="celery.backends.cache.html" title="Backend: Cache - celery.backends.cache"
+          <a href="celery.backends.amqp.html" title="Backend: AMQP - celery.backends.amqp"
              >previous</a> |</li>
         <li><a href="../index.html">Celery v0.7.0 (unstable) documentation</a> &raquo;</li>
           <li><a href="index.html" >Module API Reference</a> &raquo;</li> 

+ 6 - 6
reference/celery.bin.celeryd.html

@@ -21,7 +21,7 @@
     <script type="text/javascript" src="../static/doctools.js"></script>
     <link rel="top" title="Celery v0.7.0 (unstable) documentation" href="../index.html" />
     <link rel="up" title="Module API Reference" href="index.html" />
-    <link rel="next" title="Change history" href="../changelog.html" />
+    <link rel="next" title="Celery Initialize - celery.bin.celeryinit" href="celery.bin.celeryinit.html" />
     <link rel="prev" title="Django Fields - celery.fields" href="celery.fields.html" /> 
   </head>
   <body>
@@ -35,7 +35,7 @@
           <a href="../modindex.html" title="Global Module Index"
              accesskey="M">modules</a> |</li>
         <li class="right" >
-          <a href="../changelog.html" title="Change history"
+          <a href="celery.bin.celeryinit.html" title="Celery Initialize - celery.bin.celeryinit"
              accesskey="N">next</a> |</li>
         <li class="right" >
           <a href="celery.fields.html" title="Django Fields - celery.fields"
@@ -137,7 +137,7 @@ running in the background somewhere.</p>
 
 <dl class="function">
 <dt id="celery.bin.celeryd.install_restart_signal_handler">
-<tt class="descclassname">celery.bin.celeryd.</tt><tt class="descname">install_restart_signal_handler</tt><big>(</big><em>worker</em>, <em>context</em><big>)</big><a class="headerlink" href="#celery.bin.celeryd.install_restart_signal_handler" title="Permalink to this definition">¶</a></dt>
+<tt class="descclassname">celery.bin.celeryd.</tt><tt class="descname">install_restart_signal_handler</tt><big>(</big><em>worker</em><big>)</big><a class="headerlink" href="#celery.bin.celeryd.install_restart_signal_handler" title="Permalink to this definition">¶</a></dt>
 <dd>Installs a signal handler that restarts the current program
 when it receives the <tt class="docutils literal"><span class="pre">SIGHUP</span></tt> signal.</dd></dl>
 
@@ -163,8 +163,8 @@ when it receives the <tt class="docutils literal"><span class="pre">SIGHUP</span
             <p class="topless"><a href="celery.fields.html"
                                   title="previous chapter">Django Fields - celery.fields</a></p>
             <h4>Next topic</h4>
-            <p class="topless"><a href="../changelog.html"
-                                  title="next chapter">Change history</a></p>
+            <p class="topless"><a href="celery.bin.celeryinit.html"
+                                  title="next chapter">Celery Initialize - celery.bin.celeryinit</a></p>
             <h3>This Page</h3>
             <ul class="this-page-menu">
               <li><a href="../sources/reference/celery.bin.celeryd.txt"
@@ -197,7 +197,7 @@ when it receives the <tt class="docutils literal"><span class="pre">SIGHUP</span
           <a href="../modindex.html" title="Global Module Index"
              >modules</a> |</li>
         <li class="right" >
-          <a href="../changelog.html" title="Change history"
+          <a href="celery.bin.celeryinit.html" title="Celery Initialize - celery.bin.celeryinit"
              >next</a> |</li>
         <li class="right" >
           <a href="celery.fields.html" title="Django Fields - celery.fields"

+ 66 - 1
reference/celery.execute.html

@@ -52,6 +52,71 @@
             
   <div class="section" id="module-celery.execute">
 <h1>Executing Tasks - celery.execute<a class="headerlink" href="#module-celery.execute" title="Permalink to this headline">¶</a></h1>
+<dl class="class">
+<dt id="celery.execute.ExecuteWrapper">
+<em class="property">
+class </em><tt class="descclassname">celery.execute.</tt><tt class="descname">ExecuteWrapper</tt><big>(</big><em>fun</em>, <em>task_id</em>, <em>task_name</em>, <em>args=None</em>, <em>kwargs=None</em><big>)</big><a class="headerlink" href="#celery.execute.ExecuteWrapper" 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">&quot;DONE&quot;</span></tt>.</p>
+<p>If the call raises <a title="celery.exceptions.RetryTaskError" class="reference external" href="celery.exceptions.html#celery.exceptions.RetryTaskError"><tt class="xref docutils literal"><span class="pre">celery.exceptions.RetryTaskError</span></tt></a>, it extracts
+the original exception, uses that as the result and sets the task status
+to <tt class="docutils literal"><span class="pre">&quot;RETRY&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>fun</em> &#8211; Callable object to execute.</li>
+<li><em>task_id</em> &#8211; The unique id of the task.</li>
+<li><em>task_name</em> &#8211; Name of the task.</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 last">the function return value on success, or
+the exception instance on failure.</p>
+</td>
+</tr>
+</tbody>
+</table>
+<dl class="method">
+<dt id="celery.execute.ExecuteWrapper.handle_failure">
+<tt class="descname">handle_failure</tt><big>(</big><em>exc</em>, <em>exc_info</em><big>)</big><a class="headerlink" href="#celery.execute.ExecuteWrapper.handle_failure" title="Permalink to this definition">¶</a></dt>
+<dd>Handle exception.</dd></dl>
+
+<dl class="method">
+<dt id="celery.execute.ExecuteWrapper.handle_retry">
+<tt class="descname">handle_retry</tt><big>(</big><em>exc</em>, <em>exc_info</em><big>)</big><a class="headerlink" href="#celery.execute.ExecuteWrapper.handle_retry" title="Permalink to this definition">¶</a></dt>
+<dd>Handle retry exception.</dd></dl>
+
+<dl class="method">
+<dt id="celery.execute.ExecuteWrapper.handle_success">
+<tt class="descname">handle_success</tt><big>(</big><em>retval</em><big>)</big><a class="headerlink" href="#celery.execute.ExecuteWrapper.handle_success" title="Permalink to this definition">¶</a></dt>
+<dd><p>Handle successful execution.</p>
+<dl class="docutils">
+<dt>Saves the result to the current result store (skipped if the callable</dt>
+<dd>has a <tt class="docutils literal"><span class="pre">ignore_result</span></tt> attribute set to <tt class="xref docutils literal"><span class="pre">True</span></tt>).</dd>
+</dl>
+<p>If the callable has a <tt class="docutils literal"><span class="pre">on_success</span></tt> function, it as called with
+<tt class="docutils literal"><span class="pre">retval</span></tt> as argument.</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>retval</em> &#8211; The return value.</td>
+</tr>
+</tbody>
+</table>
+</dd></dl>
+
+</dd></dl>
+
 <dl class="function">
 <dt id="celery.execute.apply">
 <tt class="descclassname">celery.execute.</tt><tt class="descname">apply</tt><big>(</big><em>task</em>, <em>args</em>, <em>kwargs</em>, <em>**options</em><big>)</big><a class="headerlink" href="#celery.execute.apply" title="Permalink to this definition">¶</a></dt>
@@ -117,7 +182,7 @@ on establishing a connection to the AMQP server.</li>
 </ul>
 </td>
 </tr>
-<tr class="field"><th class="field-name" colspan="2">Raises <a title="celery.registry.NotRegistered" class="reference external" href="celery.registry.html#celery.registry.NotRegistered">celery.registry.NotRegistered</a>:</th></tr>
+<tr class="field"><th class="field-name" colspan="2">Raises <a title="celery.exceptions.NotRegistered" class="reference external" href="celery.exceptions.html#celery.exceptions.NotRegistered">celery.exceptions.NotRegistered</a>:</th></tr>
 <tr><td>&nbsp;</td><td class="field-body"><p class="first">exception if no such task
 has been registered in the task registry.</p>
 </td>

+ 1 - 1
reference/celery.fields.html

@@ -64,7 +64,7 @@ then it must [well, should] be a pickled one).</dd></dl>
 <dl class="class">
 <dt id="celery.fields.PickledObjectField">
 <em class="property">
-class </em><tt class="descclassname">celery.fields.</tt><tt class="descname">PickledObjectField</tt><big>(</big><em>verbose_name=None</em>, <em>name=None</em>, <em>primary_key=False</em>, <em>max_length=None</em>, <em>unique=False</em>, <em>blank=False</em>, <em>null=False</em>, <em>db_index=False</em>, <em>rel=None</em>, <em>default=&lt;class django.db.models.fields.NOT_PROVIDED at 0x215bd50&gt;</em>, <em>editable=True</em>, <em>serialize=True</em>, <em>unique_for_date=None</em>, <em>unique_for_month=None</em>, <em>unique_for_year=None</em>, <em>choices=None</em>, <em>help_text=''</em>, <em>db_column=None</em>, <em>db_tablespace=None</em>, <em>auto_created=False</em><big>)</big><a class="headerlink" href="#celery.fields.PickledObjectField" title="Permalink to this definition">¶</a></dt>
+class </em><tt class="descclassname">celery.fields.</tt><tt class="descname">PickledObjectField</tt><big>(</big><em>verbose_name=None</em>, <em>name=None</em>, <em>primary_key=False</em>, <em>max_length=None</em>, <em>unique=False</em>, <em>blank=False</em>, <em>null=False</em>, <em>db_index=False</em>, <em>rel=None</em>, <em>default=&lt;class django.db.models.fields.NOT_PROVIDED at 0x214ce70&gt;</em>, <em>editable=True</em>, <em>serialize=True</em>, <em>unique_for_date=None</em>, <em>unique_for_month=None</em>, <em>unique_for_year=None</em>, <em>choices=None</em>, <em>help_text=''</em>, <em>db_column=None</em>, <em>db_tablespace=None</em>, <em>auto_created=False</em><big>)</big><a class="headerlink" href="#celery.fields.PickledObjectField" title="Permalink to this definition">¶</a></dt>
 <dd><p>A field that automatically pickles/unpickles its value.</p>
 <dl class="method">
 <dt id="celery.fields.PickledObjectField.get_db_prep_lookup">

+ 2 - 7
reference/celery.pool.html

@@ -124,7 +124,7 @@ class </em><tt class="descclassname">celery.pool.</tt><tt class="descname">TaskP
 
 <dl class="method">
 <dt id="celery.pool.TaskPool.apply_async">
-<tt class="descname">apply_async</tt><big>(</big><em>target</em>, <em>args=None</em>, <em>kwargs=None</em>, <em>callbacks=None</em>, <em>errbacks=None</em>, <em>on_ack=None</em>, <em>meta=None</em><big>)</big><a class="headerlink" href="#celery.pool.TaskPool.apply_async" title="Permalink to this definition">¶</a></dt>
+<tt class="descname">apply_async</tt><big>(</big><em>target</em>, <em>args=None</em>, <em>kwargs=None</em>, <em>callbacks=None</em>, <em>errbacks=None</em>, <em>on_ack=&lt;function &lt;lambda&gt; at 0x21a7c70&gt;</em><big>)</big><a class="headerlink" href="#celery.pool.TaskPool.apply_async" title="Permalink to this definition">¶</a></dt>
 <dd><p>Equivalent of the :func:<tt class="docutils literal"><span class="pre">apply</span></tt> built-in function.</p>
 <p>All <tt class="docutils literal"><span class="pre">callbacks</span></tt> and <tt class="docutils literal"><span class="pre">errbacks</span></tt> should complete immediately since
 otherwise the thread which handles the result will get blocked.</p>
@@ -132,15 +132,10 @@ otherwise the thread which handles the result will get blocked.</p>
 
 <dl class="method">
 <dt id="celery.pool.TaskPool.on_ready">
-<tt class="descname">on_ready</tt><big>(</big><em>callbacks</em>, <em>errbacks</em>, <em>meta</em>, <em>ret_value</em><big>)</big><a class="headerlink" href="#celery.pool.TaskPool.on_ready" title="Permalink to this definition">¶</a></dt>
+<tt class="descname">on_ready</tt><big>(</big><em>callbacks</em>, <em>errbacks</em>, <em>on_ack</em>, <em>ret_value</em><big>)</big><a class="headerlink" href="#celery.pool.TaskPool.on_ready" title="Permalink to this definition">¶</a></dt>
 <dd>What to do when a worker task is ready and its return value has
 been collected.</dd></dl>
 
-<dl class="method">
-<dt id="celery.pool.TaskPool.on_return">
-<tt class="descname">on_return</tt><big>(</big><em>callbacks</em>, <em>errbacks</em>, <em>on_ack</em>, <em>meta</em>, <em>ret_value</em><big>)</big><a class="headerlink" href="#celery.pool.TaskPool.on_return" title="Permalink to this definition">¶</a></dt>
-<dd>What to do when the process returns.</dd></dl>
-
 <dl class="method">
 <dt id="celery.pool.TaskPool.start">
 <tt class="descname">start</tt><big>(</big><big>)</big><a class="headerlink" href="#celery.pool.TaskPool.start" title="Permalink to this definition">¶</a></dt>

+ 4 - 15
reference/celery.registry.html

@@ -53,18 +53,6 @@
   <div class="section" id="module-celery.registry">
 <h1>Task Registry - celery.registry<a class="headerlink" href="#module-celery.registry" title="Permalink to this headline">¶</a></h1>
 <p>celery.registry</p>
-<dl class="exception">
-<dt id="celery.registry.AlreadyRegistered">
-<em class="property">
-exception </em><tt class="descclassname">celery.registry.</tt><tt class="descname">AlreadyRegistered</tt><a class="headerlink" href="#celery.registry.AlreadyRegistered" title="Permalink to this definition">¶</a></dt>
-<dd>The task is already registered.</dd></dl>
-
-<dl class="exception">
-<dt id="celery.registry.NotRegistered">
-<em class="property">
-exception </em><tt class="descclassname">celery.registry.</tt><tt class="descname">NotRegistered</tt><a class="headerlink" href="#celery.registry.NotRegistered" title="Permalink to this definition">¶</a></dt>
-<dd>The task is not registered.</dd></dl>
-
 <dl class="class">
 <dt id="celery.registry.TaskRegistry">
 <em class="property">
@@ -126,7 +114,7 @@ from <tt class="xref docutils literal"><span class="pre">celery.task.Task</span>
 task is used as the name of the task, but you can override it
 using this option.</td>
 </tr>
-<tr class="field"><th class="field-name" colspan="2">Raises <a title="celery.registry.AlreadyRegistered" class="reference internal" href="#celery.registry.AlreadyRegistered">AlreadyRegistered</a>:</th></tr>
+<tr class="field"><th class="field-name" colspan="2">Raises <a title="celery.registry.TaskRegistry.AlreadyRegistered" class="reference internal" href="#celery.registry.TaskRegistry.AlreadyRegistered">AlreadyRegistered</a>:</th></tr>
 <tr><td>&nbsp;</td><td class="field-body">if the task is already registered.</td>
 </tr>
 </tbody>
@@ -144,8 +132,9 @@ using this option.</td>
 <tr class="field"><th class="field-name">Parameter:</th><td class="field-body"><em>name</em> &#8211; name of the task to unregister, or a
 <tt class="xref docutils literal"><span class="pre">celery.task.Task</span></tt> class with a valid <tt class="docutils literal"><span class="pre">name</span></tt> attribute.</td>
 </tr>
-<tr class="field"><th class="field-name" colspan="2">Raises <a title="celery.registry.NotRegistered" class="reference internal" href="#celery.registry.NotRegistered">NotRegistered</a>:</th></tr>
-<tr><td>&nbsp;</td><td class="field-body">if the task has not been registered.</td>
+<tr class="field"><th class="field-name" colspan="2">Raises <a title="celery.exceptions.NotRegistered" class="reference external" href="celery.exceptions.html#celery.exceptions.NotRegistered">celery.exceptions.NotRegistered</a>:</th></tr>
+<tr><td>&nbsp;</td><td class="field-body">if the task has not
+been registered.</td>
 </tr>
 </tbody>
 </table>

+ 4 - 10
reference/celery.result.html

@@ -199,9 +199,9 @@ contains the resulting value.</blockquote>
 <tr class="field"><th class="field-name">Parameter:</th><td class="field-body"><em>timeout</em> &#8211; How long to wait in seconds, before the
 operation times out.</td>
 </tr>
-<tr class="field"><th class="field-name" colspan="2">Raises <a title="celery.result.TimeoutError" class="reference internal" href="#celery.result.TimeoutError">TimeoutError</a>:</th></tr>
-<tr><td>&nbsp;</td><td class="field-body">if <tt class="docutils literal"><span class="pre">timeout</span></tt> is not <tt class="xref docutils literal"><span class="pre">None</span></tt> and
-the result does not arrive within <tt class="docutils literal"><span class="pre">timeout</span></tt> seconds.</td>
+<tr class="field"><th class="field-name" colspan="2">Raises <a title="celery.exceptions.TimeoutError" class="reference external" href="celery.exceptions.html#celery.exceptions.TimeoutError">celery.exceptions.TimeoutError</a>:</th></tr>
+<tr><td>&nbsp;</td><td class="field-body">if <tt class="docutils literal"><span class="pre">timeout</span></tt> is not <tt class="xref docutils literal"><span class="pre">None</span></tt>
+and the result does not arrive within <tt class="docutils literal"><span class="pre">timeout</span></tt> seconds.</td>
 </tr>
 </tbody>
 </table>
@@ -356,7 +356,7 @@ were called.</p>
 <tr class="field"><th class="field-name">Parameter:</th><td class="field-body"><em>timeout</em> &#8211; The time in seconds, how long
 it will wait for results, before the operation times out.</td>
 </tr>
-<tr class="field"><th class="field-name" colspan="2">Raises <a title="celery.result.TimeoutError" class="reference internal" href="#celery.result.TimeoutError">TimeoutError</a>:</th></tr>
+<tr class="field"><th class="field-name" colspan="2">Raises <a title="celery.exceptions.TimeoutError" class="reference external" href="celery.exceptions.html#celery.exceptions.TimeoutError">celery.exceptions.TimeoutError</a>:</th></tr>
 <tr><td>&nbsp;</td><td class="field-body">if <tt class="docutils literal"><span class="pre">timeout</span></tt> is not <tt class="xref docutils literal"><span class="pre">None</span></tt>
 and the operation takes longer than <tt class="docutils literal"><span class="pre">timeout</span></tt> seconds.</td>
 </tr>
@@ -426,12 +426,6 @@ waiting for execution.</td>
 
 </dd></dl>
 
-<dl class="exception">
-<dt id="celery.result.TimeoutError">
-<em class="property">
-exception </em><tt class="descclassname">celery.result.</tt><tt class="descname">TimeoutError</tt><a class="headerlink" href="#celery.result.TimeoutError" title="Permalink to this definition">¶</a></dt>
-<dd>The operation timed out.</dd></dl>
-
 </div>
 
 

+ 5 - 5
reference/celery.signals.html

@@ -21,7 +21,7 @@
     <script type="text/javascript" src="../static/doctools.js"></script>
     <link rel="top" title="Celery v0.7.0 (unstable) documentation" href="../index.html" />
     <link rel="up" title="Module API Reference" href="index.html" />
-    <link rel="next" title="Built-in Task Classes - celery.task.builtins" href="celery.task.builtins.html" />
+    <link rel="next" title="Exceptions - celery.exceptions" href="celery.exceptions.html" />
     <link rel="prev" title="Task Registry - celery.registry" href="celery.registry.html" /> 
   </head>
   <body>
@@ -35,7 +35,7 @@
           <a href="../modindex.html" title="Global Module Index"
              accesskey="M">modules</a> |</li>
         <li class="right" >
-          <a href="celery.task.builtins.html" title="Built-in Task Classes - celery.task.builtins"
+          <a href="celery.exceptions.html" title="Exceptions - celery.exceptions"
              accesskey="N">next</a> |</li>
         <li class="right" >
           <a href="celery.registry.html" title="Task Registry - celery.registry"
@@ -64,8 +64,8 @@
             <p class="topless"><a href="celery.registry.html"
                                   title="previous chapter">Task Registry - celery.registry</a></p>
             <h4>Next topic</h4>
-            <p class="topless"><a href="celery.task.builtins.html"
-                                  title="next chapter">Built-in Task Classes - celery.task.builtins</a></p>
+            <p class="topless"><a href="celery.exceptions.html"
+                                  title="next chapter">Exceptions - celery.exceptions</a></p>
             <h3>This Page</h3>
             <ul class="this-page-menu">
               <li><a href="../sources/reference/celery.signals.txt"
@@ -98,7 +98,7 @@
           <a href="../modindex.html" title="Global Module Index"
              >modules</a> |</li>
         <li class="right" >
-          <a href="celery.task.builtins.html" title="Built-in Task Classes - celery.task.builtins"
+          <a href="celery.exceptions.html" title="Exceptions - celery.exceptions"
              >next</a> |</li>
         <li class="right" >
           <a href="celery.registry.html" title="Task Registry - celery.registry"

+ 52 - 17
reference/celery.task.base.html

@@ -94,12 +94,6 @@ defined in the REPL (that is the python shell, or <tt class="docutils literal"><
 
 </dd></dl>
 
-<dl class="exception">
-<dt id="celery.task.base.MaxRetriesExceededError">
-<em class="property">
-exception </em><tt class="descclassname">celery.task.base.</tt><tt class="descname">MaxRetriesExceededError</tt><a class="headerlink" href="#celery.task.base.MaxRetriesExceededError" title="Permalink to this definition">¶</a></dt>
-<dd>The tasks max restart limit has been exceeded.</dd></dl>
-
 <dl class="class">
 <dt id="celery.task.base.PeriodicTask">
 <em class="property">
@@ -138,12 +132,6 @@ not defined.</td>
 </div>
 </dd></dl>
 
-<dl class="exception">
-<dt id="celery.task.base.RetryTaskError">
-<em class="property">
-exception </em><tt class="descclassname">celery.task.base.</tt><tt class="descname">RetryTaskError</tt><big>(</big><em>message</em>, <em>exc</em>, <em>*args</em>, <em>**kwargs</em><big>)</big><a class="headerlink" href="#celery.task.base.RetryTaskError" title="Permalink to this definition">¶</a></dt>
-<dd>The task is to be retried later.</dd></dl>
-
 <dl class="class">
 <dt id="celery.task.base.Task">
 <em class="property">
@@ -394,6 +382,51 @@ with this object, i.e.:</p>
 </div>
 </dd></dl>
 
+<dl class="method">
+<dt id="celery.task.base.Task.on_failure">
+<tt class="descclassname">Task.</tt><tt class="descname">on_failure</tt><big>(</big><em>exc</em><big>)</big><a class="headerlink" href="#celery.task.base.Task.on_failure" title="Permalink to this definition">¶</a></dt>
+<dd><p>Error handler.</p>
+<p>This is run by the worker when the task fails.</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>exc</em> &#8211; The exception raised by the task.</td>
+</tr>
+</tbody>
+</table>
+</dd></dl>
+
+<dl class="method">
+<dt id="celery.task.base.Task.on_retry">
+<tt class="descclassname">Task.</tt><tt class="descname">on_retry</tt><big>(</big><em>exc</em><big>)</big><a class="headerlink" href="#celery.task.base.Task.on_retry" title="Permalink to this definition">¶</a></dt>
+<dd><p>Retry handler.</p>
+<p>This is run by the worker when the task is to be retried.</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>exc</em> &#8211; The exception sent to <a title="celery.task.base.Task.retry" class="reference internal" href="#celery.task.base.Task.retry"><tt class="xref docutils literal"><span class="pre">retry()</span></tt></a>.</td>
+</tr>
+</tbody>
+</table>
+</dd></dl>
+
+<dl class="method">
+<dt id="celery.task.base.Task.on_success">
+<tt class="descclassname">Task.</tt><tt class="descname">on_success</tt><big>(</big><em>retval</em><big>)</big><a class="headerlink" href="#celery.task.base.Task.on_success" title="Permalink to this definition">¶</a></dt>
+<dd><p>Success handler.</p>
+<p>This is run by the worker when 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">Parameter:</th><td class="field-body"><em>retval</em> &#8211; The return value of the task.</td>
+</tr>
+</tbody>
+</table>
+</dd></dl>
+
 <dl class="method">
 <dt id="celery.task.base.Task.retry">
 <tt class="descclassname">Task.</tt><tt class="descname">retry</tt><big>(</big><em>args</em>, <em>kwargs</em>, <em>exc=None</em>, <em>throw=True</em>, <em>**options</em><big>)</big><a class="headerlink" href="#celery.task.base.Task.retry" title="Permalink to this definition">¶</a></dt>
@@ -408,7 +441,8 @@ with this object, i.e.:</p>
 <li><em>exc</em> &#8211; Optional exception to raise instead of
 <tt class="xref docutils literal"><span class="pre">MaxRestartsExceededError</span></tt> when the max restart limit has
 been exceeded.</li>
-<li><em>throw</em> &#8211; Do not raise the <a title="celery.task.base.RetryTaskError" class="reference internal" href="#celery.task.base.RetryTaskError"><tt class="xref docutils literal"><span class="pre">RetryTaskError</span></tt></a> exception,
+<li><em>throw</em> &#8211; Do not raise the
+<a title="celery.exceptions.RetryTaskError" class="reference external" href="celery.exceptions.html#celery.exceptions.RetryTaskError"><tt class="xref docutils literal"><span class="pre">celery.exceptions.RetryTaskError</span></tt></a> exception,
 that tells the worker that the task is to be retried.</li>
 <li><em>countdown</em> &#8211; Time in seconds to delay the retry for.</li>
 <li><em>eta</em> &#8211; Explicit time and date to run the retry at (must be a
@@ -418,10 +452,11 @@ meth:<cite>apply_async</cite>. See <a title="celery.execute.apply_async" class="
 </ul>
 </td>
 </tr>
-<tr class="field"><th class="field-name" colspan="2">Raises <a title="celery.task.base.RetryTaskError" class="reference internal" href="#celery.task.base.RetryTaskError">RetryTaskError</a>:</th></tr>
-<tr><td>&nbsp;</td><td class="field-body"><p class="first last">To tell the worker that the task has been
-re-sent for retry. This always happens except if the <tt class="docutils literal"><span class="pre">throw</span></tt>
-keyword argument has been explicitly set to <tt class="xref docutils literal"><span class="pre">False</span></tt>.</p>
+<tr class="field"><th class="field-name" colspan="2">Raises <a title="celery.exceptions.RetryTaskError" class="reference external" href="celery.exceptions.html#celery.exceptions.RetryTaskError">celery.exceptions.RetryTaskError</a>:</th></tr>
+<tr><td>&nbsp;</td><td class="field-body"><p class="first last">To tell the worker that the
+task has been re-sent for retry. This always happens except if
+the <tt class="docutils literal"><span class="pre">throw</span></tt> keyword argument has been explicitly set
+to <tt class="xref docutils literal"><span class="pre">False</span></tt>.</p>
 </td>
 </tr>
 </tbody>

+ 5 - 5
reference/celery.task.builtins.html

@@ -22,7 +22,7 @@
     <link rel="top" title="Celery v0.7.0 (unstable) documentation" href="../index.html" />
     <link rel="up" title="Module API Reference" href="index.html" />
     <link rel="next" title="Common Task Strategies - celery.task.strategy" href="celery.task.strategy.html" />
-    <link rel="prev" title="Signals - celery.signals" href="celery.signals.html" /> 
+    <link rel="prev" title="Exceptions - celery.exceptions" href="celery.exceptions.html" /> 
   </head>
   <body>
     <div class="related">
@@ -38,7 +38,7 @@
           <a href="celery.task.strategy.html" title="Common Task Strategies - celery.task.strategy"
              accesskey="N">next</a> |</li>
         <li class="right" >
-          <a href="celery.signals.html" title="Signals - celery.signals"
+          <a href="celery.exceptions.html" title="Exceptions - celery.exceptions"
              accesskey="P">previous</a> |</li>
         <li><a href="../index.html">Celery v0.7.0 (unstable) documentation</a> &raquo;</li>
           <li><a href="index.html" accesskey="U">Module API Reference</a> &raquo;</li> 
@@ -95,8 +95,8 @@ class </em><tt class="descclassname">celery.task.builtins.</tt><tt class="descna
       <div class="sphinxsidebar">
         <div class="sphinxsidebarwrapper">
             <h4>Previous topic</h4>
-            <p class="topless"><a href="celery.signals.html"
-                                  title="previous chapter">Signals - celery.signals</a></p>
+            <p class="topless"><a href="celery.exceptions.html"
+                                  title="previous chapter">Exceptions - celery.exceptions</a></p>
             <h4>Next topic</h4>
             <p class="topless"><a href="celery.task.strategy.html"
                                   title="next chapter">Common Task Strategies - celery.task.strategy</a></p>
@@ -135,7 +135,7 @@ class </em><tt class="descclassname">celery.task.builtins.</tt><tt class="descna
           <a href="celery.task.strategy.html" title="Common Task Strategies - celery.task.strategy"
              >next</a> |</li>
         <li class="right" >
-          <a href="celery.signals.html" title="Signals - celery.signals"
+          <a href="celery.exceptions.html" title="Exceptions - celery.exceptions"
              >previous</a> |</li>
         <li><a href="../index.html">Celery v0.7.0 (unstable) documentation</a> &raquo;</li>
           <li><a href="index.html" >Module API Reference</a> &raquo;</li> 

+ 1 - 1
reference/celery.utils.html

@@ -97,7 +97,7 @@ yield the last value infinitely.</dd></dl>
 
 <dl class="function">
 <dt id="celery.utils.retry_over_time">
-<tt class="descclassname">celery.utils.</tt><tt class="descname">retry_over_time</tt><big>(</big><em>fun</em>, <em>catch</em>, <em>args=</em><span class="optional">[</span><span class="optional">]</span>, <em>kwargs={}</em>, <em>errback=&lt;function &lt;lambda&gt; at 0x21b6af0&gt;</em>, <em>max_retries=None</em>, <em>interval_start=2</em>, <em>interval_step=2</em>, <em>interval_max=30</em><big>)</big><a class="headerlink" href="#celery.utils.retry_over_time" title="Permalink to this definition">¶</a></dt>
+<tt class="descclassname">celery.utils.</tt><tt class="descname">retry_over_time</tt><big>(</big><em>fun</em>, <em>catch</em>, <em>args=</em><span class="optional">[</span><span class="optional">]</span>, <em>kwargs={}</em>, <em>errback=&lt;function &lt;lambda&gt; at 0x21a7c70&gt;</em>, <em>max_retries=None</em>, <em>interval_start=2</em>, <em>interval_step=2</em>, <em>interval_max=30</em><big>)</big><a class="headerlink" href="#celery.utils.retry_over_time" title="Permalink to this definition">¶</a></dt>
 <dd><p>Retry the function over and over until max retries is exceeded.</p>
 <p>For each retry we sleep a for a while before we try again, this interval
 is increased for every retry until the max seconds is reached.</p>

+ 4 - 39
reference/celery.worker.job.html

@@ -56,7 +56,7 @@
 <dl class="class">
 <dt id="celery.worker.job.TaskWrapper">
 <em class="property">
-class </em><tt class="descclassname">celery.worker.job.</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>, <em>on_ack=None</em>, <em>retries=0</em>, <em>**opts</em><big>)</big><a class="headerlink" href="#celery.worker.job.TaskWrapper" title="Permalink to this definition">¶</a></dt>
+class </em><tt class="descclassname">celery.worker.job.</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>, <em>on_ack=&lt;function &lt;lambda&gt; at 0x21a7c70&gt;</em>, <em>retries=0</em>, <em>**opts</em><big>)</big><a class="headerlink" href="#celery.worker.job.TaskWrapper" title="Permalink to this definition">¶</a></dt>
 <dd><p>Class wrapping a task to be run.</p>
 <table class="docutils field-list" frame="void" rules="none">
 <col class="field-name" />
@@ -106,8 +106,7 @@ class </em><tt class="descclassname">celery.worker.job.</tt><tt class="descname"
 <dl class="method">
 <dt id="celery.worker.job.TaskWrapper.execute">
 <tt class="descname">execute</tt><big>(</big><em>loglevel=None</em>, <em>logfile=None</em><big>)</big><a class="headerlink" href="#celery.worker.job.TaskWrapper.execute" title="Permalink to this definition">¶</a></dt>
-<dd><p>Execute the task in a <a title="celery.worker.job.jail" class="reference internal" href="#celery.worker.job.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>
+<dd><p>Execute the task in a <a title="celery.execute.ExecuteWrapper" class="reference external" href="celery.execute.html#celery.execute.ExecuteWrapper"><tt class="xref docutils literal"><span class="pre">celery.execute.ExecuteWrapper</span></tt></a>.</p>
 <table class="docutils field-list" frame="void" rules="none">
 <col class="field-name" />
 <col class="field-body" />
@@ -171,51 +170,17 @@ the message is also rejected.</td>
 
 <dl class="method">
 <dt id="celery.worker.job.TaskWrapper.on_failure">
-<tt class="descname">on_failure</tt><big>(</big><em>exc_info</em>, <em>meta</em><big>)</big><a class="headerlink" href="#celery.worker.job.TaskWrapper.on_failure" title="Permalink to this definition">¶</a></dt>
+<tt class="descname">on_failure</tt><big>(</big><em>exc_info</em><big>)</big><a class="headerlink" href="#celery.worker.job.TaskWrapper.on_failure" title="Permalink to this definition">¶</a></dt>
 <dd>The handler used if the task raised an exception.</dd></dl>
 
 <dl class="method">
 <dt id="celery.worker.job.TaskWrapper.on_success">
-<tt class="descname">on_success</tt><big>(</big><em>ret_value</em>, <em>meta</em><big>)</big><a class="headerlink" href="#celery.worker.job.TaskWrapper.on_success" title="Permalink to this definition">¶</a></dt>
+<tt class="descname">on_success</tt><big>(</big><em>ret_value</em><big>)</big><a class="headerlink" href="#celery.worker.job.TaskWrapper.on_success" title="Permalink to this definition">¶</a></dt>
 <dd>The handler used if the task was successfully processed (
 without raising an exception).</dd></dl>
 
 </dd></dl>
 
-<dl class="function">
-<dt id="celery.worker.job.jail">
-<tt class="descclassname">celery.worker.job.</tt><tt class="descname">jail</tt><big>(</big><em>task_id</em>, <em>task_name</em>, <em>func</em>, <em>args</em>, <em>kwargs</em><big>)</big><a class="headerlink" href="#celery.worker.job.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">&quot;DONE&quot;</span></tt>.</p>
-<p>If the call raises <a title="celery.task.base.RetryTaskError" class="reference external" href="celery.task.base.html#celery.task.base.RetryTaskError"><tt class="xref docutils literal"><span class="pre">celery.task.base.RetryTaskError</span></tt></a>, it extracts
-the original exception, uses that as the result and sets the task status
-to <tt class="docutils literal"><span class="pre">&quot;RETRY&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>task_name</em> &#8211; The name 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 last">the function return value on success, or
-the exception instance on failure.</p>
-</td>
-</tr>
-</tbody>
-</table>
-</dd></dl>
-
 </div>
 
 

+ 4 - 1
reference/index.html

@@ -56,7 +56,7 @@
 <tbody valign="top">
 <tr class="field"><th class="field-name">Release:</th><td class="field-body">0.7</td>
 </tr>
-<tr class="field"><th class="field-name">Date:</th><td class="field-body">August 20, 2009</td>
+<tr class="field"><th class="field-name">Date:</th><td class="field-body">August 27, 2009</td>
 </tr>
 </tbody>
 </table>
@@ -67,6 +67,7 @@
 <li class="toctree-l1"><a class="reference external" href="celery.task.html">Task Information and Utilities - celery.task</a></li>
 <li class="toctree-l1"><a class="reference external" href="celery.registry.html">Task Registry - celery.registry</a></li>
 <li class="toctree-l1"><a class="reference external" href="celery.signals.html">Signals - celery.signals</a></li>
+<li class="toctree-l1"><a class="reference external" href="celery.exceptions.html">Exceptions - celery.exceptions</a></li>
 <li class="toctree-l1"><a class="reference external" href="celery.task.builtins.html">Built-in Task Classes - celery.task.builtins</a></li>
 <li class="toctree-l1"><a class="reference external" href="celery.task.strategy.html">Common Task Strategies - celery.task.strategy</a></li>
 <li class="toctree-l1"><a class="reference external" href="celery.loaders.html">Loaders - celery.loaders</a></li>
@@ -85,6 +86,7 @@
 <li class="toctree-l1"><a class="reference external" href="celery.backends.base.html">Backend: Base - celery.backends.base</a></li>
 <li class="toctree-l1"><a class="reference external" href="celery.backends.database.html">Backend: Database - celery.backends.database</a></li>
 <li class="toctree-l1"><a class="reference external" href="celery.backends.cache.html">Backend: Cache - celery.backends.cache</a></li>
+<li class="toctree-l1"><a class="reference external" href="celery.backends.amqp.html">Backend: AMQP - celery.backends.amqp</a></li>
 <li class="toctree-l1"><a class="reference external" href="celery.backends.tyrant.html">Backend: Tokyo Tyrant - celery.backends.tyrant</a></li>
 <li class="toctree-l1"><a class="reference external" href="celery.conf.html">Configuration - celery.conf</a></li>
 <li class="toctree-l1"><a class="reference external" href="celery.datastructures.html">Datastructures - celery.datastructures</a></li>
@@ -95,6 +97,7 @@
 <li class="toctree-l1"><a class="reference external" href="celery.models.html">Django Models - celery.models</a></li>
 <li class="toctree-l1"><a class="reference external" href="celery.fields.html">Django Fields - celery.fields</a></li>
 <li class="toctree-l1"><a class="reference external" href="celery.bin.celeryd.html">Celery Worker Daemon - celery.bin.celeryd</a></li>
+<li class="toctree-l1"><a class="reference external" href="celery.bin.celeryinit.html">Celery Initialize - celery.bin.celeryinit</a></li>
 </ul>
 </div>
 

Різницю між файлами не показано, бо вона завелика
+ 0 - 0
searchindex.js


+ 3 - 0
sources/reference/index.txt

@@ -14,6 +14,7 @@
     celery.task
     celery.registry
     celery.signals
+    celery.exceptions
     celery.task.builtins
     celery.task.strategy
     celery.loaders
@@ -32,6 +33,7 @@
     celery.backends.base
     celery.backends.database
     celery.backends.cache
+    celery.backends.amqp
     celery.backends.tyrant
     celery.conf
     celery.datastructures
@@ -42,3 +44,4 @@
     celery.models
     celery.fields
     celery.bin.celeryd
+    celery.bin.celeryinit

+ 1 - 1
tutorials/index.html

@@ -56,7 +56,7 @@
 <tbody valign="top">
 <tr class="field"><th class="field-name">Release:</th><td class="field-body">0.7</td>
 </tr>
-<tr class="field"><th class="field-name">Date:</th><td class="field-body">August 20, 2009</td>
+<tr class="field"><th class="field-name">Date:</th><td class="field-body">August 27, 2009</td>
 </tr>
 </tbody>
 </table>

Деякі файли не було показано, через те що забагато файлів було змінено