

def timeoutCallback(self, message):
    if (message['content']['count'] < 5):
        message['content']['count'] += 1
        self.annotationDispatcher.send(message['content'], self.workerName, self.timeout)
    else:
        self.documentsNotAnnotated += 1
        if ((self.documentsNotAnnotated == message.totalDocumentsDispatched) or ((self.documentsAnnotated + self.documentsNotAnnotated) == self.totalDocumentsDispatched)):
            self.__terminate()

dataset/ETHPy150Open pandastrike/bayzee/src/annotation_dispatcher.py AnnotationDispatcher.timeoutCallback/VarMisuse@75/97 `self`->`message`