(self)
| 1252 | yield val |
| 1253 | |
| 1254 | async def _execute(self) -> list[MODEL]: |
| 1255 | instance_list = await self._db.executor_class( |
| 1256 | model=self.model, |
| 1257 | db=self._db, |
| 1258 | prefetch_map=self._prefetch_map, |
| 1259 | prefetch_queries=self._prefetch_queries, |
| 1260 | select_related_idx=self._select_related_idx, # type: ignore |
| 1261 | ).execute_select( |
| 1262 | *self.query.get_parameterized_sql(), |
| 1263 | custom_fields=list(self._annotations.keys()), |
| 1264 | ) |
| 1265 | if self._single: |
| 1266 | if len(instance_list) == 1: |
| 1267 | return instance_list[0] |
| 1268 | if not instance_list: |
| 1269 | if self._raise_does_not_exist: |
| 1270 | raise DoesNotExist(self.model) |
| 1271 | return None # type: ignore |
| 1272 | raise MultipleObjectsReturned(self.model) |
| 1273 | return instance_list |
| 1274 | |
| 1275 | |
| 1276 | class UpdateQuery(AwaitableQuery): |
no test coverage detected