client_runner.cpython-311.pyc•3.15 kB
�
ry�h �
�� � d dl Z d dlZd dlZd dlmZ d dlmZ d dlmZ d dl m
Z
d dlmZ d dl
mZ d dlmZ ed �
� � ej � d e j � e j � e j � e� � � � � � � � d dlmZ G d� d
� � Zdefd�Zedk r ej ed� � � � dS dS )� N)�Agent)�AsyncOpenAI)�MCPServerStreamableHTTP)�
FallbackModel)�OpenAIProvider)�OpenAIResponsesModel)�load_dotenvT)�override)�QUERY_SYSTEM_PROMPTc �$ � e Zd Zd� Zdedefd�ZdS )�Clientc �D � t t j � d� � �� � | _ t d� � | _ t t dt | j �� � �� � t dt | j �� � �� � � � | _
d S )N�OPENAI_API_KEY)�api_keyzhttp://127.0.0.1:8000/mcpzgpt-5)�
openai_client)�
model_name�providerzgpt-4.1)r �os�environ�getr r �serverr r r �model)�selfs �*/Users/sharhad/mcp/client/client_runner.py�__init__zClient.__init__ s� � �(�2�:�>�>�BR�3S�3S�T�T�T���-�.I�J�J���"� �$�)��8J�K�K�K�
�
�
�
!�&�)�$�:L�M�M�M�
�
�
�
�
��
�
�
� �query�returnc � � K � t | j dt | j g�� � }|� |� � � d {V ��S )N�query_agent)�name�
system_prompt�toolsets)r r r r �run)r r �agents r r zClient.query! sR � � � ���J� �/���}�
�
�
�� �Y�Y�u�%�%�%�%�%�%�%�%�%r N)�__name__�
__module__�__qualname__r �strr � r r r
r
sE � � � � � �
�
�
�&�� &�� &� &� &� &� &� &r r
r c � � K � t � � }|� | � � � d {V ��}t |j � � d S )N)r
r �print�output)r �client�results r �mainr0 * sH � � � �
�X�X�F��<�<��&�&�
&�
&�
&�
&�
&�
&�F� �&�-�����r �__main__z'What is the latest 10-K for Apple Inc.?)r �sys�asyncio�pydantic_air �openair �pydantic_ai.mcpr �pydantic_ai.models.fallbackr �pydantic_ai.providers.openair �pydantic_ai.models.openair �dotenvr �path�insert�dirname�abspath�__file__�
client.promptr r
r) r0 r&