Autogenerated documentation for github.

genindex.html

@@ -45,7 +45,7 @@
 
    <h1 id="index">Index</h1>
 
-   <a href="#Symbols"><strong>Symbols</strong></a> | <a href="#A"><strong>A</strong></a> | <a href="#B"><strong>B</strong></a> | <a href="#C"><strong>C</strong></a> | <a href="#D"><strong>D</strong></a> | <a href="#E"><strong>E</strong></a> | <a href="#F"><strong>F</strong></a> | <a href="#G"><strong>G</strong></a> | <a href="#I"><strong>I</strong></a> | <a href="#J"><strong>J</strong></a> | <a href="#K"><strong>K</strong></a> | <a href="#L"><strong>L</strong></a> | <a href="#M"><strong>M</strong></a> | <a href="#N"><strong>N</strong></a> | <a href="#O"><strong>O</strong></a> | <a href="#P"><strong>P</strong></a> | <a href="#Q"><strong>Q</strong></a> | <a href="#R"><strong>R</strong></a> | <a href="#S"><strong>S</strong></a> | <a href="#T"><strong>T</strong></a> | <a href="#U"><strong>U</strong></a> | <a href="#W"><strong>W</strong></a> 
+   <a href="#Symbols"><strong>Symbols</strong></a> | <a href="#A"><strong>A</strong></a> | <a href="#B"><strong>B</strong></a> | <a href="#C"><strong>C</strong></a> | <a href="#D"><strong>D</strong></a> | <a href="#E"><strong>E</strong></a> | <a href="#F"><strong>F</strong></a> | <a href="#G"><strong>G</strong></a> | <a href="#I"><strong>I</strong></a> | <a href="#J"><strong>J</strong></a> | <a href="#K"><strong>K</strong></a> | <a href="#L"><strong>L</strong></a> | <a href="#M"><strong>M</strong></a> | <a href="#N"><strong>N</strong></a> | <a href="#O"><strong>O</strong></a> | <a href="#P"><strong>P</strong></a> | <a href="#R"><strong>R</strong></a> | <a href="#S"><strong>S</strong></a> | <a href="#T"><strong>T</strong></a> | <a href="#U"><strong>U</strong></a> | <a href="#W"><strong>W</strong></a> 
 
    <hr />
 
@@ -77,11 +77,11 @@
 <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>
+  </dl></dd></dl></td><td width="33%" valign="top"><dl>
 <dt>-f, --logfile</dt>
   <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>
+  </dl></dd>
 <dt>-g, --gid</dt>
   <dd><dl>
     <dt><a href="reference/celery.bin.celeryd.html#cmdoption-celeryd-g">celeryd command line option</a></dt>
@@ -98,10 +98,6 @@
   <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>
-  </dl></dd>
 </dl></td></tr></table>
 
 <h2 id="A">A</h2>
@@ -184,7 +180,6 @@
     <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></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>
@@ -229,9 +224,6 @@
 <dl>
 
 <dt><a href="reference/celery.log.html#celery.log.emergency_error">emergency_error() (in module celery.log)</a></dt>
-<dt><a href="reference/celery.worker.html#celery.worker.WorkController.empty_msg_emit_every">empty_msg_emit_every (celery.worker.WorkController attribute)</a></dt>
-<dt><a href="reference/celery.conf.html#celery.conf.EMPTY_MSG_EMIT_EVERY">EMPTY_MSG_EMIT_EVERY (in module celery.conf)</a>, <a href="reference/celery.conf.html#celery.conf.EMPTY_MSG_EMIT_EVERY">[1]</a></dt>
-<dt><a href="reference/celery.worker.html#celery.worker.EmptyQueue">EmptyQueue</a></dt>
 <dt><a href="reference/celery.messaging.html#celery.messaging.TaskPublisher.encoder">encoder() (celery.messaging.TaskPublisher method)</a></dt>
 <dt><a href="reference/celery.timer.html#celery.timer.EventTimer.event">event (celery.timer.EventTimer attribute)</a></dt>
 <dt><a href="reference/celery.timer.html#celery.timer.EventTimer">EventTimer (class in celery.timer)</a></dt>
