在Luigi中使用FloatParameter()函数传递浮点数参数给下一个任务

在Luigi中，可以通过使用FloatParameter()函数来定义一个接受浮点数参数的任务，并将该参数传递给下一个任务。

下面是一个使用FloatParameter()函数的简单示例：

import luigi

class FirstTask(luigi.Task):
    # 定义一个浮点数参数num，并设置默认值为0.0
    num = luigi.FloatParameter(default=0.0)

    def output(self):
        # 返回一个TaskOutput对象，用于标识任务的输出文件或目录
        return luigi.LocalTarget("output.txt")

    def run(self):
        with self.output().open('w') as f:
            f.write(str(self.num))

class SecondTask(luigi.Task):
    def requires(self):
        # 设置依赖于FirstTask，并传递浮点数参数
        return FirstTask(num=3.14)

    def output(self):
        return luigi.LocalTarget("output.txt")

    def run(self):
        with self.input().open('r') as f:
            num = float(f.read().strip())
            print("Received num from FirstTask:", num)

if __name__ == '__main__':
    luigi.build([SecondTask()], local_scheduler=True)

在上面的示例中，首先定义了一个FirstTask任务，该任务具有一个名为num的浮点数参数。在run()方法中，将num参数的值写入output.txt文件中。

然后定义了一个SecondTask任务，该任务依赖于FirstTask任务，并向FirstTask传递浮点数参数3.14。在run()方法中，读取FirstTask输出文件中的值，并打印出来。

最后，通过调用luigi.build()方法来运行SecondTask任务。

在命令行中运行该脚本，可以看到输出"Received num from FirstTask: 3.14"，表明成功传递了浮点数参数。

Luigi的FloatParameter()函数用于定义接受浮点数参数的任务，并且可以通过在任务实例化时传递参数的方式进行使用。这样可以实现任务之间的参数传递和依赖关系的建立。