From 433a6eb09e664b6ac6ca33f24670a22fe1f67fd6 Mon Sep 17 00:00:00 2001 From: Dan Hatton Date: Wed, 8 Apr 2026 06:41:54 +0100 Subject: [PATCH] direct publish causes problems, will need to use an API endpoint when they are available --- src/murfey/workflows/spa/ctf_estimation.py | 5 ----- src/murfey/workflows/spa/motion_correction.py | 6 ------ src/murfey/workflows/spa/picking.py | 7 ------- 3 files changed, 18 deletions(-) diff --git a/src/murfey/workflows/spa/ctf_estimation.py b/src/murfey/workflows/spa/ctf_estimation.py index 62df177b8..fbe6eda85 100644 --- a/src/murfey/workflows/spa/ctf_estimation.py +++ b/src/murfey/workflows/spa/ctf_estimation.py @@ -14,7 +14,6 @@ from smartem_backend.api_client import SmartEMAPIClient from smartem_backend.model.http_request import MicrographUpdateRequest from smartem_backend.model.http_response import MicrographResponse - from smartem_backend.mq_publisher import publish_ctf_estimation_completed from smartem_common.entity_status import MicrographStatus SMARTEM_ACTIVE = True @@ -47,10 +46,6 @@ def ctf_estimated(message: dict, murfey_db: Session) -> dict[str, bool]: update, MicrographResponse, ) - publish_ctf_estimation_completed( - micrograph_uuid=movie.smartem_uuid, - ctf_max_res=message["ctf_max_resolution"], - ) except Exception: logger.warning( "Failed to emit CTF estimation complete event to smartem", diff --git a/src/murfey/workflows/spa/motion_correction.py b/src/murfey/workflows/spa/motion_correction.py index 3681ccf18..0a50da167 100644 --- a/src/murfey/workflows/spa/motion_correction.py +++ b/src/murfey/workflows/spa/motion_correction.py @@ -14,7 +14,6 @@ from smartem_backend.api_client import SmartEMAPIClient from smartem_backend.model.http_request import MicrographUpdateRequest from smartem_backend.model.http_response import MicrographResponse - from smartem_backend.mq_publisher import publish_motion_correction_completed from smartem_common.entity_status import MicrographStatus SMARTEM_ACTIVE = True @@ -49,11 +48,6 @@ def motion_corrected(message: dict, murfey_db: Session) -> dict[str, bool]: update, MicrographResponse, ) - publish_motion_correction_completed( - micrograph_uuid=movie.smartem_uuid, - total_motion=message["total_motion"], - average_motion=message["average_motion"], - ) except Exception: logger.warning( "Failed to emit motion correction complete event to smartem", diff --git a/src/murfey/workflows/spa/picking.py b/src/murfey/workflows/spa/picking.py index 2473573a8..f500a35b5 100644 --- a/src/murfey/workflows/spa/picking.py +++ b/src/murfey/workflows/spa/picking.py @@ -36,7 +36,6 @@ from smartem_backend.api_client import SmartEMAPIClient from smartem_backend.model.http_request import MicrographUpdateRequest from smartem_backend.model.http_response import MicrographResponse - from smartem_backend.mq_publisher import publish_particle_picking_completed from smartem_common.entity_status import MicrographStatus SMARTEM_ACTIVE = True @@ -465,12 +464,6 @@ def particles_picked(message: dict, murfey_db: Session) -> dict[str, bool]: update, MicrographResponse, ) - publish_particle_picking_completed( - micrograph_uuid=movie.smartem_uuid, - number_of_particles_picked=len( - message.get("particle_diameters", []) - ), - ) except Exception: logger.warning( "Failed to emit particle picking complete event to smartem",