Skip to content

Commit

Permalink
Addition of a feature that dumps generate scripts to /tmp (#92)
Browse files Browse the repository at this point in the history
Correction of some docstring warnings.

Removal of script generation.

Addition of script generation to StepRecord.

Update to use the StepRecord script generation.

Refactoring to move launching to StepRecord.

Tweaks and bug fixes.

Tweak to make tmp_dir use a boolean.

Reworking of tmp_dir in ExecutionGraph.

Two versions of lulesh_sample1 for Unix and Mac.

Correction of flake8 warnings.

Addition of --usetmp to CLI.

Addition of use_tmp to Study setup.

Addition of logging and cleanup.

Addition of logging.

Addition of clean up after study completes.

Tweak to generate workspaces on the fly.

Signed-off-by: Francesco Di Natale <dinatale3@llnl.gov>
  • Loading branch information
FrankD412 committed Apr 23, 2018
1 parent d7900c3 commit 9f3243d
Show file tree
Hide file tree
Showing 6 changed files with 294 additions and 149 deletions.
11 changes: 7 additions & 4 deletions maestrowf/conductor.py
Original file line number Diff line number Diff line change
Expand Up @@ -26,7 +26,7 @@
# OUT OF OR IN CONNECTION WITH THE SOFTWARE OR THE USE OR OTHER DEALINGS IN THE
# SOFTWARE.
###############################################################################

"""A script for launching the Maestro conductor for study monitoring."""
from argparse import ArgumentParser, RawTextHelpFormatter
from filelock import FileLock, Timeout
from datetime import datetime
Expand All @@ -50,9 +50,7 @@


def setup_argparser():
"""
Method for setting up the program's argument parser.
"""
"""Method for setting up the program's argument parser."""
parser = ArgumentParser(prog="ExecutionManager",
description="An application for checking and "
"managing an ExecutionDAG within an executing"
Expand Down Expand Up @@ -126,6 +124,7 @@ def setup_logging(args, name):


def main():
"""Run the main segment of the conductor."""
# Set up and parse the ArgumentParser
parser = setup_argparser()
args = parser.parse_args()
Expand Down Expand Up @@ -180,6 +179,10 @@ def main():
# Sleep for SLEEPTIME in args
sleep(args.sleeptime)

logger.info("Cleaning up...")
dag.cleanup()
logger.info("Squeaky clean!")

# Explicitly return a 0 status.
sys.exit(0)

Expand Down

0 comments on commit 9f3243d

Please sign in to comment.