smartem_backend.mq_publisher#

Members

publish_acquisition_created

Publish acquisition created event to RabbitMQ

publish_acquisition_deleted

Publish acquisition deleted event to RabbitMQ

publish_acquisition_updated

Publish acquisition updated event to RabbitMQ

publish_agent_instruction_created

Publish agent instruction created event to RabbitMQ

publish_agent_instruction_expired

Publish agent instruction expired event to RabbitMQ

publish_agent_instruction_updated

Publish agent instruction updated event to RabbitMQ

publish_atlas_created

Publish atlas created event to RabbitMQ

publish_atlas_deleted

Publish atlas deleted event to RabbitMQ

publish_atlas_tile_created

Publish atlas tile created event to RabbitMQ

publish_atlas_tile_deleted

Publish atlas tile deleted event to RabbitMQ

publish_atlas_tile_updated

Publish atlas tile updated event to RabbitMQ

publish_atlas_updated

Publish atlas updated event to RabbitMQ

publish_ctf_estimation_completed

Publish CTF estimation completed event to RabbitMQ

publish_ctf_estimation_registered

Publish CTF estimation registered (after motion correction completed) event to RabbitMQ

publish_foilhole_created

Publish foil hole created event to RabbitMQ

publish_foilhole_deleted

Publish foil hole deleted event to RabbitMQ

publish_foilhole_model_prediction

Publish model prediction event for a foil hole to RabbitMQ

publish_foilhole_updated

Publish foil hole updated event to RabbitMQ

publish_grid_created

Publish grid created event to RabbitMQ

publish_grid_deleted

Publish grid deleted event to RabbitMQ

publish_grid_registered

Publish grid updated event to RabbitMQ

publish_grid_updated

Publish grid updated event to RabbitMQ

publish_gridsquare_created

Publish grid square created event to RabbitMQ

publish_gridsquare_deleted

Publish grid square deleted event to RabbitMQ

publish_gridsquare_lowmag_created

Publish low mag grid square created event to RabbitMQ

publish_gridsquare_lowmag_deleted

Publish low mag grid square deleted event to RabbitMQ

publish_gridsquare_lowmag_updated

Publish low mag grid square updated event to RabbitMQ

publish_gridsquare_model_prediction

Publish model prediction event for a grid square to RabbitMQ

publish_gridsquare_registered

Publish grid square updated event to RabbitMQ

publish_gridsquare_updated

Publish grid square updated event to RabbitMQ

publish_micrograph_created

Publish micrograph created event to RabbitMQ

publish_micrograph_deleted

Publish micrograph deleted event to RabbitMQ

publish_micrograph_updated

Publish micrograph updated event to RabbitMQ

publish_model_parameter_update

Publish model parameter update event to RabbitMQ

publish_motion_correction_completed

Publish motion correction completed event to RabbitMQ

publish_motion_correction_registered

Publish motion correction registered (after motion correction completed) event to RabbitMQ

publish_multi_foilhole_model_prediction

Publish model prediction event for a list of foil holes to RabbitMQ

publish_refresh_predictions

Publish event to trigger overall prediction recalculation

smartem_backend.mq_publisher.publish_acquisition_created(uuid, id=None, **kwargs)[source]#

Publish acquisition created event to RabbitMQ

smartem_backend.mq_publisher.publish_acquisition_updated(uuid, id=None)[source]#

Publish acquisition updated event to RabbitMQ

smartem_backend.mq_publisher.publish_acquisition_deleted(uuid)[source]#

Publish acquisition deleted event to RabbitMQ

smartem_backend.mq_publisher.publish_atlas_created(uuid, id=None, grid_uuid=None)[source]#

Publish atlas created event to RabbitMQ

smartem_backend.mq_publisher.publish_atlas_updated(uuid, id=None, grid_uuid=None)[source]#

Publish atlas updated event to RabbitMQ

smartem_backend.mq_publisher.publish_atlas_deleted(uuid)[source]#

Publish atlas deleted event to RabbitMQ

smartem_backend.mq_publisher.publish_atlas_tile_created(uuid, id=None, atlas_uuid=None)[source]#

Publish atlas tile created event to RabbitMQ

smartem_backend.mq_publisher.publish_atlas_tile_updated(uuid, id=None, atlas_uuid=None)[source]#

Publish atlas tile updated event to RabbitMQ

smartem_backend.mq_publisher.publish_atlas_tile_deleted(uuid)[source]#

Publish atlas tile deleted event to RabbitMQ

smartem_backend.mq_publisher.publish_grid_created(uuid, acquisition_uuid=None)[source]#

Publish grid created event to RabbitMQ

smartem_backend.mq_publisher.publish_grid_updated(uuid, acquisition_uuid=None)[source]#

Publish grid updated event to RabbitMQ

smartem_backend.mq_publisher.publish_grid_deleted(uuid)[source]#

Publish grid deleted event to RabbitMQ

