如何终止Celery任务中运行的长时间Python函数进程？

需求场景 #

我需要终止Celery任务中正在运行的长时间Python函数，示例任务代码如下：

@shared_task()
def celery_task():
    # 希望能终止这个任务，打断正在运行的long_function
    results = long_function()
    results.to_csv('results.csv')
    return "done!"

现有方案的问题 #

• AbortableTask不适用：Celery的AbortableTask要求在短函数调用间设置检查点来判断是否终止，但我的long_function会持续运行数分钟，无法插入检查点。就算在保存结果前检查任务状态，函数运行期间还是会占用不必要的资源。
• 撤销任务的terminate选项有风险：Celery官方明确不建议使用terminate选项，原文说明：

The terminate option is a last resort for administrators when a task is stuck. It’s not for terminating the task, it’s for terminating the process that’s executing the task, and that process may have already started processing another task at the point when the signal is sent, so for this reason you must never call this programmatically.

补充背景 #

这是一个Flask应用，用户提交任务后如果想修改输入，需要能终止正在运行的任务（任务耗时数分钟），且用户只能查看自己最新提交任务的结果。当前实现是允许用户提交新任务，但担心多用户场景下Worker会被不必要的任务占用资源。

已有的讨论参考 #

我了解这个问题在Stack Overflow上有过讨论，其中@kouk的答案最接近需求，但未说明如何保证终止仅针对目标任务，而非误杀进程中已启动的新任务。

内容的提问来源于stack exchange，提问作者kehunter