Revert maestro 1.1.8 support (LLNL#241)

* reverted support of Maestro 1.1.8

* removed tests that use maestro validation

* fixed style

Author: ben-bay

CHANGELOG.md

@@ -7,7 +7,6 @@ and this project adheres to [Semantic Versioning](https://semver.org/spec/v2.0.0
 ## [Unreleased]
 
 ### Added
-- Integrated Maestro validation into merlin.
 - The sample generation command now logs stdout, stderr, and cmd.sh to merlin_info.
 - Add the bank and walltime keywords to the batch slurm launch, these
   will not alter the lsf launch.
@@ -17,7 +16,6 @@ and this project adheres to [Semantic Versioning](https://semver.org/spec/v2.0.0
 ### Fixed
 - Updated to new celery (4.4.5) syntax for signature return codes.
 - Corrected prior bugfix.
-- Unfroze Maestro version dependency.
 - Slightly improved logic by using regex to match variable tokens.
 
 ## [1.6.1]

merlin/celery.py

@@ -29,10 +29,7 @@
 ###############################################################################
 
 """Updated celery configuration."""
-from __future__ import (
-    absolute_import,
-    print_function,
-)
+from __future__ import absolute_import, print_function
 
 import logging
 import os
@@ -43,10 +40,7 @@
 from celery.signals import worker_process_init
 
 import merlin.common.security.encrypt_backend_traffic
-from merlin.config import (
-    broker,
-    results_backend,
-)
+from merlin.config import broker, results_backend
 from merlin.config.configfile import CONFIG
 from merlin.log_formatter import FORMATS
 from merlin.router import route_for_task

merlin/common/sample_index_factory.py

@@ -33,10 +33,7 @@
 """
 from parse import parse
 
-from merlin.common.sample_index import (
-    MAX_SAMPLE,
-    SampleIndex,
-)
+from merlin.common.sample_index import MAX_SAMPLE, SampleIndex
 from merlin.utils import cd
 
 

merlin/common/tasks.py

@@ -29,25 +29,13 @@
 ###############################################################################
 
 """Test tasks."""
-from __future__ import (
-    absolute_import,
-    unicode_literals,
-)
+from __future__ import absolute_import, unicode_literals
 
 import logging
 import os
 
-from celery import (
-    chain,
-    chord,
-    group,
-    shared_task,
-    signature,
-)
-from celery.exceptions import (
-    OperationalError,
-    TimeoutError,
-)
+from celery import chain, chord, group, shared_task, signature
+from celery.exceptions import OperationalError, TimeoutError
 
 from merlin.common.abstracts.enums import ReturnCode
 from merlin.common.sample_index import uniform_directories

merlin/config/broker.py

@@ -36,10 +36,7 @@
 import os
 from os.path import expanduser
 
-from merlin.config.configfile import (
-    CONFIG,
-    get_ssl_entries,
-)
+from merlin.config.configfile import CONFIG, get_ssl_entries
 
 
 try:

merlin/config/results_backend.py

@@ -36,10 +36,7 @@
 import logging
 import os
 
-from merlin.config.configfile import (
-    CONFIG,
-    get_ssl_entries,
-)
+from merlin.config.configfile import CONFIG, get_ssl_entries
 
 
 try:

merlin/display.py

@@ -40,10 +40,7 @@
 from tabulate import tabulate
 
 from merlin.ascii_art import banner_small
-from merlin.config import (
-    broker,
-    results_backend,
-)
+from merlin.config import broker, results_backend
 from merlin.config.configfile import default_config_info
 
 

merlin/examples/workflows/feature_demo/scripts/learn.py

@@ -2,7 +2,6 @@
 import sys
 
 import numpy as np
-
 from sklearn.ensemble import RandomForestRegressor
 
 

merlin/examples/workflows/hpc_demo/cumulative_sample_processor.py

@@ -1,10 +1,9 @@
 import argparse
 import os
 import sys
-
-import matplotlib.pyplot as plt
 from concurrent.futures import ProcessPoolExecutor
 
+import matplotlib.pyplot as plt
 import pandas as pd
 
 

merlin/examples/workflows/hpc_demo/sample_collector.py

@@ -1,7 +1,6 @@
 import argparse
 import os
 import sys
-
 from concurrent.futures import ProcessPoolExecutor