/jzSSKJr SSKrSSKJrJr SSKJrJr "SS\5r \ \ \ S4r "SS\\ 5rg) ) annotationsN)ABCabstractmethod)ClassVarProtocolc \rSrSr%S\S'Srg) _RunnerMetaz ClassVar[str]INFERENCE_METHODN)__name__ __module__ __qualname____firstlineno____annotations____static_attributes__r P/app/agent/.venv/lib/python3.13/site-packages/livekit/agents/inference_runner.pyr r s##rr _InferenceRunnerc`\rSrSr%0rS\S'\S Sj5r\S Sj5r \S Sj5r Sr g) r _RunnersDictregistered_runnersc[R"5[R"5:wa [S5eURUR ;a[ SURS35eXR UR'g)Nz5InferenceRunner must be registered on the main threadzInferenceRunner z already registered) threadingcurrent_thread main_thread RuntimeErrorr r ValueError)cls runner_classs rregister_runner _InferenceRunner.register_runnersm  # # %)>)>)@ @VW W  ( (C,B,B B/ 0M0M/NNabc c@L|<<=rcg)z8Initialize the runner. This is used to load models, etc.Nr )selfs r initialize_InferenceRunner.initialize rcg)z Run inference on the given data.Nr )r%datas rrun_InferenceRunner.run"r(rr N)r!ztype[_InferenceRunner]returnNone)r-r.)r*bytesr-z bytes | None) r rrrrr classmethodr"rr&r+rr rrrrsI') )MM    r) __future__rrabcrrtypingrrr dictstrtyperrr rrr7sB"#%$($C0112  sK r