def _receive_architecture_in_worker(self):
    while (not self.done):
        file_data = consume_file(self.worker_queue_file)
        if (file_data is None):
            continue
        (vs, evaluation_id, searcher_eval_token, kill) = file_data
        if kill:
            write_file((self.worker_results_prefix + str(self.rank)), 'done')
            self.done = True
            return None
        return (vs, evaluation_id, searcher_eval_token)
    return None
def _receive_architecture_in_worker(self):
    while (not self.done):
        file_data = consume_file(self.worker_queue_file)
        if (file_data is None):
            continue
        (vs, evaluation_id, searcher_eval_token, kill) = file_data
        if kill:
            write_file((self.worker_results_prefix + str(self.rank)), 'done')
            self.done = True
            return None
        return (vs, evaluation_id, searcher_eval_token)
    return None