tasks.py 472 B

1234567891011121314151617
  1. from celery import shared_task
  2. from django.contrib.auth import get_user_model
  3. from ...conf.shortcuts import get_dynamic_settings
  4. User = get_user_model()
  5. @shared_task
  6. def delete_user_with_content(pk):
  7. try:
  8. user = User.objects.get(pk=pk, is_staff=False, is_superuser=False)
  9. except User.DoesNotExist:
  10. pass
  11. else:
  12. settings = get_dynamic_settings()
  13. user.delete(anonymous_username=settings.anonymous_username, delete_content=True)