@@ -251,7 +243,6 @@
 <dt><a href="reference/celery.backends.base.html#celery.backends.base.BaseBackend.exception_to_python">exception_to_python() (celery.backends.base.BaseBackend method)</a></dt>
 <dt><a href="reference/celery.datastructures.html#celery.datastructures.ExceptionInfo">ExceptionInfo (class in celery.datastructures)</a></dt>
 <dt><a href="reference/celery.worker.html#celery.worker.TaskWrapper.execute">execute() (celery.worker.TaskWrapper method)</a></dt>
-<dt><a href="reference/celery.worker.html#celery.worker.WorkController.execute_next_task">execute_next_task() (celery.worker.WorkController method)</a></dt>
 <dt><a href="reference/celery.task.html#celery.task.execute_remote">execute_remote() (in module celery.task)</a></dt>
 <dt><a href="reference/celery.worker.html#celery.worker.TaskWrapper.execute_using_pool">execute_using_pool() (celery.worker.TaskWrapper method)</a></dt>
 <dt><a href="reference/celery.task.html#celery.task.ExecuteRemoteTask">ExecuteRemoteTask (class in celery.task)</a></dt>
@@ -418,14 +409,6 @@
 <dt><a href="reference/celery.worker.html#celery.worker.WorkController.process_task">process_task() (celery.worker.WorkController method)</a></dt>
 </dl></td></tr></table>
 
-<h2 id="Q">Q</h2>
-<table width="100%" class="indextable"><tr><td width="33%" valign="top">
-<dl>
-
-<dt><a href="reference/celery.worker.html#celery.worker.WorkController.queue_wakeup_after">queue_wakeup_after (celery.worker.WorkController attribute)</a></dt>
-<dt><a href="reference/celery.conf.html#celery.conf.QUEUE_WAKEUP_AFTER">QUEUE_WAKEUP_AFTER (in module celery.conf)</a>, <a href="reference/celery.conf.html#celery.conf.QUEUE_WAKEUP_AFTER">[1]</a></dt></dl></td><td width="33%" valign="top"><dl>
-</dl></td></tr></table>
-
 <h2 id="R">R</h2>
 <table width="100%" class="indextable"><tr><td width="33%" valign="top">
 <dl>
@@ -435,7 +418,6 @@
     <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.messaging.html#celery.messaging.TaskPublisher.requeue_task">requeue_task() (celery.messaging.TaskPublisher method)</a></dt>
@@ -463,7 +445,6 @@
 <table width="100%" class="indextable"><tr><td width="33%" valign="top">
 <dl>
 
-<dt><a href="reference/celery.worker.html#celery.worker.WorkController.schedule_retry_tasks">schedule_retry_tasks() (celery.worker.WorkController method)</a></dt>
 <dt><a href="reference/celery.conf.html#celery.conf.SEND_CELERY_TASK_ERROR_EMAILS">SEND_CELERY_TASK_ERROR_EMAILS (in module celery.conf)</a></dt>
 <dt><a href="reference/celery.log.html#celery.log.setup_logger">setup_logger() (in module celery.log)</a></dt>
 <dt><a href="reference/celery.result.html#celery.result.BaseAsyncResult.status">status (celery.result.BaseAsyncResult attribute)</a></dt>

index.html

@@ -68,6 +68,11 @@
 <li class="toctree-l3"><a class="reference external" href="introduction.html#periodic-tasks">Periodic Tasks</a></li>
 </ul>
 </li>
+<li class="toctree-l2"><a class="reference external" href="introduction.html#getting-help">Getting Help</a><ul>
+<li class="toctree-l3"><a class="reference external" href="introduction.html#mailing-list">Mailing list</a></li>
+<li class="toctree-l3"><a class="reference external" href="introduction.html#irc">IRC</a></li>
+</ul>
+</li>
 <li class="toctree-l2"><a class="reference external" href="introduction.html#bug-tracker">Bug tracker</a></li>
 <li class="toctree-l2"><a class="reference external" href="introduction.html#contributing">Contributing</a></li>
 <li class="toctree-l2"><a class="reference external" href="introduction.html#license">License</a></li>

introduction.html

@@ -286,6 +286,19 @@ Here&#8217;s an example of a periodic task:</p>
 really make sense.</p>
 </div>
 </div>
