Skip to content
Snippets Groups Projects
Commit f2efb3fb authored by Alán Muñoz's avatar Alán Muñoz
Browse files

bugfix

Former-commit-id: df390a601cab1815628cde45c21929a2b120ff65
parent bdae0e8a
No related branches found
No related tags found
No related merge requests found
...@@ -74,15 +74,16 @@ class PostProcessor: ...@@ -74,15 +74,16 @@ class PostProcessor:
# self.outpaths = parameters["outpaths"] # self.outpaths = parameters["outpaths"]
self.merger = merger(parameters["parameters"]["prepost"]["merger"]) self.merger = merger(parameters["parameters"]["prepost"]["merger"])
self.picker = picker( self.picker = picker(
parameters=parameters["parameters"]["prepost"]["picker"], parameters=parameters["parameters"]["prepost"]["picker"],
cells=Cells.from_source(filename), cells=Cells.from_source(filename),
) )
self.classfun = { self.classfun = {
process: self.get_process(process) process: self.get_process(process)
for process in parameters["targets"]["processes"].keys() for process in parameters["targets"]["processes"]
} }
self.parameters = { self.parameters_classfun = {
process: self.get_parameters(process) process: self.get_parameters(process)
for process in parameters["targets"]["processes"] for process in parameters["targets"]["processes"]
} }
...@@ -115,24 +116,27 @@ class PostProcessor: ...@@ -115,24 +116,27 @@ class PostProcessor:
changes_history = prev_idchanges + [merge_events] # + [picks] changes_history = prev_idchanges + [merge_events] # + [picks]
self._writer.write("/id_changes", data=changes_history) self._writer.write("/id_changes", data=changes_history)
self._writer.write( # self._writer.write(
"/postprocessing/merge_events/", # "/postprocessing/merge_events/",
data=merge_events, # data=merge_events,
meta={"source": "/cell_info/"}, # meta={"source": "/cell_info/"},
) # )
changes_history += picks # changes_history += picks
picks = self.picker.run(self._signal[self.targets["prepost"]["picker"][0]]) # picks = self.picker.run(self._signal[self.targets["prepost"]["picker"][0]])
# self._writer.write() # self._writer.write()
def run(self): def run(self):
self.run_prepost() self.run_prepost()
for process, datasets in self.processes["processes"].items(): for process, datasets in self.targets["processes"].items():
parameters = ( if process in self.parameters["parameters"].get(
self.parameters[process].from_dict(self.parameters[process]) "processes", {}
if process in self.parameters["processes"]["parameters"] ): # If we assigned parameters
else self.parameters[process].default() parameters = self.parameters_classfun[process](self.parameters[process])
)
else:
parameters = self.parameters_classfun[process].default()
loaded_process = self.classfun[process](parameters) loaded_process = self.classfun[process](parameters)
for dataset in datasets: for dataset in datasets:
if isinstance(dataset, list): # multisignal process if isinstance(dataset, list): # multisignal process
......
0% Loading or .
You are about to add 0 people to the discussion. Proceed with caution.
Finish editing this message first!
Please register or to comment