apps/waiter/tasks.py

   1 from celery.signals import task_postrun
   2 from waiter.models import WaitedFile
   3
   4
   5 def task_delete_after(task_id=None, **kwargs):
   6     WaitedFile.objects.filter(task_id=task_id).delete()
   7 task_postrun.connect(task_delete_after)