Remove direct publishes from SmartEM integration (#778)

Will replace with API calls when available

Author: d-j-hatton

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",

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",

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",