我LocalTarget
在项目的 Luigi 管道中编写二进制文件时遇到了麻烦。我在这里隔离了问题:
class LuigiTest(luigi.Task):
def output(self):
return luigi.LocalTarget('test.npz')
def run(self):
with self.output().open('wb') as fout:
np.savez_compressed(fout, array=np.asarray([1, 2, 3]))
我尝试打开'w'
,'wb'
但我不断收到以下错误:
TypeError: write() argument must be str, not bytes
我正在使用 python 3.5.1,我的 luigi 版本是 2.1.1