(self)
| 2067 | |
| 2068 | async def notify_generation_request_finished( |
| 2069 | self, request_ref: Optional[str] = None |
| 2070 | ): |
| 2071 | """通知当前 Token 对应的上游图片/视频请求已结束。""" |
| 2072 | async with self._pending_release_lock: |
| 2073 | release_event = None |
| 2074 | matched_ref = request_ref |
| 2075 | if matched_ref and matched_ref in self._pending_release_entries: |
no test coverage detected