kumar6591/data-quality-env
0
1�
2 �)�i< � �� � d dl mZ d dlmZmZ d dlmZmZ G d� de� � Z G d� de� � Z G d� d e� � Z3 G d4� d e� � Z G d � d
e� � Z G d� de� � Z
G d� de� � ZdS )� )� annotations)�Any�Literal)� BaseModel�Fieldc �B � e Zd ZU dZded< edd�� � Zded< d S )5�FindingConfidencez6A single audit finding with agent-reported confidence.r �value� g �?��ge�le�float�6confidenceN)�__name__�7__module__� __qualname__�__doc__�__annotations__r r � � �7/Users/hemanthkunta/meta/data-quality-env/env/models.pyr r sA � � � � � � �@�@��J�J�J� ����-�-�-�J�-�-�-�-�-�-r r c �Z � e Zd ZU dZded< ded< ded< ded < ded8< ded < ded < d
S )� AuditReportz/Structured audit report submitted by the agent.z dict[str, FindingConfidence]� null_issuesr �duplicate_row_countzlist[dict[str, Any]]�schema_violationsz list[str]�drifted_columns�
drift_details�relational_issues�recommended_fixesN)r r r r r r r r r r sl � � � � � � �9�9�-�-�-�-�*�*�*�*�+�+�+�+� � � � �/�/�/�/�+�+�+�+� � � � � � r r c �6 � e Zd ZU ded< dZded< dZded< dS )�Actionz,Literal['query', 'submit_report', 'fix_sql']� action_typeN�9str | None�sqlzAuditReport | None�report)r r r r r& r' r r r r# r# s@ � � � � � � �=�=�=�=��C�����!%�F�%�%�%�%�%�%r r# c �~ � e Zd ZU ded< ded< ded< ded< ded < ded10< ded < d ed
< ded< ded< ded< dS )� Observation�int�task_id�str�task_descriptionzdict[str, dict[str, str]]�tableszdict[str, int]�11row_counts�step� max_steps�query_credits_remaining�Literal['audit', 'fix']�phasezlist[dict] | None�last_query_resultr% �last_action_errorz float | None�last_fix_scoreN�r r r r r r r r) r) ! s� � � � � � � ��L�L�L�����%�%�%�%� � � � �
�I�I�I��N�N�N� � � � �"�"�"�"�(�(�(�(�!�!�!�!� � � � � � r r) c �B � e Zd ZU ded< ded< ded< ded< ded< dS )�RewardBreakdownr �base_audit_score�confidence_brier_adjustment�budget_efficiency_bonus�fix_verification_bonus�totalNr8 r r r r: r: / sI � � � � � � �����&�&�&�&�"�"�"�"�!�!�!�!��L�L�L�L�Lr r: c �R � e Zd ZU edd�� � Zded< ded< ded < d12ed < d S )
�Rewardg �g �?r r r13 r: � breakdown�bool�done�dict[str, Any]�infoN)r r r r r14 r r r r rA rA 7 sS � � � � � � ��5�D�T�*�*�*�E�*�*�*�*� � � � ��J�J�J������r rA c � � e Zd ZU ded< ded< dZded< dZded< dZded < d15Zd ed < d
Zded< dZ ded< dZ16ded< i Z ded< dZ ded< dZ
ded< dS )� EpisodeStater* r+ �seedr r0 � r1 �17 �
query_credits�auditr3 r4 � �fix_steps_remainingFrC �report_submittedrD rE � gold_faultsr r � audit_score� fix_bonusN)r r r r r0 r1 rL r4 rO rP rD rQ rR rS r r r rH rH > s� � � � � � � ��L�L�L�
�I�I�I��D�M�M�M�M��I������M�����%,�E�,�,�,�,� �� � � � � "��"�"�"�"��D�����"$�K�$�$�$�$� �K� � � � ��I������r rH N)�18__future__r �typingr r �pydanticr r r r r# r) r: rA rH r r r �<module>rW sw �� "� "� "� "� "� "� � � � � � � � � %� %� %� %� %� %� %� %�.� .� .� .� .� � .� .� .� !� !� !� !� !�)� !� !� !�&� &� &� &� &�Y� &� &� &� !� !� !� !� !�)� !� !� !� � � � � �i� � � �� � � � �Y� � � � � � � � �9� � � � � r