aboutsummaryrefslogtreecommitdiffstats
path: root/jobmanager.html
diff options
context:
space:
mode:
Diffstat (limited to 'jobmanager.html')
-rw-r--r--jobmanager.html41
1 files changed, 40 insertions, 1 deletions
diff --git a/jobmanager.html b/jobmanager.html
index 5f3da63..638acd6 100644
--- a/jobmanager.html
+++ b/jobmanager.html
@@ -182,6 +182,38 @@ HEARTBEAT</p>
182</dd></dl> 182</dd></dl>
183 183
184<dl class="method"> 184<dl class="method">
185<dt id="eventmq.jobmanager.JobManager.on_request">
186<code class="descname">on_request</code><span class="sig-paren">(</span><em>msgid</em>, <em>msg</em><span class="sig-paren">)</span><a class="headerlink" href="#eventmq.jobmanager.JobManager.on_request" title="Permalink to this definition">¶</a></dt>
187<dd><p>Handles a REQUEST command</p>
188<p>Messages are formatted like this:
189[subcmd(str), {</p>
190<blockquote>
191<div>...options...</div></blockquote>
192<p>}]</p>
193<dl class="docutils">
194<dt>Subcommands:</dt>
195<dd><dl class="first last docutils">
196<dt>run - run some callable. Options:</dt>
197<dd><dl class="first docutils">
198<dt>{</dt>
199<dd><p class="first">&#8216;callable&#8217;: func or method name (eg. walk),
200&#8216;path&#8217;: module path (eg. os.path),
201&#8216;args&#8217;: (optional) list of args,
202&#8216;kwargs&#8217;: (optional) dict of kwargs,
203&#8216;class_args&#8217;: (optional) list of args for class</p>
204<blockquote>
205<div>instantiation,</div></blockquote>
206<p class="last">&#8216;class_kwargs&#8217;: (optional) dict of kwargs for class,</p>
207</dd>
208</dl>
209<p class="last">}</p>
210</dd>
211</dl>
212</dd>
213</dl>
214</dd></dl>
215
216<dl class="method">
185<dt id="eventmq.jobmanager.JobManager.process_message"> 217<dt id="eventmq.jobmanager.JobManager.process_message">
186<code class="descname">process_message</code><span class="sig-paren">(</span><em>msg</em><span class="sig-paren">)</span><a class="headerlink" href="#eventmq.jobmanager.JobManager.process_message" title="Permalink to this definition">¶</a></dt> 218<code class="descname">process_message</code><span class="sig-paren">(</span><em>msg</em><span class="sig-paren">)</span><a class="headerlink" href="#eventmq.jobmanager.JobManager.process_message" title="Permalink to this definition">¶</a></dt>
187<dd><p>Processes a message</p> 219<dd><p>Processes a message</p>
@@ -204,11 +236,18 @@ Processing takes form of calling an <cite>on_COMMAND</cite> method.</td>
204 236
205<dl class="method"> 237<dl class="method">
206<dt id="eventmq.jobmanager.JobManager.send_inform"> 238<dt id="eventmq.jobmanager.JobManager.send_inform">
207<code class="descname">send_inform</code><span class="sig-paren">(</span><span class="sig-paren">)</span><a class="headerlink" href="#eventmq.jobmanager.JobManager.send_inform" title="Permalink to this definition">¶</a></dt> 239<code class="descname">send_inform</code><span class="sig-paren">(</span><em>queue=None</em><span class="sig-paren">)</span><a class="headerlink" href="#eventmq.jobmanager.JobManager.send_inform" title="Permalink to this definition">¶</a></dt>
208<dd><p>Send an INFORM command</p> 240<dd><p>Send an INFORM command</p>
209</dd></dl> 241</dd></dl>
210 242
211<dl class="method"> 243<dl class="method">
244<dt id="eventmq.jobmanager.JobManager.send_ready">
245<code class="descname">send_ready</code><span class="sig-paren">(</span><span class="sig-paren">)</span><a class="headerlink" href="#eventmq.jobmanager.JobManager.send_ready" title="Permalink to this definition">¶</a></dt>
246<dd><p>send the READY command upstream to indicate that JobManager is ready
247for another REQUEST message.</p>
248</dd></dl>
249
250<dl class="method">
212<dt id="eventmq.jobmanager.JobManager.start"> 251<dt id="eventmq.jobmanager.JobManager.start">
213<code class="descname">start</code><span class="sig-paren">(</span><em>addr='tcp://127.0.0.1:47291'</em><span class="sig-paren">)</span><a class="headerlink" href="#eventmq.jobmanager.JobManager.start" title="Permalink to this definition">¶</a></dt> 252<code class="descname">start</code><span class="sig-paren">(</span><em>addr='tcp://127.0.0.1:47291'</em><span class="sig-paren">)</span><a class="headerlink" href="#eventmq.jobmanager.JobManager.start" title="Permalink to this definition">¶</a></dt>
214<dd><p>Connect to <cite>addr</cite> and begin listening for job requests</p> 253<dd><p>Connect to <cite>addr</cite> and begin listening for job requests</p>