Введение в Data Engineering: дата-пайплайны: Знакомство с Luigi / Task, Target, Luigid
На видео метод output выглядит обрезанным, поэтому я решил вставить пример кода задачи сюда 😉
class MyTask(luigi.Task):
filename = luigi.Parameter()
def requires(self):
return OtherTask()
def run(self):
with self.output().open('w') as f:
f.write('Done')
def output(self):
return luigi.LocalTarget(self.filename)