Структура задачи Луиджи, чтобы получить значение из 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()
,