Offset 1, 5 lines modified | Offset 1, 5 lines modified | ||
1 | ·3f3c97c568a4b73fa4dd1e6676b21cd8·33568·python·optional·python-celery-common_4.2.1-3_all.deb | 1 | ·3f3c97c568a4b73fa4dd1e6676b21cd8·33568·python·optional·python-celery-common_4.2.1-3_all.deb |
2 | · | 2 | ·38b1a1db5c5eff083cc1b21a9c26b789·1723756·doc·optional·python-celery-doc_4.2.1-3_all.deb |
3 | ·0a8519b966f4a742963abc0605babfeb·281304·python·optional·python-celery_4.2.1-3_all.deb | 3 | ·0a8519b966f4a742963abc0605babfeb·281304·python·optional·python-celery_4.2.1-3_all.deb |
4 | ·431f46b0f41f86665bde9319b7f29f82·281416·python·optional·python3-celery_4.2.1-3_all.deb | 4 | ·431f46b0f41f86665bde9319b7f29f82·281416·python·optional·python3-celery_4.2.1-3_all.deb |
Offset 1, 3 lines modified | Offset 1, 3 lines modified | ||
1 | -rw-r--r--···0········0········0········4·2019-03-07·21:14:11.000000·debian-binary | 1 | -rw-r--r--···0········0········0········4·2019-03-07·21:14:11.000000·debian-binary |
2 | -rw-r--r--···0········0········0····156 | 2 | -rw-r--r--···0········0········0····15656·2019-03-07·21:14:11.000000·control.tar.xz |
3 | -rw-r--r--···0········0········0··1707 | 3 | -rw-r--r--···0········0········0··1707908·2019-03-07·21:14:11.000000·data.tar.xz |
Offset 104, 15 lines modified | Offset 104, 15 lines modified | ||
104 | <code·class="descname">state</code><a·class="headerlink"·href="#celery.app.trace.TraceInfo.state"·title="Permalink·to·this·definition">¶</a></dt> | 104 | <code·class="descname">state</code><a·class="headerlink"·href="#celery.app.trace.TraceInfo.state"·title="Permalink·to·this·definition">¶</a></dt> |
105 | <dd></dd></dl> | 105 | <dd></dd></dl> |
106 | </dd></dl> | 106 | </dd></dl> |
107 | <dl·class="function"> | 107 | <dl·class="function"> |
108 | <dt·id="celery.app.trace.build_tracer"> | 108 | <dt·id="celery.app.trace.build_tracer"> |
109 | <code·class="descclassname">celery.app.trace.</code><code·class="descname">build_tracer</code><span·class="sig-paren">(</span><em>name</em>,·<em>task</em>,·<em>loader=None</em>,·<em>hostname=None</em>,·<em>store_errors=True</em>,·<em>Info=<class·'celery.app.trace.TraceInfo'></em>,·<em>eager=False</em>,·<em>propagate=False</em>,·<em>app=None</em>,·<em>monotonic=<built-in·function·monotonic></em>,·<em>trace_ok_t=<class·'celery.app.trace.trace_ok_t'></em>,·<em>IGNORE_STATES=frozenset({'RE | 109 | <code·class="descclassname">celery.app.trace.</code><code·class="descname">build_tracer</code><span·class="sig-paren">(</span><em>name</em>,·<em>task</em>,·<em>loader=None</em>,·<em>hostname=None</em>,·<em>store_errors=True</em>,·<em>Info=<class·'celery.app.trace.TraceInfo'></em>,·<em>eager=False</em>,·<em>propagate=False</em>,·<em>app=None</em>,·<em>monotonic=<built-in·function·monotonic></em>,·<em>trace_ok_t=<class·'celery.app.trace.trace_ok_t'></em>,·<em>IGNORE_STATES=frozenset({'RETRY'</em>,·<em>'IGNORED'</em>,·<em>'REJECTED'})</em><span·class="sig-paren">)</span><a·class="reference·internal"·href="../../_modules/celery/app/trace.html#build_tracer"><span·class="viewcode-link">[source]</span></a><a·class="headerlink"·href="#celery.app.trace.build_tracer"·title="Permalink·to·this·definition">¶</a></dt> |
110 | <dd><p>Return·a·function·that·traces·task·execution.</p> | 110 | <dd><p>Return·a·function·that·traces·task·execution.</p> |
111 | <p>Catches·all·exceptions·and·updates·result·backend·with·the | 111 | <p>Catches·all·exceptions·and·updates·result·backend·with·the |
112 | state·and·result.</p> | 112 | state·and·result.</p> |
113 | <p>If·the·call·was·successful,·it·saves·the·result·to·the·task·result | 113 | <p>If·the·call·was·successful,·it·saves·the·result·to·the·task·result |
114 | backend,·and·sets·the·task·status·to·<cite>“SUCCESS”</cite>.</p> | 114 | backend,·and·sets·the·task·status·to·<cite>“SUCCESS”</cite>.</p> |
115 | <p>If·the·call·raises·<a·class="reference·internal"·href="../../reference/celery.exceptions.html#celery.exceptions.Retry"·title="celery.exceptions.Retry"><code·class="xref·py·py-exc·docutils·literal·notranslate"><span·class="pre">Retry</span></code></a>,·it·extracts | 115 | <p>If·the·call·raises·<a·class="reference·internal"·href="../../reference/celery.exceptions.html#celery.exceptions.Retry"·title="celery.exceptions.Retry"><code·class="xref·py·py-exc·docutils·literal·notranslate"><span·class="pre">Retry</span></code></a>,·it·extracts |
116 | the·original·exception,·uses·that·as·the·result·and·sets·the·task·state | 116 | the·original·exception,·uses·that·as·the·result·and·sets·the·task·state |
Offset 898, 15 lines modified | Offset 898, 15 lines modified | ||
898 | <dl·class="method"> | 898 | <dl·class="method"> |
899 | <dt·id="celery.backends.amqp.AMQPBackend.drain_events"> | 899 | <dt·id="celery.backends.amqp.AMQPBackend.drain_events"> |
900 | <code·class="descname">drain_events</code><span·class="sig-paren">(</span><em>connection</em>,·<em>consumer</em>,·<em>timeout=None</em>,·<em>on_interval=None</em>,·<em>now=<built-in·function·monotonic></em>,·<em>wait=None</em><span·class="sig-paren">)</span><a·class="reference·internal"·href="../../_modules/celery/backends/amqp.html#AMQPBackend.drain_events"><span·class="viewcode-link">[source]</span></a><a·class="headerlink"·href="#celery.backends.amqp.AMQPBackend.drain_events"·title="Permalink·to·this·definition">¶</a></dt> | 900 | <code·class="descname">drain_events</code><span·class="sig-paren">(</span><em>connection</em>,·<em>consumer</em>,·<em>timeout=None</em>,·<em>on_interval=None</em>,·<em>now=<built-in·function·monotonic></em>,·<em>wait=None</em><span·class="sig-paren">)</span><a·class="reference·internal"·href="../../_modules/celery/backends/amqp.html#AMQPBackend.drain_events"><span·class="viewcode-link">[source]</span></a><a·class="headerlink"·href="#celery.backends.amqp.AMQPBackend.drain_events"·title="Permalink·to·this·definition">¶</a></dt> |
901 | <dd></dd></dl> | 901 | <dd></dd></dl> |
902 | <dl·class="method"> | 902 | <dl·class="method"> |
903 | <dt·id="celery.backends.amqp.AMQPBackend.get_many"> | 903 | <dt·id="celery.backends.amqp.AMQPBackend.get_many"> |
904 | <code·class="descname">get_many</code><span·class="sig-paren">(</span><em>task_ids</em>,·<em>timeout=None</em>,·<em>no_ack=True</em>,·<em>on_message=None</em>,·<em>on_interval=None</em>,·<em>now=<built-in·function·monotonic></em>,·<em>getfields=operator.itemgetter('status'</em>,·<em>'task_id')</em>,·<em>READY_STATES=frozenset({' | 904 | <code·class="descname">get_many</code><span·class="sig-paren">(</span><em>task_ids</em>,·<em>timeout=None</em>,·<em>no_ack=True</em>,·<em>on_message=None</em>,·<em>on_interval=None</em>,·<em>now=<built-in·function·monotonic></em>,·<em>getfields=operator.itemgetter('status'</em>,·<em>'task_id')</em>,·<em>READY_STATES=frozenset({'SUCCESS'</em>,·<em>'FAILURE'</em>,·<em>'REVOKED'})</em>,·<em>PROPAGATE_STATES=frozenset({'FAILURE'</em>,·<em>'REVOKED'})</em>,·<em>**kwargs</em><span·class="sig-paren">)</span><a·class="reference·internal"·href="../../_modules/celery/backends/amqp.html#AMQPBackend.get_many"><span·class="viewcode-link">[source]</span></a><a·class="headerlink"·href="#celery.backends.amqp.AMQPBackend.get_many"·title="Permalink·to·this·definition">¶</a></dt> |
905 | <dd></dd></dl> | 905 | <dd></dd></dl> |
906 | <dl·class="method"> | 906 | <dl·class="method"> |
907 | <dt·id="celery.backends.amqp.AMQPBackend.get_task_meta"> | 907 | <dt·id="celery.backends.amqp.AMQPBackend.get_task_meta"> |
908 | <code·class="descname">get_task_meta</code><span·class="sig-paren">(</span><em>task_id</em>,·<em>backlog_limit=1000</em><span·class="sig-paren">)</span><a·class="reference·internal"·href="../../_modules/celery/backends/amqp.html#AMQPBackend.get_task_meta"><span·class="viewcode-link">[source]</span></a><a·class="headerlink"·href="#celery.backends.amqp.AMQPBackend.get_task_meta"·title="Permalink·to·this·definition">¶</a></dt> | 908 | <code·class="descname">get_task_meta</code><span·class="sig-paren">(</span><em>task_id</em>,·<em>backlog_limit=1000</em><span·class="sig-paren">)</span><a·class="reference·internal"·href="../../_modules/celery/backends/amqp.html#AMQPBackend.get_task_meta"><span·class="viewcode-link">[source]</span></a><a·class="headerlink"·href="#celery.backends.amqp.AMQPBackend.get_task_meta"·title="Permalink·to·this·definition">¶</a></dt> |
909 | <dd></dd></dl> | 909 | <dd></dd></dl> |
Offset 978, 15 lines modified | Offset 978, 15 lines modified | ||
978 | <dl·class="attribute"> | 978 | <dl·class="attribute"> |
979 | <dt·id="celery.backends.amqp.AMQPBackend.supports_native_join"> | 979 | <dt·id="celery.backends.amqp.AMQPBackend.supports_native_join"> |
980 | <code·class="descname">supports_native_join</code><em·class="property">·=·True</em><a·class="headerlink"·href="#celery.backends.amqp.AMQPBackend.supports_native_join"·title="Permalink·to·this·definition">¶</a></dt> | 980 | <code·class="descname">supports_native_join</code><em·class="property">·=·True</em><a·class="headerlink"·href="#celery.backends.amqp.AMQPBackend.supports_native_join"·title="Permalink·to·this·definition">¶</a></dt> |
981 | <dd></dd></dl> | 981 | <dd></dd></dl> |
982 | <dl·class="method"> | 982 | <dl·class="method"> |
983 | <dt·id="celery.backends.amqp.AMQPBackend.wait_for"> | 983 | <dt·id="celery.backends.amqp.AMQPBackend.wait_for"> |
984 | <code·class="descname">wait_for</code><span·class="sig-paren">(</span><em>task_id</em>,·<em>timeout=None</em>,·<em>cache=True</em>,·<em>no_ack=True</em>,·<em>on_interval=None</em>,·<em>READY_STATES=frozenset({' | 984 | <code·class="descname">wait_for</code><span·class="sig-paren">(</span><em>task_id</em>,·<em>timeout=None</em>,·<em>cache=True</em>,·<em>no_ack=True</em>,·<em>on_interval=None</em>,·<em>READY_STATES=frozenset({'SUCCESS'</em>,·<em>'FAILURE'</em>,·<em>'REVOKED'})</em>,·<em>PROPAGATE_STATES=frozenset({'FAILURE'</em>,·<em>'REVOKED'})</em>,·<em>**kwargs</em><span·class="sig-paren">)</span><a·class="reference·internal"·href="../../_modules/celery/backends/amqp.html#AMQPBackend.wait_for"><span·class="viewcode-link">[source]</span></a><a·class="headerlink"·href="#celery.backends.amqp.AMQPBackend.wait_for"·title="Permalink·to·this·definition">¶</a></dt> |
985 | <dd><p>Wait·for·task·and·return·its·result.</p> | 985 | <dd><p>Wait·for·task·and·return·its·result.</p> |
986 | <p>If·the·task·raises·an·exception,·this·exception | 986 | <p>If·the·task·raises·an·exception,·this·exception |
987 | will·be·re-raised·by·<a·class="reference·internal"·href="#celery.backends.amqp.AMQPBackend.wait_for"·title="celery.backends.amqp.AMQPBackend.wait_for"><code·class="xref·py·py-func·docutils·literal·notranslate"><span·class="pre">wait_for()</span></code></a>.</p> | 987 | will·be·re-raised·by·<a·class="reference·internal"·href="#celery.backends.amqp.AMQPBackend.wait_for"·title="celery.backends.amqp.AMQPBackend.wait_for"><code·class="xref·py·py-func·docutils·literal·notranslate"><span·class="pre">wait_for()</span></code></a>.</p> |
988 | <table·class="docutils·field-list"·frame="void"·rules="none"> | 988 | <table·class="docutils·field-list"·frame="void"·rules="none"> |
989 | <col·class="field-name"·/> | 989 | <col·class="field-name"·/> |
990 | <col·class="field-body"·/> | 990 | <col·class="field-body"·/> |
991 | <tbody·valign="top"> | 991 | <tbody·valign="top"> |
Offset 181, 15 lines modified | Offset 181, 15 lines modified | ||
181 | <dt·id="celery.result.AsyncResult.forget"> | 181 | <dt·id="celery.result.AsyncResult.forget"> |
182 | <code·class="descname">forget</code><span·class="sig-paren">(</span><span·class="sig-paren">)</span><a·class="reference·internal"·href="../_modules/celery/result.html#AsyncResult.forget"><span·class="viewcode-link">[source]</span></a><a·class="headerlink"·href="#celery.result.AsyncResult.forget"·title="Permalink·to·this·definition">¶</a></dt> | 182 | <code·class="descname">forget</code><span·class="sig-paren">(</span><span·class="sig-paren">)</span><a·class="reference·internal"·href="../_modules/celery/result.html#AsyncResult.forget"><span·class="viewcode-link">[source]</span></a><a·class="headerlink"·href="#celery.result.AsyncResult.forget"·title="Permalink·to·this·definition">¶</a></dt> |
183 | <dd><p>Forget·about·(and·possibly·remove·the·result·of)·this·task.</p> | 183 | <dd><p>Forget·about·(and·possibly·remove·the·result·of)·this·task.</p> |
184 | </dd></dl> | 184 | </dd></dl> |
185 | <dl·class="method"> | 185 | <dl·class="method"> |
186 | <dt·id="celery.result.AsyncResult.get"> | 186 | <dt·id="celery.result.AsyncResult.get"> |
187 | <code·class="descname">get</code><span·class="sig-paren">(</span><em>timeout=None</em>,·<em>propagate=True</em>,·<em>interval=0.5</em>,·<em>no_ack=True</em>,·<em>follow_parents=True</em>,·<em>callback=None</em>,·<em>on_message=None</em>,·<em>on_interval=None</em>,·<em>disable_sync_subtasks=True</em>,·<em>EXCEPTION_STATES=frozenset({'FAILURE'</em>,·<em>'RE | 187 | <code·class="descname">get</code><span·class="sig-paren">(</span><em>timeout=None</em>,·<em>propagate=True</em>,·<em>interval=0.5</em>,·<em>no_ack=True</em>,·<em>follow_parents=True</em>,·<em>callback=None</em>,·<em>on_message=None</em>,·<em>on_interval=None</em>,·<em>disable_sync_subtasks=True</em>,·<em>EXCEPTION_STATES=frozenset({'FAILURE'</em>,·<em>'RETRY'</em>,·<em>'REVOKED'})</em>,·<em>PROPAGATE_STATES=frozenset({'FAILURE'</em>,·<em>'REVOKED'})</em><span·class="sig-paren">)</span><a·class="reference·internal"·href="../_modules/celery/result.html#AsyncResult.get"><span·class="viewcode-link">[source]</span></a><a·class="headerlink"·href="#celery.result.AsyncResult.get"·title="Permalink·to·this·definition">¶</a></dt> |
188 | <dd><p>Wait·until·task·is·ready,·and·return·its·result.</p> | 188 | <dd><p>Wait·until·task·is·ready,·and·return·its·result.</p> |
189 | <div·class="admonition·warning"> | 189 | <div·class="admonition·warning"> |
190 | <p·class="first·admonition-title">Warning</p> | 190 | <p·class="first·admonition-title">Warning</p> |
191 | <p·class="last">Waiting·for·tasks·within·a·task·may·lead·to·deadlocks. | 191 | <p·class="last">Waiting·for·tasks·within·a·task·may·lead·to·deadlocks. |
192 | Please·read·<a·class="reference·internal"·href="../userguide/tasks.html#task-synchronous-subtasks"><span·class="std·std-ref">Avoid·launching·synchronous·subtasks</span></a>.</p> | 192 | Please·read·<a·class="reference·internal"·href="../userguide/tasks.html#task-synchronous-subtasks"><span·class="std·std-ref">Avoid·launching·synchronous·subtasks</span></a>.</p> |
193 | </div> | 193 | </div> |
194 | <div·class="admonition·warning"> | 194 | <div·class="admonition·warning"> |
Offset 417, 15 lines modified | Offset 417, 15 lines modified | ||
417 | <dt·id="celery.result.AsyncResult.traceback"> | 417 | <dt·id="celery.result.AsyncResult.traceback"> |
418 | <code·class="descname">traceback</code><a·class="headerlink"·href="#celery.result.AsyncResult.traceback"·title="Permalink·to·this·definition">¶</a></dt> | 418 | <code·class="descname">traceback</code><a·class="headerlink"·href="#celery.result.AsyncResult.traceback"·title="Permalink·to·this·definition">¶</a></dt> |
419 | <dd><p>Get·the·traceback·of·a·failed·task.</p> | 419 | <dd><p>Get·the·traceback·of·a·failed·task.</p> |
420 | </dd></dl> | 420 | </dd></dl> |
421 | <dl·class="method"> | 421 | <dl·class="method"> |
422 | <dt·id="celery.result.AsyncResult.wait"> | 422 | <dt·id="celery.result.AsyncResult.wait"> |
423 | <code·class="descname">wait</code><span·class="sig-paren">(</span><em>timeout=None</em>,·<em>propagate=True</em>,·<em>interval=0.5</em>,·<em>no_ack=True</em>,·<em>follow_parents=True</em>,·<em>callback=None</em>,·<em>on_message=None</em>,·<em>on_interval=None</em>,·<em>disable_sync_subtasks=True</em>,·<em>EXCEPTION_STATES=frozenset({'FAILURE'</em>,·<em>'RE | 423 | <code·class="descname">wait</code><span·class="sig-paren">(</span><em>timeout=None</em>,·<em>propagate=True</em>,·<em>interval=0.5</em>,·<em>no_ack=True</em>,·<em>follow_parents=True</em>,·<em>callback=None</em>,·<em>on_message=None</em>,·<em>on_interval=None</em>,·<em>disable_sync_subtasks=True</em>,·<em>EXCEPTION_STATES=frozenset({'FAILURE'</em>,·<em>'RETRY'</em>,·<em>'REVOKED'})</em>,·<em>PROPAGATE_STATES=frozenset({'FAILURE'</em>,·<em>'REVOKED'})</em><span·class="sig-paren">)</span><a·class="headerlink"·href="#celery.result.AsyncResult.wait"·title="Permalink·to·this·definition">¶</a></dt> |
424 | <dd><p>Wait·until·task·is·ready,·and·return·its·result.</p> | 424 | <dd><p>Wait·until·task·is·ready,·and·return·its·result.</p> |
425 | <div·class="admonition·warning"> | 425 | <div·class="admonition·warning"> |
426 | <p·class="first·admonition-title">Warning</p> | 426 | <p·class="first·admonition-title">Warning</p> |
427 | <p·class="last">Waiting·for·tasks·within·a·task·may·lead·to·deadlocks. | 427 | <p·class="last">Waiting·for·tasks·within·a·task·may·lead·to·deadlocks. |
428 | Please·read·<a·class="reference·internal"·href="../userguide/tasks.html#task-synchronous-subtasks"><span·class="std·std-ref">Avoid·launching·synchronous·subtasks</span></a>.</p> | 428 | Please·read·<a·class="reference·internal"·href="../userguide/tasks.html#task-synchronous-subtasks"><span·class="std·std-ref">Avoid·launching·synchronous·subtasks</span></a>.</p> |
429 | </div> | 429 | </div> |
430 | <div·class="admonition·warning"> | 430 | <div·class="admonition·warning"> |