noe/pipeline
1
0
Fork 0
Code Issues Pull Requests Releases Wiki Activity

[aggregator] get all postprocessors, map function

Browse Source
This commit is contained in:
Noe Brucy
2021-05-04 18:31:23 +02:00
parent a9d76f830e
commit 6a998abccd
1 changed files with 6 additions and 0 deletions
Download Patch File Download Diff File Expand all files Collapse all files
aggregator.py
+6
View File
@@ -19,6 +19,12 @@ def _map_rule(rule, arg, overwrite, path, path_out, pp_params, run_num):
class Aggregator: class Aggregator:
def get_pp_list(self):
return [self.pp[run][num] for run in self.runs for num in self.nums[run]]
def map(self, func):
return [func(pp) for pp in self.get_pp_list()]
def _not_self_dep(self, name, dep, dep_arg, overwrite, select): def _not_self_dep(self, name, dep, dep_arg, overwrite, select):
if select is not None: if select is not None:
runs, nums = self.selector.select(**select) runs, nums = self.selector.select(**select)