芹菜任务与eta从RabbitMQ中删除

我使用Django 1.6,RabbitMQ 3.5.6,celery 3.1.19.

有一个周期性任务,每30秒运行一次,并使用给定eta参数创建200个任务.在我运行芹菜工作者之后,慢慢地在RabbitMQ中创建了队列,我看到大约1200个计划任务等待被解雇.然后,我重新启动芹菜工作者,所有等待的1200个计划任务都从RabbitMQ中删除.

我如何创建任务: my_task.apply_async((arg1, arg2), eta=my_object.time_in_future)

我像这样运行工人: python manage.py celery worker -Q my_tasks_1 -A my_app -l

CELERY_ACKS_LATE被设置为True在Django设置.我找不到任何可能的原因.

我应该使用不同的配置/标志/参数运行worker吗？任何的想法？