Added debug log to keep track of message contents being sent to 'cryoem-services' for subsequent processing

Author: tieneupin

src/murfey/workflows/clem/process_raw_lifs.py

@@ -3,6 +3,7 @@
 The recipe referred to here is stored on GitLab.
 """
 
+from logging import getLogger
 from pathlib import Path
 from typing import Optional
 
@@ -11,6 +12,8 @@
 except AttributeError:
     pass  # Ignore if ISPyB credentials environment variable not set
 
+logger = getLogger("murfey.workflows.clem.process_raw_lifs")
+
 
 def zocalo_cluster_request(
     file: Path,
@@ -43,24 +46,28 @@ def zocalo_cluster_request(
         # Load machine config to get the feedback queue
         feedback_queue: str = messenger.feedback_queue
 
-        # Send the message
-        #   The keys under "parameters" will populate all the matching fields in {}
-        #   in the processing recipe
-        messenger.send(
-            "processing_recipe",
-            {
-                "recipes": ["clem-lif-to-stack"],
-                "parameters": {
-                    # Job parameters
-                    "lif_file": f"{str(file)}",
-                    "root_folder": root_folder,
-                    # Other recipe parameters
-                    "session_dir": f"{str(session_dir)}",
-                    "session_id": session_id,
-                    "job_name": job_name,
-                    "feedback_queue": feedback_queue,
-                },
+        # Construct recipe and submit it for processing
+        recipe = {
+            "recipes": ["clem-lif-to-stack"],
+            "parameters": {
+                # Job parameters
+                "lif_file": f"{str(file)}",
+                "root_folder": root_folder,
+                # Other recipe parameters
+                "session_dir": f"{str(session_dir)}",
+                "session_id": session_id,
+                "job_name": job_name,
+                "feedback_queue": feedback_queue,
             },
+        }
+        logger.debug(
+            f"Submitting LIF processing request to {messenger.feedback_queue!r} "
+            "with the following recipe: \n"
+            f"{recipe}"
+        )
+        messenger.send(
+            queue="processing_recipe",
+            message=recipe,
             new_connection=True,
         )
     else:

src/murfey/workflows/clem/process_raw_tiffs.py

@@ -3,9 +3,12 @@
 The recipe referred to here is stored on GitLab.
 """
 
+from logging import getLogger
 from pathlib import Path
 from typing import Optional
 
+logger = getLogger("murfey.workflows.clem.process_raw_tiffs")
+
 try:
     from murfey.server.ispyb import TransportManager  # Session
 except AttributeError:
@@ -50,23 +53,30 @@ def zocalo_cluster_request(
         # Load machine config to get the feedback queue
         feedback_queue: str = messenger.feedback_queue
 
-        messenger.send(
-            "processing_recipe",
-            {
-                "recipes": ["clem-tiff-to-stack"],
-                "parameters": {
-                    # Job parameters
-                    "tiff_list": "null",
-                    "tiff_file": f"{str(tiff_list[0])}",
-                    "root_folder": root_folder,
-                    "metadata": f"{str(metadata)}",
-                    # Other recipe parameters
-                    "session_dir": f"{str(session_dir)}",
-                    "session_id": session_id,
-                    "job_name": job_name,
-                    "feedback_queue": feedback_queue,
-                },
+        # Construct recipe and submit it for processing
+        recipe = {
+            "recipes": ["clem-tiff-to-stack"],
+            "parameters": {
+                # Job parameters
+                "tiff_list": "null",
+                "tiff_file": f"{str(tiff_list[0])}",
+                "root_folder": root_folder,
+                "metadata": f"{str(metadata)}",
+                # Other recipe parameters
+                "session_dir": f"{str(session_dir)}",
+                "session_id": session_id,
+                "job_name": job_name,
+                "feedback_queue": feedback_queue,
             },
+        }
+        logger.debug(
+            f"Submitting TIFF processing request to {messenger.feedback_queue!r} "
+            "with the following recipe: \n"
+            f"{recipe}"
+        )
+        messenger.send(
+            queue="processing_recipe",
+            message=recipe,
             new_connection=True,
         )
     else: