Merge pull request #51 from ecmwf/develop

feat[broker]: add user limits info log

Author: peshence

polytope_server/broker/broker.py

@@ -111,17 +111,14 @@ def check_limits(self, active_requests, request):
             user_active_requests = sum(
                 qr.collection == request.collection and qr.user == request.user for qr in active_requests
             )
+            user_limit_message = (
+                f"User {request.user} has {user_active_requests} of {limit} "
+                f"active requests in collection {request.collection}"
+            )
+            logging.info(user_limit_message)
             if user_active_requests >= limit:
-                logging.debug(
-                    f"User {request.user} has {user_active_requests} of {limit} "
-                    f"active requests in collection {request.collection}"
-                )
                 return False
             else:
-                logging.debug(
-                    f"User {request.user} has {user_active_requests} of {limit} "
-                    f"active requests in collection {request.collection}"
-                )
                 return True
 
         # Allow if no limits are exceeded

polytope_server/worker/worker.py

@@ -163,7 +163,7 @@ def run(self):
                                 extra={"request_id": id},
                             )
                             self.request.set_status(Status.FAILED)
-                            self.request.user_message = (
+                            self.request.user_message += (
                                 "Request was not processed due to an unexpected worker crash. Please contact support."
                             )
                             self.request_store.update_request(self.request)