r/guest_worker
1
0
Fork 0
Code Issues Pull requests Releases Wiki Activity

Compare commits

base: r:ac96bbff64131f204c0c327b87112121f95ea0d5
Branches Tags
r:master
r:assignment
..
compare: r:2d537e93f847b7709a9e6b99d3d37f014fa80db2
Branches Tags
r:master
r:assignment

No commits in common. "ac96bbff64131f204c0c327b87112121f95ea0d5" and "2d537e93f847b7709a9e6b99d3d37f014fa80db2" have entirely different histories.
ac96bbff64 ... 2d537e93f8

2 changed files with 1 additions and 8 deletions
Show stats Expand all files Collapse all files

3
sorteerhoed/central_management.py
View file

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

6
sorteerhoed/webserver.py
View file

@ -75,10 +75,7 @@ class WebSocketHandler(tornado.websocket.WebSocketHandler):
self.hit = self.store.currentHit 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('assignmentId'))
self.assignment_id += '_' + str(self.get_query_argument('workerId'))
self.assignment = self.hit.getLastAssignment() self.assignment = self.hit.getLastAssignment()
if self.assignment.assignment_id != self.assignment_id: if self.assignment.assignment_id != self.assignment_id:
@ -320,9 +317,6 @@ class DrawPageHandler(tornado.web.RequestHandler):
return return
assignmentId = self.get_query_argument('assignmentId', '') assignmentId = self.get_query_argument('assignmentId', '')
if len(assignmentId):
assignmentId += '_' + str(self.get_query_argument('workerId', ''))
if len(assignmentId) < 1: if len(assignmentId) < 1:
logger.critical("Accessing page without assignment id. Allowing it for debug purposes... fingers crossed?") logger.critical("Accessing page without assignment id. Allowing it for debug purposes... fingers crossed?")