在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无法被识别或找到的原因