in aidial_sdk/chat_completion/stage.py [0:0]
def open(self):
if self._opened:
raise runtime_error("The stage is already open")
self._opened = True
self._queue.put_nowait(
StartStageChunk(self._choice_index, self._stage_index, self._name)
)