+<div class="section" id="getting-help">
+<h2>Getting Help<a class="headerlink" href="#getting-help" title="Permalink to this headline">¶</a></h2>
+<div class="section" id="mailing-list">
+<h3>Mailing list<a class="headerlink" href="#mailing-list" title="Permalink to this headline">¶</a></h3>
+<p>Join the <a href="#id2"><span class="problematic" id="id3">`celery-users`_</span></a> mailing list for discussion about using and
+the development of celery.</p>
+</div>
+<div class="section" id="irc">
+<h3>IRC<a class="headerlink" href="#irc" title="Permalink to this headline">¶</a></h3>
+<p>Come chat with us on IRC. The <a class="reference external" href="irc://irc.freenode.net/celery">#celery</a> channel is located at the <a class="reference external" href="http://freenode.net">Freenode</a>
+network.</p>
+</div>
+</div>
 <div class="section" id="bug-tracker">
 <h2>Bug tracker<a class="headerlink" href="#bug-tracker" title="Permalink to this headline">¶</a></h2>
 <p>If you have any suggestions, bug reports or annoyances please report them
@@ -319,6 +332,7 @@ file in the top distribution directory for the full license text.</p>
 <li class="toctree-l2"><a class="reference external" href="#api-reference-documentation">API Reference Documentation</a></li>
 <li class="toctree-l2"><a class="reference external" href="#installation">Installation</a></li>
 <li class="toctree-l2"><a class="reference external" href="#usage">Usage</a></li>
+<li class="toctree-l2"><a class="reference external" href="#getting-help">Getting Help</a></li>
 <li class="toctree-l2"><a class="reference external" href="#bug-tracker">Bug tracker</a></li>
 <li class="toctree-l2"><a class="reference external" href="#contributing">Contributing</a></li>
 <li class="toctree-l2"><a class="reference external" href="#license">License</a></li>

objects.inv

@@ -43,7 +43,7 @@ celery.datastructures.PositionQueue.full method reference/celery.datastructures.
 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.worker.EmptyQueue exception reference/celery.worker.html
+celery.worker.UnknownTask exception 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
@@ -75,10 +75,8 @@ celery.result.BaseAsyncResult.successful method reference/celery.result.html
 celery.conf.LOG_FORMAT data reference/celery.conf.html
 celery.backends.database.Backend.store_result method reference/celery.backends.database.html
 celery.task.TaskSet.map_async classmethod reference/celery.task.html
-celery.worker.WorkController.receive_message method reference/celery.worker.html
-celery.worker.WorkController.schedule_retry_tasks method reference/celery.worker.html
 PeriodicTaskMeta.task attribute reference/celery.models.html
-celery.conf.EMPTY_MSG_EMIT_EVERY data reference/celery.conf.html
+celery.worker.WorkController.process_task method reference/celery.worker.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.add method reference/celery.pool.html
@@ -106,7 +104,6 @@ celery.task.TaskSet.remote_execute classmethod reference/celery.task.html
 celery.backends.tyrant.Backend.get_status method reference/celery.backends.tyrant.html
 celery.registry.TaskRegistry.NotRegistered exception reference/celery.registry.html
 celery.datastructures.PositionQueue.length attribute reference/celery.datastructures.html
-celery.worker.WorkController.process_task method reference/celery.worker.html
 celery.datastructures.PositionQueue class reference/celery.datastructures.html
 celery.messaging.TaskPublisher.delay_task method reference/celery.messaging.html
 celery.backends.base.BaseBackend.prepare_result method reference/celery.backends.base.html
@@ -140,7 +137,6 @@ celery.conf.DAEMON_LOG_LEVEL data reference/celery.conf.html
 celery.backends.database.Backend class reference/celery.backends.database.html
 celery.result.BaseAsyncResult.status attribute reference/celery.result.html
 celery.worker.TaskWrapper.kwargs attribute reference/celery.worker.html
-celery.conf.QUEUE_WAKEUP_AFTER data reference/celery.conf.html
 celery.backends.database.Backend.get_result method reference/celery.backends.database.html
 celery.worker.TaskWrapper.on_success method reference/celery.worker.html
 celery.backends.get_backend_cls function reference/celery.backends.html
