Add the xmi file from umbrello documenting our basic pipeline usecase
[htsworkflow.git] / gaworkflow / runner.py
index c1d4ba70b7f6a172513b3644d716eb6386373cbe..f81b68200bf43a4f41fd749cf1377a65859a37f2 100644 (file)
@@ -9,7 +9,7 @@ import threading
 from benderjab import rpc
 
 from gaworkflow.pipeline.configure_run import *
-from gaworkflow.pipeline.monitors import startCmdLineStatusMonitor
+from gaworkflow.pipeline.monitors import _percentCompleted
 
 #s_fc = re.compile('FC[0-9]+')
 s_fc = re.compile('_[0-9a-zA-Z]*$')
@@ -69,8 +69,13 @@ class Runner(rpc.XmlRpcBot):
         help = u"I can send [start] a run, or report [status]"
         if re.match(u"help", msg):
             reply = help
-        elif re.match("status", msg):            
-            reply = u"not implemented"
+        elif re.match("status", msg):
+            words = msg.split()
+            if len(words) == 2:
+                reply = self.getStatusReport(words[1])
+            else:
+                reply = u"Status available for: %s" \
+                        % (', '.join([k for k in self.conf_info_dict.keys()]))
         elif re.match(u"start", msg):
             words = msg.split()
             if len(words) == 2:
@@ -84,20 +89,41 @@ class Runner(rpc.XmlRpcBot):
         logging.debug("reply: " + str(reply))
         return reply
 
-        
-    def start(self, daemonize):
-        """
-        Start application
-        """
-        super(Runner, self).start(daemonize)
 
-        
-    def stop(self):
+    def getStatusReport(self, fc_num):
         """
-        shutdown application
+        Returns text status report for flow cell number 
         """
-        super(Runner, self).stop()
+        if fc_num not in self.conf_info_dict:
+            return "No record of a %s run." % (fc_num)
+
+        status = self.conf_info_dict[fc_num].status
 
+        if status is None:
+            return "No status information for %s yet." \
+                   " Probably still in configure step. Try again later." % (fc_num)
+
+        fc,ft = status.statusFirecrest()
+        bc,bt = status.statusBustard()
+        gc,gt = status.statusGerald()
+
+        tc,tt = status.statusTotal()
+
+        fp = _percentCompleted(fc, ft)
+        bp = _percentCompleted(bc, bt)
+        gp = _percentCompleted(gc, gt)
+        tp = _percentCompleted(tc, tt)
+
+        output = []
+
+        output.append(u'Firecrest: %s%% (%s/%s)' % (fp, fc, ft))
+        output.append(u'  Bustard: %s%% (%s/%s)' % (bp, bc, bt))
+        output.append(u'   Gerald: %s%% (%s/%s)' % (gp, gc, gt))
+        output.append(u'-----------------------')
+        output.append(u'    Total: %s%% (%s/%s)' % (tp, tc, tt))
+
+        return '\n'.join(output)
+    
             
     def sequencingFinished(self, run_dir):
         """
@@ -119,6 +145,7 @@ class Runner(rpc.XmlRpcBot):
 
         # Launch the job in it's own thread and turn.
         self.launchJob(run_dir, flowcell, ci)
+        return "started"
         
         
     def pipelineFinished(self, run_dir):
@@ -201,8 +228,7 @@ class Runner(rpc.XmlRpcBot):
 
         
 def main(args=None):
-    bot = Runner('demobot')
-    bot.cfg['loglevel'] = 'DEBUG'
+    bot = Runner()
     return bot.main(args)
     
 if __name__ == "__main__":