Skip to content

Commit 8c0835a

Browse files
committed
Register search maps after data collection updates
1 parent 51e771d commit 8c0835a

File tree

3 files changed

+20
-5
lines changed

3 files changed

+20
-5
lines changed

src/murfey/server/api/session_control.py

Lines changed: 4 additions & 4 deletions
Original file line numberDiff line numberDiff line change
@@ -54,16 +54,16 @@
5454
SearchMapParameters,
5555
Visit,
5656
)
57-
from murfey.util.tomo_metadata import (
58-
register_batch_position_in_database,
59-
register_search_map_in_database,
60-
)
6157
from murfey.workflows.spa.flush_spa_preprocess import (
6258
register_foil_hole as _register_foil_hole,
6359
)
6460
from murfey.workflows.spa.flush_spa_preprocess import (
6561
register_grid_square as _register_grid_square,
6662
)
63+
from murfey.workflows.tomo.tomo_metadata import (
64+
register_batch_position_in_database,
65+
register_search_map_in_database,
66+
)
6767

6868
logger = getLogger("murfey.server.api.session_control")
6969

src/murfey/server/api/workflow.py

Lines changed: 16 additions & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -50,20 +50,26 @@
5050
Movie,
5151
PreprocessStash,
5252
ProcessingJob,
53+
SearchMap,
5354
Session,
5455
SessionProcessingParameters,
5556
SPAFeedbackParameters,
5657
SPARelionParameters,
5758
Tilt,
5859
TiltSeries,
5960
)
60-
from murfey.util.models import ProcessingParametersSPA, ProcessingParametersTomo
61+
from murfey.util.models import (
62+
ProcessingParametersSPA,
63+
ProcessingParametersTomo,
64+
SearchMapParameters,
65+
)
6166
from murfey.util.processing_params import (
6267
cryolo_model_path,
6368
default_spa_parameters,
6469
motion_corrected_mrc,
6570
)
6671
from murfey.util.tomo import midpoint
72+
from murfey.workflows.tomo.tomo_metadata import register_search_map_in_database
6773

6874
logger = getLogger("murfey.server.api.workflow")
6975

@@ -136,6 +142,15 @@ def register_dc_group(
136142
dcg_murfey[0].atlas_id = atlas_id_response["return_value"]
137143
db.add(dcg_murfey[0])
138144
db.commit()
145+
146+
search_maps = db.exec(
147+
select(SearchMap)
148+
.where(SearchMap.session_id == session_id)
149+
.where(SearchMap.tag == dcg_params.tag)
150+
).all()
151+
search_map_params = SearchMapParameters(tag=dcg_params.tag)
152+
for sm in search_maps:
153+
register_search_map_in_database(session_id, sm.name, search_map_params, db)
139154
else:
140155
dcg_parameters = {
141156
"start_time": str(datetime.now()),
File renamed without changes.

0 commit comments

Comments
 (0)