train.py 文件源码

def __init__(self, data, conn):
        self.data = data
        self.parallel_count = int(data['parallel_count'])
        self.code_name = self.data['code_name']
        self.train_id = self.data['train_id']
        self.cur_iter_id = 0
        self.q = Queue(connection=conn)
        self.tasks = []
        self.enqueue_task()