| Offset 1, 3 lines modified | Offset 1, 3 lines modified | ||
| 1 | · | 1 | ·6ea177e104d7f2d053ab53cb242dccc1·1733208·doc·optional·python-taskflow-doc_5.0.0-3_all.deb |
| 2 | ·43b891a110a7c751212642769aa6e7bb·212688·python·optional·python3-taskflow_5.0.0-3_all.deb | 2 | ·43b891a110a7c751212642769aa6e7bb·212688·python·optional·python3-taskflow_5.0.0-3_all.deb |
| Offset 1, 3 lines modified | Offset 1, 3 lines modified | ||
| 1 | -rw-r--r--···0········0········0········4·2022-12-09·10:22:43.000000·debian-binary | 1 | -rw-r--r--···0········0········0········4·2022-12-09·10:22:43.000000·debian-binary |
| 2 | -rw-r--r--···0········0········0·····5988·2022-12-09·10:22:43.000000·control.tar.xz | 2 | -rw-r--r--···0········0········0·····5988·2022-12-09·10:22:43.000000·control.tar.xz |
| 3 | -rw-r--r--···0········0········0··172702 | 3 | -rw-r--r--···0········0········0··1727028·2022-12-09·10:22:43.000000·data.tar.xz |
| Offset 201, 15 lines modified | Offset 201, 15 lines modified | ||
| 201 | -rw-r--r--···0·root·········(0)·root·········(0)·······90·2022-12-09·10:22:43.000000·./usr/share/doc/python-taskflow-doc/html/_static/plus.png | 201 | -rw-r--r--···0·root·········(0)·root·········(0)·······90·2022-12-09·10:22:43.000000·./usr/share/doc/python-taskflow-doc/html/_static/plus.png |
| 202 | -rw-r--r--···0·root·········(0)·root·········(0)·····5357·2022-12-09·10:22:43.000000·./usr/share/doc/python-taskflow-doc/html/_static/pygments.css | 202 | -rw-r--r--···0·root·········(0)·root·········(0)·····5357·2022-12-09·10:22:43.000000·./usr/share/doc/python-taskflow-doc/html/_static/pygments.css |
| 203 | -rw-r--r--···0·root·········(0)·root·········(0)···169259·2022-12-09·10:22:43.000000·./usr/share/doc/python-taskflow-doc/html/genindex.html | 203 | -rw-r--r--···0·root·········(0)·root·········(0)···169259·2022-12-09·10:22:43.000000·./usr/share/doc/python-taskflow-doc/html/genindex.html |
| 204 | -rw-r--r--···0·root·········(0)·root·········(0)····15937·2022-12-09·10:22:43.000000·./usr/share/doc/python-taskflow-doc/html/index.html | 204 | -rw-r--r--···0·root·········(0)·root·········(0)····15937·2022-12-09·10:22:43.000000·./usr/share/doc/python-taskflow-doc/html/index.html |
| 205 | -rw-r--r--···0·root·········(0)·root·········(0)·····7456·2022-12-09·10:22:43.000000·./usr/share/doc/python-taskflow-doc/html/objects.inv | 205 | -rw-r--r--···0·root·········(0)·root·········(0)·····7456·2022-12-09·10:22:43.000000·./usr/share/doc/python-taskflow-doc/html/objects.inv |
| 206 | -rw-r--r--···0·root·········(0)·root·········(0)····32396·2022-12-09·10:22:43.000000·./usr/share/doc/python-taskflow-doc/html/py-modindex.html | 206 | -rw-r--r--···0·root·········(0)·root·········(0)····32396·2022-12-09·10:22:43.000000·./usr/share/doc/python-taskflow-doc/html/py-modindex.html |
| 207 | -rw-r--r--···0·root·········(0)·root·········(0)····12869·2022-12-09·10:22:43.000000·./usr/share/doc/python-taskflow-doc/html/search.html | 207 | -rw-r--r--···0·root·········(0)·root·········(0)····12869·2022-12-09·10:22:43.000000·./usr/share/doc/python-taskflow-doc/html/search.html |
| 208 | -rw-r--r--···0·root·········(0)·root·········(0)···2304 | 208 | -rw-r--r--···0·root·········(0)·root·········(0)···230467·2022-12-09·10:22:43.000000·./usr/share/doc/python-taskflow-doc/html/searchindex.js |
| 209 | drwxr-xr-x···0·root·········(0)·root·········(0)········0·2022-12-09·10:22:43.000000·./usr/share/doc/python-taskflow-doc/html/user/ | 209 | drwxr-xr-x···0·root·········(0)·root·········(0)········0·2022-12-09·10:22:43.000000·./usr/share/doc/python-taskflow-doc/html/user/ |
| 210 | -rw-r--r--···0·root·········(0)·root·········(0)····57653·2022-12-09·10:22:43.000000·./usr/share/doc/python-taskflow-doc/html/user/arguments_and_results.html | 210 | -rw-r--r--···0·root·········(0)·root·········(0)····57653·2022-12-09·10:22:43.000000·./usr/share/doc/python-taskflow-doc/html/user/arguments_and_results.html |
| 211 | -rw-r--r--···0·root·········(0)·root·········(0)···138725·2022-12-09·10:22:43.000000·./usr/share/doc/python-taskflow-doc/html/user/atoms.html | 211 | -rw-r--r--···0·root·········(0)·root·········(0)···138725·2022-12-09·10:22:43.000000·./usr/share/doc/python-taskflow-doc/html/user/atoms.html |
| 212 | -rw-r--r--···0·root·········(0)·root·········(0)····54131·2022-12-09·10:22:43.000000·./usr/share/doc/python-taskflow-doc/html/user/conductors.html | 212 | -rw-r--r--···0·root·········(0)·root·········(0)····54131·2022-12-09·10:22:43.000000·./usr/share/doc/python-taskflow-doc/html/user/conductors.html |
| 213 | -rw-r--r--···0·root·········(0)·root·········(0)···267031·2022-12-09·10:22:43.000000·./usr/share/doc/python-taskflow-doc/html/user/engines.html | 213 | -rw-r--r--···0·root·········(0)·root·········(0)···267031·2022-12-09·10:22:43.000000·./usr/share/doc/python-taskflow-doc/html/user/engines.html |
| 214 | -rw-r--r--···0·root·········(0)·root·········(0)···601384·2022-12-09·10:22:43.000000·./usr/share/doc/python-taskflow-doc/html/user/examples.html | 214 | -rw-r--r--···0·root·········(0)·root·········(0)···601384·2022-12-09·10:22:43.000000·./usr/share/doc/python-taskflow-doc/html/user/examples.html |
| 215 | -rw-r--r--···0·root·········(0)·root·········(0)····59084·2022-12-09·10:22:43.000000·./usr/share/doc/python-taskflow-doc/html/user/exceptions.html | 215 | -rw-r--r--···0·root·········(0)·root·········(0)····59084·2022-12-09·10:22:43.000000·./usr/share/doc/python-taskflow-doc/html/user/exceptions.html |
| Offset 798, 15 lines modified | Offset 798, 15 lines modified | ||
| 798 | ········"gracefulli":·3, | 798 | ········"gracefulli":·3, |
| 799 | ········"exit":·[3,·4,·5,·10,·11,·13,·17,·19], | 799 | ········"exit":·[3,·4,·5,·10,·11,·13,·17,·19], |
| 800 | ········"within":·[3,·6,·13,·19], | 800 | ········"within":·[3,·6,·13,·19], |
| 801 | ········"impl_block":·3, | 801 | ········"impl_block":·3, |
| 802 | ········"blockingconductor":·3, | 802 | ········"blockingconductor":·3, |
| 803 | ········"impl_nonblock":·3, | 803 | ········"impl_nonblock":·3, |
| 804 | ········"nonblockingconductor":·3, | 804 | ········"nonblockingconductor":·3, |
| 805 | ········"1 | 805 | ········"16":·[3,·5], |
| 806 | ········"executor_factori":·3, | 806 | ········"executor_factori":·3, |
| 807 | ········"thread":·[3,·4,·6,·8,·10,·13,·17,·19], | 807 | ········"thread":·[3,·4,·6,·8,·10,·13,·17,·19], |
| 808 | ········"custom":·[3,·10,·11,·17,·19], | 808 | ········"custom":·[3,·10,·11,·17,·19], |
| 809 | ········"pool":·[3,·4,·8], | 809 | ········"pool":·[3,·4,·8], |
| 810 | ········"select":·[3,·4,·5,·10,·11,·13,·14,·19], | 810 | ········"select":·[3,·4,·5,·10,·11,·13,·14,·19], |
| 811 | ········"simultan":·[3,·4,·19], | 811 | ········"simultan":·[3,·4,·19], |
| 812 | ········"count":·[3,·5,·10,·17,·18,·19], | 812 | ········"count":·[3,·5,·10,·17,·18,·19], |
| Offset 1624, 15 lines modified | Offset 1624, 14 lines modified | ||
| 1624 | ········"y1":·5, | 1624 | ········"y1":·5, |
| 1625 | ········"y2":·5, | 1625 | ········"y2":·5, |
| 1626 | ········"add1":·5, | 1626 | ········"add1":·5, |
| 1627 | ········"x5":·5, | 1627 | ········"x5":·5, |
| 1628 | ········"x3":·5, | 1628 | ········"x3":·5, |
| 1629 | ········"20":·5, | 1629 | ········"20":·5, |
| 1630 | ········"add5":·5, | 1630 | ········"add5":·5, |
| 1631 | ········"16":·5, | ||
| 1632 | ········"add3":·5, | 1631 | ········"add3":·5, |
| 1633 | ········"x4":·5, | 1632 | ········"x4":·5, |
| 1634 | ········"y5":·5, | 1633 | ········"y5":·5, |
| 1635 | ········"21":·5, | 1634 | ········"21":·5, |
| 1636 | ········"add4":·5, | 1635 | ········"add4":·5, |
| 1637 | ········"x6":·5, | 1636 | ········"x6":·5, |
| 1638 | ········"41":·5, | 1637 | ········"41":·5, |
| Offset 347, 15 lines modified | Offset 347, 15 lines modified | ||
| 347 | </dd></dl> | 347 | </dd></dl> |
| 348 | </section> | 348 | </section> |
| 349 | <section·id="module-taskflow.conductors.backends.impl_nonblocking"> | 349 | <section·id="module-taskflow.conductors.backends.impl_nonblocking"> |
| 350 | <span·id="non-blocking"></span><h3>Non-blocking<a·class="headerlink"·href="#module-taskflow.conductors.backends.impl_nonblocking"·title="Permalink·to·this·heading">¶</a></h3> | 350 | <span·id="non-blocking"></span><h3>Non-blocking<a·class="headerlink"·href="#module-taskflow.conductors.backends.impl_nonblocking"·title="Permalink·to·this·heading">¶</a></h3> |
| 351 | <dl·class="py·class"> | 351 | <dl·class="py·class"> |
| 352 | <dt·class="sig·sig-object·py"·id="taskflow.conductors.backends.impl_nonblocking.NonBlockingConductor"> | 352 | <dt·class="sig·sig-object·py"·id="taskflow.conductors.backends.impl_nonblocking.NonBlockingConductor"> |
| 353 | <em·class="property"><span·class="pre">class</span><span·class="w">·</span></em><span·class="sig-prename·descclassname"><span·class="pre">taskflow.conductors.backends.impl_nonblocking.</span></span><span·class="sig-name·descname"><span·class="pre">NonBlockingConductor</span></span><span·class="sig-paren">(</span><em·class="sig-param"><span·class="n"><span·class="pre">name</span></span></em>,·<em·class="sig-param"><span·class="n"><span·class="pre">jobboard</span></span></em>,·<em·class="sig-param"><span·class="n"><span·class="pre">persistence</span></span><span·class="o"><span·class="pre">=</span></span><span·class="default_value"><span·class="pre">None</span></span></em>,·<em·class="sig-param"><span·class="n"><span·class="pre">engine</span></span><span·class="o"><span·class="pre">=</span></span><span·class="default_value"><span·class="pre">None</span></span></em>,·<em·class="sig-param"><span·class="n"><span·class="pre">engine_options</span></span><span·class="o"><span·class="pre">=</span></span><span·class="default_value"><span·class="pre">None</span></span></em>,·<em·class="sig-param"><span·class="n"><span·class="pre">wait_timeout</span></span><span·class="o"><span·class="pre">=</span></span><span·class="default_value"><span·class="pre">None</span></span></em>,·<em·class="sig-param"><span·class="n"><span·class="pre">log</span></span><span·class="o"><span·class="pre">=</span></span><span·class="default_value"><span·class="pre">None</span></span></em>,·<em·class="sig-param"><span·class="n"><span·class="pre">max_simultaneous_jobs</span></span><span·class="o"><span·class="pre">=</span></span><span·class="default_value"><span·class="pre">1 | 353 | <em·class="property"><span·class="pre">class</span><span·class="w">·</span></em><span·class="sig-prename·descclassname"><span·class="pre">taskflow.conductors.backends.impl_nonblocking.</span></span><span·class="sig-name·descname"><span·class="pre">NonBlockingConductor</span></span><span·class="sig-paren">(</span><em·class="sig-param"><span·class="n"><span·class="pre">name</span></span></em>,·<em·class="sig-param"><span·class="n"><span·class="pre">jobboard</span></span></em>,·<em·class="sig-param"><span·class="n"><span·class="pre">persistence</span></span><span·class="o"><span·class="pre">=</span></span><span·class="default_value"><span·class="pre">None</span></span></em>,·<em·class="sig-param"><span·class="n"><span·class="pre">engine</span></span><span·class="o"><span·class="pre">=</span></span><span·class="default_value"><span·class="pre">None</span></span></em>,·<em·class="sig-param"><span·class="n"><span·class="pre">engine_options</span></span><span·class="o"><span·class="pre">=</span></span><span·class="default_value"><span·class="pre">None</span></span></em>,·<em·class="sig-param"><span·class="n"><span·class="pre">wait_timeout</span></span><span·class="o"><span·class="pre">=</span></span><span·class="default_value"><span·class="pre">None</span></span></em>,·<em·class="sig-param"><span·class="n"><span·class="pre">log</span></span><span·class="o"><span·class="pre">=</span></span><span·class="default_value"><span·class="pre">None</span></span></em>,·<em·class="sig-param"><span·class="n"><span·class="pre">max_simultaneous_jobs</span></span><span·class="o"><span·class="pre">=</span></span><span·class="default_value"><span·class="pre">16</span></span></em>,·<em·class="sig-param"><span·class="n"><span·class="pre">executor_factory</span></span><span·class="o"><span·class="pre">=</span></span><span·class="default_value"><span·class="pre">None</span></span></em><span·class="sig-paren">)</span><a·class="reference·internal"·href="../_modules/taskflow/conductors/backends/impl_nonblocking.html#NonBlockingConductor"><span·class="viewcode-link"><span·class="pre">[source]</span></span></a><a·class="headerlink"·href="#taskflow.conductors.backends.impl_nonblocking.NonBlockingConductor"·title="Permalink·to·this·definition">¶</a></dt> |
| 354 | <dd><p>Bases:·<a·class="reference·internal"·href="#taskflow.conductors.backends.impl_executor.ExecutorConductor"·title="taskflow.conductors.backends.impl_executor.ExecutorConductor"><code·class="xref·py·py-class·docutils·literal·notranslate"><span·class="pre">ExecutorConductor</span></code></a></p> | 354 | <dd><p>Bases:·<a·class="reference·internal"·href="#taskflow.conductors.backends.impl_executor.ExecutorConductor"·title="taskflow.conductors.backends.impl_executor.ExecutorConductor"><code·class="xref·py·py-class·docutils·literal·notranslate"><span·class="pre">ExecutorConductor</span></code></a></p> |
| 355 | <p>Non-blocking·conductor·that·processes·job(s)·using·a·thread·executor.</p> | 355 | <p>Non-blocking·conductor·that·processes·job(s)·using·a·thread·executor.</p> |
| 356 | <dl·class="simple"> | 356 | <dl·class="simple"> |
| 357 | <dt>NOTE(harlowja):·A·custom·executor·factory·can·be·provided·via·keyword</dt><dd><p>argument·<code·class="docutils·literal·notranslate"><span·class="pre">executor_factory</span></code>,·if·provided·it·will·be | 357 | <dt>NOTE(harlowja):·A·custom·executor·factory·can·be·provided·via·keyword</dt><dd><p>argument·<code·class="docutils·literal·notranslate"><span·class="pre">executor_factory</span></code>,·if·provided·it·will·be |
| 358 | invoked·at | 358 | invoked·at |
| 359 | <a·class="reference·internal"·href="#taskflow.conductors.base.Conductor.run"·title="taskflow.conductors.base.Conductor.run"><code·class="xref·py·py-meth·docutils·literal·notranslate"><span·class="pre">run()</span></code></a>·time | 359 | <a·class="reference·internal"·href="#taskflow.conductors.base.Conductor.run"·title="taskflow.conductors.base.Conductor.run"><code·class="xref·py·py-meth·docutils·literal·notranslate"><span·class="pre">run()</span></code></a>·time |
| 360 | with·one·positional·argument·(this·conductor)·and·it·must | 360 | with·one·positional·argument·(this·conductor)·and·it·must |
| Offset 364, 15 lines modified | Offset 364, 15 lines modified | ||
| 364 | backed·executor·is·selected·by·default·(it·will·have | 364 | backed·executor·is·selected·by·default·(it·will·have |
| 365 | an·equivalent·number·of·workers·as·this·conductors | 365 | an·equivalent·number·of·workers·as·this·conductors |
| 366 | simultaneous·job·count).</p> | 366 | simultaneous·job·count).</p> |
| 367 | </dd> | 367 | </dd> |
| 368 | </dl> | 368 | </dl> |
| 369 | <dl·class="py·attribute"> | 369 | <dl·class="py·attribute"> |
| 370 | <dt·class="sig·sig-object·py"·id="taskflow.conductors.backends.impl_nonblocking.NonBlockingConductor.MAX_SIMULTANEOUS_JOBS"> | 370 | <dt·class="sig·sig-object·py"·id="taskflow.conductors.backends.impl_nonblocking.NonBlockingConductor.MAX_SIMULTANEOUS_JOBS"> |
| 371 | <span·class="sig-name·descname"><span·class="pre">MAX_SIMULTANEOUS_JOBS</span></span><em·class="property"><span·class="w">·</span><span·class="p"><span·class="pre">=</span></span><span·class="w">·</span><span·class="pre">1 | 371 | <span·class="sig-name·descname"><span·class="pre">MAX_SIMULTANEOUS_JOBS</span></span><em·class="property"><span·class="w">·</span><span·class="p"><span·class="pre">=</span></span><span·class="w">·</span><span·class="pre">16</span></em><a·class="headerlink"·href="#taskflow.conductors.backends.impl_nonblocking.NonBlockingConductor.MAX_SIMULTANEOUS_JOBS"·title="Permalink·to·this·definition">¶</a></dt> |
| 372 | <dd><p>Default·maximum·number·of·jobs·that·can·be·in·progress·at·the·same·time.</p> | 372 | <dd><p>Default·maximum·number·of·jobs·that·can·be·in·progress·at·the·same·time.</p> |
| 373 | </dd></dl> | 373 | </dd></dl> |
| 374 | </dd></dl> | 374 | </dd></dl> |
| 375 | </section> | 375 | </section> |
| 376 | </section> | 376 | </section> |
| Offset 173, 26 lines modified | Offset 173, 26 lines modified | ||
| 173 | ········MAX_SIMULTANEOUS_JOBS=·1¶ | 173 | ········MAX_SIMULTANEOUS_JOBS=·1¶ |
| 174 | ············Default·maximum·number·of·jobs·that·can·be·in·progress·at·the·same | 174 | ············Default·maximum·number·of·jobs·that·can·be·in·progress·at·the·same |
| 175 | ············time. | 175 | ············time. |
| 176 | ****·Non-blocking¶·**** | 176 | ****·Non-blocking¶·**** |
| 177 | ··classtaskflow.conductors.backends.impl_nonblocking.NonBlockingConductor(name, | 177 | ··classtaskflow.conductors.backends.impl_nonblocking.NonBlockingConductor(name, |
| 178 | ··jobboard,·persistence=None,·engine=None,·engine_options=None, | 178 | ··jobboard,·persistence=None,·engine=None,·engine_options=None, |
| 179 | ··wait_timeout=None,·log=None,·max_simultaneous_jobs=1 | 179 | ··wait_timeout=None,·log=None,·max_simultaneous_jobs=16,·executor_factory=None) |
| 180 | ··[source]¶ | 180 | ··[source]¶ |
| 181 | ······Bases:·ExecutorConductor | 181 | ······Bases:·ExecutorConductor |
| 182 | ······Non-blocking·conductor·that·processes·job(s)·using·a·thread·executor. | 182 | ······Non-blocking·conductor·that·processes·job(s)·using·a·thread·executor. |
| 183 | ········NOTE(harlowja):·A·custom·executor·factory·can·be·provided·via·keyword | 183 | ········NOTE(harlowja):·A·custom·executor·factory·can·be·provided·via·keyword |
| 184 | ············argument·executor_factory,·if·provided·it·will·be·invoked·at·run() | 184 | ············argument·executor_factory,·if·provided·it·will·be·invoked·at·run() |
| 185 | ············time·with·one·positional·argument·(this·conductor)·and·it·must | 185 | ············time·with·one·positional·argument·(this·conductor)·and·it·must |
| 186 | ············return·a·compatible·executor·which·can·be·used·to·submit·jobs·to. | 186 | ············return·a·compatible·executor·which·can·be·used·to·submit·jobs·to. |
| 187 | ············If·None·is·a·provided·a·thread·pool·backed·executor·is·selected·by | 187 | ············If·None·is·a·provided·a·thread·pool·backed·executor·is·selected·by |
| 188 | ············default·(it·will·have·an·equivalent·number·of·workers·as·this | 188 | ············default·(it·will·have·an·equivalent·number·of·workers·as·this |
| 189 | ············conductors·simultaneous·job·count). | 189 | ············conductors·simultaneous·job·count). |
| 190 | ········MAX_SIMULTANEOUS_JOBS=·1 | 190 | ········MAX_SIMULTANEOUS_JOBS=·16¶ |
| 191 | ············Default·maximum·number·of·jobs·that·can·be·in·progress·at·the·same | 191 | ············Default·maximum·number·of·jobs·that·can·be·in·progress·at·the·same |
| 192 | ············time. | 192 | ············time. |
| 193 | *****·Hierarchy¶·***** | 193 | *****·Hierarchy¶·***** |
| 194 | [Inheritance·diagram·of·taskflow.conductors.base, | 194 | [Inheritance·diagram·of·taskflow.conductors.base, |
| 195 | taskflow.conductors.backends.impl_blocking, | 195 | taskflow.conductors.backends.impl_blocking, |
| 196 | taskflow.conductors.backends.impl_nonblocking, | 196 | taskflow.conductors.backends.impl_nonblocking, |