The previous project was implemented asynchronously with djang+celery. In the asynchronous task, celery can call the revoke method through the current task_id to terminate the currently running task. Now I have used nameko for a long time and have not found a similar termination method. Is there such a method or plugin?
like:
from xxx.celery import app
app.control.revoke(current_task_id, terminate=True, signal=‘SIGUSR1’)