Введение в Data Engineering: дата-пайплайны: Практические задачи построения пайплайнов / Hello World с параметрами
Итак, у нас есть всё для того, чтобы провести "чистку" кода. Вы научились объявлять задачи, строить между ними зависимости и передавать динамические параметры. С учётом, что HelloTask и WorldTask были объединены в 1 — Word2FileTask, как теперь определить зависимости у HelloWorldTask? (в методе requires)
Ниже дан шаблон, который необходимо скопировать и дополнить кодом:
class HelloWorldTask(luigi.Task):
"""Combines tasks and write the result to hello_world.txt"""
def requires(self):
return [
# напишите код зависимостей
]