X-Git-Url: http://git.onelab.eu/?a=blobdiff_plain;ds=sidebyside;f=src%2Fnepi%2Fexecution%2Fec.py;h=ad698932da849c91ae528564c1979de11f1743af;hb=c01d40579e6d77f12327072dec0fb82c41676bb0;hp=5584c681b28143c06c6ab76b0ebe421b0cac7035;hpb=6edad7ea622a35c759a3667385dbb6a294245ec0;p=nepi.git diff --git a/src/nepi/execution/ec.py b/src/nepi/execution/ec.py index 5584c681..ad698932 100644 --- a/src/nepi/execution/ec.py +++ b/src/nepi/execution/ec.py @@ -201,19 +201,9 @@ class ExperimentController(object): # EC state self._state = ECState.RUNNING - # Blacklist file for PL nodes - nepi_home = os.path.join(os.path.expanduser("~"), ".nepi") - plblacklist_file = os.path.join(nepi_home, "plblacklist.txt") - if not os.path.exists(plblacklist_file): - if os.path.isdir(nepi_home): - open(plblacklist_file, 'w').close() - else: - os.makedirs(nepi_home) - open(plblacklist_file, 'w').close() - # The runner is a pool of threads used to parallelize # execution of tasks - nthreads = int(os.environ.get("NEPI_NTHREADS", "50")) + nthreads = int(os.environ.get("NEPI_NTHREADS", "3")) self._runner = ParallelRun(maxthreads = nthreads) # Event processing thread @@ -332,7 +322,6 @@ class ExperimentController(object): :type guids: list """ - if isinstance(guids, int): guids = [guids]