Структура задачи Луиджи, чтобы получить значение из run()

У меня есть задача Python Luigi, которая принимает входные данные некоторого файла. Функция run() этой задачи предназначена для вычисления значения хеш-функции этого файла. hash = HashCalculator(self.input().path).hash() а затем переместить этот файл в другой каталог (например, /SomeDir/<first 4 digits of hash>/<hash value>.file)

Так это будет выглядеть примерно так

/SomeDir/bd12/bd12d679c214804c568ea12cb6c17...25ea36b8daf.ext

output() будет выглядеть примерно так

return luigi.LocalTarget(self.output_directory + hash[0:4] + os.sep + hash)

У меня вопрос, как я могу структурировать задачу, чтобы использовать значения в run()? В большинстве примеров используется параметр данных, который известен до выполнения задания. Я хочу использовать значение, которое производится в рамках run(),

0 ответов

Другие вопросы по тегам