(self, instance, with_valid=True)
| 789 | return self.one() |
| 790 | |
| 791 | def cancel(self, instance, with_valid=True): |
| 792 | if with_valid: |
| 793 | self.is_valid(raise_exception=True) |
| 794 | CancelInstanceSerializer(data=instance).is_valid() |
| 795 | document_id = self.data.get("document_id") |
| 796 | ListenerManagement.update_status( |
| 797 | QuerySet(Paragraph) |
| 798 | .annotate( |
| 799 | reversed_status=Reverse("status"), |
| 800 | task_type_status=Substr("reversed_status", TaskType(instance.get("type")).value, 1), |
| 801 | ) |
| 802 | .filter(task_type_status__in=[State.PENDING.value, State.STARTED.value]) |
| 803 | .filter(document_id=document_id) |
| 804 | .values("id"), |
| 805 | TaskType(instance.get("type")), |
| 806 | State.REVOKE, |
| 807 | ) |
| 808 | ListenerManagement.update_status( |
| 809 | QuerySet(Document) |
| 810 | .annotate( |
| 811 | reversed_status=Reverse("status"), |
| 812 | task_type_status=Substr("reversed_status", TaskType(instance.get("type")).value, 1), |
| 813 | ) |
| 814 | .filter(task_type_status__in=[State.PENDING.value, State.STARTED.value]) |
| 815 | .filter(id=document_id) |
| 816 | .values("id"), |
| 817 | TaskType(instance.get("type")), |
| 818 | State.REVOKE, |
| 819 | ) |
| 820 | return True |
| 821 | |
| 822 | @transaction.atomic |
| 823 | def delete(self): |
no test coverage detected