Como adicionar dinamicamente / remover tarefas periódicas ao aipo (aipo)

Se eu tiver uma função definida da seguinte forma:

<code>def add(x,y):
  return x+y
</code>

Existe uma maneira de adicionar dinamicamente essa função como um PeriodicTask de aipo e iniciá-la em tempo de execução? Eu gostaria de poder fazer algo como (pseudocódigo):

<code>some_unique_task_id = celery.beat.schedule_task(add, run_every=crontab(minute="*/30"))
celery.beat.start(some_unique_task_id)
</code>

Eu também gostaria de parar ou remover essa tarefa dinamicamente com algo como (pseudocódigo):

<code>celery.beat.remove_task(some_unique_task_id)
</code>

ou

<code>celery.beat.stop(some_unique_task_id)
</code>

FYI Eu não estou usando o djcelery, que permite gerenciar tarefas periódicas através do django admin.

questionAnswers(4)

yourAnswerToTheQuestion