目前,我有许多luigi任务一起排队,其中有一个简单的依赖链( a -> b -> c -> d)。首先执行d,最后执行a。a是被触发的任务。除a之外,所有目标都返回一个luigi.LocalTarget()对象,并有一个泛型luigi.Parameter(),它是一个字符串(包含日期和时间)。在luigi中央服务器上运行(该服务器已启用历史记录)。问题是,当我重新运行该任务a时,luigi检查历史记录,查看该特定任
我计划使用Luigi编写一个可重现的、抗故障的超参数调优任务。因此,我在“父”class HParamOptimizer中多次调用我的class TrainOneModel。为了简单起见,这里是一个更简单的hello world版本: import luigi
class HelloTask(luigi.Task):
name = luigi.parameter.Paramete
到目前为止,我未能让Luigi读取我的client.cfg文件,并将该标志设置为true,这可能是Docker的错。如果您不想从命令行运行luigi。您可以使用本模块中定义的方法以编程方式运行luigi。在这个脚本中,我可以提供一个自定义的工人计划工厂,但是我还没有完全理解这个问题。在查看了github上的和 do