Skip to content

Commit

Permalink
Merge Release 0.17.0 (refs #258)
Browse files Browse the repository at this point in the history
  • Loading branch information
daltonmatos committed Mar 8, 2021
2 parents a66eb02 + 625dea6 commit 18ee54e
Show file tree
Hide file tree
Showing 212 changed files with 542 additions and 520 deletions.
4 changes: 2 additions & 2 deletions docs-src/changelog/v0.17.0.rst
Original file line number Diff line number Diff line change
Expand Up @@ -2,7 +2,7 @@
================


Data de release:
Data de release: 2021-03-07

- Changelog: `0.17.0 <https://github.com/b2wdigital/async-worker/releases/tag/0.17.0>`_
- Raw Commits: `0.17.0 <https://github.com/b2wdigital/async-worker/compare/0.16.0...0.17.0>`_
Expand All @@ -12,4 +12,4 @@ Notas de atualização
--------------------

- Nessa versão removemos o suporte a Server Sent Events (SSE). Esse código já não estava sendo mantido e nem participou da refatoração que aconteceu no `#224 <https://github.com/b2wdigital/async-worker/pull/224>`_
- Atualização do aiohttp para versão `3.7.4`. Verifique se seu projeto funciona corretamente com essa nova versão antes de atualizar para o asyncworker `0.17.0`.
- Atualização do aiohttp para versão ``3.7.4``. Verifique se seu projeto funciona corretamente com essa nova versão antes de atualizar para o asyncworker ``0.17.0``.
77 changes: 77 additions & 0 deletions docs-src/locale/en/LC_MESSAGES/changelog/v0.17.0.po
Original file line number Diff line number Diff line change
@@ -0,0 +1,77 @@
# SOME DESCRIPTIVE TITLE.
# Copyright (C) 2019, B2W Digital
# This file is distributed under the same license as the Asyncworker
# package.
# FIRST AUTHOR <EMAIL@ADDRESS>, 2021.
#
#, fuzzy
msgid ""
msgstr ""
"Project-Id-Version: Asyncworker \n"
"Report-Msgid-Bugs-To: \n"
"POT-Creation-Date: 2021-03-07 21:36-0300\n"
"PO-Revision-Date: YEAR-MO-DA HO:MI+ZONE\n"
"Last-Translator: FULL NAME <EMAIL@ADDRESS>\n"
"Language-Team: LANGUAGE <LL@li.org>\n"
"MIME-Version: 1.0\n"
"Content-Type: text/plain; charset=utf-8\n"
"Content-Transfer-Encoding: 8bit\n"
"Generated-By: Babel 2.9.0\n"

#: ../../changelog/v0.17.0.rst:2
msgid "0.17.0"
msgstr ""

#: ../../changelog/v0.17.0.rst:5
msgid "Data de release: 2021-03-07"
msgstr ""

#: ../../changelog/v0.17.0.rst:7
msgid ""
"Changelog: `0.17.0 <https://github.com/b2wdigital/async-"
"worker/releases/tag/0.17.0>`_"
msgstr ""

#: ../../changelog/v0.17.0.rst:8
msgid ""
"Raw Commits: `0.17.0 <https://github.com/b2wdigital/async-"
"worker/compare/0.16.0...0.17.0>`_"
msgstr ""

#: ../../changelog/v0.17.0.rst:12
msgid "Notas de atualização"
msgstr ""

#: ../../changelog/v0.17.0.rst:14
msgid ""
"Nessa versão removemos o suporte a Server Sent Events (SSE). Esse código "
"já não estava sendo mantido e nem participou da refatoração que aconteceu"
" no `#224 <https://github.com/b2wdigital/async-worker/pull/224>`_"
msgstr ""

#: ../../changelog/v0.17.0.rst:15
msgid ""
"Atualização do aiohttp para versão ``3.7.4``. Verifique se seu projeto "
"funciona corretamente com essa nova versão antes de atualizar para o "
"asyncworker ``0.17.0``."
msgstr ""

#~ msgid "Data de release:"
#~ msgstr ""

#~ msgid ""
#~ "Atualização do aiohttp para versão "
#~ "`3.7.4`. Verifique se seu projeto "
#~ "funciona corretamente com essa nova "
#~ "versão antes de atualizar para o "
#~ "asyncworker `0.17.0`."
#~ msgstr ""

#~ msgid ""
#~ "Atualização do aiohttp para versão "
#~ "``3.7.4``. Verifique se seu projeto "
#~ "funciona corretamente com essa nova "
#~ "versão antes de atualizar para o "
#~ "asyncworker `0.17.0`."
#~ msgstr ""

26 changes: 11 additions & 15 deletions docs-src/locale/en/LC_MESSAGES/src/asyncworker/asyncworker.sse.po
Original file line number Diff line number Diff line change
Expand Up @@ -9,14 +9,14 @@ msgid ""
msgstr ""
"Project-Id-Version: Asyncworker \n"
"Report-Msgid-Bugs-To: \n"
"POT-Creation-Date: 2019-10-09 09:15-0300\n"
"POT-Creation-Date: 2021-03-07 21:22-0300\n"
"PO-Revision-Date: YEAR-MO-DA HO:MI+ZONE\n"
"Last-Translator: FULL NAME <EMAIL@ADDRESS>\n"
"Language-Team: LANGUAGE <LL@li.org>\n"
"MIME-Version: 1.0\n"
"Content-Type: text/plain; charset=utf-8\n"
"Content-Transfer-Encoding: 8bit\n"
"Generated-By: Babel 2.8.0\n"
"Generated-By: Babel 2.9.0\n"

#: ../../src/asyncworker/asyncworker.sse.rst:2
msgid "asyncworker.sse package"
Expand All @@ -30,19 +30,6 @@ msgstr ""
msgid "asyncworker.sse.consumer module"
msgstr ""

#: asyncworker.sse.consumer.SSEConsumer:1 asyncworker.sse.message.SSEMessage:1
#: of
msgid "Base: :class:`object`"
msgstr ""

#: asyncworker.sse.consumer.State:1 of
msgid "Base: :class:`enum.Enum`"
msgstr ""

#: asyncworker.sse.consumer.State:1 of
msgid "An enumeration."
msgstr ""

#: ../../src/asyncworker/asyncworker.sse.rst:16
msgid "asyncworker.sse.message module"
msgstr ""
Expand All @@ -51,3 +38,12 @@ msgstr ""
msgid "Module contents"
msgstr ""

#~ msgid "Base: :class:`object`"
#~ msgstr ""

#~ msgid "Base: :class:`enum.Enum`"
#~ msgstr ""

#~ msgid "An enumeration."
#~ msgstr ""

Binary file modified docs/.doctrees/changelog/index.doctree
Binary file not shown.
Binary file modified docs/.doctrees/changelog/v0.10.0.doctree
Binary file not shown.
Binary file modified docs/.doctrees/changelog/v0.10.1.doctree
Binary file not shown.
Binary file modified docs/.doctrees/changelog/v0.11.0.doctree
Binary file not shown.
Binary file modified docs/.doctrees/changelog/v0.11.1.doctree
Binary file not shown.
Binary file modified docs/.doctrees/changelog/v0.11.2.doctree
Binary file not shown.
Binary file modified docs/.doctrees/changelog/v0.11.3.doctree
Binary file not shown.
Binary file modified docs/.doctrees/changelog/v0.11.4.doctree
Binary file not shown.
Binary file modified docs/.doctrees/changelog/v0.11.5.doctree
Binary file not shown.
Binary file modified docs/.doctrees/changelog/v0.12.0.doctree
Binary file not shown.
Binary file modified docs/.doctrees/changelog/v0.12.1.doctree
Binary file not shown.
Binary file modified docs/.doctrees/changelog/v0.13.0.doctree
Binary file not shown.
Binary file modified docs/.doctrees/changelog/v0.14.0.doctree
Binary file not shown.
Binary file modified docs/.doctrees/changelog/v0.14.1.doctree
Binary file not shown.
Binary file modified docs/.doctrees/changelog/v0.15.0.doctree
Binary file not shown.
Binary file modified docs/.doctrees/changelog/v0.15.1.doctree
Binary file not shown.
Binary file modified docs/.doctrees/changelog/v0.15.2.doctree
Binary file not shown.
Binary file modified docs/.doctrees/changelog/v0.16.0.doctree
Binary file not shown.
Binary file added docs/.doctrees/changelog/v0.17.0.doctree
Binary file not shown.
Binary file modified docs/.doctrees/changelog/v0.2.0.doctree
Binary file not shown.
Binary file modified docs/.doctrees/changelog/v0.6.0.doctree
Binary file not shown.
Binary file modified docs/.doctrees/devguide/custom-decorators.doctree
Binary file not shown.
Binary file modified docs/.doctrees/devguide/index.doctree
Binary file not shown.
Binary file modified docs/.doctrees/devguide/tests.doctree
Binary file not shown.
Binary file modified docs/.doctrees/environment.pickle
Binary file not shown.
Binary file modified docs/.doctrees/incompat.doctree
Binary file not shown.
Binary file modified docs/.doctrees/index.doctree
Binary file not shown.
Binary file modified docs/.doctrees/intro.doctree
Binary file not shown.
Binary file modified docs/.doctrees/src/asyncworker/asyncworker.doctree
Binary file not shown.
Binary file modified docs/.doctrees/src/asyncworker/asyncworker.easyqueue.doctree
Binary file not shown.
Binary file modified docs/.doctrees/src/asyncworker/asyncworker.http.doctree
Binary file not shown.
Binary file not shown.
Binary file not shown.
Binary file modified docs/.doctrees/src/asyncworker/asyncworker.metrics.doctree
Binary file not shown.
Binary file modified docs/.doctrees/src/asyncworker/asyncworker.rabbitmq.doctree
Binary file not shown.
Binary file modified docs/.doctrees/src/asyncworker/asyncworker.signals.doctree
Binary file not shown.
Binary file not shown.
Binary file modified docs/.doctrees/src/asyncworker/asyncworker.sse.doctree
Binary file not shown.
Binary file modified docs/.doctrees/src/asyncworker/asyncworker.testing.doctree
Binary file not shown.
Binary file modified docs/.doctrees/src/asyncworker/asyncworker.types.doctree
Binary file not shown.
Binary file modified docs/.doctrees/src/asyncworker/modules.doctree
Binary file not shown.
Binary file modified docs/.doctrees/update.doctree
Binary file not shown.
Binary file modified docs/.doctrees/userguide/asyncworker-app/hooks.doctree
Binary file not shown.
Binary file modified docs/.doctrees/userguide/asyncworker-app/index.doctree
Binary file not shown.
Binary file modified docs/.doctrees/userguide/asyncworker-app/intro.doctree
Binary file not shown.
Binary file modified docs/.doctrees/userguide/asyncworker-app/storage.doctree
Binary file not shown.
Binary file modified docs/.doctrees/userguide/handlers/http/doc.doctree
Binary file not shown.
Binary file modified docs/.doctrees/userguide/handlers/http/exposed-metrics.doctree
Binary file not shown.
Binary file modified docs/.doctrees/userguide/handlers/http/index.doctree
Binary file not shown.
Binary file modified docs/.doctrees/userguide/handlers/index.doctree
Binary file not shown.
Binary file modified docs/.doctrees/userguide/handlers/rabbitmq/doc.doctree
Binary file not shown.
Binary file not shown.
Binary file modified docs/.doctrees/userguide/handlers/rabbitmq/index.doctree
Binary file not shown.
Binary file modified docs/.doctrees/userguide/index.doctree
Binary file not shown.
Binary file modified docs/.doctrees/userguide/metrics/autoexposed-metrics.doctree
Binary file not shown.
Binary file modified docs/.doctrees/userguide/metrics/config.doctree
Binary file not shown.
Binary file modified docs/.doctrees/userguide/metrics/index.doctree
Binary file not shown.
Binary file modified docs/.doctrees/userguide/metrics/types/index.doctree
Binary file not shown.
Binary file modified docs/.doctrees/userguide/metrics/types/type_counter.doctree
Binary file not shown.
Binary file modified docs/.doctrees/userguide/metrics/types/type_gauge.doctree
Binary file not shown.
Binary file modified docs/.doctrees/userguide/metrics/types/type_histogram.doctree
Binary file not shown.
Binary file modified docs/.doctrees/userguide/quickstart.doctree
Binary file not shown.
Binary file modified docs/.doctrees/userguide/utils/index.doctree
Binary file not shown.
Binary file modified docs/.doctrees/userguide/utils/run_every.doctree
Binary file not shown.
Binary file modified docs/.doctrees/userguide/utils/timeit.doctree
Binary file not shown.
Binary file modified docs/.doctrees/versions.doctree
Binary file not shown.
3 changes: 1 addition & 2 deletions docs/_modules/asyncworker/app.html
Original file line number Diff line number Diff line change
Expand Up @@ -47,13 +47,12 @@ <h1>Código fonte para asyncworker.app</h1><div class="highlight"><pre>
<span class="kn">from</span> <span class="nn">asyncworker.signals.base</span> <span class="kn">import</span> <span class="n">Signal</span><span class="p">,</span> <span class="n">Freezable</span>
<span class="kn">from</span> <span class="nn">asyncworker.signals.handlers.http</span> <span class="kn">import</span> <span class="n">HTTPServer</span>
<span class="kn">from</span> <span class="nn">asyncworker.signals.handlers.rabbitmq</span> <span class="kn">import</span> <span class="n">RabbitMQ</span>
<span class="kn">from</span> <span class="nn">asyncworker.signals.handlers.sse</span> <span class="kn">import</span> <span class="n">SSE</span>
<span class="kn">from</span> <span class="nn">asyncworker.task_runners</span> <span class="kn">import</span> <span class="n">ScheduledTaskRunner</span>
<span class="kn">from</span> <span class="nn">asyncworker.utils</span> <span class="kn">import</span> <span class="n">entrypoint</span>


<div class="viewcode-block" id="App"><a class="viewcode-back" href="../../src/asyncworker/asyncworker.html#asyncworker.app.App">[documentos]</a><span class="k">class</span> <span class="nc">App</span><span class="p">(</span><span class="n">MutableMapping</span><span class="p">,</span> <span class="n">Freezable</span><span class="p">):</span>
<span class="n">handlers</span> <span class="o">=</span> <span class="p">(</span><span class="n">RabbitMQ</span><span class="p">(),</span> <span class="n">HTTPServer</span><span class="p">(),</span> <span class="n">SSE</span><span class="p">())</span>
<span class="n">handlers</span> <span class="o">=</span> <span class="p">(</span><span class="n">RabbitMQ</span><span class="p">(),</span> <span class="n">HTTPServer</span><span class="p">())</span>
<span class="n">shutdown_os_signals</span> <span class="o">=</span> <span class="p">(</span><span class="n">Signals</span><span class="o">.</span><span class="n">SIGINT</span><span class="p">,</span> <span class="n">Signals</span><span class="o">.</span><span class="n">SIGTERM</span><span class="p">)</span>

<span class="k">def</span> <span class="fm">__init__</span><span class="p">(</span>
Expand Down
9 changes: 0 additions & 9 deletions docs/_modules/asyncworker/connections.html
Original file line number Diff line number Diff line change
Expand Up @@ -130,15 +130,6 @@ <h1>Código fonte para asyncworker.connections</h1><div class="highlight"><pre>

<span class="n">_TYPE_COUNTER</span><span class="p">:</span> <span class="n">Counter</span><span class="p">[</span><span class="n">Type</span><span class="p">[</span><span class="n">Connection</span><span class="p">]]</span> <span class="o">=</span> <span class="n">collections</span><span class="o">.</span><span class="n">Counter</span><span class="p">()</span>


<div class="viewcode-block" id="SSEConnection"><a class="viewcode-back" href="../../src/asyncworker/asyncworker.html#asyncworker.connections.SSEConnection">[documentos]</a><span class="k">class</span> <span class="nc">SSEConnection</span><span class="p">(</span><span class="n">Connection</span><span class="p">):</span>
<span class="n">url</span><span class="p">:</span> <span class="nb">str</span>
<span class="n">user</span><span class="p">:</span> <span class="n">Optional</span><span class="p">[</span><span class="nb">str</span><span class="p">]</span> <span class="o">=</span> <span class="kc">None</span>
<span class="n">password</span><span class="p">:</span> <span class="n">Optional</span><span class="p">[</span><span class="nb">str</span><span class="p">]</span> <span class="o">=</span> <span class="kc">None</span>
<span class="n">route_type</span> <span class="o">=</span> <span class="n">RouteTypes</span><span class="o">.</span><span class="n">SSE</span>
<span class="n">name</span><span class="p">:</span> <span class="n">Optional</span><span class="p">[</span><span class="nb">str</span><span class="p">]</span> <span class="o">=</span> <span class="kc">None</span></div>


<span class="n">Message</span> <span class="o">=</span> <span class="n">Union</span><span class="p">[</span><span class="n">List</span><span class="p">,</span> <span class="n">Dict</span><span class="p">]</span>


Expand Down
1 change: 0 additions & 1 deletion docs/_modules/asyncworker/options.html
Original file line number Diff line number Diff line change
Expand Up @@ -71,7 +71,6 @@ <h1>Código fonte para asyncworker.options</h1><div class="highlight"><pre>

<div class="viewcode-block" id="RouteTypes"><a class="viewcode-back" href="../../src/asyncworker/asyncworker.html#asyncworker.options.RouteTypes">[documentos]</a><span class="k">class</span> <span class="nc">RouteTypes</span><span class="p">(</span><span class="n">AutoNameEnum</span><span class="p">):</span>
<span class="n">AMQP_RABBITMQ</span> <span class="o">=</span> <span class="n">auto</span><span class="p">()</span>
<span class="n">SSE</span> <span class="o">=</span> <span class="n">auto</span><span class="p">()</span>
<span class="n">HTTP</span> <span class="o">=</span> <span class="n">auto</span><span class="p">()</span></div>
</pre></div>

Expand Down
32 changes: 2 additions & 30 deletions docs/_modules/asyncworker/routes.html
Original file line number Diff line number Diff line change
Expand Up @@ -85,10 +85,10 @@ <h1>Código fonte para asyncworker.routes</h1><div class="highlight"><pre>
<span class="k">return</span> <span class="nb">super</span><span class="p">(</span><span class="n">Model</span><span class="p">,</span> <span class="bp">self</span><span class="p">)</span><span class="o">.</span><span class="fm">__eq__</span><span class="p">(</span><span class="n">other</span><span class="p">)</span>

<span class="k">def</span> <span class="fm">__len__</span><span class="p">(</span><span class="bp">self</span><span class="p">):</span>
<span class="k">return</span> <span class="nb">len</span><span class="p">(</span><span class="bp">self</span><span class="o">.</span><span class="n">fields</span><span class="p">)</span>
<span class="k">return</span> <span class="nb">len</span><span class="p">(</span><span class="bp">self</span><span class="o">.</span><span class="n">__fields__</span><span class="p">)</span>

<div class="viewcode-block" id="Model.keys"><a class="viewcode-back" href="../../src/asyncworker/asyncworker.html#asyncworker.routes.Model.keys">[documentos]</a> <span class="k">def</span> <span class="nf">keys</span><span class="p">(</span><span class="bp">self</span><span class="p">):</span>
<span class="k">return</span> <span class="bp">self</span><span class="o">.</span><span class="n">fields</span><span class="o">.</span><span class="n">keys</span><span class="p">()</span></div>
<span class="k">return</span> <span class="bp">self</span><span class="o">.</span><span class="n">__fields__</span><span class="o">.</span><span class="n">keys</span><span class="p">()</span></div>

<div class="viewcode-block" id="Model.get"><a class="viewcode-back" href="../../src/asyncworker/asyncworker.html#asyncworker.routes.Model.get">[documentos]</a> <span class="k">def</span> <span class="nf">get</span><span class="p">(</span><span class="bp">self</span><span class="p">,</span> <span class="n">key</span><span class="p">,</span> <span class="n">default</span><span class="o">=</span><span class="kc">None</span><span class="p">):</span>
<span class="k">try</span><span class="p">:</span>
Expand Down Expand Up @@ -123,8 +123,6 @@ <h1>Código fonte para asyncworker.routes</h1><div class="highlight"><pre>
<span class="k">return</span> <span class="n">HTTPRoute</span><span class="p">(</span><span class="o">**</span><span class="n">data</span><span class="p">)</span>
<span class="k">if</span> <span class="n">type_</span> <span class="o">==</span> <span class="n">RouteTypes</span><span class="o">.</span><span class="n">AMQP_RABBITMQ</span><span class="p">:</span>
<span class="k">return</span> <span class="n">AMQPRoute</span><span class="p">(</span><span class="o">**</span><span class="n">data</span><span class="p">)</span>
<span class="k">if</span> <span class="n">type_</span> <span class="o">==</span> <span class="n">RouteTypes</span><span class="o">.</span><span class="n">SSE</span><span class="p">:</span>
<span class="k">return</span> <span class="n">SSERoute</span><span class="p">(</span><span class="o">**</span><span class="n">data</span><span class="p">)</span>
<span class="k">raise</span> <span class="ne">ValueError</span><span class="p">(</span><span class="sa">f</span><span class="s2">&quot;&#39;</span><span class="si">{</span><span class="n">type_</span><span class="si">}</span><span class="s2">&#39; is an invalid RouteType.&quot;</span><span class="p">)</span></div></div>


Expand Down Expand Up @@ -201,28 +199,6 @@ <h1>Código fonte para asyncworker.routes</h1><div class="highlight"><pre>
<span class="n">options</span><span class="p">:</span> <span class="n">AMQPRouteOptions</span></div>


<span class="k">class</span> <span class="nc">_SSERouteOptions</span><span class="p">(</span><span class="n">_RouteOptions</span><span class="p">):</span>
<span class="n">bulk_size</span><span class="p">:</span> <span class="nb">int</span> <span class="o">=</span> <span class="n">DefaultValues</span><span class="o">.</span><span class="n">BULK_SIZE</span>
<span class="n">bulk_flush_interval</span><span class="p">:</span> <span class="nb">int</span> <span class="o">=</span> <span class="n">DefaultValues</span><span class="o">.</span><span class="n">BULK_FLUSH_INTERVAL</span>
<span class="n">headers</span><span class="p">:</span> <span class="n">Dict</span><span class="p">[</span><span class="nb">str</span><span class="p">,</span> <span class="nb">str</span><span class="p">]</span> <span class="o">=</span> <span class="p">{}</span>


<div class="viewcode-block" id="SSERoute"><a class="viewcode-back" href="../../src/asyncworker/asyncworker.html#asyncworker.routes.SSERoute">[documentos]</a><span class="k">class</span> <span class="nc">SSERoute</span><span class="p">(</span><span class="n">Route</span><span class="p">):</span>
<span class="nb">type</span><span class="p">:</span> <span class="n">RouteTypes</span> <span class="o">=</span> <span class="n">RouteTypes</span><span class="o">.</span><span class="n">SSE</span>
<span class="n">headers</span><span class="p">:</span> <span class="n">Dict</span><span class="p">[</span><span class="nb">str</span><span class="p">,</span> <span class="nb">str</span><span class="p">]</span> <span class="o">=</span> <span class="p">{}</span>
<span class="n">options</span><span class="p">:</span> <span class="n">_SSERouteOptions</span> <span class="o">=</span> <span class="n">_SSERouteOptions</span><span class="p">()</span>

<div class="viewcode-block" id="SSERoute.add_default_headers"><a class="viewcode-back" href="../../src/asyncworker/asyncworker.html#asyncworker.routes.SSERoute.add_default_headers">[documentos]</a> <span class="nd">@validator</span><span class="p">(</span><span class="s2">&quot;options&quot;</span><span class="p">,</span> <span class="n">pre</span><span class="o">=</span><span class="kc">True</span><span class="p">,</span> <span class="n">whole</span><span class="o">=</span><span class="kc">True</span><span class="p">,</span> <span class="n">always</span><span class="o">=</span><span class="kc">True</span><span class="p">)</span>
<span class="k">def</span> <span class="nf">add_default_headers</span><span class="p">(</span><span class="bp">cls</span><span class="p">,</span> <span class="n">v</span><span class="p">,</span> <span class="n">values</span><span class="p">,</span> <span class="o">**</span><span class="n">kwargs</span><span class="p">):</span>
<span class="n">headers</span> <span class="o">=</span> <span class="p">{</span>
<span class="o">**</span><span class="n">values</span><span class="o">.</span><span class="n">pop</span><span class="p">(</span><span class="s2">&quot;headers&quot;</span><span class="p">,</span> <span class="p">{}),</span>
<span class="o">**</span><span class="n">values</span><span class="o">.</span><span class="n">pop</span><span class="p">(</span><span class="s2">&quot;default_options&quot;</span><span class="p">,</span> <span class="p">{})</span><span class="o">.</span><span class="n">get</span><span class="p">(</span><span class="s2">&quot;headers&quot;</span><span class="p">,</span> <span class="p">{}),</span>
<span class="p">}</span>
<span class="n">v</span><span class="p">[</span><span class="s2">&quot;headers&quot;</span><span class="p">]</span> <span class="o">=</span> <span class="n">headers</span>

<span class="k">return</span> <span class="n">v</span></div></div>


<div class="viewcode-block" id="call_http_handler"><a class="viewcode-back" href="../../src/asyncworker/asyncworker.html#asyncworker.routes.call_http_handler">[documentos]</a><span class="k">async</span> <span class="k">def</span> <span class="nf">call_http_handler</span><span class="p">(</span><span class="n">request</span><span class="p">:</span> <span class="n">RequestWrapper</span><span class="p">,</span> <span class="n">handler</span><span class="p">:</span> <span class="n">RouteHandler</span><span class="p">):</span>
<span class="n">arg_resolver</span> <span class="o">=</span> <span class="n">ArgResolver</span><span class="p">(</span><span class="n">registry</span><span class="o">=</span><span class="n">request</span><span class="o">.</span><span class="n">types_registry</span><span class="p">)</span>
<span class="k">try</span><span class="p">:</span>
Expand Down Expand Up @@ -261,10 +237,6 @@ <h1>Código fonte para asyncworker.routes</h1><div class="highlight"><pre>
<span class="k">def</span> <span class="nf">amqp_routes</span><span class="p">(</span><span class="bp">self</span><span class="p">)</span> <span class="o">-&gt;</span> <span class="n">Iterable</span><span class="p">[</span><span class="n">AMQPRoute</span><span class="p">]:</span>
<span class="k">return</span> <span class="bp">self</span><span class="o">.</span><span class="n">_get_routes_for_type</span><span class="p">(</span><span class="n">AMQPRoute</span><span class="p">)</span>

<span class="nd">@cached_property</span>
<span class="k">def</span> <span class="nf">sse_routes</span><span class="p">(</span><span class="bp">self</span><span class="p">)</span> <span class="o">-&gt;</span> <span class="n">Iterable</span><span class="p">[</span><span class="n">SSERoute</span><span class="p">]:</span>
<span class="k">return</span> <span class="bp">self</span><span class="o">.</span><span class="n">_get_routes_for_type</span><span class="p">(</span><span class="n">SSERoute</span><span class="p">)</span>

<span class="k">def</span> <span class="fm">__setitem__</span><span class="p">(</span><span class="bp">self</span><span class="p">,</span> <span class="n">key</span><span class="p">:</span> <span class="n">RouteHandler</span><span class="p">,</span> <span class="n">value</span><span class="p">:</span> <span class="n">Union</span><span class="p">[</span><span class="n">Dict</span><span class="p">,</span> <span class="n">Route</span><span class="p">]):</span>

<span class="k">if</span> <span class="ow">not</span> <span class="nb">isinstance</span><span class="p">(</span><span class="n">value</span><span class="p">,</span> <span class="n">Route</span><span class="p">):</span>
Expand Down
3 changes: 0 additions & 3 deletions docs/_modules/index.html
Original file line number Diff line number Diff line change
Expand Up @@ -56,9 +56,6 @@ <h1>Todos os módulos onde este código está disponível</h1>
<li><a href="asyncworker/signals/handlers/base.html">asyncworker.signals.handlers.base</a></li>
<li><a href="asyncworker/signals/handlers/http.html">asyncworker.signals.handlers.http</a></li>
<li><a href="asyncworker/signals/handlers/rabbitmq.html">asyncworker.signals.handlers.rabbitmq</a></li>
<li><a href="asyncworker/signals/handlers/sse.html">asyncworker.signals.handlers.sse</a></li>
<li><a href="asyncworker/sse/consumer.html">asyncworker.sse.consumer</a></li>
<li><a href="asyncworker/sse/message.html">asyncworker.sse.message</a></li>
<li><a href="asyncworker/task_runners.html">asyncworker.task_runners</a></li>
<li><a href="asyncworker/testing.html">asyncworker.testing</a></li>
<li><a href="asyncworker/time.html">asyncworker.time</a></li>
Expand Down

0 comments on commit 18ee54e

Please sign in to comment.