所以这个问题可能相当简单。我有一个工作,应该运行约30分钟,我不希望我的程序等待30分钟的结果。我想获得一个任务名称或id或类似的东西,并将控制权返回给用户,以便用户稍后可以使用我的程序查询进程状态。
https://github.com/spotify/luigi/blob/695010420105dc836096201a00d2f032f0143b84/luigi/interface.py查看interface.py,我没有看到任何相关的内容。这是不可能的吗?或者说我该如何做到这一点?谢谢!
p。如果有人能告诉我在哪里可以查询luigi守护进程的任务状态,我将不胜感激。
我看到这里有几个问题:
- 如何获得任务名称或id:在任务中,您可以通过
self.task_id
获得此信息,您可以在任务的run
方法中将其写入文件,数据库,队列等。 - 如何将控制权返回给用户。应该像后台任务一样简单(例如,在luigi命令后面加上*nix中的
&
或按ctrl-z,然后在提示符下输入bg
)。 - 如何获得任务的状态-您可以在运行时将其写出来,但也可以在
http://yourluigidhost:8082/api/task_list
检查api