Autogenerated documentation for github.

changelog.html

@@ -61,7 +61,7 @@ taskset as it was a single entity.</p>
 </dd>
 </dl>
 </li>
-<li><p class="first"><strong>IMPORTANT</strong> Celery now depends on carrot &gt;= 0.4.0.</p>
+<li><p class="first"><strong>IMPORTANT</strong> Celery now depends on carrot &gt;= 0.4.1.</p>
 </li>
 <li><dl class="first docutils">
 <dt>The celery daemon now sends task errors to the registered admin e-mails.</dt>
@@ -106,6 +106,13 @@ been renamed, while others are new:</p>
 </dl>
 </li>
 <li><dl class="first docutils">
+<dt>Make every new worker process re-establish it&#8217;s Django DB connection,</dt>
+<dd><p class="first last">this solving the &#8220;MySQL connection died?&#8221; exceptions.
+Thanks to Vitaly Babiy and Jirka Vejrazka.</p>
+</dd>
+</dl>
+</li>
+<li><dl class="first docutils">
 <dt><strong>IMOPORTANT</strong> Now using pickle to encode task arguments. This means you</dt>
 <dd><p class="first last">now can pass complex python objects to tasks as arguments.</p>
 </dd>

genindex.html

@@ -141,8 +141,8 @@
 <dt><a href="reference/celery.platform.html#module-celery.platform">celery.platform (module)</a></dt>
 <dt><a href="reference/celery.registry.html#module-celery.registry">celery.registry (module)</a></dt>
 <dt><a href="reference/celery.result.html#module-celery.result">celery.result (module)</a></dt>
-<dt><a href="reference/celery.task.html#module-celery.task">celery.task (module)</a></dt></dl></td><td width="33%" valign="top"><dl>
-<dt><a href="reference/celery.timer.html#module-celery.timer">celery.timer (module)</a></dt>
+<dt><a href="reference/celery.task.html#module-celery.task">celery.task (module)</a></dt>
+<dt><a href="reference/celery.timer.html#module-celery.timer">celery.timer (module)</a></dt></dl></td><td width="33%" valign="top"><dl>
 <dt><a href="reference/celery.worker.html#module-celery.worker">celery.worker (module)</a></dt>
 <dt>celeryd command line option</dt>
   <dd><dl>
