|
@@ -5,13 +5,13 @@
|
|
|
<head>
|
|
|
<meta http-equiv="Content-Type" content="text/html; charset=utf-8" />
|
|
|
|
|
|
- <title>Task Pool - celery.pool — Celery v0.3.11 (unstable) documentation</title>
|
|
|
+ <title>Task Pool - celery.pool — Celery v0.3.12 (unstable) 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">
|
|
|
var DOCUMENTATION_OPTIONS = {
|
|
|
URL_ROOT: '../',
|
|
|
- VERSION: '0.3.11 (unstable)',
|
|
|
+ VERSION: '0.3.12 (unstable)',
|
|
|
COLLAPSE_MODINDEX: false,
|
|
|
FILE_SUFFIX: '.html',
|
|
|
HAS_SOURCE: true
|
|
@@ -19,7 +19,7 @@
|
|
|
</script>
|
|
|
<script type="text/javascript" src="../static/jquery.js"></script>
|
|
|
<script type="text/javascript" src="../static/doctools.js"></script>
|
|
|
- <link rel="top" title="Celery v0.3.11 (unstable) documentation" href="../index.html" />
|
|
|
+ <link rel="top" title="Celery v0.3.12 (unstable) documentation" href="../index.html" />
|
|
|
<link rel="up" title="Module API Reference" href="index.html" />
|
|
|
<link rel="next" title="Backends - celery.backends" href="celery.backends.html" />
|
|
|
<link rel="prev" title="Multiprocessing Worker - celery.worker" href="celery.worker.html" />
|
|
@@ -40,7 +40,7 @@
|
|
|
<li class="right" >
|
|
|
<a href="celery.worker.html" title="Multiprocessing Worker - celery.worker"
|
|
|
accesskey="P">previous</a> |</li>
|
|
|
- <li><a href="../index.html">Celery v0.3.11 (unstable) documentation</a> »</li>
|
|
|
+ <li><a href="../index.html">Celery v0.3.12 (unstable) documentation</a> »</li>
|
|
|
<li><a href="index.html" accesskey="U">Module API Reference</a> »</li>
|
|
|
</ul>
|
|
|
</div>
|
|
@@ -56,7 +56,7 @@
|
|
|
<dl class="class">
|
|
|
<dt id="celery.pool.TaskPool">
|
|
|
<em class="property">
|
|
|
-class </em><tt class="descclassname">celery.pool.</tt><tt class="descname">TaskPool</tt><big>(</big><em>limit</em>, <em>reap_timeout=None</em>, <em>logger=None</em><big>)</big><a class="headerlink" href="#celery.pool.TaskPool" title="Permalink to this definition">¶</a></dt>
|
|
|
+class </em><tt class="descclassname">celery.pool.</tt><tt class="descname">TaskPool</tt><big>(</big><em>limit</em>, <em>logger=None</em><big>)</big><a class="headerlink" href="#celery.pool.TaskPool" title="Permalink to this definition">¶</a></dt>
|
|
|
<dd><p>Pool of running child processes, which starts waiting for the
|
|
|
processes to finish when the queue limit has been reached.</p>
|
|
|
<table class="docutils field-list" frame="void" rules="none">
|
|
@@ -93,28 +93,20 @@ to accept new processes.</p>
|
|
|
<col class="field-name" />
|
|
|
<col class="field-body" />
|
|
|
<tbody valign="top">
|
|
|
-<tr class="field"><th class="field-name">Parameter:</th><td class="field-body"><p class="first"><em>result</em> – A <tt class="xref docutils literal"><span class="pre">multiprocessing.AsyncResult</span></tt> instance, as
|
|
|
-returned by <tt class="xref docutils literal"><span class="pre">multiprocessing.Pool.apply_async()</span></tt>.</p>
|
|
|
-</td>
|
|
|
+<tr class="field"><th class="field-name">Parameter:</th><td class="field-body"><em>result</em> – A <tt class="xref docutils literal"><span class="pre">multiprocessing.AsyncResult</span></tt> instance, as
|
|
|
+returned by <tt class="xref docutils literal"><span class="pre">multiprocessing.Pool.apply_async()</span></tt>.</td>
|
|
|
</tr>
|
|
|
<tr class="field"><th class="field-name" colspan="2">Option callbacks:</th></tr>
|
|
|
-<tr><td> </td><td class="field-body"><p class="first">List of callbacks to execute if the task was
|
|
|
-successful. Must have the function signature:</p>
|
|
|
-<blockquote>
|
|
|
-<p><tt class="docutils literal"><span class="pre">mycallback(result,</span> <span class="pre">meta)</span></tt></p>
|
|
|
-</blockquote>
|
|
|
-</td>
|
|
|
+<tr><td> </td><td class="field-body">List of callbacks to execute if the task was
|
|
|
+successful. Must have the function signature:
|
|
|
+<tt class="docutils literal"><span class="pre">mycallback(result,</span> <span class="pre">meta)</span></tt></td>
|
|
|
</tr>
|
|
|
<tr class="field"><th class="field-name" colspan="2">Option errbacks:</th></tr>
|
|
|
-<tr><td> </td><td class="field-body"><p class="first">List of errbacks to execute if the task raised
|
|
|
-and exception. Must have the function signature:</p>
|
|
|
-<blockquote>
|
|
|
-<p><tt class="docutils literal"><span class="pre">myerrback(exc,</span> <span class="pre">meta)</span></tt>.</p>
|
|
|
-</blockquote>
|
|
|
-</td>
|
|
|
+<tr><td> </td><td class="field-body">List of errbacks to execute if the task raised
|
|
|
+and exception. Must have the function signature:
|
|
|
+<tt class="docutils literal"><span class="pre">myerrback(exc,</span> <span class="pre">meta)</span></tt>.</td>
|
|
|
</tr>
|
|
|
-<tr class="field"><th class="field-name">Option tid:</th><td class="field-body"><p class="first last">The tid for this task (unqiue pool id).</p>
|
|
|
-</td>
|
|
|
+<tr class="field"><th class="field-name">Option tid:</th><td class="field-body">The tid for this task (unqiue pool id).</td>
|
|
|
</tr>
|
|
|
</tbody>
|
|
|
</table>
|
|
@@ -146,16 +138,7 @@ has been reached.</td>
|
|
|
<dl class="method">
|
|
|
<dt id="celery.pool.TaskPool.get_worker_pids">
|
|
|
<tt class="descname">get_worker_pids</tt><big>(</big><big>)</big><a class="headerlink" href="#celery.pool.TaskPool.get_worker_pids" title="Permalink to this definition">¶</a></dt>
|
|
|
-<dd><p>Returns the process id’s of all the pool workers.</p>
|
|
|
-<table class="docutils field-list" frame="void" rules="none">
|
|
|
-<col class="field-name" />
|
|
|
-<col class="field-body" />
|
|
|
-<tbody valign="top">
|
|
|
-<tr class="field"><th class="field-name">Return type:</th><td class="field-body">list</td>
|
|
|
-</tr>
|
|
|
-</tbody>
|
|
|
-</table>
|
|
|
-</dd></dl>
|
|
|
+<dd>Returns the process id’s of all the pool workers.</dd></dl>
|
|
|
|
|
|
<dl class="method">
|
|
|
<dt id="celery.pool.TaskPool.on_ready">
|
|
@@ -177,8 +160,7 @@ been collected.</dd></dl>
|
|
|
<dt id="celery.pool.TaskPool.run">
|
|
|
<tt class="descname">run</tt><big>(</big><big>)</big><a class="headerlink" href="#celery.pool.TaskPool.run" title="Permalink to this definition">¶</a></dt>
|
|
|
<dd><p>Run the task pool.</p>
|
|
|
-<p>Will launch all worker processes so they are ready
|
|
|
-for processing tasks.</p>
|
|
|
+<p>Will pre-fork all workers so they’re ready to accept tasks.</p>
|
|
|
</dd></dl>
|
|
|
|
|
|
<dl class="method">
|
|
@@ -246,7 +228,7 @@ for processing tasks.</p>
|
|
|
<li class="right" >
|
|
|
<a href="celery.worker.html" title="Multiprocessing Worker - celery.worker"
|
|
|
>previous</a> |</li>
|
|
|
- <li><a href="../index.html">Celery v0.3.11 (unstable) documentation</a> »</li>
|
|
|
+ <li><a href="../index.html">Celery v0.3.12 (unstable) documentation</a> »</li>
|
|
|
<li><a href="index.html" >Module API Reference</a> »</li>
|
|
|
</ul>
|
|
|
</div>
|