Skip to content

Commit 1c08889

Browse files
committed
Only mark tomograms as requested if the rmq message has been posted
1 parent bbdeaf3 commit 1c08889

File tree

1 file changed

+2
-3
lines changed

1 file changed

+2
-3
lines changed

src/murfey/server/feedback.py

Lines changed: 2 additions & 3 deletions
Original file line numberDiff line numberDiff line change
@@ -1899,9 +1899,6 @@ def feedback_callback(header: dict, message: dict) -> None:
18991899
and not relevant_tilt_series.processing_requested
19001900
and relevant_tilt_series.tilt_series_length > 2
19011901
):
1902-
relevant_tilt_series.processing_requested = True
1903-
murfey_db.add(relevant_tilt_series)
1904-
19051902
instrument_name = (
19061903
murfey_db.exec(
19071904
select(db.Session).where(db.Session.id == session_id)
@@ -1953,6 +1950,8 @@ def feedback_callback(header: dict, message: dict) -> None:
19531950
logger.info(
19541951
f"No transport object found. Zocalo message would be {zocalo_message}"
19551952
)
1953+
relevant_tilt_series.processing_requested = True
1954+
murfey_db.add(relevant_tilt_series)
19561955

19571956
prom.preprocessed_movies.labels(processing_job=collected_ids[2].id).inc()
19581957
murfey_db.commit()

0 commit comments

Comments
 (0)