我有一个任务队列,用户可以将任务推送到其中,一次只能运行一个任务,由队列的并发设置强制执行。在某些情况下(例如长时间运行的任务),他们可能希望取消正在运行的任务以释放队列以处理下一个任务。
为了实现这一点,我一直将任务队列作为 Flask 应用程序运行,如果用户希望取消任务,我会为给定的队列和任务调用 python 客户端库的delete_task方法。
但是,我看到即使在删除任务之后,基础任务也会继续处理。一直在尝试查找有关 Cloud Tasks 如何处理被删除任务的文档,但没有找到任何具体的内容。
希望我能够监听某种信号,以便在收到删除时优雅地关闭进程。或者如果父任务被删除,底层进程将被杀死。
以前有人使用过 Cloud Tasks API 吗?假设已删除的任务将清除所有正在运行的进程是否正确?