在luigi中使用task_namespace会产生错误



我正在尝试理解一个使用luigi构建管道的程序。我已经了解了基本知识,但还有这个

class Task5(luigi.Task):
task_namespace = "examples"
# something else

当我用task_namespace注释这一行时,程序运行正常,但这一行失败了:

luigi.task_register.TaskClassNotFoundException: No task Task5. Did you mean:
Task                                                                 
worker  

我找不到使用task_namespace的简单示例。有人能向我解释一下如何使用这个吗?

此外,什么是";名称空间";任务?

经过大量研究,我找到了答案。task_namespace更改任务的名称。所以现在如果你想引用Task5,你应该把它称为examples.Task5,否则它就不会被识别。这就是Task5未被识别或发现的原因

相关内容

最新更新