Использование пространства имен задач в luigi приводит к ошибке

#python #luigi

#python #luigi

Вопрос:

Я пытаюсь понять программу, которая использует 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 используется. Может кто-нибудь объяснить мне, как это использовать?

Кроме того, что такое «пространство имен» задачи?

Комментарии:

1. какую команду вы используете для запуска своей задачи?

2. python script.py Task5 --local-scheduler

Ответ №1:

Я нашел ответ после долгих исследований. task_namespace изменяет имя задачи. Итак, теперь, если вы хотите сослаться на Task5 , вы должны ссылаться на него как examples.Task5 , потому что в противном случае он не будет распознан. Вот почему Task5 не был распознан или найден