You signed in with another tab or window. Reload to refresh your session.You signed out in another tab or window. Reload to refresh your session.You switched accounts on another tab or window. Reload to refresh your session.Dismiss alert
<ttclass="descname">connection</tt><aclass="headerlink" href="#celery.backends.amqp.AMQPBackend.connection" title="Permalink to this definition">¶</a></dt>
75
75
<dd></dd></dl>
76
76
77
+
<dlclass="method">
78
+
<dtid="celery.backends.amqp.AMQPBackend.consume">
79
+
<ttclass="descname">consume</tt><big>(</big><em>task_id</em>, <em>timeout=None</em><big>)</big><aclass="headerlink" href="#celery.backends.amqp.AMQPBackend.consume" title="Permalink to this definition">¶</a></dt>
<ttclass="descname">get_task_meta</tt><big>(</big><em>task_id</em>, <em>cache=True</em><big>)</big><aclass="headerlink" href="#celery.backends.amqp.AMQPBackend.get_task_meta" title="Permalink to this definition">¶</a></dt>
85
+
<dd></dd></dl>
86
+
87
+
<dlclass="method">
88
+
<dtid="celery.backends.amqp.AMQPBackend.poll">
89
+
<ttclass="descname">poll</tt><big>(</big><em>task_id</em><big>)</big><aclass="headerlink" href="#celery.backends.amqp.AMQPBackend.poll" title="Permalink to this definition">¶</a></dt>
<ttclass="descname">reload_task_result</tt><big>(</big><em>task_id</em><big>)</big><aclass="headerlink" href="#celery.backends.amqp.AMQPBackend.reload_task_result" title="Permalink to this definition">¶</a></dt>
<ttclass="descname">wait_for</tt><big>(</big><em>task_id</em>, <em>timeout=None</em><big>)</big><aclass="headerlink" href="#celery.backends.amqp.AMQPBackend.wait_for" title="Permalink to this definition">¶</a></dt>
123
+
<ttclass="descname">wait_for</tt><big>(</big><em>task_id</em>, <em>timeout=None</em>, <em>cache=True</em><big>)</big><aclass="headerlink" href="#celery.backends.amqp.AMQPBackend.wait_for" title="Permalink to this definition">¶</a></dt>
<ttclass="descclassname">BaseBackend.</tt><ttclass="descname">is_successful</tt><big>(</big><em>task_id</em><big>)</big><aclass="headerlink" href="#celery.backends.base.BaseBackend.is_successful" title="Permalink to this definition">¶</a></dt>
108
-
<dd><p>Returns <ttclass="xref docutils literal"><spanclass="pre">True</span></tt> if the task was successfully executed.</p>
<ttclass="descclassname">BaseBackend.</tt><ttclass="descname">mark_as_done</tt><big>(</big><em>task_id</em>, <em>result</em><big>)</big><aclass="headerlink" href="#celery.backends.base.BaseBackend.mark_as_done" title="Permalink to this definition">¶</a></dt>
<ttclass="descname">stop</tt><big>(</big><big>)</big><aclass="headerlink" href="#celery.concurrency.processes.TaskPool.stop" title="Permalink to this definition">¶</a></dt>
<ttclass="descname">terminate</tt><big>(</big><big>)</big><aclass="headerlink" href="#celery.concurrency.processes.TaskPool.terminate" title="Permalink to this definition">¶</a></dt>
<ttclass="descclassname">Pool.</tt><ttclass="descname">imap</tt><big>(</big><em>func</em>, <em>iterable</em>, <em>chunksize=1</em><big>)</big><aclass="headerlink" href="#celery.concurrency.processes.pool.Pool.imap" title="Permalink to this definition">¶</a></dt>
220
-
<dd><p>Equivalent of <cite>itertools.imap()</cite> – can be MUCH slower than <cite>Pool.map()</cite></p>
220
+
<dd><p>Equivalent of <cite>itertools.imap()</cite> – can be MUCH slower
<emclass="property">class </em><ttclass="descclassname">celery.log.</tt><ttclass="descname">ColourFormatter</tt><big>(</big><em>msg</em>, <em>use_colour=True</em><big>)</big><aclass="headerlink" href="#celery.log.ColourFormatter" title="Permalink to this definition">¶</a></dt>
60
+
<dtid="celery.log.ColorFormatter">
61
+
<emclass="property">class </em><ttclass="descclassname">celery.log.</tt><ttclass="descname">ColorFormatter</tt><big>(</big><em>msg</em>, <em>use_color=True</em><big>)</big><aclass="headerlink" href="#celery.log.ColorFormatter" title="Permalink to this definition">¶</a></dt>
62
62
<dd><dlclass="method">
63
-
<dtid="celery.log.ColourFormatter.format">
64
-
<ttclass="descname">format</tt><big>(</big><em>record</em><big>)</big><aclass="headerlink" href="#celery.log.ColourFormatter.format" title="Permalink to this definition">¶</a></dt>
63
+
<dtid="celery.log.ColorFormatter.format">
64
+
<ttclass="descname">format</tt><big>(</big><em>record</em><big>)</big><aclass="headerlink" href="#celery.log.ColorFormatter.format" title="Permalink to this definition">¶</a></dt>
<ttclass="descclassname">celery.log.</tt><ttclass="descname">setup_logger</tt><big>(</big><em>loglevel=30</em>, <em>logfile=None</em>, <em>format='</em><spanclass="optional">[</span>, <em>%(asctime)s: %(levelname)s/%(processName)s</em><spanclass="optional">]</span>, <em>%(message)s'</em>, <em>colourize=True</em>, <em>**kwargs</em><big>)</big><aclass="headerlink" href="#celery.log.setup_logger" title="Permalink to this definition">¶</a></dt>
184
+
<ttclass="descclassname">celery.log.</tt><ttclass="descname">setup_logger</tt><big>(</big><em>loglevel=30</em>, <em>logfile=None</em>, <em>format='</em><spanclass="optional">[</span>, <em>%(asctime)s: %(levelname)s/%(processName)s</em><spanclass="optional">]</span>, <em>%(message)s'</em>, <em>colorize=True</em>, <em>**kwargs</em><big>)</big><aclass="headerlink" href="#celery.log.setup_logger" title="Permalink to this definition">¶</a></dt>
185
185
<dd><p>Setup the <ttclass="docutils literal"><spanclass="pre">multiprocessing</span></tt> logger. If <ttclass="docutils literal"><spanclass="pre">logfile</span></tt> is not specified,
186
186
then <ttclass="docutils literal"><spanclass="pre">stderr</span></tt> is used.</p>
187
187
<p>Returns logger object.</p>
188
188
</dd></dl>
189
189
190
190
<dlclass="function">
191
191
<dtid="celery.log.setup_task_logger">
192
-
<ttclass="descclassname">celery.log.</tt><ttclass="descname">setup_task_logger</tt><big>(</big><em>loglevel=30</em>, <em>logfile=None</em>, <em>format='</em><spanclass="optional">[</span>, <em>%(asctime)s: %(levelname)s/%(processName)s</em><spanclass="optional">]</span><spanclass="optional">[</span>, <em>%(task_name)s(%(task_id)s)</em><spanclass="optional">]</span>, <em>%(message)s'</em>, <em>colourize=True</em>, <em>task_kwargs=None</em>, <em>**kwargs</em><big>)</big><aclass="headerlink" href="#celery.log.setup_task_logger" title="Permalink to this definition">¶</a></dt>
192
+
<ttclass="descclassname">celery.log.</tt><ttclass="descname">setup_task_logger</tt><big>(</big><em>loglevel=30</em>, <em>logfile=None</em>, <em>format='</em><spanclass="optional">[</span>, <em>%(asctime)s: %(levelname)s/%(processName)s</em><spanclass="optional">]</span><spanclass="optional">[</span>, <em>%(task_name)s(%(task_id)s)</em><spanclass="optional">]</span>, <em>%(message)s'</em>, <em>colorize=True</em>, <em>task_kwargs=None</em>, <em>**kwargs</em><big>)</big><aclass="headerlink" href="#celery.log.setup_task_logger" title="Permalink to this definition">¶</a></dt>
193
193
<dd><p>Setup the task logger. If <ttclass="docutils literal"><spanclass="pre">logfile</span></tt> is not specified, then
194
194
<ttclass="docutils literal"><spanclass="pre">stderr</span></tt> is used.</p>
<emclass="property">class </em><ttclass="descclassname">celery.routes.</tt><ttclass="descname">MapRoute</tt><big>(</big><em>map</em><big>)</big><aclass="headerlink" href="#celery.routes.MapRoute" title="Permalink to this definition">¶</a></dt>
61
-
<dd><dlclass="method">
61
+
<dd><p>Makes a router out of a <ttclass="xref py py-class docutils literal"><spanclass="pre">dict</span></tt>.</p>
62
+
<dlclass="method">
62
63
<dtid="celery.routes.MapRoute.route_for_task">
63
64
<ttclass="descname">route_for_task</tt><big>(</big><em>task</em>, <em>*args</em>, <em>**kwargs</em><big>)</big><aclass="headerlink" href="#celery.routes.MapRoute.route_for_task" title="Permalink to this definition">¶</a></dt>
<ttclass="descclassname">celery.routes.</tt><ttclass="descname">firstmatcher</tt><big>(</big><em>method</em><big>)</big><aclass="headerlink" href="#celery.routes.firstmatcher" title="Permalink to this definition">¶</a></dt>
76
-
<dd><p>With a list of instances, find the first instance that returns a
77
-
value for the given method.</p>
77
+
<dd><p>Returns a functions that with a list of instances,
78
+
finds the first instance that returns a value for the given method.</p>
0 commit comments