我有这个luigi任务,它所需的输入是'test_file.txt‘。我想通过测试类来更改所需的输入。我需要更改输入,以便能够用文件测试类的功能。我尝试了下面的代码,但是打印的结果仍然是初始路径-‘test_file.txt’。如何仅在测试中更改路径?(以“data.json”作为打印结果。import pytest
d
我有几个文本文件是用UTF-8编码的。我正在用luigi构建数据流,我想要的是一个接一个地将文件读入unicode字符串,清理它们,最后将它们写入一些新的UTF-8文件中。问题是,在run类的CleanText方法中,我似乎无法在luigi.LocalTarget中使用unicode。任何想法都将不胜感激!这是我的代码:import o
我试图使用内置的(原子) Luigi方法使用pandas.read_excel()在我的luigi工作流中打开一个excel文件。如果self.input()是我的excel文档的luigi目标,我想执行如下操作:
with self.input().open('r') as f: pandas.read_excel(f)UnicodeDecodeError: 'utf-8' codec can'
我是Luigi的新手,正在尝试在我的流程中有一个条件分支。分支任务将评估一个条件,并根据结果跳过它的一些子项。为了测试这一点,我只有一个虚拟任务,它检查当前小时,如果流在早上执行,则返回True,否则返回False。该任务有两个子任务,一个在控制台中打印'Morning‘,另一个在控制台中打印’下午‘。在做了一些研究之后,我不知道Luigi是否有能力做这样的事情。def output(self):
return lui