浏览代码

Autogenerated documentation for github.

Ask Solem 15 年之前
父节点
当前提交
67c5e5d5f6

+ 59 - 3
faq.html

@@ -134,7 +134,12 @@ using <tt class="docutils literal"><span class="pre">discard_all</span></tt>.</p
 </div>
 <div class="section" id="can-i-use-celery-with-activemq-stomp">
 <h3>Can I use celery with ActiveMQ/STOMP?<a class="headerlink" href="#can-i-use-celery-with-activemq-stomp" title="Permalink to this headline">¶</a></h3>
-<p><strong>Answer</strong>: Yes. But this is very experimental for now.</p>
+<p><strong>Answer</strong>: Yes. But this is somewhat experimental for now.
+It is certainly working ok for me in a test configuration, but it has not
+been tested in production like RabbitMQ. If you have any problems with
+using STOMP and celery, please report the bugs to the issue tracker:</p>
+<blockquote>
+<a class="reference external" href="http://github.com/ask/celery/issues/">http://github.com/ask/celery/issues/</a></blockquote>
 <p>First you have to use the <tt class="docutils literal"><span class="pre">master</span></tt> branch of <tt class="docutils literal"><span class="pre">celery</span></tt>:</p>
 <div class="highlight-python"><pre>$ git clone git://github.com/ask/celery.git
 $ cd celery
@@ -165,14 +170,14 @@ carrot needs to maintain the same interface for both AMQP and STOMP (obviously
 the one with the most capabilities won).</p>
 <p>Use the following specific settings in your <tt class="docutils literal"><span class="pre">settings.py</span></tt>:</p>
 <div class="highlight-python"><div class="highlight"><pre><span class="c"># Makes python-stomp the default backend for carrot.</span>
-<span class="n">CARROT_BACKEND</span> <span class="o">=</span> <span class="s">&quot;pystomp&quot;</span>
+<span class="n">CARROT_BACKEND</span> <span class="o">=</span> <span class="s">&quot;stomp&quot;</span>
 
 <span class="c"># STOMP hostname and port settings.</span>
 <span class="n">AMQP_HOST</span> <span class="o">=</span> <span class="s">&quot;localhost&quot;</span>
 <span class="n">AMQP_PORT</span> <span class="o">=</span> <span class="mf">61613</span>
 
 <span class="c"># The queue name to use (both queue and exchange must be set to the</span>
-<span class="c"># same queue name when using STOMP!!!)</span>
+<span class="c"># same queue name when using STOMP)</span>
 <span class="n">CELERY_AMQP_CONSUMER_QUEUE</span> <span class="o">=</span> <span class="s">&quot;/queue/celery&quot;</span>
 <span class="n">CELERY_AMQP_EXCHANGE</span> <span class="o">=</span> <span class="s">&quot;/queue/celery&quot;</span>
 </pre></div>
@@ -257,6 +262,55 @@ configuration:</p>
 </pre></div>
 </div>
 </div>
+<div class="section" id="can-i-use-celery-without-django">
+<h3>Can I use celery without Django?<a class="headerlink" href="#can-i-use-celery-without-django" title="Permalink to this headline">¶</a></h3>
+<p><strong>Answer:</strong> Yes. But you have to either create a custom loader, or use the
+default loader with a configuration file.</p>
+</div>
+</div>
+<div class="section" id="using-the-default-loader">
+<h2>Using the default loader<a class="headerlink" href="#using-the-default-loader" title="Permalink to this headline">¶</a></h2>
+<p>You need a configuration file named <tt class="docutils literal"><span class="pre">celeryconfig.py</span></tt>, either in the
+directory you run <tt class="docutils literal"><span class="pre">celeryd</span></tt> in, or in a Python library path where it is
+able to find it. The configuration file can contain any of the settings
+described in <a title="" class="reference external" href="reference/celery.conf.html#module-celery.conf"><tt class="xref docutils literal"><span class="pre">celery.conf</span></tt></a>, and in additional if you&#8217;re using the
+database backend you have to configure the database. Here is an example
+configuration using the database backend with MySQL:</p>
+<div class="highlight-python"><div class="highlight"><pre><span class="c"># Broker configuration</span>
+<span class="n">AMQP_SERVER</span> <span class="o">=</span> <span class="s">&quot;localhost&quot;</span>
+<span class="n">AMQP_PORT</span> <span class="o">=</span> <span class="s">&quot;5672&quot;</span>
+<span class="n">AMQP_VHOST</span> <span class="o">=</span> <span class="s">&quot;celery&quot;</span>
+<span class="n">AMQP_USER</span> <span class="o">=</span> <span class="s">&quot;celery&quot;</span>
+<span class="n">AMQP_PASSWORD</span> <span class="o">=</span> <span class="s">&quot;celerysecret&quot;</span>
+<span class="n">CARROT_BACKEND</span><span class="o">=</span><span class="s">&quot;amqp&quot;</span>
+
+<span class="c"># Using the database backend.</span>
+<span class="n">CELERY_BACKEND</span> <span class="o">=</span> <span class="s">&quot;database&quot;</span>
+
+<span class="c"># Number of processes that processes tasks simultaneously.</span>
+<span class="n">CELERYD_CONCURRENCY</span> <span class="o">=</span> <span class="mf">8</span>
+
+<span class="c"># Modules to import when celeryd starts.</span>
+<span class="c"># This must import every module where you register tasks so celeryd</span>
+<span class="c"># is able to find and run them.</span>
+<span class="n">CELERY_IMPORTS</span> <span class="o">=</span> <span class="p">(</span><span class="s">&quot;mytaskmodule1&quot;</span><span class="p">,</span> <span class="s">&quot;mytaskmodule2&quot;</span><span class="p">)</span>
+</pre></div>
+</div>
+<p>Now with this configuration file in the current directory you have to
+run <tt class="docutils literal"><span class="pre">celeryinit</span></tt> to create the database tables:</p>
+<div class="highlight-python"><pre>$ celeryinit</pre>
+</div>
+<p>Then you should be able to successfully run <tt class="docutils literal"><span class="pre">celeryd</span></tt>:</p>
+<div class="highlight-python"><pre>$ celeryd --loglevel=INFO</pre>
+</div>
+<p>and send a task from a python shell (note that it must be able to import
+<tt class="docutils literal"><span class="pre">celeryconfig.py</span></tt>):</p>
+<div class="highlight-python"><div class="highlight"><pre><span class="gp">&gt;&gt;&gt; </span><span class="kn">from</span> <span class="nn">celery.task.builtins</span> <span class="kn">import</span> <span class="n">PingTask</span>
+<span class="gp">&gt;&gt;&gt; </span><span class="n">result</span> <span class="o">=</span> <span class="n">PingTask</span><span class="o">.</span><span class="n">apply_async</span><span class="p">()</span>
+<span class="gp">&gt;&gt;&gt; </span><span class="n">result</span><span class="o">.</span><span class="n">get</span><span class="p">()</span>
+<span class="go">&#39;pong&#39;</span>
+</pre></div>
+</div>
 </div>
 </div>
 
@@ -282,8 +336,10 @@ configuration:</p>
 <li><a class="reference external" href="#can-i-use-celery-with-activemq-stomp">Can I use celery with ActiveMQ/STOMP?</a></li>
 <li><a class="reference external" href="#which-features-are-not-supported-when-using-stomp">Which features are not supported when using STOMP?</a></li>
 <li><a class="reference external" href="#can-i-send-some-tasks-to-only-some-servers">Can I send some tasks to only some servers?</a></li>
+<li><a class="reference external" href="#can-i-use-celery-without-django">Can I use celery without Django?</a></li>
 </ul>
 </li>
+<li><a class="reference external" href="#using-the-default-loader">Using the default loader</a></li>
 </ul>
 </li>
 </ul>

+ 41 - 10
genindex.html

@@ -168,6 +168,7 @@
 <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>
     <dt><a href="reference/celery.worker.html#celery.worker.WorkController.bucket_queue">(celery.worker.WorkController attribute)</a></dt>
