Deploy preview for PR 1027 🛫

Author: jon-wurtz

pr-preview/pr-1027/reference/bloqade/analog/task/exclusive/index.html

@@ -40,26 +40,26 @@
 </span><span id=__span-0-254><a id=__codelineno-0-254 name=__codelineno-0-254></a><span class=sd>    Please ensure that it is relatively large, otherwise</span>
 </span><span id=__span-0-255><a id=__codelineno-0-255 name=__codelineno-0-255></a><span class=sd>    the server could get overloaded with queries.</span>
 </span><span id=__span-0-256><a id=__codelineno-0-256 name=__codelineno-0-256></a><span class=sd>    &quot;&quot;&quot;</span>
-</span><span id=__span-0-257><a id=__codelineno-0-257 name=__codelineno-0-257></a>    <span class=k>if</span> <span class=bp>self</span><span class=o>.</span><span class=n>_task_result_ir</span><span class=o>.</span><span class=n>task_status</span> <span class=ow>is</span> <span class=n>QuEraTaskStatusCode</span><span class=o>.</span><span class=n>Unsubmitted</span><span class=p>:</span>
-</span><span id=__span-0-258><a id=__codelineno-0-258 name=__codelineno-0-258></a>        <span class=k>raise</span> <span class=ne>ValueError</span><span class=p>(</span><span class=s2>&quot;Task ID not found.&quot;</span><span class=p>)</span>
-</span><span id=__span-0-259><a id=__codelineno-0-259 name=__codelineno-0-259></a>
-</span><span id=__span-0-260><a id=__codelineno-0-260 name=__codelineno-0-260></a>    <span class=k>if</span> <span class=bp>self</span><span class=o>.</span><span class=n>_task_result_ir</span><span class=o>.</span><span class=n>task_status</span> <span class=ow>in</span> <span class=p>[</span>
-</span><span id=__span-0-261><a id=__codelineno-0-261 name=__codelineno-0-261></a>        <span class=n>QuEraTaskStatusCode</span><span class=o>.</span><span class=n>Completed</span><span class=p>,</span>
-</span><span id=__span-0-262><a id=__codelineno-0-262 name=__codelineno-0-262></a>        <span class=n>QuEraTaskStatusCode</span><span class=o>.</span><span class=n>Partial</span><span class=p>,</span>
-</span><span id=__span-0-263><a id=__codelineno-0-263 name=__codelineno-0-263></a>        <span class=n>QuEraTaskStatusCode</span><span class=o>.</span><span class=n>Failed</span><span class=p>,</span>
-</span><span id=__span-0-264><a id=__codelineno-0-264 name=__codelineno-0-264></a>        <span class=n>QuEraTaskStatusCode</span><span class=o>.</span><span class=n>Unaccepted</span><span class=p>,</span>
-</span><span id=__span-0-265><a id=__codelineno-0-265 name=__codelineno-0-265></a>        <span class=n>QuEraTaskStatusCode</span><span class=o>.</span><span class=n>Cancelled</span><span class=p>,</span>
-</span><span id=__span-0-266><a id=__codelineno-0-266 name=__codelineno-0-266></a>    <span class=p>]:</span>
-</span><span id=__span-0-267><a id=__codelineno-0-267 name=__codelineno-0-267></a>        <span class=k>return</span> <span class=bp>self</span>
-</span><span id=__span-0-268><a id=__codelineno-0-268 name=__codelineno-0-268></a>
-</span><span id=__span-0-269><a id=__codelineno-0-269 name=__codelineno-0-269></a>    <span class=n>status</span> <span class=o>=</span> <span class=bp>self</span><span class=o>.</span><span class=n>status</span><span class=p>()</span>
-</span><span id=__span-0-270><a id=__codelineno-0-270 name=__codelineno-0-270></a>    <span class=k>if</span> <span class=n>status</span> <span class=ow>in</span> <span class=p>[</span><span class=n>QuEraTaskStatusCode</span><span class=o>.</span><span class=n>Completed</span><span class=p>,</span> <span class=n>QuEraTaskStatusCode</span><span class=o>.</span><span class=n>Partial</span><span class=p>]:</span>
-</span><span id=__span-0-271><a id=__codelineno-0-271 name=__codelineno-0-271></a>        <span class=bp>self</span><span class=o>.</span><span class=n>_task_result_ir</span> <span class=o>=</span> <span class=bp>self</span><span class=o>.</span><span class=n>_http_handler</span><span class=o>.</span><span class=n>fetch_results</span><span class=p>(</span><span class=bp>self</span><span class=o>.</span><span class=n>_task_id</span><span class=p>)</span>
-</span><span id=__span-0-272><a id=__codelineno-0-272 name=__codelineno-0-272></a>    <span class=k>else</span><span class=p>:</span>
-</span><span id=__span-0-273><a id=__codelineno-0-273 name=__codelineno-0-273></a>        <span class=n>time</span><span class=o>.</span><span class=n>sleep</span><span class=p>(</span><span class=n>poll_interval</span><span class=p>)</span>
-</span><span id=__span-0-274><a id=__codelineno-0-274 name=__codelineno-0-274></a>        <span class=bp>self</span><span class=o>.</span><span class=n>pull</span><span class=p>(</span><span class=n>poll_interval</span><span class=p>)</span>
+</span><span id=__span-0-257><a id=__codelineno-0-257 name=__codelineno-0-257></a>
+</span><span id=__span-0-258><a id=__codelineno-0-258 name=__codelineno-0-258></a>    <span class=k>while</span> <span class=kc>True</span><span class=p>:</span>
+</span><span id=__span-0-259><a id=__codelineno-0-259 name=__codelineno-0-259></a>        <span class=k>if</span> <span class=bp>self</span><span class=o>.</span><span class=n>_task_result_ir</span><span class=o>.</span><span class=n>task_status</span> <span class=ow>is</span> <span class=n>QuEraTaskStatusCode</span><span class=o>.</span><span class=n>Unsubmitted</span><span class=p>:</span>
+</span><span id=__span-0-260><a id=__codelineno-0-260 name=__codelineno-0-260></a>            <span class=k>raise</span> <span class=ne>ValueError</span><span class=p>(</span><span class=s2>&quot;Task ID not found.&quot;</span><span class=p>)</span>
+</span><span id=__span-0-261><a id=__codelineno-0-261 name=__codelineno-0-261></a>
+</span><span id=__span-0-262><a id=__codelineno-0-262 name=__codelineno-0-262></a>        <span class=k>if</span> <span class=bp>self</span><span class=o>.</span><span class=n>_task_result_ir</span><span class=o>.</span><span class=n>task_status</span> <span class=ow>in</span> <span class=p>[</span>
+</span><span id=__span-0-263><a id=__codelineno-0-263 name=__codelineno-0-263></a>            <span class=n>QuEraTaskStatusCode</span><span class=o>.</span><span class=n>Completed</span><span class=p>,</span>
+</span><span id=__span-0-264><a id=__codelineno-0-264 name=__codelineno-0-264></a>            <span class=n>QuEraTaskStatusCode</span><span class=o>.</span><span class=n>Partial</span><span class=p>,</span>
+</span><span id=__span-0-265><a id=__codelineno-0-265 name=__codelineno-0-265></a>            <span class=n>QuEraTaskStatusCode</span><span class=o>.</span><span class=n>Failed</span><span class=p>,</span>
+</span><span id=__span-0-266><a id=__codelineno-0-266 name=__codelineno-0-266></a>            <span class=n>QuEraTaskStatusCode</span><span class=o>.</span><span class=n>Unaccepted</span><span class=p>,</span>
+</span><span id=__span-0-267><a id=__codelineno-0-267 name=__codelineno-0-267></a>            <span class=n>QuEraTaskStatusCode</span><span class=o>.</span><span class=n>Cancelled</span><span class=p>,</span>
+</span><span id=__span-0-268><a id=__codelineno-0-268 name=__codelineno-0-268></a>        <span class=p>]:</span>
+</span><span id=__span-0-269><a id=__codelineno-0-269 name=__codelineno-0-269></a>            <span class=k>return</span> <span class=bp>self</span>
+</span><span id=__span-0-270><a id=__codelineno-0-270 name=__codelineno-0-270></a>
+</span><span id=__span-0-271><a id=__codelineno-0-271 name=__codelineno-0-271></a>        <span class=n>status</span> <span class=o>=</span> <span class=bp>self</span><span class=o>.</span><span class=n>status</span><span class=p>()</span>
+</span><span id=__span-0-272><a id=__codelineno-0-272 name=__codelineno-0-272></a>        <span class=k>if</span> <span class=n>status</span> <span class=ow>in</span> <span class=p>[</span><span class=n>QuEraTaskStatusCode</span><span class=o>.</span><span class=n>Completed</span><span class=p>,</span> <span class=n>QuEraTaskStatusCode</span><span class=o>.</span><span class=n>Partial</span><span class=p>]:</span>
+</span><span id=__span-0-273><a id=__codelineno-0-273 name=__codelineno-0-273></a>            <span class=bp>self</span><span class=o>.</span><span class=n>_task_result_ir</span> <span class=o>=</span> <span class=bp>self</span><span class=o>.</span><span class=n>_http_handler</span><span class=o>.</span><span class=n>fetch_results</span><span class=p>(</span><span class=bp>self</span><span class=o>.</span><span class=n>_task_id</span><span class=p>)</span>
+</span><span id=__span-0-274><a id=__codelineno-0-274 name=__codelineno-0-274></a>            <span class=k>return</span> <span class=bp>self</span>
 </span><span id=__span-0-275><a id=__codelineno-0-275 name=__codelineno-0-275></a>
