also since nothing is currently using the pipelineFinished message
authorDiane Trout <diane@caltech.edu>
Tue, 22 Apr 2008 21:58:04 +0000 (21:58 +0000)
committerDiane Trout <diane@caltech.edu>
Tue, 22 Apr 2008 21:58:04 +0000 (21:58 +0000)
from runner remove it

gaworkflow/automation/runner.py

index f81b68200bf43a4f41fd749cf1377a65859a37f2..84e9af2d310d36c37cbdf632b4f0846adabf7e68 100644 (file)
@@ -1,4 +1,5 @@
 #!/usr/bin/env python
+from glob import glob
 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))
+                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))
@@ -210,7 +214,7 @@ class Runner(rpc.XmlRpcBot):
                 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))