smartem_backend.mq_publisher.publish_grid_registered(uuid: str)[source]#

Publish grid updated event to RabbitMQ

smartem_backend.mq_publisher.publish_gridsquare_created(uuid, grid_uuid=None, gridsquare_id=None)[source]#

Publish grid square created event to RabbitMQ

smartem_backend.mq_publisher.publish_gridsquare_updated(uuid, grid_uuid=None, gridsquare_id=None)[source]#

Publish grid square updated event to RabbitMQ

smartem_backend.mq_publisher.publish_gridsquare_deleted(uuid)[source]#

Publish grid square deleted event to RabbitMQ

smartem_backend.mq_publisher.publish_gridsquare_registered(uuid: str, count: int | None = None)[source]#

Publish grid square updated event to RabbitMQ

smartem_backend.mq_publisher.publish_gridsquare_lowmag_created(uuid, grid_uuid=None, gridsquare_id=None)[source]#

Publish low mag grid square created event to RabbitMQ

smartem_backend.mq_publisher.publish_gridsquare_lowmag_updated(uuid, grid_uuid=None, gridsquare_id=None)[source]#

Publish low mag grid square updated event to RabbitMQ

smartem_backend.mq_publisher.publish_gridsquare_lowmag_deleted(uuid)[source]#

Publish low mag grid square deleted event to RabbitMQ

smartem_backend.mq_publisher.publish_foilhole_created(uuid, foilhole_id=None, gridsquare_uuid=None, gridsquare_id=None)[source]#

Publish foil hole created event to RabbitMQ

smartem_backend.mq_publisher.publish_foilhole_updated(uuid, foilhole_id=None, gridsquare_uuid=None, gridsquare_id=None)[source]#

Publish foil hole updated event to RabbitMQ

smartem_backend.mq_publisher.publish_foilhole_deleted(uuid)[source]#

Publish foil hole deleted event to RabbitMQ

smartem_backend.mq_publisher.publish_micrograph_created(uuid, foilhole_uuid=None, foilhole_id=None, micrograph_id=None)[source]#

Publish micrograph created event to RabbitMQ

smartem_backend.mq_publisher.publish_micrograph_updated(uuid, foilhole_uuid=None, foilhole_id=None, micrograph_id=None)[source]#

Publish micrograph updated event to RabbitMQ

smartem_backend.mq_publisher.publish_micrograph_deleted(uuid)[source]#

Publish micrograph deleted event to RabbitMQ

smartem_backend.mq_publisher.publish_gridsquare_model_prediction(gridsquare_uuid: str, model_name: str, prediction_value: float, metric: str | None = None)[source]#

Publish model prediction event for a grid square to RabbitMQ

smartem_backend.mq_publisher.publish_foilhole_model_prediction(foilhole_uuid: str, model_name: str, prediction_value: float, metric: str | None = None)[source]#

Publish model prediction event for a foil hole to RabbitMQ

smartem_backend.mq_publisher.publish_multi_foilhole_model_prediction(foilhole_uuids: list[str], model_name: str, prediction_value: float, metric: str | None = None)[source]#

Publish model prediction event for a list of foil holes to RabbitMQ

smartem_backend.mq_publisher.publish_model_parameter_update(grid_uuid: str, model_name: str, key: str, value: float, metric: str | None = None, group: str = '')[source]#

Publish model parameter update event to RabbitMQ

smartem_backend.mq_publisher.publish_motion_correction_completed(micrograph_uuid: str, total_motion: float, average_motion: float)[source]#

Publish motion correction completed event to RabbitMQ

smartem_backend.mq_publisher.publish_motion_correction_registered(micrograph_uuid: str, quality: bool, metric_name: str | None = None)[source]#

Publish motion correction registered (after motion correction completed) event to RabbitMQ

smartem_backend.mq_publisher.publish_ctf_estimation_completed(micrograph_uuid: str, ctf_max_res: float)[source]#

Publish CTF estimation completed event to RabbitMQ

smartem_backend.mq_publisher.publish_ctf_estimation_registered(micrograph_uuid: str, quality: bool, metric_name: str | None = None)[source]#

Publish CTF estimation registered (after motion correction completed) event to RabbitMQ

smartem_backend.mq_publisher.publish_refresh_predictions(grid_uuid: str)[source]#

Publish event to trigger overall prediction recalculation

smartem_backend.mq_publisher.publish_agent_instruction_created(instruction_id, session_id, agent_id, instruction_type, payload, **kwargs)[source]#

Publish agent instruction created event to RabbitMQ

smartem_backend.mq_publisher.publish_agent_instruction_updated(instruction_id, session_id, agent_id, status, acknowledged_at=None)[source]#

Publish agent instruction updated event to RabbitMQ

smartem_backend.mq_publisher.publish_agent_instruction_expired(instruction_id, session_id, agent_id, expires_at, retry_count)[source]#

Publish agent instruction expired event to RabbitMQ