|
|
@@ -5,13 +5,13 @@
|
|
|
<head>
|
|
|
<meta http-equiv="Content-Type" content="text/html; charset=utf-8" />
|
|
|
|
|
|
- <title>Index — Celery v0.3.2 (unstable) documentation</title>
|
|
|
+ <title>Index — Celery v0.3.5 (unstable) documentation</title>
|
|
|
<link rel="stylesheet" href="static/agogo.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.2 (unstable)',
|
|
|
+ VERSION: '0.3.5 (unstable)',
|
|
|
COLLAPSE_MODINDEX: false,
|
|
|
FILE_SUFFIX: '.html',
|
|
|
HAS_SOURCE: true
|
|
|
@@ -19,13 +19,13 @@
|
|
|
</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.2 (unstable) documentation" href="index.html" />
|
|
|
+ <link rel="top" title="Celery v0.3.5 (unstable) documentation" href="index.html" />
|
|
|
</head>
|
|
|
<body>
|
|
|
|
|
|
<div class="header-wrapper">
|
|
|
<div class="header">
|
|
|
- <h1><a href="index.html">Celery v0.3.2 (unstable) documentation</a></h1>
|
|
|
+ <h1><a href="index.html">Celery v0.3.5 (unstable) documentation</a></h1>
|
|
|
<div class="rel">
|
|
|
<a href="" title="General Index"
|
|
|
accesskey="I">index</a> |
|
|
|
@@ -54,15 +54,27 @@
|
|
|
<table width="100%" class="indextable"><tr><td width="33%" valign="top">
|
|
|
<dl>
|
|
|
|
|
|
+<dt>--chroot</dt>
|
|
|
+ <dd><dl>
|
|
|
+ <dt><a href="reference/celery.bin.celeryd.html#cmdoption-celeryd--chroot">celeryd command line option</a></dt>
|
|
|
+ </dl></dd>
|
|
|
<dt>--discard</dt>
|
|
|
<dd><dl>
|
|
|
<dt><a href="reference/celery.bin.celeryd.html#cmdoption-celeryd--discard">celeryd command line option</a></dt>
|
|
|
</dl></dd>
|
|
|
+<dt>--umask</dt>
|
|
|
+ <dd><dl>
|
|
|
+ <dt><a href="reference/celery.bin.celeryd.html#cmdoption-celeryd--umask">celeryd command line option</a></dt>
|
|
|
+ </dl></dd>
|
|
|
+<dt>--workdir</dt>
|
|
|
+ <dd><dl>
|
|
|
+ <dt><a href="reference/celery.bin.celeryd.html#cmdoption-celeryd--workdir">celeryd command line option</a></dt>
|
|
|
+ </dl></dd>
|
|
|
<dt>-c, --concurrency</dt>
|
|
|
<dd><dl>
|
|
|
<dt><a href="reference/celery.bin.celeryd.html#cmdoption-celeryd-c">celeryd command line option</a></dt>
|
|
|
</dl></dd>
|
|
|
-<dt>-d, --daemon</dt>
|
|
|
+<dt>-d, --detach, --daemon</dt>
|
|
|
<dd><dl>
|
|
|
<dt><a href="reference/celery.bin.celeryd.html#cmdoption-celeryd-d">celeryd command line option</a></dt>
|
|
|
</dl></dd>
|
|
|
@@ -70,6 +82,10 @@
|
|
|
<dd><dl>
|
|
|
<dt><a href="reference/celery.bin.celeryd.html#cmdoption-celeryd-f">celeryd command line option</a></dt>
|
|
|
</dl></dd></dl></td><td width="33%" valign="top"><dl>
|
|
|
+<dt>-g, --gid</dt>
|
|
|
+ <dd><dl>
|
|
|
+ <dt><a href="reference/celery.bin.celeryd.html#cmdoption-celeryd-g">celeryd command line option</a></dt>
|
|
|
+ </dl></dd>
|
|
|
<dt>-l, --loglevel</dt>
|
|
|
<dd><dl>
|
|
|
<dt><a href="reference/celery.bin.celeryd.html#cmdoption-celeryd-l">celeryd command line option</a></dt>
|
|
|
@@ -78,6 +94,10 @@
|
|
|
<dd><dl>
|
|
|
<dt><a href="reference/celery.bin.celeryd.html#cmdoption-celeryd-p">celeryd command line option</a></dt>
|
|
|
</dl></dd>
|
|
|
+<dt>-u, --uid</dt>
|
|
|
+ <dd><dl>
|
|
|
+ <dt><a href="reference/celery.bin.celeryd.html#cmdoption-celeryd-u">celeryd command line option</a></dt>
|
|
|
+ </dl></dd>
|
|
|
<dt>-w, --wakeup-after</dt>
|
|
|
<dd><dl>
|
|
|
<dt><a href="reference/celery.bin.celeryd.html#cmdoption-celeryd-w">celeryd command line option</a></dt>
|
|
|
@@ -88,14 +108,17 @@
|
|
|
<table width="100%" class="indextable"><tr><td width="33%" valign="top">
|
|
|
<dl>
|
|
|
|
|
|
+<dt><a href="reference/celery.bin.celeryd.html#celery.bin.celeryd.acquire_pidlock">acquire_pidlock() (in module celery.bin.celeryd)</a></dt>
|
|
|
+<dt><a href="reference/celery.pool.html#celery.pool.TaskPool.add">add() (celery.pool.TaskPool method)</a></dt>
|
|
|
<dt><a href="reference/celery.registry.html#celery.registry.AlreadyRegistered">AlreadyRegistered</a></dt>
|
|
|
<dt><a href="reference/celery.conf.html#celery.conf.AMQP_CONSUMER_QUEUE">AMQP_CONSUMER_QUEUE (in module celery.conf)</a>, <a href="reference/celery.conf.html#celery.conf.AMQP_CONSUMER_QUEUE">[1]</a></dt>
|
|
|
<dt><a href="reference/celery.conf.html#celery.conf.AMQP_CONSUMER_ROUTING_KEY">AMQP_CONSUMER_ROUTING_KEY (in module celery.conf)</a>, <a href="reference/celery.conf.html#celery.conf.AMQP_CONSUMER_ROUTING_KEY">[1]</a></dt>
|
|
|
<dt><a href="reference/celery.conf.html#celery.conf.AMQP_EXCHANGE">AMQP_EXCHANGE (in module celery.conf)</a>, <a href="reference/celery.conf.html#celery.conf.AMQP_EXCHANGE">[1]</a></dt>
|
|
|
<dt><a href="reference/celery.conf.html#celery.conf.AMQP_EXCHANGE_TYPE">AMQP_EXCHANGE_TYPE (in module celery.conf)</a>, <a href="reference/celery.conf.html#celery.conf.AMQP_EXCHANGE_TYPE">[1]</a></dt>
|
|
|
<dt><a href="reference/celery.conf.html#celery.conf.AMQP_PUBLISHER_ROUTING_KEY">AMQP_PUBLISHER_ROUTING_KEY (in module celery.conf)</a>, <a href="reference/celery.conf.html#celery.conf.AMQP_PUBLISHER_ROUTING_KEY">[1]</a></dt>
|
|
|
-<dt><a href="reference/celery.task.html#celery.task.Task.apply_async">apply_async() (celery.task.Task class method)</a></dt>
|
|
|
+<dt><a href="reference/celery.pool.html#celery.pool.TaskPool.apply_async">apply_async() (celery.pool.TaskPool method)</a></dt>
|
|
|
<dd><dl>
|
|
|
+ <dt><a href="reference/celery.task.html#celery.task.Task.apply_async">(celery.task.Task class method)</a></dt>
|
|
|
<dt><a href="reference/celery.task.html#celery.task.apply_async">(in module celery.task)</a></dt>
|
|
|
</dl></dd></dl></td><td width="33%" valign="top"><dl>
|
|
|
<dt><a href="reference/celery.worker.html#celery.worker.TaskWrapper.args">args (celery.worker.TaskWrapper attribute)</a></dt>
|
|
|
@@ -142,23 +165,27 @@
|
|
|
<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>
|
|
|
-<dt><a href="reference/celery.platform.html#module-celery.platform">celery.platform (module)</a></dt>
|
|
|
+<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.task.html#module-celery.task">celery.task (module)</a></dt>
|
|
|
-<dt><a href="reference/celery.timer.html#module-celery.timer">celery.timer (module)</a></dt></dl></td><td width="33%" valign="top"><dl>
|
|
|
+<dt><a href="reference/celery.timer.html#module-celery.timer">celery.timer (module)</a></dt>
|
|
|
<dt><a href="reference/celery.worker.html#module-celery.worker">celery.worker (module)</a></dt>
|
|
|
<dt>celeryd command line option</dt>
|
|
|
<dd><dl>
|
|
|
+ <dt><a href="reference/celery.bin.celeryd.html#cmdoption-celeryd--chroot">--chroot</a></dt>
|
|
|
<dt><a href="reference/celery.bin.celeryd.html#cmdoption-celeryd--discard">--discard</a></dt>
|
|
|
+ <dt><a href="reference/celery.bin.celeryd.html#cmdoption-celeryd--umask">--umask</a></dt>
|
|
|
+ <dt><a href="reference/celery.bin.celeryd.html#cmdoption-celeryd--workdir">--workdir</a></dt>
|
|
|
<dt><a href="reference/celery.bin.celeryd.html#cmdoption-celeryd-c">-c, --concurrency</a></dt>
|
|
|
- <dt><a href="reference/celery.bin.celeryd.html#cmdoption-celeryd-d">-d, --daemon</a></dt>
|
|
|
+ <dt><a href="reference/celery.bin.celeryd.html#cmdoption-celeryd-d">-d, --detach, --daemon</a></dt>
|
|
|
<dt><a href="reference/celery.bin.celeryd.html#cmdoption-celeryd-f">-f, --logfile</a></dt>
|
|
|
+ <dt><a href="reference/celery.bin.celeryd.html#cmdoption-celeryd-g">-g, --gid</a></dt>
|
|
|
<dt><a href="reference/celery.bin.celeryd.html#cmdoption-celeryd-l">-l, --loglevel</a></dt>
|
|
|
<dt><a href="reference/celery.bin.celeryd.html#cmdoption-celeryd-p">-p, --pidfile</a></dt>
|
|
|
+ <dt><a href="reference/celery.bin.celeryd.html#cmdoption-celeryd-u">-u, --uid</a></dt>
|
|
|
<dt><a href="reference/celery.bin.celeryd.html#cmdoption-celeryd-w">-w, --wakeup-after</a></dt>
|
|
|
- </dl></dd>
|
|
|
-<dt><a href="reference/celery.platform.html#celery.platform.PIDFile.check">check() (celery.platform.PIDFile method)</a></dt>
|
|
|
+ </dl></dd></dl></td><td width="33%" valign="top"><dl>
|
|
|
<dt><a href="reference/celery.backends.base.html#celery.backends.base.BaseBackend.cleanup">cleanup() (celery.backends.base.BaseBackend method)</a></dt>
|
|
|
<dd><dl>
|
|
|
<dt><a href="reference/celery.backends.database.html#celery.backends.database.Backend.cleanup">(celery.backends.database.Backend method)</a></dt>
|
|
|
@@ -177,7 +204,6 @@
|
|
|
<dt><a href="reference/celery.conf.html#celery.conf.DAEMON_LOG_FILE">DAEMON_LOG_FILE (in module celery.conf)</a>, <a href="reference/celery.conf.html#celery.conf.DAEMON_LOG_FILE">[1]</a></dt>
|
|
|
<dt><a href="reference/celery.conf.html#celery.conf.DAEMON_LOG_LEVEL">DAEMON_LOG_LEVEL (in module celery.conf)</a>, <a href="reference/celery.conf.html#celery.conf.DAEMON_LOG_LEVEL">[1]</a></dt>
|
|
|
<dt><a href="reference/celery.conf.html#celery.conf.DAEMON_PID_FILE">DAEMON_PID_FILE (in module celery.conf)</a>, <a href="reference/celery.conf.html#celery.conf.DAEMON_PID_FILE">[1]</a></dt>
|
|
|
-<dt><a href="reference/celery.platform.html#celery.platform.daemonize">daemonize() (in module celery.platform)</a></dt>
|
|
|
<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_DAEMON_LOG_FILE">DEFAULT_DAEMON_LOG_FILE (in module celery.conf)</a></dt>
|
|
|
@@ -239,10 +265,13 @@
|
|
|
<dt><a href="reference/celery.result.html#celery.result.TaskSetResult.failed">failed() (celery.result.TaskSetResult method)</a></dt>
|
|
|
<dt><a href="reference/celery.datastructures.html#celery.datastructures.PositionQueue.filled">filled (celery.datastructures.PositionQueue attribute)</a></dt>
|
|
|
<dt><a href="reference/celery.registry.html#celery.registry.TaskRegistry.filter_types">filter_types() (celery.registry.TaskRegistry method)</a></dt>
|
|
|
-<dt><a href="reference/celery.backends.base.html#celery.backends.base.find_nearest_pickleable_exception">find_nearest_pickleable_exception() (in module celery.backends.base)</a></dt></dl></td><td width="33%" valign="top"><dl>
|
|
|
-<dt><a href="reference/celery.discovery.html#celery.discovery.find_related_module">find_related_module() (in module celery.discovery)</a></dt>
|
|
|
+<dt><a href="reference/celery.backends.base.html#celery.backends.base.find_nearest_pickleable_exception">find_nearest_pickleable_exception() (in module celery.backends.base)</a></dt>
|
|
|
+<dt><a href="reference/celery.discovery.html#celery.discovery.find_related_module">find_related_module() (in module celery.discovery)</a></dt></dl></td><td width="33%" valign="top"><dl>
|
|
|
<dt><a href="reference/celery.worker.html#celery.worker.TaskWrapper.from_message">from_message() (celery.worker.TaskWrapper class method)</a></dt>
|
|
|
<dt><a href="reference/celery.datastructures.html#celery.datastructures.PositionQueue.full">full() (celery.datastructures.PositionQueue method)</a></dt>
|
|
|
+ <dd><dl>
|
|
|
+ <dt><a href="reference/celery.pool.html#celery.pool.TaskPool.full">(celery.pool.TaskPool method)</a></dt>
|
|
|
+ </dl></dd>
|
|
|
</dl></td></tr></table>
|
|
|
|
|
|
<h2 id="G">G</h2>
|
|
|
@@ -260,15 +289,13 @@
|
|
|
<dt><a href="reference/celery.backends.html#celery.backends.get_default_periodicstatus_backend_cls">get_default_periodicstatus_backend_cls (in module celery.backends)</a></dt>
|
|
|
<dt><a href="reference/celery.backends.html#celery.backends.get_default_periodicstatus_backend_cls">get_default_periodicstatus_backend_cls() (in module celery.backends)</a></dt>
|
|
|
<dt><a href="reference/celery.task.html#celery.task.Task.get_logger">get_logger() (celery.task.Task method)</a></dt>
|
|
|
-<dt><a href="reference/celery.platform.html#celery.platform.PIDFile.get_pid">get_pid() (celery.platform.PIDFile method)</a></dt>
|
|
|
-<dt><a href="reference/celery.task.html#celery.task.Task.get_publisher">get_publisher() (celery.task.Task method)</a></dt></dl></td><td width="33%" valign="top"><dl>
|
|
|
+<dt><a href="reference/celery.task.html#celery.task.Task.get_publisher">get_publisher() (celery.task.Task method)</a></dt>
|
|
|
<dt><a href="reference/celery.backends.base.html#celery.backends.base.BaseBackend.get_result">get_result() (celery.backends.base.BaseBackend method)</a></dt>
|
|
|
<dd><dl>
|
|
|
<dt><a href="reference/celery.backends.cache.html#celery.backends.cache.Backend.get_result">(celery.backends.cache.Backend method)</a></dt>
|
|
|
<dt><a href="reference/celery.backends.database.html#celery.backends.database.Backend.get_result">(celery.backends.database.Backend method)</a></dt>
|
|
|
<dt><a href="reference/celery.backends.tyrant.html#celery.backends.tyrant.Backend.get_result">(celery.backends.tyrant.Backend method)</a></dt>
|
|
|
- </dl></dd>
|
|
|
-<dt><a href="reference/celery.backends.tyrant.html#celery.backends.tyrant.Backend.get_server">get_server() (celery.backends.tyrant.Backend method)</a></dt>
|
|
|
+ </dl></dd></dl></td><td width="33%" valign="top"><dl>
|
|
|
<dt><a href="reference/celery.backends.base.html#celery.backends.base.BaseBackend.get_status">get_status() (celery.backends.base.BaseBackend method)</a></dt>
|
|
|
<dd><dl>
|
|
|
<dt><a href="reference/celery.backends.cache.html#celery.backends.cache.Backend.get_status">(celery.backends.cache.Backend method)</a></dt>
|
|
|
@@ -280,6 +307,7 @@
|
|
|
<dt><a href="reference/celery.registry.html#celery.registry.TaskRegistry.get_task">(celery.registry.TaskRegistry method)</a></dt>
|
|
|
</dl></dd>
|
|
|
<dt><a href="reference/celery.managers.html#celery.managers.PeriodicTaskManager.get_waiting_tasks">get_waiting_tasks() (celery.managers.PeriodicTaskManager method)</a></dt>
|
|
|
+<dt><a href="reference/celery.pool.html#celery.pool.TaskPool.get_worker_pids">get_worker_pids() (celery.pool.TaskPool method)</a></dt>
|
|
|
</dl></td></tr></table>
|
|
|
|
|
|
<h2 id="I">I</h2>
|
|
|
@@ -328,10 +356,14 @@
|
|
|
<dt><a href="reference/celery.models.html#PeriodicTaskMeta.last_run_at">last_run_at (PeriodicTaskMeta attribute)</a></dt>
|
|
|
<dt><a href="reference/celery.timer.html#celery.timer.EventTimer.last_triggered">last_triggered (celery.timer.EventTimer attribute)</a></dt>
|
|
|
<dt><a href="reference/celery.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.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.worker.html#celery.worker.WorkController.logfile">logfile (celery.worker.WorkController attribute)</a></dt>
|
|
|
-<dt><a href="reference/celery.worker.html#celery.worker.WorkController.logger">logger (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>
|
|
|
+ <dt><a href="reference/celery.worker.html#celery.worker.WorkController.logger">(celery.worker.WorkController attribute)</a></dt>
|
|
|
+ </dl></dd>
|
|
|
<dt><a href="reference/celery.worker.html#celery.worker.WorkController.loglevel">loglevel (celery.worker.WorkController attribute)</a></dt>
|
|
|
</dl></td></tr></table>
|
|
|
|
|
|
@@ -339,7 +371,6 @@
|
|
|
<table width="100%" class="indextable"><tr><td width="33%" valign="top">
|
|
|
<dl>
|
|
|
|
|
|
-<dt><a href="reference/celery.bin.celeryd.html#celery.bin.celeryd.main">main() (in module celery.bin.celeryd)</a></dt>
|
|
|
<dt><a href="reference/celery.task.html#celery.task.TaskSet.map">map() (celery.task.TaskSet class method)</a></dt>
|
|
|
<dt><a href="reference/celery.task.html#celery.task.TaskSet.map_async">map_async() (celery.task.TaskSet class method)</a></dt>
|
|
|
<dt><a href="reference/celery.backends.base.html#celery.backends.base.BaseBackend.mark_as_done">mark_as_done() (celery.backends.base.BaseBackend method)</a></dt></dl></td><td width="33%" valign="top"><dl>
|
|
|
@@ -363,7 +394,10 @@
|
|
|
<dl>
|
|
|
|
|
|
<dt><a href="reference/celery.worker.html#celery.worker.TaskWrapper.on_failure">on_failure() (celery.worker.TaskWrapper method)</a></dt>
|
|
|
-<dt><a href="reference/celery.worker.html#celery.worker.TaskWrapper.on_success">on_success() (celery.worker.TaskWrapper method)</a></dt></dl></td><td width="33%" valign="top"><dl>
|
|
|
+<dt><a href="reference/celery.pool.html#celery.pool.TaskPool.on_ready">on_ready() (celery.pool.TaskPool method)</a></dt>
|
|
|
+<dt><a href="reference/celery.pool.html#celery.pool.TaskPool.on_return">on_return() (celery.pool.TaskPool method)</a></dt></dl></td><td width="33%" valign="top"><dl>
|
|
|
+<dt><a href="reference/celery.worker.html#celery.worker.TaskWrapper.on_success">on_success() (celery.worker.TaskWrapper method)</a></dt>
|
|
|
+<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>
|
|
|
|
|
|
<h2 id="P">P</h2>
|
|
|
@@ -375,12 +409,12 @@
|
|
|
<dt><a href="reference/celery.managers.html#celery.managers.PeriodicTaskManager">PeriodicTaskManager (class in celery.managers)</a></dt>
|
|
|
<dt><a href="reference/celery.models.html#PeriodicTaskMeta">PeriodicTaskMeta (built-in class)</a></dt>
|
|
|
<dt><a href="reference/celery.worker.html#celery.worker.PeriodicWorkController">PeriodicWorkController (class in celery.worker)</a></dt>
|
|
|
-<dt><a href="reference/celery.platform.html#celery.platform.PIDFile">PIDFile (class in celery.platform)</a></dt>
|
|
|
-<dt><a href="reference/celery.worker.html#celery.worker.WorkController.pool">pool (celery.worker.WorkController attribute)</a></dt></dl></td><td width="33%" valign="top"><dl>
|
|
|
-<dt><a href="reference/celery.datastructures.html#celery.datastructures.PositionQueue">PositionQueue (class in celery.datastructures)</a></dt>
|
|
|
+<dt><a href="reference/celery.worker.html#celery.worker.WorkController.pool">pool (celery.worker.WorkController attribute)</a></dt>
|
|
|
+<dt><a href="reference/celery.datastructures.html#celery.datastructures.PositionQueue">PositionQueue (class in celery.datastructures)</a></dt></dl></td><td width="33%" valign="top"><dl>
|
|
|
<dt><a href="reference/celery.datastructures.html#celery.datastructures.PositionQueue.UnfilledPosition">PositionQueue.UnfilledPosition (class in celery.datastructures)</a></dt>
|
|
|
<dt><a href="reference/celery.backends.base.html#celery.backends.base.BaseBackend.prepare_exception">prepare_exception() (celery.backends.base.BaseBackend method)</a></dt>
|
|
|
<dt><a href="reference/celery.backends.base.html#celery.backends.base.BaseBackend.prepare_result">prepare_result() (celery.backends.base.BaseBackend method)</a></dt>
|
|
|
+<dt><a href="reference/celery.backends.base.html#celery.backends.base.BaseBackend.process_cleanup">process_cleanup() (celery.backends.base.BaseBackend method)</a></dt>
|
|
|
<dt><a href="reference/celery.worker.html#celery.worker.WorkController.process_task">process_task() (celery.worker.WorkController method)</a></dt>
|
|
|
</dl></td></tr></table>
|
|
|
|
|
|
@@ -400,28 +434,29 @@
|
|
|
<dd><dl>
|
|
|
<dt><a href="reference/celery.result.html#celery.result.TaskSetResult.ready">(celery.result.TaskSetResult method)</a></dt>
|
|
|
</dl></dd>
|
|
|
+<dt><a href="reference/celery.pool.html#celery.pool.TaskPool.reap">reap() (celery.pool.TaskPool method)</a></dt>
|
|
|
<dt><a href="reference/celery.worker.html#celery.worker.WorkController.receive_message">receive_message() (celery.worker.WorkController method)</a></dt>
|
|
|
<dt><a href="reference/celery.registry.html#celery.registry.TaskRegistry.register">register() (celery.registry.TaskRegistry method)</a></dt>
|
|
|
<dt><a href="reference/celery.task.html#celery.task.TaskSet.remote_execute">remote_execute() (celery.task.TaskSet class method)</a></dt>
|
|
|
-<dt><a href="reference/celery.platform.html#celery.platform.PIDFile.remove">remove() (celery.platform.PIDFile method)</a></dt>
|
|
|
-<dt><a href="reference/celery.platform.html#celery.platform.remove_pidfile">remove_pidfile() (in module celery.platform)</a></dt>
|
|
|
<dt><a href="reference/celery.messaging.html#celery.messaging.TaskPublisher.requeue_task">requeue_task() (celery.messaging.TaskPublisher method)</a></dt>
|
|
|
<dt><a href="reference/celery.worker.html#celery.worker.WorkController.reset_connection">reset_connection() (celery.worker.WorkController method)</a></dt>
|
|
|
<dt><a href="reference/celery.result.html#celery.result.BaseAsyncResult.result">result (celery.result.BaseAsyncResult attribute)</a></dt>
|
|
|
<dd><dl>
|
|
|
<dt><a href="reference/celery.models.html#TaskMeta.result">(TaskMeta attribute)</a></dt>
|
|
|
- </dl></dd></dl></td><td width="33%" valign="top"><dl>
|
|
|
-<dt><a href="reference/celery.task.html#celery.task.AsynchronousMapTask.run">run() (celery.task.AsynchronousMapTask method)</a></dt>
|
|
|
+ </dl></dd>
|
|
|
+<dt><a href="reference/celery.pool.html#celery.pool.TaskPool.run">run() (celery.pool.TaskPool method)</a></dt>
|
|
|
<dd><dl>
|
|
|
+ <dt><a href="reference/celery.task.html#celery.task.AsynchronousMapTask.run">(celery.task.AsynchronousMapTask method)</a></dt>
|
|
|
<dt><a href="reference/celery.task.html#celery.task.DeleteExpiredTaskMetaTask.run">(celery.task.DeleteExpiredTaskMetaTask method)</a></dt>
|
|
|
<dt><a href="reference/celery.task.html#celery.task.ExecuteRemoteTask.run">(celery.task.ExecuteRemoteTask method)</a></dt>
|
|
|
<dt><a href="reference/celery.task.html#celery.task.Task.run">(celery.task.Task method)</a></dt>
|
|
|
<dt><a href="reference/celery.task.html#celery.task.TaskSet.run">(celery.task.TaskSet method)</a></dt>
|
|
|
<dt><a href="reference/celery.worker.html#celery.worker.PeriodicWorkController.run">(celery.worker.PeriodicWorkController method)</a></dt>
|
|
|
<dt><a href="reference/celery.worker.html#celery.worker.WorkController.run">(celery.worker.WorkController method)</a></dt>
|
|
|
- </dl></dd>
|
|
|
+ </dl></dd></dl></td><td width="33%" valign="top"><dl>
|
|
|
<dt><a href="reference/celery.task.html#celery.task.PeriodicTask.run_every">run_every (celery.task.PeriodicTask attribute)</a></dt>
|
|
|
<dt><a href="reference/celery.backends.database.html#celery.backends.database.Backend.run_periodic_tasks">run_periodic_tasks() (celery.backends.database.Backend method)</a></dt>
|
|
|
+<dt><a href="reference/celery.bin.celeryd.html#celery.bin.celeryd.run_worker">run_worker() (in module celery.bin.celeryd)</a></dt>
|
|
|
</dl></td></tr></table>
|
|
|
|
|
|
<h2 id="S">S</h2>
|
|
|
@@ -477,8 +512,9 @@
|
|
|
<dt><a href="reference/celery.messaging.html#celery.messaging.TaskConsumer">TaskConsumer (class in celery.messaging)</a></dt>
|
|
|
<dt><a href="reference/celery.managers.html#celery.managers.TaskManager">TaskManager (class in celery.managers)</a></dt>
|
|
|
<dt><a href="reference/celery.models.html#TaskMeta">TaskMeta (built-in class)</a></dt>
|
|
|
-<dt><a href="reference/celery.messaging.html#celery.messaging.TaskPublisher">TaskPublisher (class in celery.messaging)</a></dt>
|
|
|
-<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.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></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.html#celery.task.TaskSet">TaskSet (class in celery.task)</a></dt>
|
|
|
@@ -519,9 +555,9 @@
|
|
|
|
|
|
<dt><a href="reference/celery.result.html#celery.result.BaseAsyncResult.wait">wait() (celery.result.BaseAsyncResult method)</a></dt>
|
|
|
<dt><a href="reference/celery.backends.base.html#celery.backends.base.BaseBackend.wait_for">wait_for() (celery.backends.base.BaseBackend method)</a></dt>
|
|
|
-<dt><a href="reference/celery.result.html#celery.result.TaskSetResult.waiting">waiting() (celery.result.TaskSetResult method)</a></dt></dl></td><td width="33%" valign="top"><dl>
|
|
|
+<dt><a href="reference/celery.pool.html#celery.pool.TaskPool.wait_for_result">wait_for_result() (celery.pool.TaskPool method)</a></dt></dl></td><td width="33%" valign="top"><dl>
|
|
|
+<dt><a href="reference/celery.result.html#celery.result.TaskSetResult.waiting">waiting() (celery.result.TaskSetResult method)</a></dt>
|
|
|
<dt><a href="reference/celery.worker.html#celery.worker.WorkController">WorkController (class in celery.worker)</a></dt>
|
|
|
-<dt><a href="reference/celery.platform.html#celery.platform.PIDFile.write">write() (celery.platform.PIDFile method)</a></dt>
|
|
|
</dl></td></tr></table>
|
|
|
|
|
|
|
Ask Solem