sorteerhoed/central_management.py

@@ -326,8 +326,7 @@ class CentralManagement():
                             sqsHit = self.currentHit
                             updateStatus = True
                             
-                        assId = signal.params['event']['AssignmentId'] + '_' + signal.params['event']['WorkerId']
-                        sqsAssignment = sqsHit.getAssignmentById(assId)
+                        sqsAssignment = sqsHit.getAssignmentById(signal.params['event']['AssignmentId'])
                         if not sqsAssignment:
                             self.logger.critical(f"Invalid assignmentId given for hit: {signal.params['event']}")
                             continue

sorteerhoed/webserver.py

@@ -75,10 +75,7 @@ class WebSocketHandler(tornado.websocket.WebSocketHandler):
 
         self.hit = self.store.currentHit
 
-        # my core assumption about assignment_id was wrong. It is not unique per worker, so we need to merge those
         self.assignment_id = str(self.get_query_argument('assignmentId'))
-        self.assignment_id += '_' + str(self.get_query_argument('workerId'))
-        
         self.assignment = self.hit.getLastAssignment()
         
         if self.assignment.assignment_id != self.assignment_id:
@@ -320,9 +317,6 @@ class DrawPageHandler(tornado.web.RequestHandler):
                 return
 
             assignmentId = self.get_query_argument('assignmentId', '')
-            if len(assignmentId):
-                assignmentId += '_' + str(self.get_query_argument('workerId', ''))
-            
             if len(assignmentId) < 1:
                 logger.critical("Accessing page without assignment id. Allowing it for debug purposes... fingers crossed?")