@@ -163,7 +159,6 @@ PeriodicTaskMeta.name attribute reference/celery.models.html
 celery.backends.base.BaseBackend.is_done method reference/celery.backends.base.html
 celery.backends.tyrant.Backend.is_done method reference/celery.backends.tyrant.html
 celery.worker.TaskWrapper.extend_with_default_kwargs method reference/celery.worker.html
-celery.worker.WorkController.execute_next_task method reference/celery.worker.html
 celery.result.BaseAsyncResult.task_id attribute reference/celery.result.html
 celery.backends.cache.Backend.is_done method reference/celery.backends.cache.html
 celery.task.Task.get_consumer method reference/celery.task.html
@@ -172,14 +167,11 @@ celery.messaging.TaskPublisher.delay_task_in_set method reference/celery.messagi
 celery.backends.base.BaseBackend.UnpickleableExceptionWrapper exception reference/celery.backends.base.html
 celery.task.AsynchronousMapTask.run method reference/celery.task.html
 celery.worker.PeriodicWorkController.run method reference/celery.worker.html
-celery.worker.WorkController.empty_msg_emit_every attribute reference/celery.worker.html
-celery.worker.UnknownTask exception reference/celery.worker.html
 celery.worker.TaskWrapper.task_id attribute reference/celery.worker.html
 celery.managers.PeriodicTaskManager.get_waiting_tasks method reference/celery.managers.html
 celery.backends.base.BaseBackend.mark_as_failure method reference/celery.backends.base.html
 celery.worker.WorkController.loglevel attribute reference/celery.worker.html
 celery.task.TaskSet.join method reference/celery.task.html
-celery.worker.WorkController.queue_wakeup_after attribute reference/celery.worker.html
 celery.registry.TaskRegistry.get_all_regular method reference/celery.registry.html
 celery.worker.WorkController.run method reference/celery.worker.html
 celery.registry.TaskRegistry class reference/celery.registry.html

reference/celery.bin.celeryd.html

@@ -73,13 +73,6 @@
 <tt class="descname">-p</tt><tt class="descclassname"></tt><tt class="descclassname">, </tt><tt class="descname">--pidfile</tt><tt class="descclassname"></tt><a class="headerlink" href="#cmdoption-celeryd-p" title="Permalink to this definition">¶</a></dt>
 <dd>Path to pidfile.</dd></dl>
 
-<dl class="cmdoption">
-<dt id="cmdoption-celeryd-w">
-<tt class="descname">-w</tt><tt class="descclassname"></tt><tt class="descclassname">, </tt><tt class="descname">--wakeup-after</tt><tt class="descclassname"></tt><a class="headerlink" href="#cmdoption-celeryd-w" title="Permalink to this definition">¶</a></dt>
-<dd>If the queue is empty, this is the time <em>in seconds</em> the
-daemon sleeps until it wakes up to check if there&#8217;s any
-new messages on the queue.</dd></dl>
-
 <dl class="cmdoption">
 <dt id="cmdoption-celeryd-d">
 <tt class="descname">-d</tt><tt class="descclassname"></tt><tt class="descclassname">, </tt><tt class="descname">--detach</tt><tt class="descclassname"></tt><tt class="descclassname">, </tt><tt class="descname">--daemon</tt><tt class="descclassname"></tt><a class="headerlink" href="#cmdoption-celeryd-d" title="Permalink to this definition">¶</a></dt>
@@ -136,7 +129,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=10</em>, <em>daemon=False</em>, <em>loglevel=20</em>, <em>logfile='celeryd.log'</em>, <em>discard=False</em>, <em>pidfile='celeryd.pid'</em>, <em>queue_wakeup_after=0.10000000000000001</em>, <em>umask=0</em>, <em>uid=None</em>, <em>gid=None</em>, <em>working_directory=None</em>, <em>chroot=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=10</em>, <em>daemon=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>working_directory=None</em>, <em>chroot=None</em>, <em>**kwargs</em><big>)</big><a class="headerlink" href="#celery.bin.celeryd.run_worker" title="Permalink to this definition">¶</a></dt>
 <dd>Run the celery daemon.</dd></dl>
 
 </div>

reference/celery.conf.html

@@ -133,17 +133,15 @@ for more information.</dd></dl>
 <dt>
 <tt class="descclassname">celery.conf.</tt><tt class="descname">DAEMON_LOG_LEVEL</tt></dt>
 <dd><dl class="data">
