dh6_NSSKJr SSKJrJrJrJrJrJrJ r J r SSK J r J r SSKJr SSKJr SSKJr SSKJrJr SSKJr SS KJr SS KJrJrJr SS KJ r \(aSS K!r!SS K"J#r# SSK$J%r& SSjr'SSjr(SSjr)SSjr*SSjr+\"5"SS\ 55r,g )) annotations) TYPE_CHECKINGAnyCallableDictOptionalSequenceTypeUnion)OpenAIAssistantRunnable OutputType)beta)CallbackManager)dumpd)RunnableConfig ensure_config)BaseTool)convert_to_openai_tool) BaseModelFieldmodel_validator)SelfN)NotGiven) ToolResourcescSSKnUR"SS0S9$![an[S5UeSnAf[an[S5UeSnAff=f)zGet the OpenAI client. Returns: openai.OpenAI: OpenAI client Raises: ImportError: If `openai` is not installed. AttributeError: If the installed `openai` version is not compatible. rN OpenAI-Beta assistants=v2default_headersBUnable to import openai, please install with `pip install openai`.wPlease make sure you are using a v1.23-compatible version of openai. You can install with `pip install "openai>=1.23"`.)openaiOpenAI ImportErrorAttributeErrorr"es h/var/www/html/shao/venv/lib/python3.13/site-packages/langchain_community/agents/openai_assistant/base.py_get_openai_clientr)sc }}m_-MNN  P    =   A  . A  AA cSSKnUR"SS0S9$![an[S5UeSnAf[an[S5UeSnAff=f)zGet the async OpenAI client. Returns: openai.AsyncOpenAI: Async OpenAI client Raises: ImportError: If `openai` is not installed. AttributeError: If the installed `openai` version is not compatible. rNrrrr r!)r" AsyncOpenAIr$r%r&s r(_get_openai_async_clientr-7se !!=/2RSS  P    =  r*cP/nUHnURUSS0SS0/S.5 M U$)zConvert file_ids into attachments File search and Code interpreter will be turned on by default. Args: file_ids (list): List of file_ids that need to be converted into attachments. Returns: list: List of attachments converted from file_ids. type file_searchcode_interpreter)file_idtools)append)file_ids attachmentsids r("_convert_file_ids_into_attachmentsr8PsDK!=1Fs r(_get_assistants_toolrBzs#4(( %d++r9cr\rSrSr%Sr\"\S9rS\S'Sr S\S'S\S 'S r S \S 'S r S\S'\ "SS9SSj5r \0SSSS.SSjj5rS S!Sjjr\SSS.S"Sjj5rS S!SjjrS#SjrS$SjrS#SjrS$SjrSrg)%OpenAIAssistantV2Runnablea Run an OpenAI Assistant. Attributes: client (Any): OpenAI or AzureOpenAI client. async_client (Any): Async OpenAI or AzureOpenAI client. assistant_id (str): OpenAI assistant ID. check_every_ms (float): Frequency to check progress in milliseconds. as_agent (bool): Whether to use the assistant as a LangChain agent. Example using OpenAI tools: .. code-block:: python from langchain.agents.openai_assistant import OpenAIAssistantV2Runnable assistant = OpenAIAssistantV2Runnable.create_assistant( name="math assistant", instructions="You are a personal math tutor. Write and run code to answer math questions.", tools=[{"type": "code_interpreter"}], model="gpt-4-1106-preview" ) output = assistant.invoke({"content": "What's 10 - 4 raised to the 2.7"}) Example using custom tools and AgentExecutor: .. code-block:: python from langchain.agents.openai_assistant import OpenAIAssistantV2Runnable from langchain.agents import AgentExecutor from langchain.tools import E2BDataAnalysisTool tools = [E2BDataAnalysisTool(api_key="...")] agent = OpenAIAssistantV2Runnable.create_assistant( name="langchain assistant e2b tool", instructions="You are a personal math tutor. Write and run code to answer math questions.", tools=tools, model="gpt-4-1106-preview", as_agent=True ) agent_executor = AgentExecutor(agent=agent, tools=tools) agent_executor.invoke({"content": "Analyze the data..."}) Example using custom tools and custom execution: .. code-block:: python from langchain.agents.openai_assistant import OpenAIAssistantV2Runnable from langchain.agents import AgentExecutor from langchain_core.agents import AgentFinish from langchain.tools import E2BDataAnalysisTool tools = [E2BDataAnalysisTool(api_key="...")] agent = OpenAIAssistantV2Runnable.create_assistant( name="langchain assistant e2b tool", instructions="You are a personal math tutor. Write and run code to answer math questions.", tools=tools, model="gpt-4-1106-preview", as_agent=True ) def execute_agent(agent, tools, input): tool_map = {tool.name: tool for tool in tools} response = agent.invoke(input) while not isinstance(response, AgentFinish): tool_outputs = [] for action in response: tool_output = tool_map[action.tool].invoke(action.tool_input) tool_outputs.append({"output": tool_output, "tool_call_id": action.tool_call_id}) response = agent.invoke( { "tool_outputs": tool_outputs, "run_id": action.run_id, "thread_id": action.thread_id } ) return response response = execute_agent(agent, tools, {"content": "What's 10 - 4 raised to the 2.7"}) next_response = execute_agent(agent, tools, {"content": "now add 17.241", "thread_id": response.thread_id}) )default_factoryrclientN async_clientstr assistant_idg@@floatcheck_every_msFboolas_agentafter)modec~URc/SSKnURRnUR"US9UlU$)z?Validate that the async client is set, otherwise initialize it.Nr)api_key)rHr"rGrRr,)selfr"rRs r(validate_async_client/OpenAIAssistantV2Runnable.validate_async_clients:    $ kk))G & 2 27 CD  r9) model_kwargsrGtool_resources extra_bodyc U=(d [5nUcSSKJn U nURRR "SUUUV s/sHn [ U 5PM sn UUUS.UD6n U"SU RUS.U D6$s sn f)apCreate an OpenAI Assistant and instantiate the Runnable. Args: name (str): Assistant name. instructions (str): Assistant instructions. tools (Sequence[Union[BaseTool, dict]]): Assistant tools. Can be passed in OpenAI format or as BaseTools. tool_resources (Optional[Union[AssistantToolResources, dict, NotGiven]]): Assistant tool resources. Can be passed in OpenAI format. model (str): Assistant model to use. client (Optional[Union[openai.OpenAI, openai.AzureOpenAI]]): OpenAI or AzureOpenAI client. Will create default OpenAI client (Assistant v2) if not specified. model_kwargs: Additional model arguments. Only available for temperature and top_p parameters. extra_body: Additional body parameters to be passed to the assistant. Returns: OpenAIAssistantRunnable: The configured assistant runnable. r NOT_GIVEN)name instructionsr3rWmodelrX)rJrG)r) openai._typesr[r assistantscreaterBr7) clsr\r]r3r^rVrGrWrXkwargsr[r> assistants r(create_assistant*OpenAIAssistantV2Runnable.create_assistantsD/-/  ! /&NKK**11 %:?@%$'-%@)!   F VFvFF AsA:c x[U5n[R"URS5URS5URS5S9nUR [ U5XRS5=(d UR 5S9n[URS/55nURS/5U-nUR(aeURS 5(aOURUS 5nURRRRR"S0UD6n OS U;a>S US UURS 5S./URS5S.n URX5n OSU;abURRRR R#US US S UURS 5S9n UR%U5n O:URRRRR"S0UD6n UR'U R(U R*5n UR1U 5n UR3U 5 U $![,an UR/U 5 U eSn A ff=f![,a$n UR/XR55S9 U eSn A ff=f)aXInvoke the assistant. Args: input (dict): Runnable input dict that can have: content: User message when starting a new run. thread_id: Existing thread to use. run_id: Existing run to use. Should only be supplied when providing the tool output for a required action after an initial invocation. file_ids: (deprecated) File ids to include in new run. Use 'attachments' instead attachments: Assistant files to include in new run. (v2 API). message_metadata: Metadata to associate with new message. thread_metadata: Metadata to associate with new thread. Only relevant when new thread being created. instructions: Additional run instructions. model: Override Assistant model for this run. tools: Override Assistant tools for this run. tool_resources: Override Assistant tool resources for this run (v2 API). run_metadata: Metadata to associate with new run. config (Optional[RunnableConfig]): Configuration for the run. Returns: OutputType: If self.as_agent, will return Union[List[OpenAIAssistantAction], OpenAIAssistantFinish]. Otherwise, will return OpenAI types Union[List[ThreadMessage], List[RequiredActionFunctionToolCall]]. Raises: BaseException: If an error occurs during the invocation. callbackstagsmetadatainheritable_callbacksinheritable_tagsinheritable_metadatarun_namer\r5r6intermediate_steps thread_idusercontentmessage_metadatarolerur6rkthread_metadatamessagesrkrun_idrurxr6rkNrkr_)rr configuregeton_chain_startrget_namer8rN_parse_intermediate_stepsrGrthreadsrunssubmit_tool_outputs_create_thread_and_runr{rb _create_run _wait_for_runr7rs BaseExceptionon_chain_error _get_response on_chain_endr=rSinputconfigrdcallback_manager run_managerfilesr6 tool_outputsrunthread_r'responses r(invoke OpenAIAssistantV2Runnable.invoke+sBv&*44"(**["9#ZZ/!'J!7  '55 $KZZ %;%Nt}}6 36::j"3MNjj3e; & }}+?!@!@#==./  kk&&..33GGW,WE)%+',Y'7+6(- 2D(E !!& *; < 11%@&KK$$,,55<<+&!), +"YY'9: =&&u-kk&&..33GGP%P$$SVVS]];C ))#.H  $ $X .O   & &q )G     & &q88: & >G s1?FI&J & J0JJ J9J44J9)rHrWc# U=(d [5nUcSSKJn UnUV s/sHn [U 5PM n n URR R UUU UUS9IShvN n U"SU RUS.UD6$s sn fN7f)aCreate an AsyncOpenAI Assistant and instantiate the Runnable. Args: name (str): Assistant name. instructions (str): Assistant instructions. tools (Sequence[Union[BaseTool, dict]]): Assistant tools. Can be passed in OpenAI format or as BaseTools. tool_resources (Optional[Union[AssistantToolResources, dict, NotGiven]]): Assistant tool resources. Can be passed in OpenAI format. model (str): Assistant model to use. async_client (Optional[Union[openai.OpenAI, openai.AzureOpenAI]]): OpenAI or AzureOpenAI async client. Will create default async_client if not specified. Returns: AsyncOpenAIAssistantRunnable: The configured assistant runnable. NrrZ)r\r]r3rWr^)rJrHr_)r-r`r[rBrrarbr7) rcr\r]r3r^rHrWrdr[r> openai_toolsres r(acreate_assistant+OpenAIAssistantV2Runnable.acreate_assistants<$A'?'A  ! /&N?DEut,T2u E&++66==%) >  R <R6RRF s#BA?,B%B&Bc # U=(d 0n[R"URS5URS5URS5S9nUR[ U5XRS5=(d UR 5S9n[ URS/55nURS/5U-nUR(anURS 5(aXURUS 5nURRRRR"S0UD6IS hvN n GOS U;aFS US UURS5S./URS5S.n URX5IS hvN n OSU;arURRRRR!US US S UURS5S9IS hvN n UR#U5IS hvN n OBURRRRR"S0UD6IS hvN n UR%U R&U R(5IS hvN n UR/U 5n UR1U 5 U $GN`GNNNNaN5![*an UR-U 5 U eS n A ff=f![*a$n UR-XR35S9 U eS n A ff=f7f)aZAsync invoke assistant. Args: input (dict): Runnable input dict that can have: content: User message when starting a new run. thread_id: Existing thread to use. run_id: Existing run to use. Should only be supplied when providing the tool output for a required action after an initial invocation. file_ids: (deprecated) File ids to include in new run. Use 'attachments' instead attachments: Assistant files to include in new run. (v2 API). message_metadata: Metadata to associate with new message. thread_metadata: Metadata to associate with new thread. Only relevant when new thread being created. instructions: Additional run instructions. model: Override Assistant model for this run. tools: Override Assistant tools for this run. tool_resources: Override Assistant tool resources for this run (v2 API). run_metadata: Metadata to associate with new run. config (Optional[RunnableConfig]): Configuration for the run. Returns: OutputType: If self.as_agent, will return Union[List[OpenAIAssistantAction], OpenAIAssistantFinish]. Otherwise, will return OpenAI types Union[List[ThreadMessage], List[RequiredActionFunctionToolCall]]. Raises: BaseException: If an error occurs during the invocation. rirjrkrlrprqr5r6rrNrsrtrurvrwryrzr|r}r~r_)rrrrrrr8rNrrHrrrr_acreate_thread_and_runr{rb _acreate_run_await_for_runr7rsrrrrr=rs r(ainvoke!OpenAIAssistantV2Runnable.ainvokesB2*44"(**["9#ZZ/!'J!7  '55 $KZZ %;%Nt}}6 36::j"3MNjj3e; * }}+?!@!@#==./  !--22::??SS"E)%+',Y'7+6(- 2D(E !!& *; < !88GG&++0088AAHH+&!), +"YY'9: I!--e44!--22::??SS++CFFCMMBBC ))#.H  $ $X .OY H5C   & &q )G     & &q88: & >G sB>K=A8J'9J:A J'JAJ'%J&J'>J!?AJ'J#-J'/J%0J'5K K=J'J'J'!J'#J'%J'' K 1KK  K= K:K55K::K=cSnUR5VVs0sHup4X2;dM X4_M nnnURRRRR "US4SUR 0UD6$s snnf)zCreate a new run within an existing thread. Args: input (dict): The input data for the new run. Returns: Any: The created run object. )r]r^r3rW run_metadatatruncation_strategymax_prompt_tokensrsrJ)itemsrGrrrrbrJ)rSrallowed_assistant_paramskvparamss r(r%OpenAIAssistantV2Runnable._create_runs$  $);;=R=41A4Q$!$=R{{'',,33 +  **   Ss A7A7cUR5VVs0sHup4US;dM X4_M nnnURS5=n(aXbS'URRRR "SUR US.UD6nU$s snnf)zCreate a new thread and run. Args: input (dict): The input data for the run. thread (dict): The thread data to create. Returns: Any: The created thread and run. r]r^r3rrWrJrr_)rrrGrrcreate_and_runrJrSrrrrrrWrs r(r0OpenAIAssistantV2Runnable._create_thread_and_run2s  %FF AD%  #YY'78 8> 8'5# $kk&&55 **     s BBc# UR5VVs0sHup#US;dM X#_M nnnURRRRR "US4SUR 0UD6IShvN $s snnfN 7f)zAsynchronously create a new run within an existing thread. Args: input (dict): The input data for the new run. Returns: Any: The created run object. )r]r^r3rWrrsrJN)rrHrrrrbrJ)rSrrrrs r(r&OpenAIAssistantV2Runnable._acreate_runJs  %XX AD%  &&++3388?? +  **      s!B BBAB;B< Bc6# UR5VVs0sHup4US;dM X4_M nnnURS5=n(aXbS'URRRR "SUR US.UD6IShvN nU$s snnfN 7f)zAsynchronously create a new thread and run simultaneously. Args: input (dict): The input data for the run. thread (dict): The thread data to create. Returns: Any: The created thread and run. rrWrNr_)rrrHrrrrJrs r(r1OpenAIAssistantV2Runnable._acreate_thread_and_run^s  %FF AD%  #YY'78 8> 8'5# $%%**22AA **       s!B BBAB B B)rH)returnr)r\rIr]rIr3Sequence[Union[BaseTool, dict]]r^rIrVzdict[str, float]rGz2Optional[Union[openai.OpenAI, openai.AzureOpenAI]]rW7Optional[Union[AssistantToolResources, dict, NotGiven]]rXzOptional[object]rdrrr )N)rr=rzOptional[RunnableConfig]rdrrr )r\rIr]rIr3rr^rIrHz:Union[Dict[str, Any], Type[BaseModel], Callable, BaseTool]rrM)r>rrzDict[str, Any])- __future__rtypingrrrrrr r r &langchain.agents.openai_assistant.baser r langchain_core._apirlangchain_core.callbacksrlangchain_core.loadrlangchain_core.runnablesrrlangchain_core.toolsr%langchain_core.utils.function_callingrpydanticrrrtyping_extensionsrr"r`ropenai.types.beta.assistantrAssistantToolResourcesr)r-r8r@rBrDr_r9r(rs"   W$4%B)H66"&S22* D *, D,,*d 7ddr9