def _receive_results_in_master(self, src):
    result = consume_file((self.worker_results_prefix + str((src + 1))))
    if (result == 'done'):
        self.finished += 1
        return None
    return result
def _receive_results_in_master(self, src):
    result = consume_file((self.worker_results_prefix + str((src + 1))))
    if (result == 'done'):
        self.finished += 1
        return None
    return result