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

clean(pipe): Remove comments

parent 9dc1a596
No related branches found
No related tags found
No related merge requests found
...@@ -20,7 +20,7 @@ from agora.abc import ParametersABC, ProcessABC ...@@ -20,7 +20,7 @@ from agora.abc import ParametersABC, ProcessABC
from agora.io.metadata import MetaData, parse_logfiles from agora.io.metadata import MetaData, parse_logfiles
from agora.io.reader import StateReader from agora.io.reader import StateReader
from agora.io.signal import Signal from agora.io.signal import Signal
from agora.io.writer import ( # BabyWriter, from agora.io.writer import (
LinearBabyWriter, LinearBabyWriter,
StateWriter, StateWriter,
TilerWriter, TilerWriter,
...@@ -34,8 +34,6 @@ from extraction.core.extractor import Extractor, ExtractorParameters ...@@ -34,8 +34,6 @@ from extraction.core.extractor import Extractor, ExtractorParameters
from extraction.core.functions.defaults import exparams_from_meta from extraction.core.functions.defaults import exparams_from_meta
from postprocessor.core.processor import PostProcessor, PostProcessorParameters from postprocessor.core.processor import PostProcessor, PostProcessorParameters
# from postprocessor.compiler import ExperimentCompiler, PageOrganiser
class PipelineParameters(ParametersABC): class PipelineParameters(ParametersABC):
_pool_index = None _pool_index = None
...@@ -536,15 +534,6 @@ class Pipeline(ProcessABC): ...@@ -536,15 +534,6 @@ class Pipeline(ProcessABC):
finally: finally:
_close_session(session) _close_session(session)
# try:
# compiler = ExperimentCompiler(None, filepath)
# tmp = compiler.run()
# po = PageOrganiser(tmp, grid_spec=(3, 2))
# po.plot()
# po.save(fullpath / f"{directory}report.pdf")
# except Exception as e:
# print("Report failed: {}".format(e))
@staticmethod @staticmethod
def check_earlystop(filename: str, es_parameters: dict, tile_size: int): def check_earlystop(filename: str, es_parameters: dict, tile_size: int):
s = Signal(filename) s = Signal(filename)
...@@ -700,29 +689,6 @@ class Pipeline(ProcessABC): ...@@ -700,29 +689,6 @@ class Pipeline(ProcessABC):
except Exception: except Exception:
pass pass
# Delete datasets to overwrite and update pipeline data
# Use existing parameters
# with h5py.File(filename, "a") as f:
# pparams = PipelineParameters.from_yaml(
# f.attrs["parameters"]
# ).to_dict()
# for k, v in ow.items():
# if v:
# for gname in self.writer_groups[k]:
# if gname in f:
# del f[gname]
# pparams[k] = config[k]
# meta.add_fields(
# {
# "parameters": PipelineParameters.from_dict(
# pparams
# ).to_yaml()
# },
# overwrite=True,
# )
meta.run() meta.run()
meta.add_fields( # Add non-logfile metadata meta.add_fields( # Add non-logfile metadata
{ {
......
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