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:
add.apply_async(args=[10, 10], expires=60)
@task(expires=50)
Comments
Post a Comment