Skip to content

Commit 73f4dba

Browse files
committed
Factors out common code from pipeline setup funcs
1 parent e6bd24b commit 73f4dba

File tree

1 file changed

+14
-18
lines changed

1 file changed

+14
-18
lines changed

bioimageio/core/proc_setup.py

Lines changed: 14 additions & 18 deletions
Original file line numberDiff line numberDiff line change
@@ -141,7 +141,7 @@ def get_requried_sample_measures(model: AnyModelDescr) -> RequiredSampleMeasures
141141
{m for m in s.post_measures if isinstance(m, SampleMeasureBase)},
142142
)
143143

144-
def _prepare_v4_preprocs(tensor_descrs: Sequence[v0_4.InputTensorDescr]) -> Tuple[List[Processing], Set[Measure]]:
144+
def _prepare_v4_preprocs(tensor_descrs: Sequence[v0_4.InputTensorDescr]) -> List[Processing]:
145145
procs: List[Processing] = []
146146
for t_descr in tensor_descrs:
147147
member_id = TensorId(str(t_descr.name))
@@ -150,10 +150,9 @@ def _prepare_v4_preprocs(tensor_descrs: Sequence[v0_4.InputTensorDescr]) -> Tupl
150150
)
151151
for proc_d in t_descr.preprocessing:
152152
procs.append(preproc_v4_to_processing(t_descr, proc_d))
153-
measures = {m for proc in procs for m in proc.required_measures}
154-
return (procs, measures)
153+
return procs
155154

156-
def _prepare_v4_postprocs(tensor_descrs: Sequence[v0_4.OutputTensorDescr]) -> Tuple[List[Processing], Set[Measure]]:
155+
def _prepare_v4_postprocs(tensor_descrs: Sequence[v0_4.OutputTensorDescr]) -> List[Processing]:
157156
procs: List[Processing] = []
158157
for t_descr in tensor_descrs:
159158
member_id = TensorId(str(t_descr.name))
@@ -162,39 +161,36 @@ def _prepare_v4_postprocs(tensor_descrs: Sequence[v0_4.OutputTensorDescr]) -> Tu
162161
)
163162
for proc_d in t_descr.postprocessing:
164163
procs.append(postproc_v4_to_processing(t_descr, proc_d))
165-
measures = {m for proc in procs for m in proc.required_measures}
166-
return (procs, measures)
164+
return procs
167165

168-
def _prepare_v5_preprocs(tensor_descrs: Sequence[v0_5.InputTensorDescr]) -> Tuple[List[Processing], Set[Measure]]:
166+
def _prepare_v5_preprocs(tensor_descrs: Sequence[v0_5.InputTensorDescr]) -> List[Processing]:
169167
procs: List[Processing] = []
170168
for t_descr in tensor_descrs:
171169
for proc_d in t_descr.preprocessing:
172170
procs.append(preproc_v5_to_processing(t_descr, proc_d))
173-
measures = {m for proc in procs for m in proc.required_measures}
174-
return (procs, measures)
171+
return procs
175172

176-
def _prepare_v5_postprocs(tensor_descrs: Sequence[v0_5.OutputTensorDescr]) -> Tuple[List[Processing], Set[Measure]]:
173+
def _prepare_v5_postprocs(tensor_descrs: Sequence[v0_5.OutputTensorDescr]) -> List[Processing]:
177174
procs: List[Processing] = []
178175
for t_descr in tensor_descrs:
179176
for proc_d in t_descr.postprocessing:
180177
procs.append(postproc_v5_to_processing(t_descr, proc_d))
181-
measures = {m for proc in procs for m in proc.required_measures}
182-
return (procs, measures)
178+
return procs
183179

184180

185181
def _prepare_setup_pre_and_postprocessing(model: AnyModelDescr) -> _SetupProcessing:
186182
if isinstance(model, v0_4.ModelDescr):
187-
pre, pre_measures = _prepare_v4_preprocs(model.inputs)
188-
post, post_measures = _prepare_v4_postprocs(model.outputs)
183+
pre = _prepare_v4_preprocs(model.inputs)
184+
post = _prepare_v4_postprocs(model.outputs)
189185
elif isinstance(model, v0_5.ModelDescr):
190-
pre, pre_measures = _prepare_v5_preprocs(model.inputs)
191-
post, post_measures = _prepare_v5_postprocs(model.outputs)
186+
pre = _prepare_v5_preprocs(model.inputs)
187+
post = _prepare_v5_postprocs(model.outputs)
192188
else:
193189
assert_never(model)
194190

195191
return _SetupProcessing(
196192
pre=pre,
197193
post=post,
198-
pre_measures=pre_measures,
199-
post_measures=post_measures,
194+
pre_measures={m for proc in pre for m in proc.required_measures},
195+
post_measures={m for proc in post for m in proc.required_measures},
200196
)

0 commit comments

Comments
 (0)