1

次のプログラムは何も出力せず、エラーもスローしません。クラスのrun()メソッドの形で何か不足していますか?to_S3()

class to_S3(luigi.Task):

    #The class Mysql_to_tsv converts the data returned by a query on a Mysqldb and stores the data in a tsv in a local file.

    def requires(self):
        return [Mysql_to_tsv]

    def output(self):
        return luigi.S3Target("https://s3.amazonaws.com/bucket-name/luigi_attempt.tsv")

クラスのoutput()メソッドは次のとおりです。Mysql_to_tsv()

def output(self):
        return luigi.LocalTarget('/Users/user/Desktop/Work/Luigi/test_data.tsv')

タスクの正しいクラス実装を手伝ってください。

4

2 に答える 2

0

はい、すべての非外部 luigi タスクにはrun()メソッドが必要です。

于 2015-08-26T07:41:52.170 に答える