(
self,
state: "OpenAIFormatter.ResponsesStream",
)
| 9159 | ) |
| 9160 | |
| 9161 | def start_response_stream( |
| 9162 | self, |
| 9163 | state: "OpenAIFormatter.ResponsesStream", |
| 9164 | ) -> List[Dict[str, Any]]: |
| 9165 | if state.started: |
| 9166 | return [] |
| 9167 | state.started = True |
| 9168 | response = self._response_stream_response( |
| 9169 | state, |
| 9170 | status="in_progress", |
| 9171 | usage=None, |
| 9172 | incomplete_details=None, |
| 9173 | completed_at=None, |
| 9174 | ) |
| 9175 | return [ |
| 9176 | self._response_event(state, "response.created", response=response), |
| 9177 | self._response_event(state, "response.in_progress", response=response), |
| 9178 | ] |
| 9179 | |
| 9180 | @staticmethod |
| 9181 | def _response_item_status( |
no test coverage detected