次のプログラムは何も出力せず、エラーもスローしません。クラスの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')
タスクの正しいクラス実装を手伝ってください。