I am trying to use redbeat to schedule periodic tasks that user can start or delete. I followed the normal way of doin both but for some reason deleted tasks keeps running
for initiating i used
key = "task_1" e = Entry(key,'tasks.check_sequence', 10,args=[id], app=celery) e.save()
while for deletion i used
key = "redbeat:task_1" e = Entry.from_key(key, app=celery) e.delete()
it doesn't return any error while deleting. However, task are still running on celery. What did i do wrong ?
Also, is there any way to delete all tasks at one time if things got messy while development ?
Hello,
I am trying to use redbeat to schedule periodic tasks that user can start or delete. I followed the normal way of doin both but for some reason deleted tasks keeps running
for initiating i used
key = "task_1" e = Entry(key,'tasks.check_sequence', 10,args=[id], app=celery) e.save()
while for deletion i used
key = "redbeat:task_1" e = Entry.from_key(key, app=celery) e.delete()
it doesn't return any error while deleting. However, task are still running on celery. What did i do wrong ?
Also, is there any way to delete all tasks at one time if things got messy while development ?
Regards,