From b37ae3ef5756492e359513ecdb55c7195388bbff Mon Sep 17 00:00:00 2001 From: x12sa Date: Mon, 23 Mar 2026 16:29:30 +0100 Subject: [PATCH] wip message to scilog when tomo starts --- .../plugins/flomni/flomni.py | 59 ++++++++++--------- 1 file changed, 32 insertions(+), 27 deletions(-) diff --git a/csaxs_bec/bec_ipython_client/plugins/flomni/flomni.py b/csaxs_bec/bec_ipython_client/plugins/flomni/flomni.py index 5058f1e..75c314b 100644 --- a/csaxs_bec/bec_ipython_client/plugins/flomni/flomni.py +++ b/csaxs_bec/bec_ipython_client/plugins/flomni/flomni.py @@ -1583,16 +1583,17 @@ class Flomni( return self.sample_get_name(0) def write_to_scilog(self, content, tags: list = None): - try: - if tags is not None: - tags.append("BEC") - else: - tags = ["BEC"] - msg = bec.logbook.LogbookMessage() - msg.add_text(content).add_tag(tags) - self.client.logbook.send_logbook_message(msg) - except Exception: - logger.warning("Failed to write to scilog.") + pass + # try: + # if tags is not None: + # tags.append("BEC") + # else: + # tags = ["BEC"] + # msg = bec.tomo_progress.tomo_progressMessage() + # msg.add_text(content).add_tag(tags) + # self.client.tomo_progress.send_tomo_progress_message(msg) + # except Exception: + # logger.warning("Failed to write to scilog.") def tomo_alignment_scan(self): """ @@ -1644,16 +1645,17 @@ class Flomni( ) def _write_subtomo_to_scilog(self, subtomo_number): - dev = builtins.__dict__.get("dev") - bec = builtins.__dict__.get("bec") - if self.tomo_id > 0: - tags = ["BEC_subtomo", self.sample_name, f"tomo_id_{self.tomo_id}"] - else: - tags = ["BEC_subtomo", self.sample_name] - self.write_to_scilog( - f"Starting subtomo: {subtomo_number}. First scan number: {bec.queue.next_scan_number}.", - tags, - ) + pass + # dev = builtins.__dict__.get("dev") + # bec = builtins.__dict__.get("bec") + # if self.tomo_id > 0: + # tags = ["BEC_subtomo", self.sample_name, f"tomo_id_{self.tomo_id}"] + # else: + # tags = ["BEC_subtomo", self.sample_name] + # self.write_to_scilog( + # f"Starting subtomo: {subtomo_number}. First scan number: {bec.queue.next_scan_number}.", + # tags, + # ) def sub_tomo_scan(self, subtomo_number, start_angle=None): """ @@ -1975,7 +1977,7 @@ class Flomni( start_str = self.progress.get("tomo_start_time") projection = self.progress["projection"] total = self.progress["total_projections"] - if start_str is not None and total > 0 and projection > 0: + if start_str is not None and total > 0 and projection > 9: elapsed = ( datetime.datetime.now() - datetime.datetime.fromisoformat(start_str) ).total_seconds() @@ -2304,13 +2306,16 @@ class Flomni( # "xterm /work/sls/spec/local/XOMNY/bin/upload/upload_last_pon.sh &", shell=True # ) # status = subprocess.run(f"cp /tmp/spec-e20131-specES1.pdf {user_target}", shell=True) - msg = bec.logbook.LogbookMessage() - logo_path = os.path.join(os.path.dirname(os.path.abspath(__file__)), "LamNI_logo.png") - msg.add_file(logo_path).add_text("".join(content).replace("\n", "

")).add_tag( - ["BEC", "tomo_parameters", f"dataset_id_{dataset_id}", "flOMNI", self.sample_name] - ) - self.client.logbook.send_logbook_message(msg) + # msg = bec.tomo_progress.tomo_progressMessage() + # logo_path = os.path.join(os.path.dirname(os.path.abspath(__file__)), "LamNI_logo.png") + # msg.add_file(logo_path).add_text("".join(content).replace("\n", "

")).add_tag( + # ["BEC", "tomo_parameters", f"dataset_id_{dataset_id}", "flOMNI", self.sample_name] + # ) + # self.client.tomo_progress.send_tomo_progress_message("~/data/raw/documentation/tomo_scan_ID_{self.tomo_id}.pdf").send() + bec.messaging.scilog.new().add_text(content.replace("\n", "\r\n")).send() + + # bec.messaging.scilog.new().add_attachment() if __name__ == "__main__": import builtins