projects
/
htsworkflow.git
/ commitdiff
commit
grep
author
committer
pickaxe
?
search:
re
summary
|
shortlog
|
log
|
commit
| commitdiff |
tree
raw
|
patch
|
inline
| side by side (parent:
0e7ba51
)
also since nothing is currently using the pipelineFinished message
author
Diane Trout
<diane@caltech.edu>
Tue, 22 Apr 2008 21:58:04 +0000
(21:58 +0000)
committer
Diane Trout
<diane@caltech.edu>
Tue, 22 Apr 2008 21:58:04 +0000
(21:58 +0000)
from runner remove it
gaworkflow/automation/runner.py
patch
|
blob
|
history
diff --git
a/gaworkflow/automation/runner.py
b/gaworkflow/automation/runner.py
index f81b68200bf43a4f41fd749cf1377a65859a37f2..84e9af2d310d36c37cbdf632b4f0846adabf7e68 100644
(file)
--- a/
gaworkflow/automation/runner.py
+++ b/
gaworkflow/automation/runner.py
@@
-1,4
+1,5
@@
#!/usr/bin/env python
#!/usr/bin/env python
+from glob import glob
import logging
import os
import re
import logging
import os
import re
@@
-196,6
+197,9
@@
class Runner(rpc.XmlRpcBot):
if status:
logging.info("Runner: Configure: success")
self.reportMsg("Configure (%s): success" % (run_dir))
if status:
logging.info("Runner: Configure: success")
self.reportMsg("Configure (%s): success" % (run_dir))
+ self.reportMsg(
+ os.linesep.join(glob(os.path.join(run_dir,'Data','C*')))
+ )
else:
logging.error("Runner: Configure: failed")
self.reportMsg("Configure (%s): FAILED" % (run_dir))
else:
logging.error("Runner: Configure: failed")
self.reportMsg("Configure (%s): FAILED" % (run_dir))
@@
-210,7
+214,7
@@
class Runner(rpc.XmlRpcBot):
run_status = run_pipeline(conf_info)
if run_status is True:
logging.info('Runner: Pipeline: success')
run_status = run_pipeline(conf_info)
if run_status is True:
logging.info('Runner: Pipeline: success')
- self.
piplineFinished(run_dir
)
+ self.
reportMsg("Pipeline run (%s): Finished" % (run_dir,)
)
else:
logging.info('Runner: Pipeline: failed')
self.reportMsg("Pipeline run (%s): FAILED" % (run_dir))
else:
logging.info('Runner: Pipeline: failed')
self.reportMsg("Pipeline run (%s): FAILED" % (run_dir))