-<dt id="celery.conf.QUEUE_WAKEUP_AFTER">
-<tt class="descclassname">celery.conf.</tt><tt class="descname">QUEUE_WAKEUP_AFTER</tt><a class="headerlink" href="#celery.conf.QUEUE_WAKEUP_AFTER" title="Permalink to this definition">¶</a></dt>
-<dd>The time (in seconds) the celery worker should sleep when there&#8217;s
-no messages left on the queue. After the time is slept, the worker
-wakes up and checks the queue again.</dd></dl>
+<dt id="celery.conf.DAEMON_PID_FILE">
+<tt class="descclassname">celery.conf.</tt><tt class="descname">DAEMON_PID_FILE</tt><a class="headerlink" href="#celery.conf.DAEMON_PID_FILE" title="Permalink to this definition">¶</a></dt>
+<dd>Full path to the daemon pidfile.</dd></dl>
 
 </dd></dl>
 
 <dl class="data">
-<dt id="celery.conf.DAEMON_PID_FILE">
-<tt class="descclassname">celery.conf.</tt><tt class="descname">DAEMON_PID_FILE</tt><a class="headerlink" href="#celery.conf.DAEMON_PID_FILE" title="Permalink to this definition">¶</a></dt>
+<dt>
+<tt class="descclassname">celery.conf.</tt><tt class="descname">DAEMON_PID_FILE</tt></dt>
 <dd><dl class="data">
 <dt>
 <tt class="descclassname">celery.conf.</tt><tt class="descname">DAEMON_CONCURRENCY</tt></dt>
@@ -161,16 +159,6 @@ wakes up and checks the queue again.</dd></dl>
 
 </dd></dl>
 
-<dl class="data">
-<dt id="celery.conf.EMPTY_MSG_EMIT_EVERY">
-<tt class="descclassname">celery.conf.</tt><tt class="descname">EMPTY_MSG_EMIT_EVERY</tt><a class="headerlink" href="#celery.conf.EMPTY_MSG_EMIT_EVERY" title="Permalink to this definition">¶</a></dt>
-<dd><dl class="data">
-<dt>
-<tt class="descclassname">celery.conf.</tt><tt class="descname">DAEMON_PID_FILE</tt></dt>
-<dd>Full path to the daemon pidfile.</dd></dl>
-
-</dd></dl>
-
 <dl class="data">
 <dt id="celery.conf.LOG_FORMAT">
 <tt class="descclassname">celery.conf.</tt><tt class="descname">LOG_FORMAT</tt><a class="headerlink" href="#celery.conf.LOG_FORMAT" title="Permalink to this definition">¶</a></dt>
