diff --git a/bothub/common/signals.py b/bothub/common/signals.py index 3d7ef531..34bc5b06 100644 --- a/bothub/common/signals.py +++ b/bothub/common/signals.py @@ -15,3 +15,15 @@ def handle_save(self, sender, instance, **kwargs): "es_handle_save", args=[instance.pk, app_label, model_name] ) ) + + def handle_pre_delete(self, sender, instance, **kwargs): + """ + Logs deletions are now handled in delete_nlp_logs task + """ + pass + + def handle_delete(self, sender, instance, **kwargs): + """ + Logs deletions are now handled in delete_nlp_logs task + """ + pass diff --git a/bothub/common/tasks.py b/bothub/common/tasks.py index 1f45ef1d..61a5ace2 100644 --- a/bothub/common/tasks.py +++ b/bothub/common/tasks.py @@ -14,6 +14,7 @@ from bothub import translate from bothub.api.grpc.connect_grpc_client import ConnectGRPCClient from bothub.celery import app +from bothub.common.documents import RepositoryNLPLogDocument from bothub.common.models import ( RepositoryQueueTask, RepositoryReports, @@ -270,6 +271,7 @@ def delete_nlp_logs(): max_id = batch[-1].id with transaction.atomic(): for log in batch: + RepositoryNLPLogDocument.search().query("match", pk=log.pk).delete() log.delete() num_updated += len(batch)