|
12 | 12 | import traceback |
13 | 13 | from ast import literal_eval |
14 | 14 | from pathlib import Path |
| 15 | +from typing import Literal, Optional |
15 | 16 |
|
16 | 17 | from pydantic import BaseModel, validator |
17 | 18 | from sqlmodel import Session, select |
|
31 | 32 | logger = logging.getLogger("murfey.workflows.clem.register_preprocessing_results") |
32 | 33 |
|
33 | 34 |
|
| 35 | +# Define align and merge parameters here |
| 36 | +crop_to_n_frames: Optional[int] = 50 |
| 37 | +align_self: Literal["enabled", ""] = "enabled" |
| 38 | +flatten: Literal["mean", "min", "max", ""] = "mean" |
| 39 | +align_across: Literal["enabled", ""] = "enabled" |
| 40 | + |
| 41 | + |
34 | 42 | class LIFPreprocessingResult(BaseModel): |
35 | 43 | image_stack: Path |
36 | 44 | metadata: Path |
@@ -187,10 +195,10 @@ def register_lif_preprocessing_result( |
187 | 195 | series_name=result.series_name, |
188 | 196 | images=image_stacks, |
189 | 197 | metadata=result.metadata, |
190 | | - crop_to_n_frames=50, |
191 | | - align_self="enabled", |
192 | | - flatten="mean", |
193 | | - align_across="enabled", |
| 198 | + crop_to_n_frames=crop_to_n_frames, |
| 199 | + align_self=align_self, |
| 200 | + flatten=flatten, |
| 201 | + align_across=align_across, |
194 | 202 | messenger=_transport_object, |
195 | 203 | ) |
196 | 204 | if cluster_response is False: |
@@ -370,10 +378,10 @@ def register_tiff_preprocessing_result( |
370 | 378 | series_name=result.series_name, |
371 | 379 | images=image_stacks, |
372 | 380 | metadata=result.metadata, |
373 | | - crop_to_n_frames=50, |
374 | | - align_self="enabled", |
375 | | - flatten="mean", |
376 | | - align_across="enabled", |
| 381 | + crop_to_n_frames=crop_to_n_frames, |
| 382 | + align_self=align_self, |
| 383 | + flatten=flatten, |
| 384 | + align_across=align_across, |
377 | 385 | messenger=_transport_object, |
378 | 386 | ) |
379 | 387 | if cluster_response is False: |
|
0 commit comments