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

java - Static nested class instance -

c# - Bluetooth LE CanUpdate Characteristic property -

JavaScript - Replace variable from string in all occurrences -