如何使用Luigi更新和删除数据？

import luigi

class UpdateDataTask(luigi.Task):
    data_path = luigi.Parameter()

    def requires(self):
        # 定义任务的依赖关系，例如前置任务
        return []

    def output(self):
        # 定义任务的输出，例如更新后的数据文件
        return luigi.LocalTarget(self.data_path)

    def run(self):
        # 执行数据更新操作，例如使用SQL语句更新数据库
        # update_data(self.data_path)
        with self.output().open('w') as f:
            f.write('Updated data')

class DeleteDataTask(luigi.Task):
    data_path = luigi.Parameter()

    def requires(self):
        # 定义任务的依赖关系，例如前置任务
        return []

    def output(self):
        # 定义任务的输出，例如删除后的数据文件
        return luigi.LocalTarget(self.data_path)

    def run(self):
        # 执行数据删除操作，例如删除文件或数据库记录
        # delete_data(self.data_path)
        with self.output().open('w') as f:
            f.write('Deleted data')

if __name__ == '__main__':
    luigi.run()

python my_tasks.py UpdateDataTask --data-path /path/to/data.txt
python my_tasks.py DeleteDataTask --data-path /path/to/data.txt