Я использую Luigi для выполнения нескольких задач, а затем мне нужно перенаправить вывод в стандартизованное расположение файла. Я написал WrapperTask с перегруженной complete() способом, чтобы сделат
У меня возникли проблемы с написанием двоичного файла LocalTarget в контуре Луиджи в моем проекте. Я изолировал проблему здесь: class LuigiTest(luigi.Task):
def output(self):
return luigi.L
Я получаю сообщение об ошибке «Исключение: невозможно сопоставить None с Task/dict/list». Я новичок в Луиджи. пожалуйста, advisehow может вставить в таблицу postgres, читая данные из файла.
У меня есть luigi Задача python, которая включает в себя некоторые библиотеки pyspark. Теперь я хотел бы отправить эту задачу на mesos с помощью spark-submit. Что делать, чтобы запустить его? Ниже мой
У меня проблема с настройкой повторной политики luigi для каждой задачи. Я настроил глобальный файл luigi.cfg следующим образом: [scheduler]
retry-delay: 1
retry_count: 5
[worker]
keep_alive: tru