2

ドキュメントからpython luigiのを実行しようとしました:

class TaskA(luigi.Task):
    def output(self):
        return luigi.LocalTarget('xyz')

class FlipLinesBackwards(luigi.Task):
    def requires(self):
        return TaskA()

    def output(self):
        return luigi.LocalTarget('abc')

    def run(self):
        f = self.input().open('r') # this will return a file stream that reads from "xyz"
        g = self.output().open('w')
        for line in f:
           g.write('%s\n', ''.join(reversed(line.strip().split())))
        g.close() # needed because files are atomic

コマンドラインを使用して実行しました:

python Luigi_Test.py FlipLinesBackwards --local-scheduler

これにより、実行しているディレクトリにファイルが作成されるという印象を受けましたが、そうではありませんか?

私は何か間違ったことをしていますか?

4

1 に答える 1