o i@svddlmZddlZddlmZddlZddlmZegejfZ ej e dBdZ dd d Z dd d Z dddZdS)) annotationsN)Callable)loggeragent_http_sessionreturn_ClientFactorycs ddfdd }t||S)Nraiohttp.ClientSessioncsjdusjr3tdddlm}z|jj}Wn ty$d}Ynwtj ddd}tj ||dS)Nz-http_session(): creating a new httpclient ctxr)get_job_context2x)limit_per_hostkeepalive_timeout)proxy connector) closedrdebugjobr proc http_proxy RuntimeErroraiohttp TCPConnector ClientSession)r rr g_sessionc/var/www/html/livekit_bhavya/venv/lib/python3.10/site-packages/livekit/agents/utils/http_context.py _new_sessions   z&_new_session_ctx.._new_sessionrr ) _ContextVarset)rrrr_new_session_ctxs r"r cCs td}|dur td|S)zOptional utility function to avoid having to manually manage an aiohttp.ClientSession lifetime. On job processes, this http session will be bound to the main event loop. NaAttempted to use an http session outside of a job context. This is probably because you are trying to use a plugin without using the agent worker api. You may need to create your own aiohttp.ClientSession, pass it into the plugin constructor as a kwarg, and manage its lifecycle.)r getrvalrrr http_session(s r&Nonecs@td}|durtd|IdHtddSdS)Nz*http_session(): closing the httpclient ctx)r r#rrcloser!r$rrr_close_http_ctx6s  r))rrr)rr') __future__r contextvarscollections.abcrrlogrrr ContextVarr r"r&r)rrrrs