@@ -161,6 +161,7 @@
 <dt><a href="reference/celery.result.html#celery.result.TaskSetResult.completed_count">completed_count() (celery.result.TaskSetResult method)</a></dt>
 <dt><a href="reference/celery.worker.html#celery.worker.WorkController.concurrency">concurrency (celery.worker.WorkController attribute)</a></dt>
 <dt><a href="reference/celery.worker.html#celery.worker.WorkController.connection_diagnostics">connection_diagnostics() (celery.worker.WorkController 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>
@@ -210,11 +211,14 @@
 <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></dl></td><td width="33%" valign="top"><dl>
+  </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></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.worker.html#celery.worker.TaskWrapper.execute">execute() (celery.worker.TaskWrapper method)</a></dt>
 <dt><a href="reference/celery.worker.html#celery.worker.WorkController.execute_next_task">execute_next_task() (celery.worker.WorkController method)</a></dt>
 <dt><a href="reference/celery.task.html#celery.task.execute_remote">execute_remote() (in module celery.task)</a></dt>
@@ -330,6 +334,7 @@
 <table width="100%" class="indextable"><tr><td width="33%" valign="top">
 <dl>
 
+<dt><a href="reference/celery.bin.celeryd.html#celery.bin.celeryd.main">main() (in module celery.bin.celeryd)</a></dt>
 <dt><a href="reference/celery.task.html#celery.task.TaskSet.map">map() (celery.task.TaskSet class method)</a></dt>
 <dt><a href="reference/celery.task.html#celery.task.TaskSet.map_async">map_async() (celery.task.TaskSet class method)</a></dt>
 <dt><a href="reference/celery.backends.base.html#celery.backends.base.BaseBackend.mark_as_done">mark_as_done() (celery.backends.base.BaseBackend method)</a></dt></dl></td><td width="33%" valign="top"><dl>
@@ -360,6 +365,7 @@
 <table width="100%" class="indextable"><tr><td width="33%" valign="top">
 <dl>
 
+<dt><a href="reference/celery.bin.celeryd.html#celery.bin.celeryd.parse_options">parse_options() (in module celery.bin.celeryd)</a></dt>
 <dt><a href="reference/celery.task.html#celery.task.PeriodicTask">PeriodicTask (class in celery.task)</a></dt>
 <dt><a href="reference/celery.managers.html#celery.managers.PeriodicTaskManager">PeriodicTaskManager (class in celery.managers)</a></dt>
 <dt><a href="reference/celery.models.html#PeriodicTaskMeta">PeriodicTaskMeta (built-in class)</a></dt>
@@ -367,7 +373,9 @@
 <dt><a href="reference/celery.worker.html#celery.worker.WorkController.pool">pool (celery.worker.WorkController attribute)</a></dt></dl></td><td width="33%" valign="top"><dl>
 <dt><a href="reference/celery.datastructures.html#celery.datastructures.PositionQueue">PositionQueue (class in celery.datastructures)</a></dt>
 <dt><a href="reference/celery.datastructures.html#celery.datastructures.PositionQueue.UnfilledPosition">PositionQueue.UnfilledPosition (class in celery.datastructures)</a></dt>
+<dt><a href="reference/celery.backends.base.html#celery.backends.base.BaseBackend.prepare_exception">prepare_exception() (celery.backends.base.BaseBackend method)</a></dt>
 <dt><a href="reference/celery.backends.base.html#celery.backends.base.BaseBackend.prepare_result">prepare_result() (celery.backends.base.BaseBackend method)</a></dt>
+<dt><a href="reference/celery.worker.html#celery.worker.WorkController.process_task">process_task() (celery.worker.WorkController method)</a></dt>
 </dl></td></tr></table>
 
 <h2 id="Q">Q</h2>
@@ -392,19 +400,24 @@
 <dt><a href="reference/celery.platform.html#celery.platform.PIDFile.remove">remove() (celery.platform.PIDFile method)</a></dt>
 <dt><a href="reference/celery.platform.html#celery.platform.remove_pidfile">remove_pidfile() (in module celery.platform)</a></dt>
 <dt><a href="reference/celery.messaging.html#celery.messaging.TaskPublisher.requeue_task">requeue_task() (celery.messaging.TaskPublisher method)</a></dt>
-<dt><a href="reference/celery.worker.html#celery.worker.WorkController.reset_connection">reset_connection() (celery.worker.WorkController method)</a></dt></dl></td><td width="33%" valign="top"><dl>
+<dt><a href="reference/celery.worker.html#celery.worker.WorkController.reset_connection">reset_connection() (celery.worker.WorkController method)</a></dt>
 <dt><a href="reference/celery.result.html#celery.result.BaseAsyncResult.result">result (celery.result.BaseAsyncResult attribute)</a></dt>
   <dd><dl>
     <dt><a href="reference/celery.models.html#TaskMeta.result">(TaskMeta attribute)</a></dt>
-  </dl></dd>
-<dt><a href="reference/celery.task.html#celery.task.ExecuteRemoteTask.run">run() (celery.task.ExecuteRemoteTask method)</a></dt>
+  </dl></dd></dl></td><td width="33%" valign="top"><dl>
+<dt><a href="reference/celery.task.html#celery.task.AsynchronousMapTask.run">run() (celery.task.AsynchronousMapTask method)</a></dt>
   <dd><dl>
+    <dt><a href="reference/celery.task.html#celery.task.DeleteExpiredTaskMetaTask.run">(celery.task.DeleteExpiredTaskMetaTask method)</a></dt>
+    <dt><a href="reference/celery.task.html#celery.task.ExecuteRemoteTask.run">(celery.task.ExecuteRemoteTask method)</a></dt>
     <dt><a href="reference/celery.task.html#celery.task.Task.run">(celery.task.Task method)</a></dt>
     <dt><a href="reference/celery.task.html#celery.task.TaskSet.run">(celery.task.TaskSet method)</a></dt>
     <dt><a href="reference/celery.worker.html#celery.worker.WorkController.run">(celery.worker.WorkController method)</a></dt>
   </dl></dd>
 <dt><a href="reference/celery.task.html#celery.task.PeriodicTask.run_every">run_every (celery.task.PeriodicTask attribute)</a></dt>
-<dt><a href="reference/celery.worker.html#celery.worker.WorkController.run_periodic_tasks">run_periodic_tasks() (celery.worker.WorkController method)</a></dt>
+<dt><a href="reference/celery.backends.database.html#celery.backends.database.Backend.run_periodic_tasks">run_periodic_tasks() (celery.backends.database.Backend method)</a></dt>
+  <dd><dl>
+    <dt><a href="reference/celery.worker.html#celery.worker.WorkController.run_periodic_tasks">(celery.worker.WorkController method)</a></dt>
+  </dl></dd>
 </dl></td></tr></table>
 
 <h2 id="S">S</h2>
@@ -460,8 +473,8 @@
 <dt><a href="reference/celery.messaging.html#celery.messaging.TaskConsumer">TaskConsumer (class in celery.messaging)</a></dt>
 <dt><a href="reference/celery.managers.html#celery.managers.TaskManager">TaskManager (class in celery.managers)</a></dt>
 <dt><a href="reference/celery.models.html#TaskMeta">TaskMeta (built-in class)</a></dt>
-<dt><a href="reference/celery.messaging.html#celery.messaging.TaskPublisher">TaskPublisher (class in celery.messaging)</a></dt></dl></td><td width="33%" valign="top"><dl>
-<dt><a href="reference/celery.registry.html#celery.registry.TaskRegistry">TaskRegistry (class in celery.registry)</a></dt>
+<dt><a href="reference/celery.messaging.html#celery.messaging.TaskPublisher">TaskPublisher (class in celery.messaging)</a></dt>
+<dt><a href="reference/celery.registry.html#celery.registry.TaskRegistry">TaskRegistry (class in celery.registry)</a></dt></dl></td><td width="33%" valign="top"><dl>
 <dt><a href="reference/celery.registry.html#celery.registry.TaskRegistry.AlreadyRegistered">TaskRegistry.AlreadyRegistered</a></dt>
 <dt><a href="reference/celery.registry.html#celery.registry.TaskRegistry.NotRegistered">TaskRegistry.NotRegistered</a></dt>
 <dt><a href="reference/celery.task.html#celery.task.TaskSet">TaskSet (class in celery.task)</a></dt>
@@ -481,6 +494,7 @@
     <dt><a href="reference/celery.task.html#celery.task.TaskSet.total">(celery.task.TaskSet attribute)</a></dt>
   </dl></dd>
 <dt><a href="reference/celery.models.html#PeriodicTaskMeta.total_run_count">total_run_count (PeriodicTaskMeta attribute)</a></dt>
+<dt><a href="reference/celery.datastructures.html#celery.datastructures.ExceptionInfo.traceback">traceback (celery.datastructures.ExceptionInfo attribute)</a></dt>
 <dt><a href="reference/celery.task.html#celery.task.Task.type">type (celery.task.Task attribute)</a></dt>
 <dt><a href="reference/celery.backends.tyrant.html#celery.backends.tyrant.Backend.tyrant_host">tyrant_host (celery.backends.tyrant.Backend attribute)</a></dt>
 <dt><a href="reference/celery.backends.tyrant.html#celery.backends.tyrant.Backend.tyrant_port">tyrant_port (celery.backends.tyrant.Backend attribute)</a></dt>

objects.inv

@@ -25,6 +25,7 @@ celery.backends.base.BaseBackend.get_result method reference/celery.backends.bas
 celery.task.dmap function reference/celery.task.html
 celery.result.BaseAsyncResult.is_done method reference/celery.result.html
 celery.worker.TaskWrapper.execute method reference/celery.worker.html
+celery.backends.database.Backend.run_periodic_tasks method reference/celery.backends.database.html
 celery.result.TaskSetResult.subtasks attribute reference/celery.result.html
 celery.backends.tyrant.Backend.tyrant_port attribute reference/celery.backends.tyrant.html
 celery.worker.WorkController.task_consumer attribute reference/celery.worker.html
@@ -34,6 +35,7 @@ celery.registry.AlreadyRegistered exception reference/celery.registry.html
 celery.backends.base.UnpickleableExceptionWrapper exception reference/celery.backends.base.html
 TASK_STATUS_FAILURE data reference/celery.models.html
 celery.task.execute_remote function reference/celery.task.html
+celery.bin.celeryd.main function reference/celery.bin.celeryd.html
 celery.result.BaseAsyncResult.backend attribute reference/celery.result.html
 celery.worker.TaskWrapper class reference/celery.worker.html
 celery.messaging.TaskPublisher.encoder method reference/celery.messaging.html
@@ -49,26 +51,28 @@ celery.backends.base.UnpickleableExceptionWrapper.exc_args attribute reference/c
 celery.backends.tyrant.Backend class reference/celery.backends.tyrant.html
 celery.worker.WorkController.pool attribute reference/celery.worker.html
 celery.task.DeleteExpiredTaskMetaTask class reference/celery.task.html
+celery.datastructures.ExceptionInfo.traceback attribute reference/celery.datastructures.html
 celery.managers.TaskManager.get_all_expired method reference/celery.managers.html
 TaskMeta.task_id attribute reference/celery.models.html
 celery.discovery.autodiscover function reference/celery.discovery.html
 celery.result.TaskSetResult.ready method reference/celery.result.html
-celery.worker.WorkController.receive_message method reference/celery.worker.html
+celery.datastructures.ExceptionInfo class reference/celery.datastructures.html
 celery.backends.get_default_backend_cls data reference/celery.backends.html
 celery.task.Task.apply_async classmethod reference/celery.task.html
 celery.backends.tyrant.Backend.get_result method reference/celery.backends.tyrant.html
 celery.result.TaskSetResult.total attribute reference/celery.result.html
-celery.task.TaskSet class reference/celery.task.html
+celery.backends.base.find_nearest_pickleable_exception function reference/celery.backends.base.html
 celery.task.AsynchronousMapTask class reference/celery.task.html
 celery.managers.PeriodicTaskManager class reference/celery.managers.html
 celery.timer.EventTimer.event attribute reference/celery.timer.html
 TaskMeta class reference/celery.models.html
 celery.worker.TaskWrapper.from_message classmethod reference/celery.worker.html
+celery.backends.base.BaseBackend.exception_to_python method reference/celery.backends.base.html
 celery.platform.PIDFile.get_pid method reference/celery.platform.html
 celery.task.Task.run method reference/celery.task.html
 celery.result.BaseAsyncResult class reference/celery.result.html
 celery.platform.PIDFile.check method reference/celery.platform.html
-TASK_STATUS_RETRY data reference/celery.models.html
+celery.conf.LOG_FORMAT data reference/celery.conf.html
 celery.backends.database.Backend.store_result method reference/celery.backends.database.html
 celery.task.TaskSet.map_async classmethod reference/celery.task.html
 celery.platform.PIDFile.remove method reference/celery.platform.html
@@ -85,6 +89,7 @@ PeriodicTaskMeta.last_run_at attribute reference/celery.models.html
 celery.task.Task.get_publisher method reference/celery.task.html
 celery.result.TaskSetResult.itersubtasks method reference/celery.result.html
 celery.backends.base.BaseBackend.cleanup method reference/celery.backends.base.html
+celery.bin.celeryd.parse_options function reference/celery.bin.celeryd.html
 celery.task.discard_all function reference/celery.task.html
 celery.backends.database.Backend.get_status method reference/celery.backends.database.html
 PeriodicTaskMeta class reference/celery.models.html
@@ -94,11 +99,14 @@ celery.conf.AMQP_CONSUMER_ROUTING_KEY data reference/celery.conf.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.backends.base.BaseBackend.mark_as_failure method reference/celery.backends.base.html
+celery.backends.base.BaseBackend.prepare_exception method reference/celery.backends.base.html
+celery.task.TaskSet.remote_execute classmethod reference/celery.task.html
 celery.backends.tyrant.Backend.get_status method reference/celery.backends.tyrant.html
 celery.registry.TaskRegistry.NotRegistered exception reference/celery.registry.html
 celery.datastructures.PositionQueue.length attribute reference/celery.datastructures.html
+celery.worker.WorkController.process_task method reference/celery.worker.html
 celery.datastructures.PositionQueue class reference/celery.datastructures.html
+celery.messaging.TaskPublisher.delay_task method reference/celery.messaging.html
 celery.backends.base.BaseBackend.prepare_result method reference/celery.backends.base.html
 celery.result.TaskSetResult class reference/celery.result.html
 celery.backends.base.BaseBackend.UnpickleableExceptionWrapper.exc_module attribute reference/celery.backends.base.html
@@ -108,17 +116,18 @@ celery.worker.WorkController.connection_diagnostics method reference/celery.work
 celery.managers.TaskManager class reference/celery.managers.html
 celery.backends.base.BaseBackend.store_result method reference/celery.backends.base.html
 celery.worker.jail function reference/celery.worker.html
-celery.task.TaskSet.remote_execute classmethod reference/celery.task.html
 celery.result.TaskSetResult.waiting method reference/celery.result.html
 celery.result.AsyncResult.task_id attribute reference/celery.result.html
 celery.timer.EventTimer.interval attribute reference/celery.timer.html
 celery.result.BaseAsyncResult.successful method reference/celery.result.html
 celery.timer.TimeoutError exception reference/celery.timer.html
 celery.backends.tyrant.Backend.get_server method reference/celery.backends.tyrant.html
-celery.conf.LOG_FORMAT data reference/celery.conf.html
+celery.task.TaskSet class reference/celery.task.html
+TASK_STATUS_RETRY data reference/celery.models.html
 TASK_STATUSES data reference/celery.models.html
 celery.managers.TaskManager.get_task method reference/celery.managers.html
 celery.conf.AMQP_EXCHANGE data reference/celery.conf.html
+celery.datastructures.ExceptionInfo.exception attribute reference/celery.datastructures.html
 celery.result.TaskSetResult.subtask_ids attribute reference/celery.result.html
 PeriodicTaskMeta.delay method reference/celery.models.html
 celery.timer.TimeoutTimer.timeout attribute reference/celery.timer.html
@@ -139,7 +148,7 @@ celery.task.TaskSet.map classmethod reference/celery.task.html
 celery.backends.cache.Backend.get_result method reference/celery.backends.cache.html
 celery.task.Task.get_logger method reference/celery.task.html
 celery.conf.DAEMON_LOG_FILE data reference/celery.conf.html
-celery.backends.base.find_nearest_pickleable_exception function reference/celery.backends.base.html
+celery.backends.base.BaseBackend.create_exception_cls method reference/celery.backends.base.html
 celery.task.PeriodicTask class reference/celery.task.html
 celery.registry.TaskRegistry.unregister method reference/celery.registry.html
 celery.backends.base.BaseBackend.UnpickleableExceptionWrapper.exc_args attribute reference/celery.backends.base.html
@@ -157,12 +166,13 @@ celery.backends.cache.Backend.is_done method reference/celery.backends.cache.htm
 celery.task.Task.get_consumer method reference/celery.task.html
 celery.messaging.TaskPublisher.delay_task_in_set method reference/celery.messaging.html
 celery.backends.base.BaseBackend.UnpickleableExceptionWrapper exception reference/celery.backends.base.html
+celery.task.AsynchronousMapTask.run method reference/celery.task.html
 celery.platform.PIDFile.write method reference/celery.platform.html
 celery.platform.remove_pidfile function reference/celery.platform.html
 celery.platform.PIDFile class reference/celery.platform.html
 celery.worker.TaskWrapper.task_id attribute reference/celery.worker.html
 celery.managers.PeriodicTaskManager.get_waiting_tasks method reference/celery.managers.html
-celery.messaging.TaskPublisher.delay_task method reference/celery.messaging.html
+celery.backends.base.BaseBackend.mark_as_failure method reference/celery.backends.base.html
 celery.worker.WorkController.loglevel attribute reference/celery.worker.html
 celery.task.TaskSet.join method reference/celery.task.html
 celery.worker.WorkController.queue_wakeup_after attribute reference/celery.worker.html
@@ -170,11 +180,13 @@ celery.registry.TaskRegistry.get_all_regular method reference/celery.registry.ht
 celery.worker.WorkController.run method reference/celery.worker.html
 celery.registry.TaskRegistry class reference/celery.registry.html
 celery.backends.DefaultBackend class reference/celery.backends.html
+celery.task.DeleteExpiredTaskMetaTask.run method reference/celery.task.html
 celery.worker.UnknownTask exception reference/celery.worker.html
 celery.timer.TimeoutTimer class reference/celery.timer.html
 celery.backends.get_default_periodicstatus_backend_cls function reference/celery.backends.html
 celery.result.BaseAsyncResult.wait method reference/celery.result.html
 celery.result.TaskSetResult.join method reference/celery.result.html
+celery.worker.WorkController.reset_connection method reference/celery.worker.html
 celery.task.TaskSet.run method reference/celery.task.html
 celery.task.ExecuteRemoteTask.run method reference/celery.task.html
 celery.backends.base.BaseBackend.UnpickleableExceptionWrapper.exc_cls_name attribute reference/celery.backends.base.html
@@ -187,7 +199,7 @@ TaskMeta.status attribute reference/celery.models.html
 celery.worker.WorkController.concurrency attribute reference/celery.worker.html
 celery.backends.database.Backend.is_done method reference/celery.backends.database.html
 celery.backends.tyrant.Backend.tyrant_host attribute reference/celery.backends.tyrant.html
-celery.worker.WorkController.reset_connection method reference/celery.worker.html
+celery.worker.WorkController.receive_message method reference/celery.worker.html
 celery.conf.AMQP_CONSUMER_QUEUE data reference/celery.conf.html
 TASK_STATUSES_CHOICES data reference/celery.models.html
 celery.backends.base.BaseBackend.mark_as_retry method reference/celery.backends.base.html

reference/celery.backends.base.html

@@ -108,6 +108,16 @@ exception </em><tt class="descname">UnpickleableExceptionWrapper</tt><big>(</big
 <dd>Backend cleanup. Is run by
 <a title="celery.task.DeleteExpiredTaskMetaTask" class="reference external" href="celery.task.html#celery.task.DeleteExpiredTaskMetaTask"><tt class="xref docutils literal"><span class="pre">celery.task.DeleteExpiredTaskMetaTask</span></tt></a>.</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>
+<dd>Convert serialized exception to Python exception.</dd></dl>
+
 <dl class="method">
 <dt id="celery.backends.base.BaseBackend.get_result">
 <tt class="descclassname">BaseBackend.</tt><tt class="descname">get_result</tt><big>(</big><em>task_id</em><big>)</big><a class="headerlink" href="#celery.backends.base.BaseBackend.get_result" title="Permalink to this definition">¶</a></dt>
@@ -138,6 +148,11 @@ exception </em><tt class="descname">UnpickleableExceptionWrapper</tt><big>(</big
 <tt class="descclassname">BaseBackend.</tt><tt class="descname">mark_as_retry</tt><big>(</big><em>task_id</em>, <em>exc</em><big>)</big><a class="headerlink" href="#celery.backends.base.BaseBackend.mark_as_retry" title="Permalink to this definition">¶</a></dt>
 <dd>Mark task for retry.</dd></dl>
 
+<dl class="method">
+<dt id="celery.backends.base.BaseBackend.prepare_exception">
+<tt class="descclassname">BaseBackend.</tt><tt class="descname">prepare_exception</tt><big>(</big><em>exc</em><big>)</big><a class="headerlink" href="#celery.backends.base.BaseBackend.prepare_exception" title="Permalink to this definition">¶</a></dt>
+<dd>Prepare exception for serialization.</dd></dl>
+
 <dl class="method">
 <dt id="celery.backends.base.BaseBackend.prepare_result">
 <tt class="descclassname">BaseBackend.</tt><tt class="descname">prepare_result</tt><big>(</big><em>result</em><big>)</big><a class="headerlink" href="#celery.backends.base.BaseBackend.prepare_result" title="Permalink to this definition">¶</a></dt>

reference/celery.backends.database.html

@@ -77,6 +77,11 @@ class </em><tt class="descclassname">celery.backends.database.</tt><tt class="de
 <tt class="descname">is_done</tt><big>(</big><em>task_id</em><big>)</big><a class="headerlink" href="#celery.backends.database.Backend.is_done" title="Permalink to this definition">¶</a></dt>
 <dd>Returns <tt class="xref docutils literal"><span class="pre">True</span></tt> if task with <tt class="docutils literal"><span class="pre">task_id</span></tt> has been executed.</dd></dl>
 
+<dl class="method">
+<dt id="celery.backends.database.Backend.run_periodic_tasks">
+<tt class="descname">run_periodic_tasks</tt><big>(</big><big>)</big><a class="headerlink" href="#celery.backends.database.Backend.run_periodic_tasks" title="Permalink to this definition">¶</a></dt>
+<dd>Run all waiting periodic tasks.</dd></dl>
+
 <dl class="method">
 <dt id="celery.backends.database.Backend.store_result">
 <tt class="descname">store_result</tt><big>(</big><em>task_id</em>, <em>result</em>, <em>status</em><big>)</big><a class="headerlink" href="#celery.backends.database.Backend.store_result" title="Permalink to this definition">¶</a></dt>

reference/celery.bin.celeryd.html

@@ -85,6 +85,16 @@ new messages on the queue.</dd></dl>
 <tt class="descname">-d</tt><tt class="descclassname"></tt><tt class="descclassname">, </tt><tt class="descname">--daemon</tt><tt class="descclassname"></tt><a class="headerlink" href="#cmdoption-celeryd-d" title="Permalink to this definition">¶</a></dt>
 <dd>Run in the background as a daemon.</dd></dl>
 
+<dl class="function">
+<dt id="celery.bin.celeryd.main">
+<tt class="descclassname">celery.bin.celeryd.</tt><tt class="descname">main</tt><big>(</big><em>concurrency=10</em>, <em>daemon=False</em>, <em>loglevel=20</em>, <em>logfile='celeryd.log'</em>, <em>pidfile='celeryd.pid'</em>, <em>queue_wakeup_after=0.29999999999999999</em><big>)</big><a class="headerlink" href="#celery.bin.celeryd.main" title="Permalink to this definition">¶</a></dt>
+<dd>Run the celery daemon.</dd></dl>
+
+<dl class="function">
+<dt id="celery.bin.celeryd.parse_options">
+<tt class="descclassname">celery.bin.celeryd.</tt><tt class="descname">parse_options</tt><big>(</big><em>arguments</em><big>)</big><a class="headerlink" href="#celery.bin.celeryd.parse_options" title="Permalink to this definition">¶</a></dt>
+<dd>Option parsers for the available options to <tt class="docutils literal"><span class="pre">celeryd</span></tt>.</dd></dl>
+
 </div>
 
 

reference/celery.datastructures.html

@@ -52,6 +52,32 @@
   <div class="section" id="module-celery.datastructures">
 <h1>Datastructures - celery.datastructures<a class="headerlink" href="#module-celery.datastructures" title="Permalink to this headline">¶</a></h1>
 <p>Custom Datastructures</p>
+<dl class="class">
+<dt id="celery.datastructures.ExceptionInfo">
+<em class="property">
+class </em><tt class="descclassname">celery.datastructures.</tt><tt class="descname">ExceptionInfo</tt><big>(</big><em>exc_info</em><big>)</big><a class="headerlink" href="#celery.datastructures.ExceptionInfo" title="Permalink to this definition">¶</a></dt>
+<dd><p>Exception wrapping an exception and its traceback.</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_info</em> &#8211; The exception tuple info as returned by
+<tt class="xref docutils literal"><span class="pre">traceback.format_exception()</span></tt>.</td>
+</tr>
+</tbody>
+</table>
+<dl class="attribute">
+<dt id="celery.datastructures.ExceptionInfo.exception">
+<tt class="descname">exception</tt><a class="headerlink" href="#celery.datastructures.ExceptionInfo.exception" title="Permalink to this definition">¶</a></dt>
+<dd>The original exception.</dd></dl>
+
+<dl class="attribute">
+<dt id="celery.datastructures.ExceptionInfo.traceback">
+<tt class="descname">traceback</tt><a class="headerlink" href="#celery.datastructures.ExceptionInfo.traceback" title="Permalink to this definition">¶</a></dt>
+<dd>A traceback from the point when <a title="celery.datastructures.ExceptionInfo.exception" class="reference internal" href="#celery.datastructures.ExceptionInfo.exception"><tt class="xref docutils literal"><span class="pre">exception</span></tt></a> was raised.</dd></dl>
+
+</dd></dl>
+
 <dl class="class">
 <dt id="celery.datastructures.PositionQueue">
 <em class="property">

reference/celery.registry.html

@@ -51,6 +51,7 @@
 		
   <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">

reference/celery.result.html

@@ -327,7 +327,7 @@ will be reraised by <a title="celery.result.TaskSetResult.join" class="reference
 <dl class="method">
 <dt id="celery.result.TaskSetResult.ready">
 <tt class="descname">ready</tt><big>(</big><big>)</big><a class="headerlink" href="#celery.result.TaskSetResult.ready" title="Permalink to this definition">¶</a></dt>
-<dd><p>Is the task readyu?</p>
+<dd><p>Is the task ready?</p>
 <table class="docutils field-list" frame="void" rules="none">
 <col class="field-name" />
 <col class="field-body" />

reference/celery.task.html

@@ -56,8 +56,14 @@
 <dt id="celery.task.AsynchronousMapTask">
 <em class="property">
 class </em><tt class="descclassname">celery.task.</tt><tt class="descname">AsynchronousMapTask</tt><a class="headerlink" href="#celery.task.AsynchronousMapTask" title="Permalink to this definition">¶</a></dt>
-<dd>Task used internally by <a title="celery.task.dmap_async" class="reference internal" href="#celery.task.dmap_async"><tt class="xref docutils literal"><span class="pre">dmap_async()</span></tt></a> and
-<a title="celery.task.TaskSet.map_async" class="reference internal" href="#celery.task.TaskSet.map_async"><tt class="xref docutils literal"><span class="pre">TaskSet.map_async()</span></tt></a>.</dd></dl>
+<dd><p>Task used internally by <a title="celery.task.dmap_async" class="reference internal" href="#celery.task.dmap_async"><tt class="xref docutils literal"><span class="pre">dmap_async()</span></tt></a> and
+<a title="celery.task.TaskSet.map_async" class="reference internal" href="#celery.task.TaskSet.map_async"><tt class="xref docutils literal"><span class="pre">TaskSet.map_async()</span></tt></a>.</p>
+<dl class="method">
+<dt id="celery.task.AsynchronousMapTask.run">
+<tt class="descname">run</tt><big>(</big><em>serfunc</em>, <em>args</em>, <em>**kwargs</em><big>)</big><a class="headerlink" href="#celery.task.AsynchronousMapTask.run" title="Permalink to this definition">¶</a></dt>
+<dd>The method run by <tt class="docutils literal"><span class="pre">celeryd</span></tt>.</dd></dl>
+
+</dd></dl>
 
 <dl class="class">
 <dt id="celery.task.DeleteExpiredTaskMetaTask">
@@ -66,6 +72,11 @@ class </em><tt class="descclassname">celery.task.</tt><tt class="descname">Delet
 <dd><p>A periodic task that deletes expired task metadata every day.</p>
 <p>This runs the current backend&#8217;s
 <a title="celery.backends.base.BaseBackend.cleanup" class="reference external" href="celery.backends.base.html#celery.backends.base.BaseBackend.cleanup"><tt class="xref docutils literal"><span class="pre">celery.backends.base.BaseBackend.cleanup()</span></tt></a> method.</p>
+<dl class="method">
+<dt id="celery.task.DeleteExpiredTaskMetaTask.run">
+<tt class="descname">run</tt><big>(</big><em>**kwargs</em><big>)</big><a class="headerlink" href="#celery.task.DeleteExpiredTaskMetaTask.run" title="Permalink to this definition">¶</a></dt>
+<dd>The method run by <tt class="docutils literal"><span class="pre">celeryd</span></tt>.</dd></dl>
+
 </dd></dl>
 
 <dl class="class">

reference/celery.worker.html

@@ -270,6 +270,11 @@ necessary.</dd></dl>
 waiting on the queue.</p>
 </dd></dl>
 
+<dl class="method">
+<dt id="celery.worker.WorkController.process_task">
+<tt class="descname">process_task</tt><big>(</big><em>message</em><big>)</big><a class="headerlink" href="#celery.worker.WorkController.process_task" title="Permalink to this definition">¶</a></dt>
+<dd>Process task message by passing it to the pool of workers.</dd></dl>
+
 <dl class="method">
 <dt id="celery.worker.WorkController.receive_message">
 <tt class="descname">receive_message</tt><big>(</big><big>)</big><a class="headerlink" href="#celery.worker.WorkController.receive_message" title="Permalink to this definition">¶</a></dt>

sources/changelog.txt

@@ -14,7 +14,7 @@ arguments, so be sure to flush your task queue before you upgrade.
 		instance, which lets you inspect the status and return values of a
 		taskset as it was a single entity.
 
-	* **IMPORTANT** Celery now depends on carrot >= 0.4.0.
+	* **IMPORTANT** Celery now depends on carrot >= 0.4.1.
 
 	* The celery daemon now sends task errors to the registered admin e-mails.
 		To turn off this feature, set ``SEND_CELERY_TASK_ERROR_EMAILS`` to
@@ -53,6 +53,10 @@ arguments, so be sure to flush your task queue before you upgrade.
 	* Task errors are now logged using loglevel ``ERROR`` instead of ``INFO``,
 		and backtraces are dumped. Thanks to Grégoire Cachet.
 
+	* Make every new worker process re-establish it's Django DB connection,
+		this solving the "MySQL connection died?" exceptions.
+		Thanks to Vitaly Babiy and Jirka Vejrazka.
+
 	* **IMOPORTANT** Now using pickle to encode task arguments. This means you
 		now can pass complex python objects to tasks as arguments.