自定义运行模块报错

由junglewolfz创建，最终由junglewolfz更新于2022-12-20 14:20 被浏览 24 用户

问题

自定义运行模块这样写怎么不行呢

def bigquant_run(bq_graph, inputs):
    features_my = inputs[0].read()
    print('features_my',features_my)
    for x in features_my:
        features = list(x)
        print('x',x)
        parameters_list = []

        for feature in features:
            parameters = {'m3.features':feature}
            parameters_list.append({'parameters': parameters})

        def run(parameters):
            try:
                print(parameters)
                return g.run(parameters)
            except Exception as e:
                print('ERROR --------', e)
                return None

        results = T.parallel_map(run, parameters_list, max_workers=2, remote_run=True, silent=True)
        print(results)
    return results

https://bigquant.com/experimentshare/038dbeae53cd4f859ad2c5184631df60

\

解答

自定义运行模块是不需要连线的。当然也可以连线，有一个上游的模块作为输入。 方便分享一下代码链接吗？这样我们更好的排查？

自定义模块 是平台的高级优化算子，使用可参考示例：https://bigquant.com/wiki/doc/mokuai-jianjie-tzXIdkJnBW