projects
/
htsworkflow.git
/ commitdiff
commit
grep
author
committer
pickaxe
?
search:
re
summary
|
shortlog
|
log
|
commit
| commitdiff |
tree
raw
|
patch
|
inline
| side by side (parent:
aef99a5
)
Work towards a working runner bot... still needs a bit of work.
author
Brandon King
<kingb@caltech.edu>
Fri, 21 Dec 2007 02:13:47 +0000
(
02:13
+0000)
committer
Brandon King
<kingb@caltech.edu>
Fri, 21 Dec 2007 02:13:47 +0000
(
02:13
+0000)
gaworkflow/runner.py
patch
|
blob
|
history
diff --git
a/gaworkflow/runner.py
b/gaworkflow/runner.py
index 40aa9c86d16e80640b1062b5322d747eaaf584e0..5eb625b863933b4dd5ffa43f1c934211b0126eb1 100644
(file)
--- a/
gaworkflow/runner.py
+++ b/
gaworkflow/runner.py
@@
-28,8
+28,6
@@
def _get_flowcell_from_rundir(run_dir):
return dirname[mo.start():]
return dirname[mo.start():]
-def _runner():
-
class Runner(rpc.XmlRpcBot):
"""
class Runner(rpc.XmlRpcBot):
"""
@@
-46,7
+44,8
@@
class Runner(rpc.XmlRpcBot):
self.conf_info_dict = {}
self.register_function(self.sequencingFinished)
self.conf_info_dict = {}
self.register_function(self.sequencingFinished)
- self.eventTasks.append(self.update)
+ #self.eventTasks.append(self.update)
+
def read_config(self, section=None, configfile=None):
super(Runner, self).read_config(section, configfile)
def read_config(self, section=None, configfile=None):
super(Runner, self).read_config(section, configfile)
@@
-71,20
+70,25
@@
class Runner(rpc.XmlRpcBot):
else:
reply = u"need runfolder name"
else:
else:
reply = u"need runfolder name"
else:
- reply = u"I didn't understand '%s'" %(msg)
+ reply = u"I didn't understand '%s'" %(msg)
+
+ logging.debug("reply: " + str(reply))
return reply
return reply
+
def start(self, daemonize):
"""
Start application
"""
super(Runner, self).start(daemonize)
def start(self, daemonize):
"""
Start application
"""
super(Runner, self).start(daemonize)
+
def stop(self):
"""
shutdown application
"""
super(Runner, self).stop()
def stop(self):
"""
shutdown application
"""
super(Runner, self).stop()
+
def sequencingFinished(self, run_dir):
"""
def sequencingFinished(self, run_dir):
"""
@@
-106,7
+110,6
@@
class Runner(rpc.XmlRpcBot):
# Launch the job in it's own thread and turn.
self.launchJob(run_dir, flowcell, ci)
# Launch the job in it's own thread and turn.
self.launchJob(run_dir, flowcell, ci)
-
def pipelineFinished(self, run_dir):
# need to strip off self.watch_dir from rundir I suspect.
def pipelineFinished(self, run_dir):
# need to strip off self.watch_dir from rundir I suspect.
@@
-127,7
+130,7
@@
class Runner(rpc.XmlRpcBot):
def _runner(self, run_dir, flowcell, conf_info):
# retrieve config step
cfg_filepath = os.path.abspath('config32auto.txt')
def _runner(self, run_dir, flowcell, conf_info):
# retrieve config step
cfg_filepath = os.path.abspath('config32auto.txt')
- status_retrieve_cfg = retrieve_config(c
i
,
+ status_retrieve_cfg = retrieve_config(c
onf_info
,
flowcell,
cfg_filepath,
self.genome_dir)
flowcell,
cfg_filepath,
self.genome_dir)
@@
-173,6
+176,7
@@
class Runner(rpc.XmlRpcBot):
def main(args=None):
bot = Runner()
def main(args=None):
bot = Runner()
+ bot.cfg['loglevel'] = 'DEBUG'
return bot.main(args)
if __name__ == "__main__":
return bot.main(args)
if __name__ == "__main__":