-</span><span id=__span-0-276><a id=__codelineno-0-276 name=__codelineno-0-276></a>    <span class=k>return</span> <span class=bp>self</span>
+</span><span id=__span-0-276><a id=__codelineno-0-276 name=__codelineno-0-276></a>        <span class=n>time</span><span class=o>.</span><span class=n>sleep</span><span class=p>(</span><span class=n>poll_interval</span><span class=p>)</span>
 </span></code></pre></div></td></tr></table></div> </details> </div> </div> </div> </div> </div> <div class="doc doc-object doc-class"> <h2 id=bloqade.analog.task.exclusive.HTTPHandlerABC class="doc doc-heading"> <span class="doc doc-object-name doc-class-name">HTTPHandlerABC</span> <a href=#bloqade.analog.task.exclusive.HTTPHandlerABC class=headerlink title="Permanent link">&para;</a></h2> <div class="doc doc-contents "> <div class="doc doc-children"> <div class="doc doc-object doc-function"> <h3 id=bloqade.analog.task.exclusive.HTTPHandlerABC.fetch_results class="doc doc-heading"> <span class="doc doc-object-name doc-function-name">fetch_results</span> <span class="doc doc-labels"> <small class="doc doc-label doc-label-abstractmethod"><code>abstractmethod</code></small> </span> <a href=#bloqade.analog.task.exclusive.HTTPHandlerABC.fetch_results class=headerlink title="Permanent link">&para;</a></h3> <div class="language-python doc-signature highlight"><pre><span></span><code><span id=__span-0-1><a id=__codelineno-0-1 name=__codelineno-0-1 href=#__codelineno-0-1></a><span class=nf>fetch_results</span><span class=p>(</span><span class=n>task_id</span><span class=p>)</span>
 </span></code></pre></div> <div class="doc doc-contents "> <p>Fetch the task results from the AirTable.</p> <p><span class=doc-section-title>Parameters:</span></p> <table> <thead> <tr> <th>Name</th> <th>Type</th> <th>Description</th> <th>Default</th> </tr> </thead> <tbody> <tr class=doc-section-item> <td> <code>task_id</code> </td> <td> <code><span title=str>str</span></code> </td> <td> <div class=doc-md-description> <p>The task id to be queried.</p> </div> </td> <td> <em>required</em> </td> </tr> </tbody> </table> <p>returns response: The response from the AirTable. used for error handling</p> <details class=quote> <summary>Source code in <code>src/bloqade/analog/task/exclusive.py</code></summary> <div class="language-python highlight"><table class=highlighttable><tr><td class=linenos><div class=linenodiv><pre><span></span><span class=normal><a href=#__codelineno-0-50>50</a></span>
 <span class=normal><a href=#__codelineno-0-51>51</a></span>