我正在使用 Spotify 的 Luigi 工具来处理多个作业之间的依赖关系。
def require(self):
yield task1()`
info = retrieve_info()
yield task2(info=info)
在我的示例中，我想要求 from task1，然后检索一些取决于执行的信息task1，以便将其作为 的参数传递task2。但是，我的功能retrieve_info将无法工作，因为task1尚未运行。
我的问题是，既然我正在使用yield，task1在调用 of 之前不应该处理retrieve_info吗？Luigi 是否在迭代所需的功能，然后启动不同任务的处理？
如果最后一个假设是正确的，我如何使用所需任务的执行作为第二个所需类的输入？