Work towards getting runner to work properly.

[htsworkflow.git] / gaworkflow / runner.py

diff --git a/gaworkflow/runner.py b/gaworkflow/runner.py
index 5eb625b863933b4dd5ffa43f1c934211b0126eb1..ce27d72ad72247de199da8c95807d6856b7b95fc 100644 (file)
--- a/gaworkflow/runner.py
+++ b/gaworkflow/runner.py
@@ -11,7 +11,8 @@ from benderjab import rpc
 from gaworkflow.pipeline.configure_run import *
 from gaworkflow.pipeline.monitors import startCmdLineStatusMonitor
 
-s_fc = re.compile('FC[0-9]+')
+#s_fc = re.compile('FC[0-9]+')
+s_fc = re.compile('_[0-9a-zA-Z]*$')
 
 
 def _get_flowcell_from_rundir(run_dir):
@@ -25,7 +26,7 @@ def _get_flowcell_from_rundir(run_dir):
         logging.error('RunDir 2 FlowCell error: %s' % (run_dir))
         return None
 
-    return dirname[mo.start():]
+    return dirname[mo.start()+1:]
     
 
 
@@ -128,6 +129,7 @@ class Runner(rpc.XmlRpcBot):
 
 
     def _runner(self, run_dir, flowcell, conf_info):
+
         # retrieve config step
         cfg_filepath = os.path.abspath('config32auto.txt')
         status_retrieve_cfg = retrieve_config(conf_info,
@@ -142,7 +144,7 @@ class Runner(rpc.XmlRpcBot):
         
         # configure step
         if status_retrieve_cfg:
-            status = configure(ci)
+            status = configure(conf_info)
             if status:
                 logging.info("Runner: Configure: success")
             else:
@@ -155,7 +157,7 @@ class Runner(rpc.XmlRpcBot):
                 
                 # running step
                 print 'Running pipeline now!'
-                run_status = run_pipeline(ci)
+                run_status = run_pipeline(conf_info)
                 if run_status is True:
                     logging.info('Runner: Pipeline: success')
                     self.piplineFinished(run_dir)
@@ -175,7 +177,7 @@ class Runner(rpc.XmlRpcBot):
 
         
 def main(args=None):
-    bot = Runner()
+    bot = Runner('demobot')
     bot.cfg['loglevel'] = 'DEBUG'
     return bot.main(args)