diff --git a/examples/auxo/aggregator.py b/examples/auxo/aggregator.py
index 829bf837..27c832ae 100644
--- a/examples/auxo/aggregator.py
+++ b/examples/auxo/aggregator.py
@@ -102,9 +102,9 @@ def event_monitor(self):
                     break
 
             # Handle events queued on the aggregator
-            elif len(self.sever_events_queue) > 0:
+            elif len(self.server_events_queue) > 0:
 
-                client_id, current_event, meta, data = self.sever_events_queue.popleft()
+                client_id, current_event, meta, data = self.server_events_queue.popleft()
                 logging.info(f"Event {current_event} is received from client {client_id}")
                 event_type, cohort_id = decode_msg(current_event)
 
diff --git a/fedscale/cloud/aggregation/aggregator.py b/fedscale/cloud/aggregation/aggregator.py
index a49bde8d..05746f80 100755
--- a/fedscale/cloud/aggregation/aggregator.py
+++ b/fedscale/cloud/aggregation/aggregator.py
@@ -71,7 +71,7 @@ def __init__(self, args):
 
         # ======== Event Queue =======
         self.individual_client_events = {}  # Unicast
-        self.sever_events_queue = collections.deque()
+        self.server_events_queue = collections.deque()
         self.broadcast_events_queue = collections.deque()  # Broadcast
 
         # ======== runtime information ========
@@ -177,7 +177,7 @@ def init_control_communication(self):
             self, self.grpc_server)
         port = '[::]:{}'.format(self.args.ps_port)
 
-        logging.info(f'%%%%%%%%%% Opening aggregator sever using port {port} %%%%%%%%%%')
+        logging.info(f'%%%%%%%%%% Opening aggregator server using port {port} %%%%%%%%%%')
 
         self.grpc_server.add_insecure_port(port)
         self.grpc_server.start()
@@ -750,7 +750,7 @@ def add_event_handler(self, client_id, event, meta, data):
             data (dictionary): Data transferred in grpc communication, could be model parameters, test result.
 
         """
-        self.sever_events_queue.append((client_id, event, meta, data))
+        self.server_events_queue.append((client_id, event, meta, data))
 
     def CLIENT_REGISTER(self, request, context):
         """FL TorchClient register to the aggregator
@@ -885,8 +885,8 @@ def event_monitor(self):
                     break
 
             # Handle events queued on the aggregator
-            elif len(self.sever_events_queue) > 0:
-                client_id, current_event, meta, data = self.sever_events_queue.popleft()
+            elif len(self.server_events_queue) > 0:
+                client_id, current_event, meta, data = self.server_events_queue.popleft()
 
                 if current_event == commons.UPLOAD_MODEL:
                     self.client_completion_handler(