python - How to set a time limit to a task if not excute within a certain time then just remove it in celery -


i'm using celery(rabbitmq broker) many tasks every minute.since task little time-consuming, tasks in queue may accumulate leads newest come task not excute in time. how can deal it?

i think find in document:

expiration

add.apply_async(args=[10, 10], expires=60) 

task expires

@task(expires=50) 

Comments

Popular posts from this blog

matlab - error with cyclic autocorrelation function -

django - (fields.E300) Field defines a relation with model 'AbstractEmailUser' which is either not installed, or is abstract -

c# - What is a good .Net RefEdit control to use with ExcelDna? -