在 Luigi 框架中,我尝试使用 set_tracking_url、set_progress_bar 和 在中央调度程序的 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在后台运行.但是我没有看到任何进度条或状态报告。我没有在任何地方找到任何答案或例子。有可能吗?
请您参考如下方法:
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}
