apps/catalogue/tasks.py

   1 from celery.task import task
   2
   3
   4 @task
   5 def refresh_by_pk(cls, pk):
   6     cls._default_manager.get(pk=pk).refresh()
   7
   8
   9 def refresh_instance(instance):
  10     refresh_by_pk.delay(type(instance), instance.pk)
  11