Add changes for d06ac13

MetPX · May 27, 2024 · 041ee08 · 041ee08
1 parent 6f3146d
commit 041ee08
Showing 1 changed file with 2 additions and 3 deletions.
diff --git a/_modules/sarracenia/flow.html b/_modules/sarracenia/flow.html
@@ -555,7 +555,6 @@ <h1>Source code for sarracenia.flow</h1><div class="highlight"><pre>
         <span class="n">logger</span><span class="o">.</span><span class="n">info</span><span class="p">(</span>
             <span class="sa">f</span><span class="s1">&#39;ok, telling </span><span class="si">{</span><span class="nb">len</span><span class="p">(</span><span class="bp">self</span><span class="o">.</span><span class="n">plugins</span><span class="p">[</span><span class="s2">&quot;please_stop&quot;</span><span class="p">])</span><span class="si">}</span><span class="s1"> callbacks about it.&#39;</span>
         <span class="p">)</span>
-        <span class="bp">self</span><span class="o">.</span><span class="n">runCallbacksTime</span><span class="p">(</span><span class="s1">&#39;please_stop&#39;</span><span class="p">)</span>
         <span class="bp">self</span><span class="o">.</span><span class="n">_stop_requested</span> <span class="o">=</span> <span class="kc">True</span>
         <span class="bp">self</span><span class="o">.</span><span class="n">metrics</span><span class="p">[</span><span class="s2">&quot;flow&quot;</span><span class="p">][</span><span class="s1">&#39;stop_requested&#39;</span><span class="p">]</span> <span class="o">=</span> <span class="kc">True</span>
 
@@ -686,7 +685,7 @@ <h1>Source code for sarracenia.flow</h1><div class="highlight"><pre>
             <span class="n">total_messages</span> <span class="o">+=</span> <span class="n">last_gather_len</span>
 
             <span class="k">if</span> <span class="p">(</span><span class="bp">self</span><span class="o">.</span><span class="n">o</span><span class="o">.</span><span class="n">messageCountMax</span> <span class="o">&gt;</span> <span class="mi">0</span><span class="p">)</span> <span class="ow">and</span> <span class="p">(</span><span class="n">total_messages</span> <span class="o">&gt;</span> <span class="bp">self</span><span class="o">.</span><span class="n">o</span><span class="o">.</span><span class="n">messageCountMax</span><span class="p">):</span>
-                <span class="bp">self</span><span class="o">.</span><span class="n">please_stop</span><span class="p">()</span>
+                <span class="bp">self</span><span class="o">.</span><span class="n">runCallbacksTime</span><span class="p">(</span><span class="s1">&#39;please_stop&#39;</span><span class="p">)</span>
 
             <span class="n">current_rate</span> <span class="o">=</span> <span class="n">total_messages</span> <span class="o">/</span> <span class="n">run_time</span>
             <span class="n">elapsed</span> <span class="o">=</span> <span class="n">now</span> <span class="o">-</span> <span class="n">last_time</span>
@@ -700,7 +699,7 @@ <h1>Source code for sarracenia.flow</h1><div class="highlight"><pre>
                     <span class="c1"># Sleep for a while. Messages can&#39;t be retried before housekeeping has run...</span>
                     <span class="n">current_sleep</span> <span class="o">=</span> <span class="mi">60</span>
                 <span class="k">else</span><span class="p">:</span>
-                    <span class="bp">self</span><span class="o">.</span><span class="n">please_stop</span><span class="p">()</span>
+                    <span class="bp">self</span><span class="o">.</span><span class="n">runCallbacksTime</span><span class="p">(</span><span class="s1">&#39;please_stop&#39;</span><span class="p">)</span>
 
             <span class="k">if</span> <span class="n">spamming</span> <span class="ow">and</span> <span class="p">(</span><span class="n">current_sleep</span> <span class="o">&lt;</span> <span class="mi">5</span><span class="p">):</span>
                 <span class="n">current_sleep</span> <span class="o">*=</span> <span class="mi">2</span>