summaryrefslogtreecommitdiff
path: root/lib
diff options
context:
space:
mode:
authorGregory Becker <becker33@llnl.gov>2019-04-03 10:49:36 -0700
committerTodd Gamblin <tgamblin@llnl.gov>2019-07-18 19:28:50 -0700
commit533a8d7c820cef51257d310d9339c5a4b1b717d5 (patch)
tree55bd0b8c76e207563469ef5e1e7f695f015f2d9c /lib
parent6cfbfcc967613d94ab0110003c18d58fb22ad9eb (diff)
downloadspack-533a8d7c820cef51257d310d9339c5a4b1b717d5.tar.gz
spack-533a8d7c820cef51257d310d9339c5a4b1b717d5.tar.bz2
spack-533a8d7c820cef51257d310d9339c5a4b1b717d5.tar.xz
spack-533a8d7c820cef51257d310d9339c5a4b1b717d5.zip
stacks: update environment add/remove algorithms
Diffstat (limited to 'lib')
-rw-r--r--lib/spack/spack/environment.py104
-rw-r--r--lib/spack/spack/spec_list.py2
-rw-r--r--lib/spack/spack/test/cmd/env.py27
3 files changed, 74 insertions, 59 deletions
diff --git a/lib/spack/spack/environment.py b/lib/spack/spack/environment.py
index abc4c63e6b..bc2126af4c 100644
--- a/lib/spack/spack/environment.py
+++ b/lib/spack/spack/environment.py
@@ -674,73 +674,61 @@ class Environment(object):
elif not spack.repo.path.exists(spec.name):
raise SpackEnvironmentError('no such package: %s' % spec.name)
- added = False
- existing = False
- for i, (name, speclist) in enumerate(self.read_specs.items()):
- # Iterate over all named lists from an OrderedDict()
- if name == list_name:
- # We need to modify this list
- # TODO: Add conditional which reimplements name-level checking
- existing = str(spec) in speclist.yaml_list
- if not existing:
- speclist.add(str(spec))
- added = True
- elif added:
- # We've already modified a list, so all later lists need to
- # have their references updated.
+ list_to_change = self.read_specs[list_name]
+ existing = str(spec) in list_to_change.yaml_list
+ if not existing:
+ list_to_change.add(str(spec))
+ index = list(self.read_specs.keys()).index(list_name)
+
+ for i, (name, speclist) in enumerate(
+ list(self.read_specs.items())[index + 1:], index + 1):
new_reference = dict((n, self.read_specs[n])
for n in list(self.read_specs.keys())[:i])
speclist.update_reference(new_reference)
+
return bool(not existing)
def remove(self, query_spec, list_name='specs', force=False):
"""Remove specs from an environment that match a query_spec"""
query_spec = Spec(query_spec)
- removed = False
- for i, (name, speclist) in enumerate(self.read_specs.items()):
- # Iterate over all named lists from an OrderedDict()
- if name == list_name:
- # We need to modify this list
- # try abstract specs first
- matches = []
-
- if not query_spec.concrete:
- matches = [s for s in speclist if s.satisfies(query_spec)]
-
- if not matches:
- # concrete specs match against concrete specs in the env
- specs_hashes = zip(
- self.concretized_user_specs, self.concretized_order)
- matches = [
- s for s, h in specs_hashes
- if query_spec.dag_hash() == h
- ]
-
- if not matches:
- raise SpackEnvironmentError(
- "Not found: {0}".format(query_spec))
-
- for spec in matches:
- if spec in speclist:
- speclist.remove(spec)
- removed = True
-
- if force and spec in self.concretized_user_specs:
- i = self.concretized_user_specs.index(spec)
- del self.concretized_user_specs[i]
-
- dag_hash = self.concretized_order[i]
- del self.concretized_order[i]
- del self.specs_by_hash[dag_hash]
- removed = True
-
- elif removed:
- # We've already modified one list, so all later lists need
- # their references updated.
- new_reference = dict((n, self.read_specs[n])
- for n in list(self.read_specs.keys())[:i])
- speclist.update_reference(new_reference)
+ list_to_change = self.read_specs[list_name]
+ matches = []
+
+ if not query_spec.concrete:
+ matches = [s for s in list_to_change if s.satisfies(query_spec)]
+
+ if not matches:
+ # concrete specs match against concrete specs in the env
+ specs_hashes = zip(
+ self.concretized_user_specs, self.concretized_order)
+ matches = [
+ s for s, h in specs_hashes
+ if query_spec.dag_hash() == h
+ ]
+
+ if not matches:
+ raise SpackEnvironmentError(
+ "Not found: {0}".format(query_spec))
+
+ for spec in matches:
+ if spec in list_to_change:
+ list_to_change.remove(spec)
+
+ if force and spec in self.concretized_user_specs:
+ i = self.concretized_user_specs.index(spec)
+ del self.concretized_user_specs[i]
+
+ dag_hash = self.concretized_order[i]
+ del self.concretized_order[i]
+ del self.specs_by_hash[dag_hash]
+
+ index = list(self.read_specs.keys()).index(list_name)
+ for i, (name, speclist) in enumerate(
+ list(self.read_specs.items())[index + 1:], index + 1):
+ new_reference = dict((n, self.read_specs[n])
+ for n in list(self.read_specs.keys())[:i])
+ speclist.update_reference(new_reference)
def concretize(self, force=False):
"""Concretize user_specs in this environment.
diff --git a/lib/spack/spack/spec_list.py b/lib/spack/spack/spec_list.py
index d7a254195e..43bbd500d8 100644
--- a/lib/spack/spack/spec_list.py
+++ b/lib/spack/spack/spec_list.py
@@ -136,7 +136,7 @@ class SpecList(object):
return ret
else:
msg = 'SpecList %s refers to ' % self.name
- msg = 'named list %s ' % name
+ msg += 'named list %s ' % name
msg += 'which does not appear in its reference dict'
raise UndefinedReferenceError(msg)
# No references in this
diff --git a/lib/spack/spack/test/cmd/env.py b/lib/spack/spack/test/cmd/env.py
index 28bda0482c..d770739db7 100644
--- a/lib/spack/spack/test/cmd/env.py
+++ b/lib/spack/spack/test/cmd/env.py
@@ -827,6 +827,33 @@ env:
assert Spec('callpath') in test.user_specs
+def test_stack_yaml_remove_from_list_force(tmpdir):
+ filename = str(tmpdir.join('spack.yaml'))
+ with open(filename, 'w') as f:
+ f.write("""\
+env:
+ definitions:
+ - packages: [mpileaks, callpath]
+ specs:
+ - matrix:
+ - [$packages]
+ - [^mpich, ^zmpi]
+""")
+ with tmpdir.as_cwd():
+ env('create', 'test', './spack.yaml')
+ with ev.read('test'):
+ concretize()
+ remove('-f', '-l', 'packages', 'mpileaks')
+ find_output = find('-c')
+
+ print find_output
+ assert False
+ test = ev.read('test')
+
+ assert Spec('mpileaks') not in test.user_specs
+ assert Spec('callpath') in test.user_specs
+
+
def test_stack_yaml_attempt_remove_from_matrix(tmpdir):
filename = str(tmpdir.join('spack.yaml'))
with open(filename, 'w') as f: