| 39 | |
| 40 | |
| 41 | class TriggerTaskQuerySerializer(serializers.Serializer): |
| 42 | trigger_id = serializers.CharField(required=True, label=_("Trigger ID")) |
| 43 | workspace_id = serializers.CharField(required=False, allow_null=True, allow_blank=True, label=_("Workspace ID")) |
| 44 | |
| 45 | def is_valid(self, *, raise_exception=False): |
| 46 | super().is_valid(raise_exception=True) |
| 47 | workspace_id = self.data.get('workspace_id') |
| 48 | query_set = QuerySet(Trigger).filter(id=self.data.get('trigger_id')) |
| 49 | if workspace_id: |
| 50 | query_set = query_set.filter(workspace_id=workspace_id) |
| 51 | if not query_set.exists(): |
| 52 | raise AppApiException(500, _('Trigger id does not exist')) |
| 53 | |
| 54 | def get_query_set(self): |
| 55 | query_set = QuerySet(TriggerTask).filter(workspace_id=self.data.get("workspace_id")).filter( |
| 56 | trigger_id=self.data.get("trigger_id")) |
| 57 | return query_set |
| 58 | |
| 59 | def list(self, with_valid=True): |
| 60 | if with_valid: |
| 61 | self.is_valid(raise_exception=True) |
| 62 | return [TriggerTaskResponse(row).data for row in self.get_query_set()] |
| 63 | |
| 64 | |
| 65 | class TriggerTaskRecordOperateSerializer(serializers.Serializer): |