diff --git a/python/lsst/rubintv/analysis/service/worker.py b/python/lsst/rubintv/analysis/service/worker.py index 8cfdf67..109d703 100644 --- a/python/lsst/rubintv/analysis/service/worker.py +++ b/python/lsst/rubintv/analysis/service/worker.py @@ -82,7 +82,9 @@ def run(self) -> None: def on_message(ws: WebSocketApp, message: str) -> None: """Message received from the server.""" + logger.info(f"Executing command: {message}") response = execute_command(message, self.data_center) + logger.info(f"Sending response") ws.send(response) logger.connection(f"Connecting to rubinTV at {self._address}:{self._port}")