@@ -191,6 +192,10 @@
 <dt><a href="reference/celery.discovery.html#module-celery.discovery">celery.discovery (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>
+<dt><a href="reference/celery.loaders.base.html#module-celery.loaders.base">celery.loaders.base (module)</a></dt>
+<dt><a href="reference/celery.loaders.default.html#module-celery.loaders.default">celery.loaders.default (module)</a></dt>
+<dt><a href="reference/celery.loaders.djangoapp.html#module-celery.loaders.djangoapp">celery.loaders.djangoapp (module)</a></dt>
 <dt><a href="reference/celery.log.html#module-celery.log">celery.log (module)</a></dt>
 <dt><a href="reference/celery.managers.html#module-celery.managers">celery.managers (module)</a></dt>
 <dt><a href="reference/celery.messaging.html#module-celery.messaging">celery.messaging (module)</a></dt>
@@ -198,15 +203,16 @@
 <dt><a href="reference/celery.pool.html#module-celery.pool">celery.pool (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.signals.html#module-celery.signals">celery.signals (module)</a></dt>
 <dt><a href="reference/celery.supervisor.html#module-celery.supervisor">celery.supervisor (module)</a></dt>
 <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.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>
+<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.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></dl></td><td width="33%" valign="top"><dl>
+<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>
 <dt>celeryd command line option</dt>
   <dd><dl>
@@ -235,6 +241,7 @@
 <dt><a href="reference/celery.monitoring.html#celery.monitoring.StatsCollector.collect">collect() (celery.monitoring.StatsCollector method)</a></dt>
 <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.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>
@@ -251,15 +258,16 @@
 <dt><a href="reference/celery.models.html#TaskMeta.date_done">date_done (TaskMeta attribute)</a></dt>
 <dt><a href="reference/celery.messaging.html#celery.messaging.TaskConsumer.decoder">decoder() (celery.messaging.TaskConsumer method)</a></dt>
 <dt><a href="reference/celery.conf.html#celery.conf.DEFAULT_AMQP_CONNECTION_MAX_RETRIES">DEFAULT_AMQP_CONNECTION_MAX_RETRIES (in module celery.conf)</a></dt>
+<dt><a href="reference/celery.task.base.html#celery.task.base.Task.default_retry_delay">default_retry_delay (celery.task.base.Task attribute)</a></dt>
 <dt><a href="reference/celery.backends.html#celery.backends.DefaultBackend">DefaultBackend (class in celery.backends)</a></dt>
 <dt><a href="reference/celery.task.base.html#celery.task.base.Task.delay">delay() (celery.task.base.Task class method)</a></dt>
   <dd><dl>
     <dt><a href="reference/celery.models.html#PeriodicTaskMeta.delay">(PeriodicTaskMeta method)</a></dt>
-  </dl></dd>
+  </dl></dd></dl></td><td width="33%" valign="top"><dl>
 <dt><a href="reference/celery.messaging.html#celery.messaging.TaskPublisher.delay_task">delay_task() (celery.messaging.TaskPublisher method)</a></dt>
   <dd><dl>
     <dt><a href="reference/celery.execute.html#celery.execute.delay_task">(in module celery.execute)</a></dt>
-  </dl></dd></dl></td><td width="33%" valign="top"><dl>
+  </dl></dd>
 <dt><a href="reference/celery.messaging.html#celery.messaging.TaskPublisher.delay_task_in_set">delay_task_in_set() (celery.messaging.TaskPublisher method)</a></dt>
 <dt><a href="reference/celery.managers.html#celery.managers.TaskManager.delete_expired">delete_expired() (celery.managers.TaskManager method)</a></dt>
 <dt><a href="reference/celery.task.builtins.html#celery.task.builtins.DeleteExpiredTaskMetaTask">DeleteExpiredTaskMetaTask (class in celery.task.builtins)</a></dt>
@@ -418,12 +426,16 @@
 <dt><a href="reference/celery.models.html#PeriodicTaskMeta.last_run_at">last_run_at (PeriodicTaskMeta attribute)</a></dt>
 <dt><a href="reference/celery.datastructures.html#celery.datastructures.PositionQueue.length">length (celery.datastructures.PositionQueue attribute)</a></dt>
 <dt><a href="reference/celery.pool.html#celery.pool.TaskPool.limit">limit (celery.pool.TaskPool attribute)</a></dt>
+<dt><a href="reference/celery.loaders.default.html#celery.loaders.default.Loader">Loader (class in celery.loaders.default)</a></dt>
+  <dd><dl>
+    <dt><a href="reference/celery.loaders.djangoapp.html#celery.loaders.djangoapp.Loader">(class in celery.loaders.djangoapp)</a></dt>
+  </dl></dd>
 <dt><a href="reference/celery.managers.html#celery.managers.MySQLTableLock.lock_table">lock_table() (celery.managers.MySQLTableLock method)</a></dt>
   <dd><dl>
     <dt><a href="reference/celery.managers.html#celery.managers.TableLock.lock_table">(celery.managers.TableLock method)</a></dt>
   </dl></dd>
-<dt><a href="reference/celery.conf.html#celery.conf.LOG_FORMAT">LOG_FORMAT (in module celery.conf)</a>, <a href="reference/celery.conf.html#celery.conf.LOG_FORMAT">[1]</a></dt>
-<dt><a href="reference/celery.conf.html#celery.conf.LOG_LEVELS">LOG_LEVELS (in module celery.conf)</a>, <a href="reference/celery.conf.html#celery.conf.LOG_LEVELS">[1]</a></dt></dl></td><td width="33%" valign="top"><dl>
+<dt><a href="reference/celery.conf.html#celery.conf.LOG_FORMAT">LOG_FORMAT (in module celery.conf)</a>, <a href="reference/celery.conf.html#celery.conf.LOG_FORMAT">[1]</a></dt></dl></td><td width="33%" valign="top"><dl>
+<dt><a href="reference/celery.conf.html#celery.conf.LOG_LEVELS">LOG_LEVELS (in module celery.conf)</a>, <a href="reference/celery.conf.html#celery.conf.LOG_LEVELS">[1]</a></dt>
 <dt><a href="reference/celery.worker.html#celery.worker.WorkController.logfile">logfile (celery.worker.WorkController attribute)</a></dt>
 <dt><a href="reference/celery.pool.html#celery.pool.TaskPool.logger">logger (celery.pool.TaskPool attribute)</a></dt>
   <dd><dl>
@@ -442,9 +454,12 @@
 <dt><a href="reference/celery.task.base.html#celery.task.base.TaskSet.map_async">map_async() (celery.task.base.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>
 <dt><a href="reference/celery.backends.base.html#celery.backends.base.BaseBackend.mark_as_failure">mark_as_failure() (celery.backends.base.BaseBackend method)</a></dt>
+<dt><a href="reference/celery.backends.base.html#celery.backends.base.BaseBackend.mark_as_retry">mark_as_retry() (celery.backends.base.BaseBackend method)</a></dt>
 <dt><a href="reference/celery.supervisor.html#celery.supervisor.OFASupervisor.max_restart_freq">max_restart_freq (celery.supervisor.OFASupervisor attribute)</a></dt>
-<dt><a href="reference/celery.supervisor.html#celery.supervisor.OFASupervisor.max_restart_freq_time">max_restart_freq_time (celery.supervisor.OFASupervisor attribute)</a></dt></dl></td><td width="33%" valign="top"><dl>
+<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.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>
@@ -485,6 +500,15 @@
     <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.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>
+  </dl></dd>
+<dt><a href="reference/celery.loaders.base.html#celery.loaders.base.BaseLoader.on_worker_init">on_worker_init() (celery.loaders.base.BaseLoader method)</a></dt>
+  <dd><dl>
+    <dt><a href="reference/celery.loaders.default.html#celery.loaders.default.Loader.on_worker_init">(celery.loaders.default.Loader method)</a></dt>
+    <dt><a href="reference/celery.loaders.djangoapp.html#celery.loaders.djangoapp.Loader.on_worker_init">(celery.loaders.djangoapp.Loader method)</a></dt>
+  </dl></dd>
 <dt><a href="reference/celery.backends.tyrant.html#celery.backends.tyrant.Backend.open">open() (celery.backends.tyrant.Backend method)</a></dt>
 </dl></td></tr></table>
 
@@ -520,6 +544,10 @@
 <table width="100%" class="indextable"><tr><td width="33%" valign="top">
 <dl>
 
+<dt><a href="reference/celery.loaders.default.html#celery.loaders.default.Loader.read_configuration">read_configuration() (celery.loaders.default.Loader method)</a></dt>
+  <dd><dl>
+    <dt><a href="reference/celery.loaders.djangoapp.html#celery.loaders.djangoapp.Loader.read_configuration">(celery.loaders.djangoapp.Loader method)</a></dt>
+  </dl></dd>
 <dt><a href="reference/celery.result.html#celery.result.BaseAsyncResult.ready">ready() (celery.result.BaseAsyncResult method)</a></dt>
   <dd><dl>
     <dt><a href="reference/celery.result.html#celery.result.TaskSetResult.ready">(celery.result.TaskSetResult method)</a></dt>
@@ -538,7 +566,9 @@
     <dt><a href="reference/celery.models.html#TaskMeta.result">(TaskMeta attribute)</a></dt>
     <dt><a href="reference/celery.result.html#celery.result.EagerResult.result">(celery.result.EagerResult attribute)</a></dt>
   </dl></dd>
-<dt><a href="reference/celery.utils.html#celery.utils.retry_over_time">retry_over_time() (in module celery.utils)</a></dt></dl></td><td width="33%" valign="top"><dl>
+<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.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>
@@ -607,6 +637,7 @@
 <dt><a href="reference/celery.supervisor.html#celery.supervisor.OFASupervisor.target">target (celery.supervisor.OFASupervisor attribute)</a></dt>
 <dt><a href="reference/celery.task.base.html#celery.task.base.Task">Task (class in celery.task.base)</a></dt>
 <dt><a href="reference/celery.models.html#PeriodicTaskMeta.task">task (PeriodicTaskMeta attribute)</a></dt>
+<dt><a href="reference/celery.task.base.html#celery.task.base.Task.MaxRetriesExceededError">Task.MaxRetriesExceededError</a></dt>
 <dt><a href="reference/celery.worker.job.html#celery.worker.job.TaskWrapper.task_func">task_func (celery.worker.job.TaskWrapper attribute)</a></dt>
 <dt><a href="reference/celery.result.html#celery.result.AsyncResult.task_id">task_id (celery.result.AsyncResult attribute)</a></dt>
   <dd><dl>
@@ -630,8 +661,8 @@
 <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.pool.html#celery.pool.TaskPool">TaskPool (class in celery.pool)</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.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.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.base.html#celery.task.base.TaskSet">TaskSet (class in celery.task.base)</a></dt>

+ 16 - 9
index.html

@@ -5,7 +5,7 @@
   <head>
     <meta http-equiv="Content-Type" content="text/html; charset=utf-8" />
     
-    <title>Celery - The Django Task Queue &mdash; Celery v0.6.0 (stable) documentation</title>
+    <title>Celery - Distributed Task Queue &mdash; Celery v0.6.0 (stable) documentation</title>
     <link rel="stylesheet" href="static/nature.css" type="text/css" />
     <link rel="stylesheet" href="static/pygments.css" type="text/css" />
     <script type="text/javascript">
@@ -20,7 +20,7 @@
     <script type="text/javascript" src="static/jquery.js"></script>
     <script type="text/javascript" src="static/doctools.js"></script>
     <link rel="top" title="Celery v0.6.0 (stable) documentation" href="" />
-    <link rel="next" title="celery - Distributed Task Queue for Django." href="introduction.html" /> 
+    <link rel="next" title="celery - Distributed Task Queue for Django/Python" href="introduction.html" /> 
   </head>
   <body>
     <div class="related">
@@ -33,7 +33,7 @@
           <a href="modindex.html" title="Global Module Index"
              accesskey="M">modules</a> |</li>
         <li class="right" >
-          <a href="introduction.html" title="celery - Distributed Task Queue for Django."
+          <a href="introduction.html" title="celery - Distributed Task Queue for Django/Python"
              accesskey="N">next</a> |</li>
         <li><a href="">Celery v0.6.0 (stable) documentation</a> &raquo;</li> 
       </ul>
@@ -44,11 +44,11 @@
         <div class="bodywrapper">
           <div class="body">
             
-  <div class="section" id="celery-the-django-task-queue">
-<h1>Celery - The Django Task Queue<a class="headerlink" href="#celery-the-django-task-queue" title="Permalink to this headline">¶</a></h1>
+  <div class="section" id="celery-distributed-task-queue">
+<h1>Celery - Distributed Task Queue<a class="headerlink" href="#celery-distributed-task-queue" title="Permalink to this headline">¶</a></h1>
 <p>Contents:</p>
 <ul>
-<li class="toctree-l1"><a class="reference external" href="introduction.html">celery - Distributed Task Queue for Django.</a><ul>
+<li class="toctree-l1"><a class="reference external" href="introduction.html">celery - Distributed Task Queue for Django/Python</a><ul>
 <li class="toctree-l2"><a class="reference external" href="introduction.html#introduction">Introduction</a></li>
 <li class="toctree-l2"><a class="reference external" href="introduction.html#overview">Overview</a></li>
 <li class="toctree-l2"><a class="reference external" href="introduction.html#features">Features</a></li>
@@ -105,8 +105,10 @@
 <li class="toctree-l3"><a class="reference external" href="faq.html#can-i-use-celery-with-activemq-stomp">Can I use celery with ActiveMQ/STOMP?</a></li>
 <li class="toctree-l3"><a class="reference external" href="faq.html#which-features-are-not-supported-when-using-stomp">Which features are not supported when using STOMP?</a></li>
 <li class="toctree-l3"><a class="reference external" href="faq.html#can-i-send-some-tasks-to-only-some-servers">Can I send some tasks to only some servers?</a></li>
+<li class="toctree-l3"><a class="reference external" href="faq.html#can-i-use-celery-without-django">Can I use celery without Django?</a></li>
 </ul>
 </li>
+<li class="toctree-l2"><a class="reference external" href="faq.html#using-the-default-loader">Using the default loader</a></li>
 </ul>
 </li>
 <li class="toctree-l1"><a class="reference external" href="reference/index.html">Module API Reference</a><ul>
@@ -115,8 +117,13 @@
 <li class="toctree-l2"><a class="reference external" href="reference/celery.result.html">Task Result - celery.result</a></li>
 <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.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>
+<li class="toctree-l2"><a class="reference external" href="reference/celery.loaders.base.html">Loader Base Classes - celery.loaders.base</a></li>
+<li class="toctree-l2"><a class="reference external" href="reference/celery.loaders.default.html">Default Loader - celery.loaders.default</a></li>
+<li class="toctree-l2"><a class="reference external" href="reference/celery.loaders.djangoapp.html">Django Loader - celery.loaders.djangoapp</a></li>
 <li class="toctree-l2"><a class="reference external" href="reference/celery.discovery.html">Task Discovery - celery.discovery</a></li>
 <li class="toctree-l2"><a class="reference external" href="reference/celery.monitoring.html">Statistics and Monitoring - celery.monitoring</a></li>
 <li class="toctree-l2"><a class="reference external" href="reference/celery.messaging.html">Messaging - celery.messaging</a></li>
@@ -193,7 +200,7 @@
         <div class="sphinxsidebarwrapper">
             <h3><a href="">Table Of Contents</a></h3>
             <ul>
-<li><a class="reference external" href="">Celery - The Django Task Queue</a><ul>
+<li><a class="reference external" href="">Celery - Distributed Task Queue</a><ul>
 <li><a class="reference external" href="#indices-and-tables">Indices and tables</a></li>
 </ul>
 </li>
@@ -201,7 +208,7 @@
 
             <h4>Next topic</h4>
             <p class="topless"><a href="introduction.html"
-                                  title="next chapter">celery - Distributed Task Queue for Django.</a></p>
+                                  title="next chapter">celery - Distributed Task Queue for Django/Python</a></p>
             <h3>This Page</h3>
             <ul class="this-page-menu">
               <li><a href="sources/index.txt"
@@ -234,7 +241,7 @@
           <a href="modindex.html" title="Global Module Index"
              >modules</a> |</li>
         <li class="right" >
-          <a href="introduction.html" title="celery - Distributed Task Queue for Django."
+          <a href="introduction.html" title="celery - Distributed Task Queue for Django/Python"
              >next</a> |</li>
         <li><a href="">Celery v0.6.0 (stable) documentation</a> &raquo;</li> 
       </ul>

+ 10 - 9
introduction.html

@@ -5,7 +5,7 @@
   <head>
     <meta http-equiv="Content-Type" content="text/html; charset=utf-8" />
     
-    <title>celery - Distributed Task Queue for Django. &mdash; Celery v0.6.0 (stable) documentation</title>
+    <title>celery - Distributed Task Queue for Django/Python &mdash; Celery v0.6.0 (stable) documentation</title>
     <link rel="stylesheet" href="static/nature.css" type="text/css" />
     <link rel="stylesheet" href="static/pygments.css" type="text/css" />
     <script type="text/javascript">
@@ -21,7 +21,7 @@
     <script type="text/javascript" src="static/doctools.js"></script>
     <link rel="top" title="Celery v0.6.0 (stable) documentation" href="index.html" />
     <link rel="next" title="Tutorials" href="tutorials/index.html" />
-    <link rel="prev" title="Celery - The Django Task Queue" href="index.html" /> 
+    <link rel="prev" title="Celery - Distributed Task Queue" href="index.html" /> 
   </head>
   <body>
     <div class="related">
@@ -37,7 +37,7 @@
           <a href="tutorials/index.html" title="Tutorials"
              accesskey="N">next</a> |</li>
         <li class="right" >
-          <a href="index.html" title="Celery - The Django Task Queue"
+          <a href="index.html" title="Celery - Distributed Task Queue"
              accesskey="P">previous</a> |</li>
         <li><a href="index.html">Celery v0.6.0 (stable) documentation</a> &raquo;</li> 
       </ul>
@@ -48,8 +48,8 @@
         <div class="bodywrapper">
           <div class="body">
             
-  <div class="section" id="celery-distributed-task-queue-for-django">
-<h1>celery - Distributed Task Queue for Django.<a class="headerlink" href="#celery-distributed-task-queue-for-django" title="Permalink to this headline">¶</a></h1>
+  <div class="section" id="celery-distributed-task-queue-for-django-python">
+<h1>celery - Distributed Task Queue for Django/Python<a class="headerlink" href="#celery-distributed-task-queue-for-django-python" title="Permalink to this headline">¶</a></h1>
 <table class="docutils field-list" frame="void" rules="none">
 <col class="field-name" />
 <col class="field-body" />
@@ -60,7 +60,8 @@
 </table>
 <div class="section" id="introduction">
 <h2>Introduction<a class="headerlink" href="#introduction" title="Permalink to this headline">¶</a></h2>
-<p><tt class="docutils literal"><span class="pre">celery</span></tt> is a distributed task queue framework for Django.</p>
+<p><strong>NOTE:</strong> See the FAQ for information about using celery outside of Django.</p>
+<p><tt class="docutils literal"><span class="pre">celery</span></tt> is a distributed task queue framework for Django/Python.</p>
 <p>It is used for executing tasks <em>asynchronously</em>, routed to one or more
 worker servers, running concurrently using multiprocessing.</p>
 <p>It is designed to solve certain problems related to running websites
@@ -371,7 +372,7 @@ file in the top distribution directory for the full license text.</p>
         <div class="sphinxsidebarwrapper">
             <h3><a href="index.html">Table Of Contents</a></h3>
             <ul>
-<li><a class="reference external" href="">celery - Distributed Task Queue for Django.</a><ul>
+<li><a class="reference external" href="">celery - Distributed Task Queue for Django/Python</a><ul>
 <li><a class="reference external" href="#introduction">Introduction</a></li>
 <li><a class="reference external" href="#overview">Overview</a></li>
 <li><a class="reference external" href="#features">Features</a></li>
@@ -406,7 +407,7 @@ file in the top distribution directory for the full license text.</p>
 
             <h4>Previous topic</h4>
             <p class="topless"><a href="index.html"
-                                  title="previous chapter">Celery - The Django Task Queue</a></p>
+                                  title="previous chapter">Celery - Distributed Task Queue</a></p>
             <h4>Next topic</h4>
             <p class="topless"><a href="tutorials/index.html"
                                   title="next chapter">Tutorials</a></p>
@@ -445,7 +446,7 @@ file in the top distribution directory for the full license text.</p>
           <a href="tutorials/index.html" title="Tutorials"
              >next</a> |</li>
         <li class="right" >
-          <a href="index.html" title="Celery - The Django Task Queue"
+          <a href="index.html" title="Celery - Distributed Task Queue"
              >previous</a> |</li>
         <li><a href="index.html">Celery v0.6.0 (stable) documentation</a> &raquo;</li> 
       </ul>

+ 20 - 0
modindex.html

@@ -101,6 +101,22 @@
      <em></em></td></tr><tr class="cg-1">
      <td></td>
      <td>&nbsp;&nbsp;&nbsp;
+     <a href="reference/celery.loaders.html#module-celery.loaders"><tt class="xref">celery.loaders</tt></a></td><td>
+     <em></em></td></tr><tr class="cg-1">
+     <td></td>
+     <td>&nbsp;&nbsp;&nbsp;
+     <a href="reference/celery.loaders.base.html#module-celery.loaders.base"><tt class="xref">celery.loaders.base</tt></a></td><td>
+     <em></em></td></tr><tr class="cg-1">
+     <td></td>
+     <td>&nbsp;&nbsp;&nbsp;
+     <a href="reference/celery.loaders.default.html#module-celery.loaders.default"><tt class="xref">celery.loaders.default</tt></a></td><td>
+     <em></em></td></tr><tr class="cg-1">
+     <td></td>
+     <td>&nbsp;&nbsp;&nbsp;
+     <a href="reference/celery.loaders.djangoapp.html#module-celery.loaders.djangoapp"><tt class="xref">celery.loaders.djangoapp</tt></a></td><td>
+     <em></em></td></tr><tr class="cg-1">
+     <td></td>
+     <td>&nbsp;&nbsp;&nbsp;
      <a href="reference/celery.log.html#module-celery.log"><tt class="xref">celery.log</tt></a></td><td>
      <em></em></td></tr><tr class="cg-1">
      <td></td>
@@ -129,6 +145,10 @@
      <em></em></td></tr><tr class="cg-1">
      <td></td>
      <td>&nbsp;&nbsp;&nbsp;
+     <a href="reference/celery.signals.html#module-celery.signals"><tt class="xref">celery.signals</tt></a></td><td>
+     <em></em></td></tr><tr class="cg-1">
+     <td></td>
+     <td>&nbsp;&nbsp;&nbsp;
      <a href="reference/celery.supervisor.html#module-celery.supervisor"><tt class="xref">celery.supervisor</tt></a></td><td>
      <em></em></td></tr><tr class="cg-1">
      <td></td>

+ 277 - 254
objects.inv

@@ -4,6 +4,7 @@
 celery.backends.base mod reference/celery.backends.base.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
 celery.bin.celeryd mod reference/celery.bin.celeryd.html
 celery.discovery mod reference/celery.discovery.html
 celery.backends.tyrant mod reference/celery.backends.tyrant.html
@@ -11,17 +12,21 @@ celery.task.builtins mod reference/celery.task.builtins.html
 celery.monitoring mod reference/celery.monitoring.html
 celery.pool mod reference/celery.pool.html
 celery.managers mod reference/celery.managers.html
+celery.signals mod reference/celery.signals.html
 celery.log mod reference/celery.log.html
 celery.backends.database mod reference/celery.backends.database.html
 celery.utils mod reference/celery.utils.html
 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.backends.cache mod reference/celery.backends.cache.html
 celery.datastructures mod reference/celery.datastructures.html
 celery.messaging mod reference/celery.messaging.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
 celery.task mod reference/celery.task.html
 celery.views mod reference/celery.views.html
 celery.worker.job mod reference/celery.worker.job.html
@@ -29,336 +34,354 @@ 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.log.emergency_error function reference/celery.log.html
-celery.execute.apply function reference/celery.execute.html
-celery.backends.base.BaseBackend.get_result method reference/celery.backends.base.html
-celery.task.dmap function reference/celery.task.html
-celery.monitoring.Statistics.on_start method reference/celery.monitoring.html
-celery.task.base.Task.ignore_result attribute reference/celery.task.base.html
-celery.result.EagerResult.wait method reference/celery.result.html
-celery.managers.TaskManager.get_all_expired method reference/celery.managers.html
-celery.result.BaseAsyncResult.is_done method reference/celery.result.html
-celery.task.base.Task.routing_key attribute reference/celery.task.base.html
-celery.pool.DynamicPool.replace_dead_workers method reference/celery.pool.html
 celery.supervisor.OFASupervisor.Process.exitcode attribute reference/celery.supervisor.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.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.backends.base.UnpickleableExceptionWrapper exception reference/celery.backends.base.html
-TASK_STATUS_FAILURE data reference/celery.models.html
-celery.result.EagerResult.is_done method reference/celery.result.html
-celery.task.base.Task.type attribute reference/celery.task.base.html
-celery.fields.PickledObjectField.to_python method reference/celery.fields.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.start method reference/celery.worker.html
-celery.views.apply function reference/celery.views.html
-celery.worker.job.TaskWrapper.execute_using_pool method reference/celery.worker.job.html
-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.discovery.find_related_module function reference/celery.discovery.html
 celery.worker.WorkController.logfile attribute reference/celery.worker.html
 celery.result.BaseAsyncResult.ready method reference/celery.result.html
-celery.supervisor.OFASupervisor.args attribute reference/celery.supervisor.html
-celery.worker.AMQPListener.start method reference/celery.worker.html
-celery.registry.TaskRegistry.AlreadyRegistered exception reference/celery.registry.html
 celery.managers.TaskManager.delete_expired method reference/celery.managers.html
-celery.registry.TaskRegistry.filter_types method reference/celery.registry.html
-celery.backends.base.UnpickleableExceptionWrapper.exc_args attribute reference/celery.backends.base.html
-celery.worker.controllers.Mediator class reference/celery.worker.controllers.html
-celery.conf.AMQP_CONSUMER_QUEUE data reference/celery.conf.html
-celery.worker.WorkController.pool attribute reference/celery.worker.html
-celery.worker.controllers.BackgroundThread class reference/celery.worker.controllers.html
-celery.worker.job.TaskWrapper.extend_with_default_kwargs method reference/celery.worker.job.html
 celery.datastructures.ExceptionInfo.traceback attribute reference/celery.datastructures.html
-celery.managers.TableLock class reference/celery.managers.html
-TaskMeta.task_id attribute reference/celery.models.html
-celery.supervisor.OFASupervisor.check_interval attribute reference/celery.supervisor.html
-celery.discovery.autodiscover function reference/celery.discovery.html
-celery.supervisor.OFASupervisor.Process.ident attribute reference/celery.supervisor.html
-celery.result.TaskSetResult.ready method reference/celery.result.html
+celery.managers.TaskManager.get_all_expired method reference/celery.managers.html
 celery.managers.table_lock attribute reference/celery.managers.html
-celery.task.base.Task.get_publisher method reference/celery.task.base.html
-celery.datastructures.ExceptionInfo class reference/celery.datastructures.html
-celery.task.base.TaskSet.map_async classmethod reference/celery.task.base.html
-celery.result.EagerResult class reference/celery.result.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.backends.get_default_backend_cls data reference/celery.backends.html
-celery.fields.PickledObjectField.get_db_prep_save method reference/celery.fields.html
-celery.monitoring.StatsCollector.dump_to_cache method reference/celery.monitoring.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
+celery.task.base.Task.get_logger method reference/celery.task.base.html
+celery.result.BaseAsyncResult.successful method reference/celery.result.html
+TASK_STATUS_RETRY data reference/celery.models.html
+celery.utils.gen_unique_id function reference/celery.utils.html
+celery.worker.WorkController.start method reference/celery.worker.html
+celery.worker.controllers.BackgroundThread.stop method reference/celery.worker.controllers.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.result.BaseAsyncResult.TimeoutError exception reference/celery.result.html
+celery.messaging.TaskPublisher class reference/celery.messaging.html
+celery.conf.AMQP_CONSUMER_ROUTING_KEY data reference/celery.conf.html
+celery.views.apply function reference/celery.views.html
+celery.worker.WorkController.periodic_work_controller attribute reference/celery.worker.html
+celery.registry.TaskRegistry.NotRegistered exception reference/celery.registry.html
+celery.datastructures.PositionQueue.length attribute reference/celery.datastructures.html
+celery.datastructures.PositionQueue class reference/celery.datastructures.html
+celery.backends.base.BaseBackend.prepare_result method reference/celery.backends.base.html
 celery.task.execute_remote function reference/celery.task.html
-celery.result.TaskSetResult.total attribute reference/celery.result.html
+celery.managers.TableLock.acquire classmethod reference/celery.managers.html
+celery.backends.base.BaseBackend.store_result method reference/celery.backends.base.html
+celery.monitoring.TimerStats.on_finish method reference/celery.monitoring.html
+celery.pool.TaskPool.on_ready method reference/celery.pool.html
+celery.task.base.TaskSet.total attribute reference/celery.task.base.html
+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.task.base.ExecuteRemoteTask.run method reference/celery.task.base.html
-celery.conf.AMQP_CONSUMER_QUEUES data reference/celery.conf.html
-celery.managers.PeriodicTaskManager class reference/celery.managers.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.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
+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.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
+celery.supervisor.MaxRestartsExceededError exception reference/celery.supervisor.html
+celery.pool.pid_is_dead function reference/celery.pool.html
+celery.monitoring.Statistics.publish method reference/celery.monitoring.html
+celery.monitoring.Statistics.on_stop method reference/celery.monitoring.html
+celery.worker.WorkController.hold_queue attribute reference/celery.worker.html
 celery.worker.job.TaskWrapper.from_message classmethod reference/celery.worker.job.html
-celery.task.base.Task.run method reference/celery.task.base.html
-TaskMeta class reference/celery.models.html
+celery.execute.delay_task function reference/celery.execute.html
+celery.backends.base.BaseBackend.process_cleanup method reference/celery.backends.base.html
+celery.task.base.ExecuteRemoteTask class reference/celery.task.base.html
+celery.worker.controllers.BackgroundThread class reference/celery.worker.controllers.html
+celery.worker.WorkController.logger attribute reference/celery.worker.html
+celery.monitoring.StatsCollector.report method reference/celery.monitoring.html
+celery.loaders.default.Loader class reference/celery.loaders.default.html
+celery.task.base.Task.max_retries attribute reference/celery.task.base.html
+celery.monitoring.StatsCollector.total_tasks_processed attribute reference/celery.monitoring.html
+celery.backends.base.BaseBackend.get_status method reference/celery.backends.base.html
+celery.supervisor.OFASupervisor.Process.start method reference/celery.supervisor.html
+celery.managers.MySQLTableLock.lock_table method reference/celery.managers.html
+celery.supervisor.OFASupervisor.Process.terminate method reference/celery.supervisor.html
+celery.execute.apply function reference/celery.execute.html
+celery.backends.base.BaseBackend.get_result method reference/celery.backends.base.html
+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.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.result.EagerResult class reference/celery.result.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.backends.base.BaseBackend.exception_to_python method reference/celery.backends.base.html
 celery.fields.PickledObject class reference/celery.fields.html
-celery.task.base.Task.get_logger method reference/celery.task.base.html
-celery.result.BaseAsyncResult class reference/celery.result.html
-celery.result.BaseAsyncResult.successful method reference/celery.result.html
-celery.conf.LOG_FORMAT data reference/celery.conf.html
-celery.result.BaseAsyncResult.TimeoutError exception reference/celery.result.html
 celery.utils.mitemgetter function reference/celery.utils.html
-celery.pool.DynamicPool class reference/celery.pool.html
-celery.backends.tyrant.Backend.close method reference/celery.backends.tyrant.html
-celery.backends.database.Backend.store_result method reference/celery.backends.database.html
-celery.worker.AMQPListener.bucket_queue attribute reference/celery.worker.html
-celery.monitoring.TaskTimerStats class reference/celery.monitoring.html
-celery.worker.job.TaskWrapper.message attribute reference/celery.worker.job.html
-PeriodicTaskMeta.task attribute reference/celery.models.html
-celery.views.task_status function reference/celery.views.html
-celery.supervisor.OFASupervisor.Process.daemon attribute reference/celery.supervisor.html
-celery.result.TaskSetResult.successful method reference/celery.result.html
-celery.backends.base.BaseBackend.wait_for method reference/celery.backends.base.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.backends.base.BaseBackend.mark_as_done method reference/celery.backends.base.html
 celery.supervisor.OFASupervisor.Process class reference/celery.supervisor.html
 celery.registry.TaskRegistry.get_all_periodic method reference/celery.registry.html
-PeriodicTaskMeta.last_run_at attribute reference/celery.models.html
 celery.utils.repeatlast function reference/celery.utils.html
-celery.worker.controllers.BackgroundThread.stop method reference/celery.worker.controllers.html
-celery.registry.TaskRegistry.unregister method reference/celery.registry.html
-celery.result.TaskSetResult.itersubtasks method reference/celery.result.html
-celery.registry.NotRegistered exception reference/celery.registry.html
-celery.bin.celeryd.acquire_pidlock function reference/celery.bin.celeryd.html
-celery.backends.base.BaseBackend.cleanup method reference/celery.backends.base.html
-celery.task.base.TaskSet.remote_execute classmethod reference/celery.task.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
+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
+celery.supervisor.OFASupervisor.Process.is_alive method reference/celery.supervisor.html
 celery.task.base.AsynchronousMapTask.run method reference/celery.task.base.html
-PeriodicTaskMeta class reference/celery.models.html
 celery.pool.DynamicPool.grow method reference/celery.pool.html
-celery.messaging.TaskPublisher class reference/celery.messaging.html
-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.pool.DynamicPool.add_worker method reference/celery.pool.html
-celery.utils.get_full_cls_name function reference/celery.utils.html
-celery.supervisor.OFASupervisor.start method reference/celery.supervisor.html
-celery.supervisor.OFASupervisor.Process.is_alive method reference/celery.supervisor.html
-celery.task.base.TaskSet.total attribute reference/celery.task.base.html
 celery.worker.WorkController class reference/celery.worker.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.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
+celery.datastructures.ExceptionInfo.exception attribute reference/celery.datastructures.html
+celery.supervisor.OFASupervisor.check_interval attribute reference/celery.supervisor.html
+celery.backends.database.Backend.cleanup method reference/celery.backends.database.html
+celery.worker.controllers.BackgroundThread.on_start method reference/celery.worker.controllers.html
+celery.backends.database.Backend class reference/celery.backends.database.html
+celery.task.builtins.PingTask class reference/celery.task.builtins.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.worker.WorkController.periodic_work_controller attribute reference/celery.worker.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.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.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
+celery.conf.ALWAYS_EAGER data reference/celery.conf.html
+celery.messaging.TaskPublisher.delay_task_in_set method reference/celery.messaging.html
+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.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.registry.TaskRegistry.NotRegistered exception reference/celery.registry.html
-celery.datastructures.PositionQueue.length attribute reference/celery.datastructures.html
-TaskMeta.date_done attribute reference/celery.models.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.pool.TaskPool.limit attribute reference/celery.pool.html
+celery.managers.MySQLTableLock class reference/celery.managers.html
+celery.loaders.base.BaseLoader class reference/celery.loaders.base.html
+celery.task.base.Task.name attribute reference/celery.task.base.html
+celery.execute.apply_async function reference/celery.execute.html
+celery.worker.AMQPListener.bucket_queue attribute reference/celery.worker.html
+TaskMeta.result attribute reference/celery.models.html
+celery.conf.SEND_CELERY_TASK_ERROR_EMAILS data reference/celery.conf.html
+celery.task.dmap function reference/celery.task.html
+celery.backends.database.Backend.run_periodic_tasks method reference/celery.backends.database.html
+celery.supervisor.OFASupervisor class reference/celery.supervisor.html
+celery.fields.PickledObjectField.to_python method reference/celery.fields.html
+celery.worker.job.TaskWrapper.execute_using_pool method reference/celery.worker.job.html
+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
+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.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
+celery.worker.job.TaskWrapper.on_failure method reference/celery.worker.job.html
+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.worker.WorkController.amqp_listener attribute reference/celery.worker.html
-celery.backends.base.BaseBackend.UnpickleableExceptionWrapper.exc_module attribute reference/celery.backends.base.html
 celery.task.dmap_async function reference/celery.task.html
-celery.supervisor.OFASupervisor class reference/celery.supervisor.html
-celery.managers.TableLock.acquire classmethod reference/celery.managers.html
-celery.managers.TaskManager class reference/celery.managers.html
-celery.backends.base.BaseBackend.store_result method reference/celery.backends.base.html
-celery.worker.AMQPListener.logger attribute reference/celery.worker.html
-celery.worker.job.TaskWrapper.task_id attribute reference/celery.worker.job.html
-celery.task.base.TaskSet.run method reference/celery.task.base.html
-celery.monitoring.TimerStats.on_finish method reference/celery.monitoring.html
-celery.worker.WorkController.stop method reference/celery.worker.html
-celery.pool.TaskPool.on_ready method reference/celery.pool.html
-celery.result.AsyncResult.task_id attribute reference/celery.result.html
+celery.result.TaskSetResult.waiting method reference/celery.result.html
 celery.supervisor.OFASupervisor.Process.pid attribute reference/celery.supervisor.html
-celery.task.base.Task.disable_error_emails attribute reference/celery.task.base.html
 celery.monitoring.StatsCollector.total_tasks_processed_by_type attribute reference/celery.monitoring.html
-celery.managers.PeriodicTaskManager.is_time method reference/celery.managers.html
-TASK_STATUS_PENDING data reference/celery.models.html
-celery.utils.gen_unique_id function reference/celery.utils.html
-TASK_STATUS_RETRY data reference/celery.models.html
-celery.task.base.PeriodicTask class reference/celery.task.base.html
+celery.supervisor.OFASupervisor.max_restart_freq attribute reference/celery.supervisor.html
 TASK_STATUSES data reference/celery.models.html
 celery.conf.AMQP_CONNECTION_RETRY data reference/celery.conf.html
-celery.backends.base.BaseBackend.mark_as_failure method reference/celery.backends.base.html
-celery.conf.AMQP_EXCHANGE data reference/celery.conf.html
-celery.datastructures.ExceptionInfo.exception attribute reference/celery.datastructures.html
+celery.task.base.TaskSet class reference/celery.task.base.html
 PeriodicTaskMeta.delay method reference/celery.models.html
-celery.worker.AMQPListener.stop method reference/celery.worker.html
-celery.backends.database.Backend.cleanup method reference/celery.backends.database.html
-celery.task.base.Task.get_consumer method reference/celery.task.base.html
-celery.worker.WorkController.mediator attribute reference/celery.worker.html
-celery.result.TaskSetResult.waiting method reference/celery.result.html
-celery.conf.DAEMON_LOG_LEVEL data reference/celery.conf.html
-celery.backends.database.Backend class reference/celery.backends.database.html
-celery.worker.AMQPListener class reference/celery.worker.html
-celery.task.builtins.PingTask.run method reference/celery.task.builtins.html
-celery.result.BaseAsyncResult.status attribute reference/celery.result.html
+celery.task.base.Task.default_retry_delay attribute reference/celery.task.base.html
 celery.conf.AMQP_CONNECTION_TIMEOUT data reference/celery.conf.html
-celery.task.builtins.PingTask class reference/celery.task.builtins.html
 celery.backends.database.Backend.get_result method reference/celery.backends.database.html
 celery.supervisor.OFASupervisor.max_restart_freq_time attribute reference/celery.supervisor.html
 celery.backends.get_backend_cls function reference/celery.backends.html
-celery.managers.TableLock.unlock_table method reference/celery.managers.html
-celery.worker.controllers.BackgroundThread.on_iteration method reference/celery.worker.controllers.html
 celery.conf.AMQP_CONNECTION_MAX_RETRIES data reference/celery.conf.html
-celery.conf.DAEMON_LOG_FILE data reference/celery.conf.html
 celery.backends.base.BaseBackend.create_exception_cls method reference/celery.backends.base.html
-celery.worker.AMQPListener.consume_messages method reference/celery.worker.html
 celery.monitoring.Statistics.stop method reference/celery.monitoring.html
-celery.result.EagerResult.status attribute reference/celery.result.html
-celery.monitoring.StatsCollector.total_task_time_running attribute reference/celery.monitoring.html
-celery.monitoring.TimerStats.time_start attribute reference/celery.monitoring.html
-celery.backends.base.find_nearest_pickleable_exception function reference/celery.backends.base.html
-celery.task.base.Task.name attribute reference/celery.task.base.html
-celery.backends.base.BaseBackend.UnpickleableExceptionWrapper.exc_args attribute reference/celery.backends.base.html
-celery.managers.TableLock.lock_table method reference/celery.managers.html
+celery.registry.TaskRegistry.unregister method reference/celery.registry.html
 celery.pool.TaskPool.stop method reference/celery.pool.html
-celery.task.base.TaskSet.arguments attribute reference/celery.task.base.html
-celery.supervisor.OFASupervisor.max_restart_freq attribute reference/celery.supervisor.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 class reference/celery.registry.html
+celery.backends.DefaultBackend class reference/celery.backends.html
+celery.task.base.Task.MaxRetriesExceededError exception reference/celery.task.base.html
+celery.loaders.base.BaseLoader.conf attribute reference/celery.loaders.base.html
+celery.worker.controllers.Mediator.bucket_queue attribute reference/celery.worker.controllers.html
+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.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
+celery.result.EagerResult.status attribute reference/celery.result.html
+celery.supervisor.OFASupervisor.kwargs attribute reference/celery.supervisor.html
+celery.worker.controllers.Mediator.callback attribute reference/celery.worker.controllers.html
+celery.messaging.TaskConsumer.decoder method reference/celery.messaging.html
+celery.task.base.Task.get_publisher method reference/celery.task.base.html
+celery.monitoring.StatsCollector.dump_to_cache method reference/celery.monitoring.html
+celery.backends.database.Backend.init_periodic_tasks method reference/celery.backends.database.html
+celery.fields.PickledObjectField.get_db_prep_lookup method reference/celery.fields.html
+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.result.TaskSetResult.completed_count method reference/celery.result.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.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.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
+celery.backends.tyrant.Backend class reference/celery.backends.tyrant.html
+celery.worker.WorkController.pool attribute reference/celery.worker.html
+celery.managers.TableLock class reference/celery.managers.html
+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.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
+celery.backends.base.BaseBackend.exception_to_python method reference/celery.backends.base.html
+celery.conf.LOG_FORMAT data reference/celery.conf.html
+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.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
+celery.pool.DynamicPool.add_worker method reference/celery.pool.html
+celery.worker.controllers.BackgroundThread.on_iteration method reference/celery.worker.controllers.html
+celery.pool.TaskPool.limit attribute reference/celery.pool.html
+celery.result.TaskSetResult.subtasks attribute reference/celery.result.html
+celery.task.base.TaskSet.run method reference/celery.task.base.html
+celery.worker.WorkController.stop method reference/celery.worker.html
+celery.result.AsyncResult.task_id attribute reference/celery.result.html
+celery.task.base.Task.disable_error_emails attribute reference/celery.task.base.html
+celery.managers.PeriodicTaskManager.is_time method reference/celery.managers.html
+celery.loaders.djangoapp.Loader.on_worker_init method reference/celery.loaders.djangoapp.html
+celery.backends.base.BaseBackend.mark_as_failure method reference/celery.backends.base.html
+celery.conf.AMQP_EXCHANGE data reference/celery.conf.html
+celery.loaders.djangoapp.Loader class reference/celery.loaders.djangoapp.html
+celery.worker.AMQPListener.stop method reference/celery.worker.html
+celery.worker.AMQPListener.logger attribute reference/celery.worker.html
+celery.worker.AMQPListener class reference/celery.worker.html
+celery.views.task_status function reference/celery.views.html
+celery.task.builtins.DeleteExpiredTaskMetaTask.run method reference/celery.task.builtins.html
+celery.task.base.Task.delay classmethod reference/celery.task.base.html
 celery.pool.TaskPool.apply_async method reference/celery.pool.html
-celery.task.ping function reference/celery.task.html
-celery.result.AsyncResult class reference/celery.result.html
 PeriodicTaskMeta.name attribute reference/celery.models.html
-celery.worker.controllers.BackgroundThread.run method reference/celery.worker.controllers.html
-celery.conf.STATISTICS_COLLECT_INTERVAL data reference/celery.conf.html
-celery.monitoring.StatsCollector.collect method reference/celery.monitoring.html
-celery.monitoring.Statistics class reference/celery.monitoring.html
 celery.monitoring.Statistics.run 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.task.base.Task.apply classmethod reference/celery.task.base.html
 celery.registry.TaskRegistry.get_task method reference/celery.registry.html
-celery.result.BaseAsyncResult.task_id attribute reference/celery.result.html
-celery.fields.PickledObjectField class reference/celery.fields.html
-celery.task.base.TaskSet.map classmethod reference/celery.task.base.html
-celery.monitoring.Statistics.start classmethod reference/celery.monitoring.html
-celery.backends.base.BaseBackend.TimeoutError exception reference/celery.backends.base.html
-celery.pool.TaskPool.logger attribute reference/celery.pool.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.managers.MySQLTableLock.unlock_table method reference/celery.managers.html
 celery.result.EagerResult.result attribute reference/celery.result.html
-celery.worker.job.TaskWrapper.kwargs attribute reference/celery.worker.job.html
 celery.utils.retry_over_time function reference/celery.utils.html
-celery.worker.AMQPListener.close_connection method reference/celery.worker.html
-celery.worker.AMQPListener.receive_message method reference/celery.worker.html
-celery.managers.PeriodicTaskManager.get_waiting_tasks method reference/celery.managers.html
 celery.managers.PeriodicTaskManager.init_entries method reference/celery.managers.html
-celery.managers.TaskManager.get_task method reference/celery.managers.html
 celery.worker.WorkController.loglevel attribute reference/celery.worker.html
-celery.supervisor.MaxRestartsExceededError exception reference/celery.supervisor.html
-celery.worker.WorkController.is_detached attribute reference/celery.worker.html
-celery.worker.AMQPListener.hold_queue attribute reference/celery.worker.html
 celery.registry.TaskRegistry.get_all_regular method reference/celery.registry.html
-celery.registry.TaskRegistry class reference/celery.registry.html
-celery.backends.DefaultBackend class reference/celery.backends.html
-celery.worker.AMQPListener.reset_connection method reference/celery.worker.html
-celery.registry.TaskRegistry.register method reference/celery.registry.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.task.builtins.DeleteExpiredTaskMetaTask class reference/celery.task.builtins.html
-celery.worker.job.jail function reference/celery.worker.job.html
 celery.worker.job.TaskWrapper.task_name attribute reference/celery.worker.job.html
-celery.worker.WorkController.bucket_queue attribute reference/celery.worker.html
-celery.execute.apply_async function reference/celery.execute.html
-celery.worker.controllers.Mediator.bucket_queue attribute reference/celery.worker.controllers.html
-celery.monitoring.Statistics.type attribute reference/celery.monitoring.html
-celery.task.base.Task class reference/celery.task.base.html
-celery.bin.celeryd.run_worker function reference/celery.bin.celeryd.html
-celery.backends.base.BaseBackend.UnpickleableExceptionWrapper.exc_cls_name attribute reference/celery.backends.base.html
 celery.pool.process_is_dead function reference/celery.pool.html
-celery.result.AsyncResult.backend attribute reference/celery.result.html
-celery.task.base.TaskSet class reference/celery.task.base.html
-celery.result.BaseAsyncResult.result attribute reference/celery.result.html
-celery.result.TaskSetResult.failed method reference/celery.result.html
-celery.task.builtins.DeleteExpiredTaskMetaTask.run method reference/celery.task.builtins.html
-celery.pool.TaskPool class reference/celery.pool.html
-celery.task.base.Task.exchange attribute reference/celery.task.base.html
-celery.worker.job.TaskWrapper class reference/celery.worker.job.html
-TaskMeta.status attribute reference/celery.models.html
-celery.worker.WorkController.concurrency attribute reference/celery.worker.html
-celery.conf.ALWAYS_EAGER data reference/celery.conf.html
+celery.worker.WorkController.amqp_listener 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.result.TimeoutError exception reference/celery.result.html
-celery.backends.tyrant.Backend class reference/celery.backends.tyrant.html
 TASK_STATUSES_CHOICES data reference/celery.models.html
-celery.utils.chunks function reference/celery.utils.html
-celery.result.EagerResult.is_ready method reference/celery.result.html
-celery.pool.pid_is_dead function reference/celery.pool.html
 celery.pool.reap_process function reference/celery.pool.html
 celery.task.base.Task.mandatory attribute reference/celery.task.base.html
-celery.datastructures.PositionQueue.filled attribute reference/celery.datastructures.html
-celery.backends.base.UnpickleableExceptionWrapper.exc_module attribute reference/celery.backends.base.html
-celery.monitoring.Statistics.on_stop method reference/celery.monitoring.html
-celery.worker.job.TaskWrapper.execute method reference/celery.worker.job.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.task.is_done function reference/celery.task.html
 celery.views.is_task_done function reference/celery.views.html
-celery.worker.controllers.PeriodicWorkController class reference/celery.worker.controllers.html
-celery.worker.controllers.BackgroundThread.on_start method reference/celery.worker.controllers.html
-celery.conf.LOG_LEVELS data reference/celery.conf.html
-celery.managers.TaskManager.is_done method reference/celery.managers.html
-celery.task.base.PeriodicTask.run_every attribute reference/celery.task.base.html
-celery.supervisor.OFASupervisor.kwargs attribute reference/celery.supervisor.html
-celery.worker.controllers.Mediator.callback attribute reference/celery.worker.controllers.html
-celery.monitoring.Statistics.publish method reference/celery.monitoring.html
-celery.messaging.TaskConsumer.decoder method reference/celery.messaging.html
-celery.execute.delay_task function reference/celery.execute.html
-celery.monitoring.TimerStats class reference/celery.monitoring.html
-celery.backends.base.BaseBackend.process_cleanup method reference/celery.backends.base.html
-celery.backends.database.Backend.init_periodic_tasks method reference/celery.backends.database.html
+TASK_STATUS_FAILURE data reference/celery.models.html
 celery.task.base.Task.apply_async classmethod reference/celery.task.base.html
-celery.task.base.ExecuteRemoteTask class reference/celery.task.base.html
 celery.log.setup_logger function reference/celery.log.html
-celery.worker.job.TaskWrapper.task_func attribute reference/celery.worker.job.html
-celery.fields.PickledObjectField.get_db_prep_lookup method reference/celery.fields.html
-celery.conf.DAEMON_CONCURRENCY data reference/celery.conf.html
-celery.pool.TaskPool.start method reference/celery.pool.html
-celery.worker.WorkController.logger attribute reference/celery.worker.html
-celery.monitoring.StatsCollector.report method reference/celery.monitoring.html
-celery.managers.MySQLTableLock class reference/celery.managers.html
-celery.worker.job.TaskWrapper.on_success method reference/celery.worker.job.html
-celery.worker.WorkController.hold_queue attribute reference/celery.worker.html
+celery.result.BaseAsyncResult class reference/celery.result.html
 celery.result.BaseAsyncResult.get method reference/celery.result.html
-celery.task.base.Task.delay classmethod reference/celery.task.base.html
-celery.result.EagerResult.TimeoutError exception reference/celery.result.html
+celery.worker.AMQPListener.hold_queue attribute reference/celery.worker.html
 celery.conf.DAEMON_PID_FILE data reference/celery.conf.html
-celery.worker.job.TaskWrapper.on_failure method reference/celery.worker.job.html
-celery.monitoring.StatsCollector.total_tasks_processed attribute reference/celery.monitoring.html
-celery.monitoring.StatsCollector.task_time_running method reference/celery.monitoring.html
+celery.task.base.TaskSet.arguments attribute reference/celery.task.base.html
 celery.worker.controllers.PeriodicWorkController.on_start method reference/celery.worker.controllers.html
-celery.backends.base.BaseBackend.get_status method reference/celery.backends.base.html
+celery.monitoring.Statistics class reference/celery.monitoring.html
 celery.registry.TaskRegistry.autodiscover method reference/celery.registry.html
-celery.monitoring.TimerStats.on_start method reference/celery.monitoring.html
-celery.supervisor.OFASupervisor.Process.start method reference/celery.supervisor.html
-celery.task.base.TaskSet.task_name attribute reference/celery.task.base.html
+celery.worker.WorkController.mediator attribute reference/celery.worker.html
 celery.managers.TableLock.release method reference/celery.managers.html
-celery.worker.job.TaskWrapper.args attribute reference/celery.worker.job.html
-PeriodicTaskMeta.total_run_count attribute reference/celery.models.html
 celery.datastructures.PositionQueue.UnfilledPosition class reference/celery.datastructures.html
-celery.result.TaskSetResult.completed_count method reference/celery.result.html
-celery.pool.TaskPool.on_return method reference/celery.pool.html
-celery.messaging.TaskConsumer class reference/celery.messaging.html
-celery.worker.WorkController.safe_process_task method reference/celery.worker.html
 celery.managers.TaskManager.store_result method reference/celery.managers.html
-celery.result.TaskSetResult.taskset_id attribute reference/celery.result.html
-celery.managers.MySQLTableLock.lock_table method reference/celery.managers.html
-celery.supervisor.OFASupervisor.Process.terminate method reference/celery.supervisor.html
-TaskMeta.result attribute reference/celery.models.html
-celery.supervisor.OFASupervisor.Process.join method reference/celery.supervisor.html
+celery.monitoring.TimerStats class reference/celery.monitoring.html
 celery.backends.tyrant.Backend.open method reference/celery.backends.tyrant.html
-celery.conf.SEND_CELERY_TASK_ERROR_EMAILS data reference/celery.conf.html

+ 6 - 0
reference/celery.backends.base.html

@@ -150,6 +150,12 @@ exception </em><tt class="descclassname">BaseBackend.</tt><tt class="descname">U
 <tt class="descclassname">BaseBackend.</tt><tt class="descname">mark_as_failure</tt><big>(</big><em>task_id</em>, <em>exc</em><big>)</big><a class="headerlink" href="#celery.backends.base.BaseBackend.mark_as_failure" title="Permalink to this definition">¶</a></dt>
 <dd>Mark task as executed with failure. Stores the execption.</dd></dl>
 
+<dl class="method">
+<dt id="celery.backends.base.BaseBackend.mark_as_retry">
+<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 as being retries. Stores the current
+exception (if any).</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>

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

@@ -142,7 +142,7 @@ running in the background somewhere.</p>
 
 <dl class="function">
 <dt id="celery.bin.celeryd.run_worker">
-<tt class="descclassname">celery.bin.celeryd.</tt><tt class="descname">run_worker</tt><big>(</big><em>concurrency=0</em>, <em>detach=False</em>, <em>loglevel=20</em>, <em>logfile='celeryd.log'</em>, <em>discard=False</em>, <em>pidfile='celeryd.pid'</em>, <em>umask=0</em>, <em>uid=None</em>, <em>gid=None</em>, <em>supervised=False</em>, <em>working_directory=None</em>, <em>chroot=None</em>, <em>statistics=None</em>, <em>**kwargs</em><big>)</big><a class="headerlink" href="#celery.bin.celeryd.run_worker" title="Permalink to this definition">¶</a></dt>
+<tt class="descclassname">celery.bin.celeryd.</tt><tt class="descname">run_worker</tt><big>(</big><em>concurrency=16</em>, <em>detach=False</em>, <em>loglevel=20</em>, <em>logfile='celeryd.log'</em>, <em>discard=False</em>, <em>pidfile='celeryd.pid'</em>, <em>umask=0</em>, <em>uid=None</em>, <em>gid=None</em>, <em>supervised=False</em>, <em>working_directory=None</em>, <em>chroot=None</em>, <em>statistics=None</em>, <em>**kwargs</em><big>)</big><a class="headerlink" href="#celery.bin.celeryd.run_worker" title="Permalink to this definition">¶</a></dt>
 <dd>Starts the celery worker server.</dd></dl>
 
 </div>

+ 5 - 5
reference/celery.discovery.html

@@ -22,7 +22,7 @@
     <link rel="top" title="Celery v0.6.0 (stable) documentation" href="../index.html" />
     <link rel="up" title="Module API Reference" href="index.html" />
     <link rel="next" title="Statistics and Monitoring - celery.monitoring" href="celery.monitoring.html" />
-    <link rel="prev" title="Common Task Strategies - celery.task.strategy" href="celery.task.strategy.html" /> 
+    <link rel="prev" title="Django Loader - celery.loaders.djangoapp" href="celery.loaders.djangoapp.html" /> 
   </head>
   <body>
     <div class="related">
@@ -38,7 +38,7 @@
           <a href="celery.monitoring.html" title="Statistics and Monitoring - celery.monitoring"
              accesskey="N">next</a> |</li>
         <li class="right" >
-          <a href="celery.task.strategy.html" title="Common Task Strategies - celery.task.strategy"
+          <a href="celery.loaders.djangoapp.html" title="Django Loader - celery.loaders.djangoapp"
              accesskey="P">previous</a> |</li>
         <li><a href="../index.html">Celery v0.6.0 (stable) documentation</a> &raquo;</li>
           <li><a href="index.html" accesskey="U">Module API Reference</a> &raquo;</li> 
@@ -73,8 +73,8 @@ module in the application, and running handler&#8217; if it finds it.</dd></dl>
       <div class="sphinxsidebar">
         <div class="sphinxsidebarwrapper">
             <h4>Previous topic</h4>
-            <p class="topless"><a href="celery.task.strategy.html"
-                                  title="previous chapter">Common Task Strategies - celery.task.strategy</a></p>
+            <p class="topless"><a href="celery.loaders.djangoapp.html"
+                                  title="previous chapter">Django Loader - celery.loaders.djangoapp</a></p>
             <h4>Next topic</h4>
             <p class="topless"><a href="celery.monitoring.html"
                                   title="next chapter">Statistics and Monitoring - celery.monitoring</a></p>
@@ -113,7 +113,7 @@ module in the application, and running handler&#8217; if it finds it.</dd></dl>
           <a href="celery.monitoring.html" title="Statistics and Monitoring - celery.monitoring"
              >next</a> |</li>
         <li class="right" >
-          <a href="celery.task.strategy.html" title="Common Task Strategies - celery.task.strategy"
+          <a href="celery.loaders.djangoapp.html" title="Django Loader - celery.loaders.djangoapp"
              >previous</a> |</li>
         <li><a href="../index.html">Celery v0.6.0 (stable) documentation</a> &raquo;</li>
           <li><a href="index.html" >Module API Reference</a> &raquo;</li> 

+ 2 - 2
reference/celery.execute.html

@@ -54,7 +54,7 @@
 <h1>Executing Tasks - celery.execute<a class="headerlink" href="#module-celery.execute" title="Permalink to this headline">¶</a></h1>
 <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>**ignored</em><big>)</big><a class="headerlink" href="#celery.execute.apply" title="Permalink to this definition">¶</a></dt>
+<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>
 <dd><p>Apply the task locally.</p>
 <p>This will block until the task completes, and returns a
 <a title="celery.result.EagerResult" class="reference external" href="celery.result.html#celery.result.EagerResult"><tt class="xref docutils literal"><span class="pre">celery.result.EagerResult</span></tt></a> instance.</p>
@@ -62,7 +62,7 @@
 
 <dl class="function">
 <dt id="celery.execute.apply_async">
-<tt class="descclassname">celery.execute.</tt><tt class="descname">apply_async</tt><big>(</big><em>task</em>, <em>args=None</em>, <em>kwargs=None</em>, <em>countdown=None</em>, <em>eta=None</em>, <em>routing_key=None</em>, <em>exchange=None</em>, <em>immediate=None</em>, <em>mandatory=None</em>, <em>priority=None</em>, <em>connection=None</em>, <em>connect_timeout=4</em>, <em>**opts</em><big>)</big><a class="headerlink" href="#celery.execute.apply_async" title="Permalink to this definition">¶</a></dt>
+<tt class="descclassname">celery.execute.</tt><tt class="descname">apply_async</tt><big>(</big><em>task</em>, <em>args=None</em>, <em>kwargs=None</em>, <em>countdown=None</em>, <em>eta=None</em>, <em>routing_key=None</em>, <em>exchange=None</em>, <em>task_id=None</em>, <em>immediate=None</em>, <em>mandatory=None</em>, <em>priority=None</em>, <em>connection=None</em>, <em>connect_timeout=4</em>, <em>**opts</em><big>)</big><a class="headerlink" href="#celery.execute.apply_async" title="Permalink to this definition">¶</a></dt>
 <dd><p>Run a task asynchronously by the celery daemon(s).</p>
 <table class="docutils field-list" frame="void" rules="none">
 <col class="field-name" />

+ 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 0x2221de0&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 0x2162f90&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">

+ 5 - 5
reference/celery.registry.html

@@ -21,7 +21,7 @@
     <script type="text/javascript" src="../static/doctools.js"></script>
     <link rel="top" title="Celery v0.6.0 (stable) 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="Signals - celery.signals" href="celery.signals.html" />
     <link rel="prev" title="Task Information and Utilities - celery.task" href="celery.task.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.signals.html" title="Signals - celery.signals"
              accesskey="N">next</a> |</li>
         <li class="right" >
           <a href="celery.task.html" title="Task Information and Utilities - celery.task"
@@ -165,8 +165,8 @@ using this option.</td>
             <p class="topless"><a href="celery.task.html"
                                   title="previous chapter">Task Information and Utilities - celery.task</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.signals.html"
+                                  title="next chapter">Signals - celery.signals</a></p>
             <h3>This Page</h3>
             <ul class="this-page-menu">
               <li><a href="../sources/reference/celery.registry.txt"
@@ -199,7 +199,7 @@ using this option.</td>
           <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.signals.html" title="Signals - celery.signals"
              >next</a> |</li>
         <li class="right" >
           <a href="celery.task.html" title="Task Information and Utilities - celery.task"

+ 94 - 11
reference/celery.task.base.html

@@ -94,6 +94,12 @@ 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">
@@ -132,6 +138,12 @@ 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">
@@ -186,6 +198,17 @@ be consumed.</dd></dl>
 <tt class="descname">priority:</tt></dt>
 <dd>The message priority. A number from <tt class="docutils literal"><span class="pre">0</span></tt> to <tt class="docutils literal"><span class="pre">9</span></tt>.</dd></dl>
 
+<dl class="attribute">
+<dt id="celery.task.base.Task.max_retries">
+<tt class="descname">max_retries</tt><a class="headerlink" href="#celery.task.base.Task.max_retries" title="Permalink to this definition">¶</a></dt>
+<dd>Maximum number of retries before giving up.</dd></dl>
+
+<dl class="attribute">
+<dt id="celery.task.base.Task.default_retry_delay">
+<tt class="descname">default_retry_delay</tt><a class="headerlink" href="#celery.task.base.Task.default_retry_delay" title="Permalink to this definition">¶</a></dt>
+<dd>Defeault time in seconds before a retry of the task should be
+executed. Default is a 1 minute delay.</dd></dl>
+
 <dl class="attribute">
 <dt id="celery.task.base.Task.ignore_result">
 <tt class="descname">ignore_result</tt><a class="headerlink" href="#celery.task.base.Task.ignore_result" title="Permalink to this definition">¶</a></dt>
@@ -239,10 +262,16 @@ the task.</p>
 <span class="gp">&gt;&gt;&gt; </span><span class="n">result</span> <span class="o">=</span> <span class="n">delay_task</span><span class="p">(</span><span class="n">MyTask</span><span class="o">.</span><span class="n">name</span><span class="p">,</span> <span class="n">some_arg</span><span class="o">=</span><span class="s">&quot;foo&quot;</span><span class="p">)</span>
 </pre></div>
 </div>
+<dl class="exception">
+<dt id="celery.task.base.Task.MaxRetriesExceededError">
+<em class="property">
+exception </em><tt class="descname">MaxRetriesExceededError</tt><a class="headerlink" href="#celery.task.base.Task.MaxRetriesExceededError" title="Permalink to this definition">¶</a></dt>
+<dd>The tasks max restart limit has been exceeded.</dd></dl>
+
 <dl class="classmethod">
 <dt id="celery.task.base.Task.apply">
 <em class="property">
-classmethod </em><tt class="descname">apply</tt><big>(</big><em>args=None</em>, <em>kwargs=None</em>, <em>**options</em><big>)</big><a class="headerlink" href="#celery.task.base.Task.apply" title="Permalink to this definition">¶</a></dt>
+classmethod </em><tt class="descclassname">Task.</tt><tt class="descname">apply</tt><big>(</big><em>args=None</em>, <em>kwargs=None</em>, <em>**options</em><big>)</big><a class="headerlink" href="#celery.task.base.Task.apply" title="Permalink to this definition">¶</a></dt>
 <dd><p>Execute this task at once, by blocking until the task
 has finished executing.</p>
 <table class="docutils field-list" frame="void" rules="none">
@@ -266,30 +295,37 @@ has finished executing.</p>
 <dl class="classmethod">
 <dt id="celery.task.base.Task.apply_async">
 <em class="property">
-classmethod </em><tt class="descname">apply_async</tt><big>(</big><em>args=None</em>, <em>kwargs=None</em>, <em>**options</em><big>)</big><a class="headerlink" href="#celery.task.base.Task.apply_async" title="Permalink to this definition">¶</a></dt>
+classmethod </em><tt class="descclassname">Task.</tt><tt class="descname">apply_async</tt><big>(</big><em>args=None</em>, <em>kwargs=None</em>, <em>**options</em><big>)</big><a class="headerlink" href="#celery.task.base.Task.apply_async" title="Permalink to this definition">¶</a></dt>
 <dd><p>Delay this task for execution by the <tt class="docutils literal"><span class="pre">celery</span></tt> daemon(s).</p>
 <table class="docutils field-list" frame="void" rules="none">
 <col class="field-name" />
 <col class="field-body" />
 <tbody valign="top">
-<tr class="field"><th class="field-name">Parameters:</th><td class="field-body"><ul class="first simple">
+<tr class="field"><th class="field-name">Parameters:</th><td class="field-body"><ul class="first last simple">
 <li><em>args</em> &#8211; positional arguments passed on to the task.</li>
 <li><em>kwargs</em> &#8211; keyword arguments passed on to the task.</li>
+<li><em>**options</em> &#8211; Any keyword arguments to pass on to
+<a title="celery.execute.apply_async" class="reference external" href="celery.execute.html#celery.execute.apply_async"><tt class="xref docutils literal"><span class="pre">celery.execute.apply_async()</span></tt></a>.</li>
 </ul>
 </td>
 </tr>
-<tr class="field"><th class="field-name">Return type:</th><td class="field-body"><p class="first last"><a title="celery.result.AsyncResult" class="reference external" href="celery.result.html#celery.result.AsyncResult"><tt class="xref docutils literal"><span class="pre">celery.result.AsyncResult</span></tt></a></p>
-</td>
+</tbody>
+</table>
+<p>See <a title="celery.execute.apply_async" class="reference external" href="celery.execute.html#celery.execute.apply_async"><tt class="xref docutils literal"><span class="pre">celery.execute.apply_async()</span></tt></a> for more information.</p>
+<table class="docutils field-list" frame="void" rules="none">
+<col class="field-name" />
+<col class="field-body" />
+<tbody valign="top">
+<tr class="field"><th class="field-name">Return type:</th><td class="field-body"><a title="celery.result.AsyncResult" class="reference external" href="celery.result.html#celery.result.AsyncResult"><tt class="xref docutils literal"><span class="pre">celery.result.AsyncResult</span></tt></a></td>
 </tr>
 </tbody>
 </table>
-<p>See <a title="celery.execute.apply_async" class="reference external" href="celery.execute.html#celery.execute.apply_async"><tt class="xref docutils literal"><span class="pre">celery.execute.apply_async()</span></tt></a>.</p>
 </dd></dl>
 
 <dl class="classmethod">
 <dt id="celery.task.base.Task.delay">
 <em class="property">
-classmethod </em><tt class="descname">delay</tt><big>(</big><em>*args</em>, <em>**kwargs</em><big>)</big><a class="headerlink" href="#celery.task.base.Task.delay" title="Permalink to this definition">¶</a></dt>
+classmethod </em><tt class="descclassname">Task.</tt><tt class="descname">delay</tt><big>(</big><em>*args</em>, <em>**kwargs</em><big>)</big><a class="headerlink" href="#celery.task.base.Task.delay" title="Permalink to this definition">¶</a></dt>
 <dd><p>Delay this task for execution by the <tt class="docutils literal"><span class="pre">celery</span></tt> daemon(s).</p>
 <table class="docutils field-list" frame="void" rules="none">
 <col class="field-name" />
@@ -311,7 +347,7 @@ classmethod </em><tt class="descname">delay</tt><big>(</big><em>*args</em>, <em>
 
 <dl class="method">
 <dt id="celery.task.base.Task.get_consumer">
-<tt class="descname">get_consumer</tt><big>(</big><em>connect_timeout=4</em><big>)</big><a class="headerlink" href="#celery.task.base.Task.get_consumer" title="Permalink to this definition">¶</a></dt>
+<tt class="descclassname">Task.</tt><tt class="descname">get_consumer</tt><big>(</big><em>connect_timeout=4</em><big>)</big><a class="headerlink" href="#celery.task.base.Task.get_consumer" title="Permalink to this definition">¶</a></dt>
 <dd><p>Get a celery task message consumer.</p>
 <table class="docutils field-list" frame="void" rules="none">
 <col class="field-name" />
@@ -332,14 +368,14 @@ with this object. i.e.:</p>
 
 <dl class="method">
 <dt id="celery.task.base.Task.get_logger">
-<tt class="descname">get_logger</tt><big>(</big><em>**kwargs</em><big>)</big><a class="headerlink" href="#celery.task.base.Task.get_logger" title="Permalink to this definition">¶</a></dt>
+<tt class="descclassname">Task.</tt><tt class="descname">get_logger</tt><big>(</big><em>**kwargs</em><big>)</big><a class="headerlink" href="#celery.task.base.Task.get_logger" title="Permalink to this definition">¶</a></dt>
 <dd><p>Get process-aware logger object.</p>
 <p>See <a title="celery.log.setup_logger" class="reference external" href="celery.log.html#celery.log.setup_logger"><tt class="xref docutils literal"><span class="pre">celery.log.setup_logger()</span></tt></a>.</p>
 </dd></dl>
 
 <dl class="method">
 <dt id="celery.task.base.Task.get_publisher">
-<tt class="descname">get_publisher</tt><big>(</big><em>connect_timeout=4</em><big>)</big><a class="headerlink" href="#celery.task.base.Task.get_publisher" title="Permalink to this definition">¶</a></dt>
+<tt class="descclassname">Task.</tt><tt class="descname">get_publisher</tt><big>(</big><em>connect_timeout=4</em><big>)</big><a class="headerlink" href="#celery.task.base.Task.get_publisher" title="Permalink to this definition">¶</a></dt>
 <dd><p>Get a celery task message publisher.</p>
 <table class="docutils field-list" frame="void" rules="none">
 <col class="field-name" />
@@ -358,9 +394,56 @@ with this object, i.e.:</p>
 </div>
 </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>
+<dd><p>Retry the task.</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>args</em> &#8211; Positional arguments to retry with.</li>
+<li><em>kwargs</em> &#8211; Keyword arguments to retry with.</li>
+<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,
+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
+<tt class="xref docutils literal"><span class="pre">datetime.datetime</span></tt> instance).</li>
+<li><em>**options</em> &#8211; Any extra options to pass on to
+meth:<cite>apply_async</cite>. See <a title="celery.execute.apply_async" class="reference external" href="celery.execute.html#celery.execute.apply_async"><tt class="xref docutils literal"><span class="pre">celery.execute.apply_async()</span></tt></a>.</li>
+</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>
+</td>
+</tr>
+</tbody>
+</table>
+<p>Example</p>
+<div class="highlight-python"><div class="highlight"><pre><span class="gp">&gt;&gt;&gt; </span><span class="k">class</span> <span class="nc">TwitterPostStatusTask</span><span class="p">(</span><span class="n">Task</span><span class="p">):</span>
+<span class="gp">... </span>
+<span class="gp">... </span>    <span class="k">def</span> <span class="nf">run</span><span class="p">(</span><span class="bp">self</span><span class="p">,</span> <span class="n">username</span><span class="p">,</span> <span class="n">password</span><span class="p">,</span> <span class="n">message</span><span class="p">,</span> <span class="o">**</span><span class="n">kwargs</span><span class="p">):</span>
+<span class="gp">... </span>        <span class="n">twitter</span> <span class="o">=</span> <span class="n">Twitter</span><span class="p">(</span><span class="n">username</span><span class="p">,</span> <span class="n">password</span><span class="p">)</span>
+<span class="gp">... </span>        <span class="k">try</span><span class="p">:</span>
+<span class="gp">... </span>            <span class="n">twitter</span><span class="o">.</span><span class="n">post_status</span><span class="p">(</span><span class="n">message</span><span class="p">)</span>
+<span class="gp">... </span>        <span class="k">except</span> <span class="n">twitter</span><span class="o">.</span><span class="n">FailWhale</span><span class="p">,</span> <span class="n">exc</span><span class="p">:</span>
+<span class="gp">... </span>            <span class="c"># Retry in 5 minutes.</span>
+<span class="gp">... </span>            <span class="bp">self</span><span class="o">.</span><span class="n">retry</span><span class="p">([</span><span class="n">username</span><span class="p">,</span> <span class="n">password</span><span class="p">,</span> <span class="n">message</span><span class="p">],</span> <span class="n">kwargs</span><span class="p">,</span>
+<span class="gp">... </span>                       <span class="n">countdown</span><span class="o">=</span><span class="mf">60</span> <span class="o">*</span> <span class="mf">5</span><span class="p">,</span> <span class="n">exc</span><span class="o">=</span><span class="n">exc</span><span class="p">)</span>
+</pre></div>
+</div>
+</dd></dl>
+
 <dl class="method">
 <dt id="celery.task.base.Task.run">
-<tt class="descname">run</tt><big>(</big><em>*args</em>, <em>**kwargs</em><big>)</big><a class="headerlink" href="#celery.task.base.Task.run" title="Permalink to this definition">¶</a></dt>
+<tt class="descclassname">Task.</tt><tt class="descname">run</tt><big>(</big><em>*args</em>, <em>**kwargs</em><big>)</big><a class="headerlink" href="#celery.task.base.Task.run" title="Permalink to this definition">¶</a></dt>
 <dd><p><em>REQUIRED</em> The actual task.</p>
 <p>All subclasses of <a title="celery.task.base.Task" class="reference internal" href="#celery.task.base.Task"><tt class="xref docutils literal"><span class="pre">Task</span></tt></a> must define the run method.</p>
 <table class="docutils field-list" frame="void" rules="none">

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

@@ -22,7 +22,7 @@
     <link rel="top" title="Celery v0.6.0 (stable) 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="Task Registry - celery.registry" href="celery.registry.html" /> 
+    <link rel="prev" title="Signals - celery.signals" href="celery.signals.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.registry.html" title="Task Registry - celery.registry"
+          <a href="celery.signals.html" title="Signals - celery.signals"
              accesskey="P">previous</a> |</li>
         <li><a href="../index.html">Celery v0.6.0 (stable) 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.registry.html"
-                                  title="previous chapter">Task Registry - celery.registry</a></p>
+            <p class="topless"><a href="celery.signals.html"
+                                  title="previous chapter">Signals - celery.signals</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.registry.html" title="Task Registry - celery.registry"
+          <a href="celery.signals.html" title="Signals - celery.signals"
              >previous</a> |</li>
         <li><a href="../index.html">Celery v0.6.0 (stable) documentation</a> &raquo;</li>
           <li><a href="index.html" >Module API Reference</a> &raquo;</li> 

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

@@ -21,7 +21,7 @@
     <script type="text/javascript" src="../static/doctools.js"></script>
     <link rel="top" title="Celery v0.6.0 (stable) documentation" href="../index.html" />
     <link rel="up" title="Module API Reference" href="index.html" />
-    <link rel="next" title="Task Discovery - celery.discovery" href="celery.discovery.html" />
+    <link rel="next" title="Loaders - celery.loaders" href="celery.loaders.html" />
     <link rel="prev" title="Built-in Task Classes - celery.task.builtins" href="celery.task.builtins.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.discovery.html" title="Task Discovery - celery.discovery"
+          <a href="celery.loaders.html" title="Loaders - celery.loaders"
              accesskey="N">next</a> |</li>
         <li class="right" >
           <a href="celery.task.builtins.html" title="Built-in Task Classes - celery.task.builtins"
@@ -106,8 +106,8 @@ the processing of its tasks throughout the time window available.</p>
             <p class="topless"><a href="celery.task.builtins.html"
                                   title="previous chapter">Built-in Task Classes - celery.task.builtins</a></p>
             <h4>Next topic</h4>
-            <p class="topless"><a href="celery.discovery.html"
-                                  title="next chapter">Task Discovery - celery.discovery</a></p>
+            <p class="topless"><a href="celery.loaders.html"
+                                  title="next chapter">Loaders - celery.loaders</a></p>
             <h3>This Page</h3>
             <ul class="this-page-menu">
               <li><a href="../sources/reference/celery.task.strategy.txt"
@@ -140,7 +140,7 @@ the processing of its tasks throughout the time window available.</p>
           <a href="../modindex.html" title="Global Module Index"
              >modules</a> |</li>
         <li class="right" >
-          <a href="celery.discovery.html" title="Task Discovery - celery.discovery"
+          <a href="celery.loaders.html" title="Loaders - celery.loaders"
              >next</a> |</li>
         <li class="right" >
           <a href="celery.task.builtins.html" title="Built-in Task Classes - celery.task.builtins"

+ 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 0x227bab0&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 0x21c2a70&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>

+ 1 - 1
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>**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=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>
 <dd><p>Class wrapping a task to be run.</p>
 <table class="docutils field-list" frame="void" rules="none">
 <col class="field-name" />

+ 6 - 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.6</td>
 </tr>
-<tr class="field"><th class="field-name">Date:</th><td class="field-body">August 13, 2009</td>
+<tr class="field"><th class="field-name">Date:</th><td class="field-body">August 15, 2009</td>
 </tr>
 </tbody>
 </table>
@@ -66,8 +66,13 @@
 <li class="toctree-l1"><a class="reference external" href="celery.result.html">Task Result - celery.result</a></li>
 <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.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>
+<li class="toctree-l1"><a class="reference external" href="celery.loaders.base.html">Loader Base Classes - celery.loaders.base</a></li>
+<li class="toctree-l1"><a class="reference external" href="celery.loaders.default.html">Default Loader - celery.loaders.default</a></li>
+<li class="toctree-l1"><a class="reference external" href="celery.loaders.djangoapp.html">Django Loader - celery.loaders.djangoapp</a></li>
 <li class="toctree-l1"><a class="reference external" href="celery.discovery.html">Task Discovery - celery.discovery</a></li>
 <li class="toctree-l1"><a class="reference external" href="celery.monitoring.html">Statistics and Monitoring - celery.monitoring</a></li>
 <li class="toctree-l1"><a class="reference external" href="celery.messaging.html">Messaging - celery.messaging</a></li>

文件差异内容过多而无法显示
+ 0 - 0
searchindex.js


+ 62 - 3
sources/faq.txt

@@ -100,7 +100,12 @@ using ``discard_all``.
 Can I use celery with ActiveMQ/STOMP?
 -------------------------------------
 
-**Answer**: Yes. But this is very experimental for now.
+**Answer**: Yes. But this is somewhat experimental for now.
+It is certainly working ok for me in a test configuration, but it has not
+been tested in production like RabbitMQ. If you have any problems with
+using STOMP and celery, please report the bugs to the issue tracker:
+
+    http://github.com/ask/celery/issues/
 
 First you have to use the ``master`` branch of ``celery``::
 
@@ -141,14 +146,14 @@ Use the following specific settings in your ``settings.py``:
 .. code-block:: python
 
     # Makes python-stomp the default backend for carrot.
-    CARROT_BACKEND = "pystomp"
+    CARROT_BACKEND = "stomp"
 
     # STOMP hostname and port settings.
     AMQP_HOST = "localhost"
     AMQP_PORT = 61613
 
     # The queue name to use (both queue and exchange must be set to the
-    # same queue name when using STOMP!!!)
+    # same queue name when using STOMP)
     CELERY_AMQP_CONSUMER_QUEUE = "/queue/celery"
     CELERY_AMQP_EXCHANGE = "/queue/celery" 
    
@@ -238,3 +243,57 @@ You can also override this using the ``routing_key`` argument to
     >>> apply_async(RefreshFeedTask, args=["http://cnn.com/rss"],
     ...             routing_key="feed.importer")
 
+
+Can I use celery without Django?
+--------------------------------
+
+**Answer:** Yes. But you have to either create a custom loader, or use the
+default loader with a configuration file.
+
+Using the default loader
+========================
+
+You need a configuration file named ``celeryconfig.py``, either in the
+directory you run ``celeryd`` in, or in a Python library path where it is
+able to find it. The configuration file can contain any of the settings
+described in :mod:`celery.conf`, and in additional if you're using the
+database backend you have to configure the database. Here is an example
+configuration using the database backend with MySQL:
+
+.. code-block:: python
+
+    # Broker configuration
+    AMQP_SERVER = "localhost"
+    AMQP_PORT = "5672"
+    AMQP_VHOST = "celery"
+    AMQP_USER = "celery"
+    AMQP_PASSWORD = "celerysecret"
+    CARROT_BACKEND="amqp"
+
+    # Using the database backend.
+    CELERY_BACKEND = "database"
+
+    # Number of processes that processes tasks simultaneously.
+    CELERYD_CONCURRENCY = 8
+
+    # Modules to import when celeryd starts.
+    # This must import every module where you register tasks so celeryd
+    # is able to find and run them.
+    CELERY_IMPORTS = ("mytaskmodule1", "mytaskmodule2")
+    
+Now with this configuration file in the current directory you have to
+run ``celeryinit`` to create the database tables::
+
+    $ celeryinit
+
+Then you should be able to successfully run ``celeryd``::
+
+    $ celeryd --loglevel=INFO
+
+and send a task from a python shell (note that it must be able to import
+``celeryconfig.py``):
+
+    >>> from celery.task.builtins import PingTask
+    >>> result = PingTask.apply_async()
+    >>> result.get()
+    'pong'

+ 3 - 3
sources/index.txt

@@ -2,9 +2,9 @@
    You can adapt this file completely to your liking, but it should at least
    contain the root `toctree` directive.
 
-================================
- Celery - The Django Task Queue
-================================
+=================================
+ Celery - Distributed Task Queue
+=================================
 
 Contents:
 

+ 6 - 4
sources/introduction.txt

@@ -1,13 +1,15 @@
-=============================================
- celery - Distributed Task Queue for Django.
-=============================================
+===================================================
+ celery - Distributed Task Queue for Django/Python
+===================================================
 
 :Version: 0.6.0
 
 Introduction
 ============
 
-``celery`` is a distributed task queue framework for Django.
+**NOTE:** See the FAQ for information about using celery outside of Django.
+
+``celery`` is a distributed task queue framework for Django/Python.
 
 It is used for executing tasks *asynchronously*, routed to one or more
 worker servers, running concurrently using multiprocessing.

+ 5 - 0
sources/reference/index.txt

@@ -13,8 +13,13 @@
     celery.result
     celery.task
     celery.registry
+    celery.signals
     celery.task.builtins
     celery.task.strategy
+    celery.loaders
+    celery.loaders.base
+    celery.loaders.default
+    celery.loaders.djangoapp
     celery.discovery
     celery.monitoring
     celery.messaging

+ 5 - 5
tutorials/index.html

@@ -21,7 +21,7 @@
     <script type="text/javascript" src="../static/doctools.js"></script>
     <link rel="top" title="Celery v0.6.0 (stable) documentation" href="../index.html" />
     <link rel="next" title="Tutorial: Creating a click counter using carrot and celery" href="clickcounter.html" />
-    <link rel="prev" title="celery - Distributed Task Queue for Django." href="../introduction.html" /> 
+    <link rel="prev" title="celery - Distributed Task Queue for Django/Python" href="../introduction.html" /> 
   </head>
   <body>
     <div class="related">
@@ -37,7 +37,7 @@
           <a href="clickcounter.html" title="Tutorial: Creating a click counter using carrot and celery"
              accesskey="N">next</a> |</li>
         <li class="right" >
-          <a href="../introduction.html" title="celery - Distributed Task Queue for Django."
+          <a href="../introduction.html" title="celery - Distributed Task Queue for Django/Python"
              accesskey="P">previous</a> |</li>
         <li><a href="../index.html">Celery v0.6.0 (stable) documentation</a> &raquo;</li> 
       </ul>
@@ -56,7 +56,7 @@
 <tbody valign="top">
 <tr class="field"><th class="field-name">Release:</th><td class="field-body">0.6</td>
 </tr>
-<tr class="field"><th class="field-name">Date:</th><td class="field-body">August 13, 2009</td>
+<tr class="field"><th class="field-name">Date:</th><td class="field-body">August 15, 2009</td>
 </tr>
 </tbody>
 </table>
@@ -81,7 +81,7 @@
         <div class="sphinxsidebarwrapper">
             <h4>Previous topic</h4>
             <p class="topless"><a href="../introduction.html"
-                                  title="previous chapter">celery - Distributed Task Queue for Django.</a></p>
+                                  title="previous chapter">celery - Distributed Task Queue for Django/Python</a></p>
             <h4>Next topic</h4>
             <p class="topless"><a href="clickcounter.html"
                                   title="next chapter">Tutorial: Creating a click counter using carrot and celery</a></p>
@@ -120,7 +120,7 @@
           <a href="clickcounter.html" title="Tutorial: Creating a click counter using carrot and celery"
              >next</a> |</li>
         <li class="right" >
-          <a href="../introduction.html" title="celery - Distributed Task Queue for Django."
+          <a href="../introduction.html" title="celery - Distributed Task Queue for Django/Python"
              >previous</a> |</li>
         <li><a href="../index.html">Celery v0.6.0 (stable) documentation</a> &raquo;</li> 
       </ul>

部分文件因为文件数量过多而无法显示