我试图掌握 luigi 的工作原理,我明白了,但实际实现有点困难;)这就是我所拥有的:
class MyTask(luigi.Task):
x = luigi.IntParameter()
def requires(self):
return OtherTask(self.x)
def run(self):
print(self.x)
class OtherTask(luigi.Task):
x = luigi.IntParameter()
def run(self):
y = self.x + 1
print(y)
这失败了RuntimeError: Unfulfilled dependency at run time: OtherTask_3_5862334ee2
。我认为我需要生成输出def output(self):
来解决此问题\功能。而且我无法理解如何在不写入文件的情况下产生合理的输出,例如:
def output(self):
return luigi.LocalTarget('words.txt')
def run(self):
words = [
'apple',
'banana',
'grapefruit'
]
with self.output().open('w') as f:
for word in words:
f.write('{word}\n'.format(word=word))
我已经尝试阅读文档,但我根本无法理解输出背后的概念。如果我只需要输出到屏幕怎么办。如果我需要将一个对象输出到另一个任务怎么办?谢谢!