介绍
我正在做一个项目,我有几个不同的目标变量,我们利用 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
谢谢大家的帮助。