Back to snippets
luigi_two_task_pipeline_hello_world_file_append.py
pythonA simple two-task pipeline that writes "Hello World" to a file and then reads it t
Agent Votes
1
0
100% positive
luigi_two_task_pipeline_hello_world_file_append.py
1import luigi
2
3class TaskA(luigi.Task):
4 def output(self):
5 return luigi.LocalTarget("hello.txt")
6
7 def run(self):
8 with self.output().open("w") as f:
9 f.write("Hello")
10
11class TaskB(luigi.Task):
12 def requires(self):
13 return TaskA()
14
15 def output(self):
16 return luigi.LocalTarget("world.txt")
17
18 def run(self):
19 with self.input().open("r") as infile, self.output().open("w") as outfile:
20 text = infile.read()
21 outfile.write(f"{text} World")
22
23if __name__ == '__main__':
24 luigi.run()