0

介绍

我正在做一个项目,我有几个不同的目标变量,我们利用 Kedro 中的相同建模框架将管道与每个目标变量挂钩。每个管道都定义有自己的命名空间。我有一个 __default__ 管道,它一起运行所有这些命名空间管道。

问题

当我在 __default__ 管道上运行时,有没有办法根据其命名空间保存日志信息?我看到链接上的帖子提到您可以登录到特定的管道文件夹(仍在尝试弄清楚如何做到这一点)。但是,我不确定是否可以让它登录到特定的命名空间文件夹。该文档仅显示如何引发额外的日志。

设置

我目前在 Kedro 0.16.6 上。该代码目前在顺序运行器上。这是我的 hooks.py

    def register_pipelines(self) -> Dict[str, Pipeline]:

        def pipeline_creation(cov):
            return pipeline(
                                create_ulm_freqsev(),
                                inputs = {'data': 'dataset'},
                                parameters = {'parameters': f'params:parameters_{cov}'},
                                namespace = f'{cov}'
                            )
        
        cov_list = ['A', 'B']

        pipeline_list = {f'{cov}': pipeline_creation(cov) for cov in cov_list}
        pipeline_list['__default__'] = reduce(add, pipeline_list.values())
        return pipeline_list

谢谢大家的帮助。

4

0 回答 0