celery_gc.py

import gc 
from celery.signals import task_postrun 

@task_postrun.connect
def gc_on_task_postrun(**kwargs): 
  gc.collect()