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.