问题描述
我试图了解一个使用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
无法被识别或找到的原因