WIP: Add debug logging

lsst-dm · Feb 6, 2025 · 822261c · 822261c
1 parent e067c61
commit 822261c
Showing 1 changed file with 2 additions and 0 deletions.
diff --git a/src/main.py b/src/main.py
@@ -283,6 +283,7 @@ def make_fanned_out_messages(message: NextVisitModel,
                     raise UnsupportedMessageError(f"No matching case for HSC salIndex {message.salIndex}")
         case instrument if instrument in instruments:
             gauges[instrument].total_received.inc()
+            logging.debug(f"make_fanned_out_messages for {instrument}.")
             return fan_out(message, instruments[instrument])
         case _:
             raise UnsupportedMessageError(f"no matching case for instrument {message.instrument}.")
@@ -357,6 +358,7 @@ def dispatch_fanned_out_messages(client: httpx.AsyncClient,
             "source": topic,
         }
 
+        logging.debug(f"Will send fan out messages")
         for fan_out_message in send_info.fan_out_messages:
             data = fan_out_message
             data_json = json.dumps(data)