Terminate running task

[geracobo]

Is there any way to terminate a task while it is running?
On this code example, I have a task that I would like to terminate due to user input:

# On my tasks
@task()
def task_that_modifies_database(model_id):
    result = long_running_api_call()
    model = Model.objects.get(model_id)
    model.value = result
    model.save()

# On my views
def user_has_cancelled(request):
    running_task = task_that_modifies_database(task_id)
    running_task.terminate()

    model = Model.object.get(model_id)
    model.value = "" # We clean the value of our model, but if task continues to run it will override.
    model.save()

    return redirect("/")

If the task is not terminated, it will override model.value. I could maybe create a flag that the task checks before saving but that's not ideal.

[RealOrangeOne]

No, although potentially when timeouts are implemented this might be possible.

In this case, I think the way to handle it varies on your business logic. A check in the background task that the current value is what it should be, combined with a mixture of transactions and select_for_update ought to catch this issue.