@@ -192,18 +180,6 @@ Default is <tt class="docutils literal"><span class="pre">[%(asctime)s:</span> <
 
 </dd></dl>
 
-<dl class="data">
-<dt>
-<tt class="descclassname">celery.conf.</tt><tt class="descname">QUEUE_WAKEUP_AFTER</tt></dt>
-<dd><dl class="data">
-<dt>
-<tt class="descclassname">celery.conf.</tt><tt class="descname">EMPTY_MSG_EMIT_EVERY</tt></dt>
-<dd>How often the celery daemon should write a log message saying there are no
-messages in the queue. If this is <tt class="xref docutils literal"><span class="pre">None</span></tt> or <tt class="docutils literal"><span class="pre">0</span></tt>, it will never print
-this message.</dd></dl>
-
-</dd></dl>
-
 </div>
 
 

reference/celery.worker.html

@@ -52,12 +52,6 @@
   <div class="section" id="module-celery.worker">
 <h1>Multiprocessing Worker - celery.worker<a class="headerlink" href="#module-celery.worker" title="Permalink to this headline">¶</a></h1>
 <p>celery.worker</p>
-<dl class="exception">
-<dt id="celery.worker.EmptyQueue">
-<em class="property">
-exception </em><tt class="descclassname">celery.worker.</tt><tt class="descname">EmptyQueue</tt><a class="headerlink" href="#celery.worker.EmptyQueue" title="Permalink to this definition">¶</a></dt>
-<dd>The message queue is currently empty.</dd></dl>
-
 <dl class="class">
 <dt id="celery.worker.PeriodicWorkController">
 <em class="property">
@@ -210,7 +204,7 @@ ignored.</dd></dl>
 <dl class="class">
 <dt id="celery.worker.WorkController">
 <em class="property">
-class </em><tt class="descclassname">celery.worker.</tt><tt class="descname">WorkController</tt><big>(</big><em>concurrency=None</em>, <em>logfile=None</em>, <em>loglevel=None</em>, <em>queue_wakeup_after=None</em>, <em>is_detached=False</em><big>)</big><a class="headerlink" href="#celery.worker.WorkController" title="Permalink to this definition">¶</a></dt>
+class </em><tt class="descclassname">celery.worker.</tt><tt class="descname">WorkController</tt><big>(</big><em>concurrency=None</em>, <em>logfile=None</em>, <em>loglevel=None</em>, <em>is_detached=False</em><big>)</big><a class="headerlink" href="#celery.worker.WorkController" title="Permalink to this definition">¶</a></dt>
 <dd><p>Executes tasks waiting in the task queue.</p>
 <table class="docutils field-list" frame="void" rules="none">
 <col class="field-name" />
@@ -220,7 +214,6 @@ class </em><tt class="descclassname">celery.worker.</tt><tt class="descname">Wor
 <li><em>concurrency</em> &#8211; see <a title="celery.worker.WorkController.concurrency" class="reference internal" href="#celery.worker.WorkController.concurrency"><tt class="xref docutils literal"><span class="pre">concurrency</span></tt></a>.</li>
 <li><em>logfile</em> &#8211; see <a title="celery.worker.WorkController.logfile" class="reference internal" href="#celery.worker.WorkController.logfile"><tt class="xref docutils literal"><span class="pre">logfile</span></tt></a>.</li>
 <li><em>loglevel</em> &#8211; see <a title="celery.worker.WorkController.loglevel" class="reference internal" href="#celery.worker.WorkController.loglevel"><tt class="xref docutils literal"><span class="pre">loglevel</span></tt></a>.</li>
-<li><em>queue_wakeup_after</em> &#8211; see <a title="celery.worker.WorkController.queue_wakeup_after" class="reference internal" href="#celery.worker.WorkController.queue_wakeup_after"><tt class="xref docutils literal"><span class="pre">queue_wakeup_after</span></tt></a>.</li>
 </ul>
 </td>
 </tr>
@@ -243,20 +236,6 @@ class </em><tt class="descclassname">celery.worker.</tt><tt class="descname">Wor
 <dd>The logfile used, if no logfile is specified it uses <tt class="docutils literal"><span class="pre">stderr</span></tt>
 (default: <a title="celery.conf.DAEMON_LOG_FILE" class="reference external" href="celery.conf.html#celery.conf.DAEMON_LOG_FILE"><tt class="xref docutils literal"><span class="pre">celery.conf.DAEMON_LOG_FILE</span></tt></a>).</dd></dl>
 
-<dl class="attribute">
-<dt id="celery.worker.WorkController.queue_wakeup_after">
-<tt class="descname">queue_wakeup_after</tt><a class="headerlink" href="#celery.worker.WorkController.queue_wakeup_after" title="Permalink to this definition">¶</a></dt>
-<dd>The time it takes for the daemon to wake up after the queue is empty,
-so it can check for more work
-(default: <a title="celery.conf.QUEUE_WAKEUP_AFTER" class="reference external" href="celery.conf.html#celery.conf.QUEUE_WAKEUP_AFTER"><tt class="xref docutils literal"><span class="pre">celery.conf.QUEUE_WAKEUP_AFTER</span></tt></a>).</dd></dl>
-
-<dl class="attribute">
-<dt id="celery.worker.WorkController.empty_msg_emit_every">
-<tt class="descname">empty_msg_emit_every</tt><a class="headerlink" href="#celery.worker.WorkController.empty_msg_emit_every" title="Permalink to this definition">¶</a></dt>
-<dd>How often the daemon emits the <tt class="docutils literal"><span class="pre">&quot;Waiting</span> <span class="pre">for</span> <span class="pre">queue...&quot;</span></tt> message.
-If this is <tt class="xref docutils literal"><span class="pre">None</span></tt>, the message will never be logged.
-(default: <a title="celery.conf.EMPTY_MSG_EMIT_EVERY" class="reference external" href="celery.conf.html#celery.conf.EMPTY_MSG_EMIT_EVERY"><tt class="xref docutils literal"><span class="pre">celery.conf.EMPTY_MSG_EMIT_EVERY</span></tt></a>)</dd></dl>
-
 <dl class="attribute">
 <dt id="celery.worker.WorkController.logger">
 <tt class="descname">logger</tt><a class="headerlink" href="#celery.worker.WorkController.logger" title="Permalink to this definition">¶</a></dt>
@@ -278,37 +257,11 @@ If this is <tt class="xref docutils literal"><span class="pre">None</span></tt>,
 <dd>Diagnose the AMQP connection, and reset connection if
 necessary.</dd></dl>
 
-<dl class="method">
-<dt id="celery.worker.WorkController.execute_next_task">
-<tt class="descname">execute_next_task</tt><big>(</big><big>)</big><a class="headerlink" href="#celery.worker.WorkController.execute_next_task" title="Permalink to this definition">¶</a></dt>
-<dd><p>Execute the next task on the queue using the multiprocessing pool.</p>
-<p>Catches all exceptions and logs them with level
-<tt class="xref docutils literal"><span class="pre">logging.CRITICAL</span></tt>.</p>
-<p>Raises <a title="celery.worker.EmptyQueue" class="reference internal" href="#celery.worker.EmptyQueue"><tt class="xref docutils literal"><span class="pre">EmptyQueue</span></tt></a> exception if there is no message
-waiting on the queue.</p>
-</dd></dl>
-
 <dl class="method">
 <dt id="celery.worker.WorkController.process_task">
 <tt class="descname">process_task</tt><big>(</big><em>message</em><big>)</big><a class="headerlink" href="#celery.worker.WorkController.process_task" title="Permalink to this definition">¶</a></dt>
 <dd>Process task message by passing it to the pool of workers.</dd></dl>
 
-<dl class="method">
-<dt id="celery.worker.WorkController.receive_message">
-<tt class="descname">receive_message</tt><big>(</big><big>)</big><a class="headerlink" href="#celery.worker.WorkController.receive_message" title="Permalink to this definition">¶</a></dt>
-<dd><p>Receive the next message from the message broker.</p>
-<p>Tries to reset the AMQP connection if not available.
-Returns <tt class="xref docutils literal"><span class="pre">None</span></tt> if no message is waiting on the queue.</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"><tt class="xref docutils literal"><span class="pre">carrot.messaging.Message</span></tt> instance.</td>
-</tr>
-</tbody>
-</table>
-</dd></dl>
-
 <dl class="method">
 <dt id="celery.worker.WorkController.reset_connection">
 <tt class="descname">reset_connection</tt><big>(</big><big>)</big><a class="headerlink" href="#celery.worker.WorkController.reset_connection" title="Permalink to this definition">¶</a></dt>
@@ -322,11 +275,6 @@ Returns <tt class="xref docutils literal"><span class="pre">None</span></tt> if
 <tt class="descname">run</tt><big>(</big><big>)</big><a class="headerlink" href="#celery.worker.WorkController.run" title="Permalink to this definition">¶</a></dt>
 <dd>Starts the workers main loop.</dd></dl>
 
-<dl class="method">
-<dt id="celery.worker.WorkController.schedule_retry_tasks">
-<tt class="descname">schedule_retry_tasks</tt><big>(</big><big>)</big><a class="headerlink" href="#celery.worker.WorkController.schedule_retry_tasks" title="Permalink to this definition">¶</a></dt>
-<dd>Reschedule all requeued tasks waiting for retry.</dd></dl>
-
 </dd></dl>
 
 <dl class="function">

sources/introduction.txt

@@ -277,6 +277,24 @@ Here's an example of a periodic task:
 **Note:** Periodic tasks does not support arguments, as this doesn't
 really make sense.
 
+Getting Help
+============
+
+Mailing list
+------------
+
+Join the `celery-users`_ mailing list for discussion about using and
+the development of celery.
+
+IRC
+---
+
+Come chat with us on IRC. The `#celery`_ channel is located at the `Freenode`_
+network.
+
+.. _`#celery`: irc://irc.freenode.net/celery
+.. _`Freenode`: http://freenode.net
+
 
 Bug tracker
 ===========