在 Luigi 的中央调度程序 Web 界面中跟踪 Long-运行 任务状态

Question

在 Luigi 框架中，我尝试使用 set_tracking_url、set_progress_bar 和 [=15] 在中央调度程序的 Web 界面中显示一个长 运行 任务的进度条=] 在 run() 方法中，像这样：

def run(self):
    self.set_tracking_url("127.0.0.1:8082")
    for i in range(100):
        self.do_long_calculation(i)
        self.set_status_message("Analyzing Id %d" % i)
        self.set_progress_percentage(i)

我 运行 任务使用

PYTHONPATH='.' luigi --module AnalysisTasks LongTask --workers=5

其中AnalysisTasks是python源文件，LongTask是run()方法所属的任务，后台luigid运行。但是我没有看到任何进度条或状态报告。我没有在任何地方找到任何答案或例子。有可能吗？

Answer 1

class MyTestTask(Task):
    name = "MyTestTask"
    target = ["test"]

    def run(self):
        for i in range(100):
            time.sleep(1)
            self.set_progress_percentage(i / 10)
            print i
        return {self.target[0]: i}