以编程方式启动luigi,而不是等待工作结果



所以这个问题可能相当简单。我有一个工作,应该运行约30分钟,我不希望我的程序等待30分钟的结果。我想获得一个任务名称或id或类似的东西,并将控制权返回给用户,以便用户稍后可以使用我的程序查询进程状态。

https://github.com/spotify/luigi/blob/695010420105dc836096201a00d2f032f0143b84/luigi/interface.py

查看interface.py,我没有看到任何相关的内容。这是不可能的吗?或者说我该如何做到这一点?谢谢!

p。如果有人能告诉我在哪里可以查询luigi守护进程的任务状态,我将不胜感激。

我看到这里有几个问题:

  1. 如何获得任务名称或id:在任务中,您可以通过self.task_id获得此信息,您可以在任务的run方法中将其写入文件,数据库,队列等。
  2. 如何将控制权返回给用户。应该像后台任务一样简单(例如,在luigi命令后面加上*nix中的&或按ctrl-z,然后在提示符下输入bg)。
  3. 如何获得任务的状态-您可以在运行时将其写出来,但也可以在http://yourluigidhost:8082/api/task_list
  4. 检查api

最新更新