Skip to content

Commit d6240e4

Browse files
committed
deploy: 20fd3bd
1 parent dea20ff commit d6240e4

File tree

1 file changed

+1
-1
lines changed

1 file changed

+1
-1
lines changed

_modules/obelisk/asynchronous/producer.html

Lines changed: 1 addition & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -85,7 +85,7 @@ <h1>Source code for obelisk.asynchronous.producer</h1><div class="highlight"><pr
8585
<span class="n">response</span> <span class="o">=</span> <span class="k">await</span> <span class="bp">self</span><span class="o">.</span><span class="n">http_post</span><span class="p">(</span><span class="sa">f</span><span class="s1">&#39;</span><span class="si">{</span><span class="bp">self</span><span class="o">.</span><span class="n">_ingest_url</span><span class="si">}</span><span class="s1">/</span><span class="si">{</span><span class="n">dataset</span><span class="si">}</span><span class="s1">&#39;</span><span class="p">,</span> <span class="n">data</span><span class="o">=</span><span class="n">data</span><span class="p">,</span>
8686
<span class="n">params</span><span class="o">=</span><span class="n">params</span><span class="p">)</span>
8787
<span class="k">if</span> <span class="n">response</span><span class="o">.</span><span class="n">status_code</span> <span class="o">!=</span> <span class="mi">204</span><span class="p">:</span>
88-
<span class="n">msg</span> <span class="o">=</span> <span class="sa">f</span><span class="s1">&#39;An error occured during data ingest. Status </span><span class="si">{</span><span class="n">response</span><span class="o">.</span><span class="n">status_code</span><span class="si">}</span><span class="s1">, messasge: </span><span class="si">{</span><span class="n">response</span><span class="o">.</span><span class="n">text</span><span class="si">}</span><span class="s1">&#39;</span>
88+
<span class="n">msg</span> <span class="o">=</span> <span class="sa">f</span><span class="s1">&#39;An error occured during data ingest. Status </span><span class="si">{</span><span class="n">response</span><span class="o">.</span><span class="n">status_code</span><span class="si">}</span><span class="s1">, message: </span><span class="si">{</span><span class="n">response</span><span class="o">.</span><span class="n">text</span><span class="si">}</span><span class="s1">&#39;</span>
8989
<span class="bp">self</span><span class="o">.</span><span class="n">log</span><span class="o">.</span><span class="n">warning</span><span class="p">(</span><span class="n">msg</span><span class="p">)</span>
9090
<span class="k">raise</span> <span class="n">ObeliskError</span><span class="p">(</span><span class="n">msg</span><span class="p">)</span>
9191
<span class="k">return</span> <span class="n">response</span></div>

0 commit comments

Comments
 (0)