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

bugfix

parent 4e8c1e53
No related branches found
No related tags found
No related merge requests found
""" """
Pipeline and chaining elements. Pipeline and chaining elements.
""" """
import logging
import os import os
from abc import ABC, abstractmethod from abc import ABC, abstractmethod
from typing import List from typing import List
...@@ -9,6 +10,8 @@ import traceback ...@@ -9,6 +10,8 @@ import traceback
import itertools import itertools
import yaml import yaml
from tqdm import tqdm
from time import perf_counter
import pandas as pd import pandas as pd
...@@ -23,7 +26,7 @@ from pcore.io.signal import Signal ...@@ -23,7 +26,7 @@ from pcore.io.signal import Signal
from extraction.core.functions.defaults import exparams_from_meta from extraction.core.functions.defaults import exparams_from_meta
from extraction.core.extractor import Extractor from extraction.core.extractor import Extractor
from extraction.core.parameters import Parameters from extraction.core.parameters import Parameters
from postprocessor.core.processor import PostProcessor from postprocessor.core.processor import PostProcessor, PostProcessorParameters
# from pcore.experiment import ExperimentOMERO, ExperimentLocal # from pcore.experiment import ExperimentOMERO, ExperimentLocal
# from pcore.utils import timed # from pcore.utils import timed
...@@ -60,7 +63,7 @@ class PipelineParameters(ParametersABC): ...@@ -60,7 +63,7 @@ class PipelineParameters(ParametersABC):
tiler=dict(), tiler=dict(),
baby=dict(tf_version=2), baby=dict(tf_version=2),
extraction=dict(), extraction=dict(),
postprocessing=dict(), postprocessing=PostProcessorParameters.default().to_dict(),
) )
...@@ -167,8 +170,8 @@ class Pipeline(ProcessABC): ...@@ -167,8 +170,8 @@ class Pipeline(ProcessABC):
# tiler.n_processed = process_from # tiler.n_processed = process_from
writer = TilerWriter(filename) writer = TilerWriter(filename)
runner = BabyRunner(tiler) # , baby_config=config["baby"])
session = initialise_tf(2) session = initialise_tf(2)
runner = BabyRunner(tiler) # , baby_config=config["baby"])
bwriter = BabyWriter(filename) bwriter = BabyWriter(filename)
params = ( params = (
Parameters.from_dict(config["extraction"]) Parameters.from_dict(config["extraction"])
......
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