Skip to content

Commit 4c83354

Browse files
committed
deploy: 23e1301
1 parent 05844ba commit 4c83354

2 files changed

Lines changed: 2 additions & 2 deletions

File tree

_modules/obelisk/sync/consumer.html

Lines changed: 1 addition & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -66,7 +66,7 @@ <h1>Source code for obelisk.sync.consumer</h1><div class="highlight"><pre>
6666
<span class="n">retry_strategy</span><span class="p">:</span> <span class="n">RetryStrategy</span> <span class="o">=</span> <span class="n">NoRetryStrategy</span><span class="p">(),</span>
6767
<span class="n">kind</span><span class="p">:</span> <span class="n">ObeliskKind</span> <span class="o">=</span> <span class="n">ObeliskKind</span><span class="o">.</span><span class="n">CLASSIC</span><span class="p">):</span>
6868
<span class="bp">self</span><span class="o">.</span><span class="n">async_consumer</span> <span class="o">=</span> <span class="n">AsyncConsumer</span><span class="p">(</span><span class="n">client</span><span class="p">,</span> <span class="n">secret</span><span class="p">,</span> <span class="n">retry_strategy</span><span class="p">,</span> <span class="n">kind</span><span class="p">)</span>
69-
<span class="bp">self</span><span class="o">.</span><span class="n">loop</span> <span class="o">=</span> <span class="n">asyncio</span><span class="o">.</span><span class="n">new_event_loop</span><span class="p">()</span></div>
69+
<span class="bp">self</span><span class="o">.</span><span class="n">loop</span> <span class="o">=</span> <span class="n">asyncio</span><span class="o">.</span><span class="n">get_event_loop</span><span class="p">()</span></div>
7070

7171

7272
<div class="viewcode-block" id="Consumer.single_chunk">

_modules/obelisk/sync/producer.html

Lines changed: 1 addition & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -61,7 +61,7 @@ <h1>Source code for obelisk.sync.producer</h1><div class="highlight"><pre>
6161
<span class="n">retry_strategy</span><span class="p">:</span> <span class="n">RetryStrategy</span> <span class="o">=</span> <span class="n">NoRetryStrategy</span><span class="p">(),</span>
6262
<span class="n">kind</span><span class="p">:</span> <span class="n">ObeliskKind</span> <span class="o">=</span> <span class="n">ObeliskKind</span><span class="o">.</span><span class="n">CLASSIC</span><span class="p">):</span>
6363
<span class="bp">self</span><span class="o">.</span><span class="n">async_producer</span> <span class="o">=</span> <span class="n">AsyncProducer</span><span class="p">(</span><span class="n">client</span><span class="p">,</span> <span class="n">secret</span><span class="p">,</span> <span class="n">retry_strategy</span><span class="p">,</span> <span class="n">kind</span><span class="p">)</span>
64-
<span class="bp">self</span><span class="o">.</span><span class="n">loop</span> <span class="o">=</span> <span class="n">asyncio</span><span class="o">.</span><span class="n">new_event_loop</span><span class="p">()</span></div>
64+
<span class="bp">self</span><span class="o">.</span><span class="n">loop</span> <span class="o">=</span> <span class="n">asyncio</span><span class="o">.</span><span class="n">get_event_loop</span><span class="p">()</span></div>
6565

6666

6767
<div class="viewcode-block" id="Producer.send">

0 commit comments

Comments
 (0)