diff options
author | Zuul <zuul@review.opendev.org> | 2023-02-09 22:24:37 +0000 |
---|---|---|
committer | Gerrit Code Review <review@openstack.org> | 2023-02-09 22:24:37 +0000 |
commit | 660afded0ff7070870939c801332bf0b87db8ca1 (patch) | |
tree | 57433ecf276639b33fe0c76ad739642f84558c15 /zuul | |
parent | fa78584675746476e73625113d954aecf26c5716 (diff) | |
parent | ac3122503f632df2febe4e919eee0e2851c2afb8 (diff) | |
download | zuul-660afded0ff7070870939c801332bf0b87db8ca1.tar.gz |
Merge "Refresh dependencies for changes in pipelines"
Diffstat (limited to 'zuul')
-rw-r--r-- | zuul/manager/__init__.py | 12 |
1 files changed, 6 insertions, 6 deletions
diff --git a/zuul/manager/__init__.py b/zuul/manager/__init__.py index 60eb479e0..832be780a 100644 --- a/zuul/manager/__init__.py +++ b/zuul/manager/__init__.py @@ -276,19 +276,19 @@ class PipelineManager(metaclass=ABCMeta): if not isinstance(change, model.Change): return - change_in_pipeline = False + to_refresh = set() for item in self.pipeline.getAllItems(): if not isinstance(item.change, model.Change): continue + if item.change.equals(change): + to_refresh.add(item.change) for dep_change_ref in item.change.commit_needs_changes: - if item.change.equals(change): - change_in_pipeline = True dep_change_key = ChangeKey.fromReference(dep_change_ref) if dep_change_key.isSameChange(change.cache_stat.key): - self.updateCommitDependencies(item.change, None, event) + to_refresh.add(item.change) - if change_in_pipeline: - self.updateCommitDependencies(change, None, event) + for existing_change in to_refresh: + self.updateCommitDependencies(existing_change, None, event) def reportEnqueue(self, item): if not self.pipeline.state.disabled: |