from celery import shared_task


@shared_task
def update_indexed_document(index, created, pk):
    indexed_doc = index.init_using_pk(pk)
    indexed_doc.prepare()
    indexed_doc.save()


@shared_task
def delete_indexed_document(index, pk):
    indexed_doc = index.get(id=pk)
    indexed_doc.delete()


__all__ = ('update_indexed_document', 'delete_indexed_document')

from celery import shared_task


@shared_task(rate_limit='50/m')
def update_indexed_document(index, created, pk):
    indexed_doc = index.init_using_pk(pk)
    indexed_doc.prepare()
    indexed_doc.save()


@shared_task
def delete_indexed_document(index, pk):
    indexed_doc = index.get(id=pk)
    indexed_doc.delete()


__all__ = ('update_indexed_document', 'delete_indexed_document')

Add rate-limit to update_indexed_document task
Add rate-limit to update_indexed_document task

  from celery import shared_task
  
  
- @shared_task
+ @shared_task(rate_limit='50/m')
  def update_indexed_document(index, created, pk):
      indexed_doc = index.init_using_pk(pk)
      indexed_doc.prepare()
      indexed_doc.save()
  
  
  @shared_task
  def delete_indexed_document(index, pk):
      indexed_doc = index.get(id=pk)
      indexed_doc.delete()
  
  
  __all__ = ('update_indexed_document', 'delete_indexed_document')
  
Add rate-limit to update_indexed_document task
## Code Before:
from celery import shared_task


@shared_task
def update_indexed_document(index, created, pk):
    indexed_doc = index.init_using_pk(pk)
    indexed_doc.prepare()
    indexed_doc.save()


@shared_task
def delete_indexed_document(index, pk):
    indexed_doc = index.get(id=pk)
    indexed_doc.delete()


__all__ = ('update_indexed_document', 'delete_indexed_document')

## Instruction:
Add rate-limit to update_indexed_document task
## Code After:
from celery import shared_task


@shared_task(rate_limit='50/m')
def update_indexed_document(index, created, pk):
    indexed_doc = index.init_using_pk(pk)
    indexed_doc.prepare()
    indexed_doc.save()


@shared_task
def delete_indexed_document(index, pk):
    indexed_doc = index.get(id=pk)
    indexed_doc.delete()


__all__ = ('update_indexed_document', 'delete_indexed_document')
