diff --git a/lwr/lwr_client/client.py b/lwr/lwr_client/client.py index 2db63655bba464963f1660fcff2872cfb274d358..47c8a30cb78c4bae7d74996c5b3d93e49c9c02b4 100644 --- a/lwr/lwr_client/client.py +++ b/lwr/lwr_client/client.py @@ -313,7 +313,9 @@ class MessageJobClient(BaseJobClient): # before queueing. setup_params = _setup_params_from_job_config(job_config) launch_params["setup_params"] = setup_params - return self.client_manager.exchange.publish("setup", launch_params) + response = self.client_manager.exchange.publish("setup", launch_params) + log.info("Job published to setup message queue.") + return response def clean(self): del self.client_manager.status_cache[self.job_id]