如何解决如何在Luigi中获取所需的先前任务输出的文件名
在我读过的Luigi的样本中,当您想使用以前的必需任务的输出文件时,可以执行以下操作
@requires(TaskB)
class TaskA(luigi.Task):
def run(self):
with self.input().open('r') as input:
input.read()...something else etc
因此,您在调用input
但是我想做些不同的事情。我需要该文件的完整文件名。我不需要打开它,只需打开文件名即可将其作为参数传递给某些函数。
如何获取上一个任务输出的文件名?
解决方法
我认为在您的情况下,self.input()
是LocalTarget。
您可以尝试self.input().path
来获取路径。
编辑:
如果TaskB
定义了多个输出(例如列表),则必须执行以下操作:
self.input()[0].path
或者您可以遍历它。 话虽如此,但不是多个输出recommended
如果TaskA
定义了多个输入,则访问输入的方式为explained here
版权声明:本文内容由互联网用户自发贡献,该文观点与技术仅代表作者本人。本站仅提供信息存储空间服务,不拥有所有权,不承担相关法律责任。如发现本站有涉嫌侵权/违法违规的内容, 请发送邮件至 dio@foxmail.com 举报,一经查实,本站将立刻删除。