From 20cfeca0809e10057ecd1cc8a384d7b9edf065b9 Mon Sep 17 00:00:00 2001 From: yxd92326 Date: Mon, 16 Jun 2025 10:31:42 +0100 Subject: [PATCH] Only mark tomograms as requested if the rmq message has been posted --- src/murfey/server/feedback.py | 5 ++--- 1 file changed, 2 insertions(+), 3 deletions(-) diff --git a/src/murfey/server/feedback.py b/src/murfey/server/feedback.py index d63ebd8f9..80108bd87 100644 --- a/src/murfey/server/feedback.py +++ b/src/murfey/server/feedback.py @@ -1899,9 +1899,6 @@ def feedback_callback(header: dict, message: dict) -> None: and not relevant_tilt_series.processing_requested and relevant_tilt_series.tilt_series_length > 2 ): - relevant_tilt_series.processing_requested = True - murfey_db.add(relevant_tilt_series) - instrument_name = ( murfey_db.exec( select(db.Session).where(db.Session.id == session_id) @@ -1953,6 +1950,8 @@ def feedback_callback(header: dict, message: dict) -> None: logger.info( f"No transport object found. Zocalo message would be {zocalo_message}" ) + relevant_tilt_series.processing_requested = True + murfey_db.add(relevant_tilt_series) prom.preprocessed_movies.labels(processing_job=collected_ids[2].id).inc() murfey_db.commit()