]jL%SrSSKJr SSKrSSKJs Jr SSK r SSK r SSK r SSK r SSK Jr SSK Jr SSKJrJrJrJrJrJr SSKrSSKJr SSKrSSKJr S S KJrJr S S KJ r \(aSS KJ!r! SS K"J#r#J$r$ SSK%J&r&J'r' \RPRSS5r*\*RWS5r,"SS\SS9r-"SS\SS9r."SS5r/S.Sjr0\"SS55r1\1"5r2Sr3S\4S'\5"S\355r6S\4S 'Sq7S!\4S"'S/S#jr8S0S$jr9S1S%jr:\S&5r;\S'5r<\"S(5r=\"S)5r>S2S*jr?S3S+jr@S4S,jrAS5S-jrBg)6z.Integration for instrumenting Pydantic models.) annotationsN) dataclass) lru_cache) TYPE_CHECKINGAnyCallableLiteral TypedDictTypeVar) ParamSpec) LogfireSpan) GLOBAL_CONFIGPydanticPlugin) get_versionValidationError) SchemaKindSchemaTypePath) CoreConfig CoreSchemazlogfire.pydanticzpydantic.validationsc$\rSrSr%SrS\S'Srg)PluginSettingsahA typed dict for the Pydantic plugin settings. This is how you can use the [`PluginSettings`][logfire.integrations.pydantic.PluginSettings] with a Pydantic model: ```py from pydantic import BaseModel from logfire.integrations.pydantic import PluginSettings class Model(BaseModel, plugin_settings=PluginSettings(logfire={'record': 'all'})): a: int ``` LogfireSettingslogfireN__name__ __module__ __qualname____firstlineno____doc____annotations____static_attributes__rZ/home/mande/repo/quber/.venv/lib/python3.13/site-packages/logfire/integrations/pydantic.pyrrs /r&rF)totalc<\rSrSr%SrS\S'S\S'S\S'S rg ) r4z%Settings for the logfire integration.floattrace_sample_ratez list[str]tags$Literal['all', 'failure', 'metrics']recordrNrrr&r'rr4s!/- O# 00r&rc\rSrSrSrSrSSjrSSjrSSjrSSjr SSjr SS jr SS jr SS jr SS jrSS jrSrg)_ValidateWrapperFz2Decorator factory for one schema validator method.)validation_method schema_name_record_logfirec$Xl[U5UlX`l[R UlURS05RS5nU(a7[U[5(aU/nUR R"U6Ulgg)Nrr-) r3get_schema_namer4r5rDEFAULT_LOGFIRE_INSTANCEr6get isinstancestr with_tags)selfr3schema_config_plugin_settingsschema_type_pathr/r-s r'__init___ValidateWrapper.__init__Ps|"3+62 88  ##Ir266v> $$$v MM33T:DM r&c^^^SSKJm TRS:Xa%[R"T5SUUU4Sjj5nU$TRS:Xa%[R"T5SUUU4Sjj5nU$TRnSoCU:HoU(d[ R "SU4S X445S [R"5;d[ R"T5(a[ R"T5OS [ R"U5[ R"U5S .-nS S U0-n[[ R"U55eS=n=pT[R"T5SUU4Sjj5nU$)zEDecorator which wraps a schema validator method with instrumentation.rrallc>[R(d T "U/UQ70UD6$TRU5nT "U/UQ70UD6nTRX45 TR SS9 U$!Ta&nTR X55 TR SS9 eSnAf[ a&nTRX65 TR SS9 eSnAff=fNT)successF)r _initialized _on_enter _on_success_count_validation_on_error_span Exception_on_exception_span) input_dataargskwargsspanresulterror exceptionrr> validators r'wrapped_validator4_ValidateWrapper.__call__..wrapped_validatorrs$11 %ZA$A&AA ~~j1 "&zCDCFCF$$T2**4*8!M'''4**5*9 ++D<**5*9s# A##B=)!B  B=!B88B=failurec<>[R(d T"U/UQ70UD6$T"U/UQ70UD6nTRSS9 U$!Ta&nTRSS9 TRU5 eSnAf[a&nTRSS9 TR U5 eSnAff=frH)rrJrM _on_error_logrO_on_exception_log) rQrRrSrUrVrWrr>rXs r'rYrZs$11$ZA$A&AA "&zCDCFCF**4*8!M'**5*9&&u- **5*9**95s# AB!A(( B5!BBmetrics)==)z/%(py2)s {%(py2)s = %(py0)s._record } == %(py5)sr>)py0py2py5zassert %(py7)spy7Nc>[R(d T"U/UQ70UD6$T"U/UQ70UD6nTRSS9 U$![a TRSS9 ef=frH)rrJrMrO)rQrRrSrUr>rXs r'rYrZsw$11$ZA$A&AA"&zCDCFCF **4*8!M !**5*9s AA)rQrrRrrSrreturnr) pydanticrr5 functoolswraps @pytest_ar_call_reprcompare @py_builtinslocals_should_repr_global_name _safereprAssertionError_format_explanation) r>rXrY @py_assert1 @py_assert4 @py_assert3 @py_format6 @py_format8rs `` @r'__call___ValidateWrapper.__call__ks , <<5 __Y ' " "( "H! Q\\Y &__Y ' " "( "H! #<< ,9 ,9, , , , ,< , , , , , ,4 , , , ,4 , , ,< , , ,9 , , , , , , , __Y ' "( "! r&c URRSURURUSSUR3S9R 5$)Nz*Pydantic {schema_name} {validation_method}infoz pydantic.)r4r3rQ_level _span_name)r6rTr4r3 __enter__)r>rQs r'rK_ValidateWrapper._on_entersS}}!! 8(("44!"4#9#9":; "  )+ r&cNURUSSUS9 URSSS5 g)NT succeeded)rIstatusrU)_set_span_attributes__exit__)r>rTrUs r'rL_ValidateWrapper._on_successs3 !!  " dD$'r&c URRSSURUR5UR SS9S.S9 g)Nwarnz"Validation on {schema_name} failedF include_url)r4 error_counterrors)level msg_template attributes)r6logr4rr)r>rVs r'r]_ValidateWrapper._on_error_logsG =#//$002,,5,9  r&c URUSSUR5URSS9S9 URS5 UR SSS5 g)NFfailedr)rIrrrr)rrr set_levelr)r>rTrVs r'rN_ValidateWrapper._on_error_spansV !! ))+<rWs r'r^"_ValidateWrapper._on_exception_logs? N#//"&y/":":  r&cURUSS[U5R3S9 UR[U5X"R5 g)NFzraised )rIr)rrrr __traceback__)r>rTrWs r'rP#_ValidateWrapper._on_exception_spansJ !! T)_5567 " d9oy2I2IJr&c UR5(a.URSU0UE5 U=RSU-- slgg)NrI ) is_recordingset_attributesmessage)r>rTrrIrs r'r%_ValidateWrapper._set_span_attributess@        G Bz B C LLC&L (L r&c^[RSXRURS.5 g)N)rIr4r3)validation_counteraddr4r3)r>rIs r'rM"_ValidateWrapper._count_validations' 73C3CZ^ZpZpq r&)r6r5r4r3N)r3z?Literal['validate_python', 'validate_json', 'validate_strings']r?rr@CoreConfig | NonerAzPluginSettings | dict[str, Any]rBrr/r.rfNone)rXrrfr)rQr)rTr rUr)rVr)rTr rVr)rWrO)rTr rWrO) rTr rr<rIboolrrrfr)rIrrfr)rr r!r"r# __slots__rCrwrKrLr]rNr^rPrrMr%rr&r'r1r1Fs<I;Z;;# ; : ; ) ;5; ;6L!\(   (  K)  r&r1cUSS;aSoU;o"(d[R"SU4SX45[R"U5S[R"5;d "U5(a[R"U5OSS.-nSS U0-n[ [R"U55eS =pUSR$USS ;aSoU;o"(d[R"SU4SX45[R"U5S[R"5;d "U5(a[R"U5OSS.-nSS U0-n[ [R"U55eS =p[US5$USS :XGaUSnUSS :XGaSoU;o"(d[R"SU4SX45[R"U5S[R"5;d "U5(a[R"U5OSS.-nSS U0-n[ [R"U55eS =pUSnS oU;o"(d[R"SU4SX45[R"U5S[R"5;d "U5(a[R"U5OSS.-nSS U0-n[ [R"U55eS =pUS Vs/sHowRS5U:XdMUPM snun[U5$[U5$US$s snf)amFind the best name to use for a schema. The follow rules are used: * If the schema represents a model or dataclass, use the name of the class. * If the root schema is a wrap/before/after validator, look at its `schema` property. * Otherwise use the schema's `type` property. Args: schema: The schema to get the name for. Returns: The name of the schema. r>modelrcls)in)z%(py1)s in %(py3)sr?)py1py3zassert %(py5)srcN> function-wrapfunction-afterfunction-before definitionszdefinition-ref schema_ref inner_schemaref) rjrkrorlrmrnrprqrr8r:) r? @py_assert0 @py_assert2 @py_format4rurr definitionschema_definitions r'r8r8s2f~//uue}%%% Q Q!6!!!!!x!!!x!!!!!!6!!!!6!!!!!!!vh/00 = (h'  #3 3 /</ / / / /< / / /< / / / / / /< / / / /< / / / / / / /*<8J *F* * * * *= * * *= * * * * * *F * * * *F * * * * * * *-3M-B#-BznnUZF[_iFi -B#  ##45 5"<0 0f~#s %M'M'c\rSrSrSr\"\R5\"S5:d\RRS5S:XaS Sjr Sr g S Sjr Sr g ) LogfirePydanticPlugini$zImplements a new API for pydantic plugins. Patches Pydantic to accept this new API shape. Set the `LOGFIRE_PYDANTIC_RECORD` environment variable to `"off"` to disable the plugin, or `PYDANTIC_DISABLE_PLUGINS` to `true` to disable all Pydantic plugins. z2.5.0LOGFIRE_PYDANTIC_RECORDoffcg)zBackwards compatibility for Pydantic < 2.5.0. This method is called every time a new `SchemaValidator` is created, and is a NO-OP for Pydantic < 2.5.0. NNNr)r>___s r'new_schema_validator*LogfirePydanticPlugin.new_schema_validator0s$r&c [5 URS5nU(a SU;aUSnO[5RnUS:Xag[ U5(a3[ 5 [ SXXcU5[ SXXcU5[ SXXcU54$g)aThis method is called every time a new `SchemaValidator` is created. Args: schema: The schema to validate against. schema_type: The original type which the schema was created from, e.g. the model class. schema_type_path: Path defining where `schema_type` was defined, or where `TypeAdapter` was called. schema_kind: The kind of schema to validate against. config: The config to use for validation. plugin_settings: The plugin settings. Returns: A tuple of decorator factories for each of the three validation methods - `validate_python`, `validate_json`, `validate_strings` or a tuple of three `None` if recording is `off`. rr/rrvalidate_python validate_jsonvalidate_strings)_patch_PluggableSchemaValidatorr:get_pydantic_plugin_configr/_include_model_patch_build_wrapperr1) r>r? schema_typerB schema_kindconfigplugin_settingslogfire_settingsr/s r'rr:s2 , -.229= H0@$@)(335<<'.//$&$%6kqr$_foiop$%7lrs $r&rN)rrrrrf/tuple[_ValidateWrapper, ...] | tuple[None, ...])r?rrrrBrrrrrrzdict[str, Any]rfr) rr r!r"r#rrg __version__osenvironr:rr%rr&r'rr$s8''(;w+??2::>>RkClpuCu $ $!$ $ < $, $, $, $- , $ $ , $ & , $,, $=, $r&r)fastapilogfire_backendfastuiztuple[str, ...]IGNORED_MODULESc#*# UH oS3v M g7f).Nr).0modules r' rms0\O&81OsIGNORED_MODULE_PREFIXESPydanticPlugin | None_pydantic_plugin_config_valuecP[b[$[RR$)zGet the Pydantic plugin config.)rr param_managerpydantic_pluginrr&r'rrrs $0,,**:::r&cUqg)zSet the pydantic plugin config.N)r) plugin_configs r'set_pydantic_plugin_configrzs %2!r&c.^^[5nURnURnTRmTR [ 5(d T[ ;agU(a[UU4SjU55(agU(a[UU4SjU55$g)z-Check whether a model should be instrumented.Fc3v># UH.n[R"US3TSTR35v M0 g7f$z::NresearchnamerpatternrrBs r'r!_include_model..s;melZaryyG9A6("=M=R=R# UH.n[R"US3TSTR35v M0 g7frrrs r'rrs;iahV]299y]vhb9I9N9N8O,PQQahrT)rincludeexcluder startswithrrany)rBrrrrs` @r'rrsy ' )FnnGnnG $ $F 011V5N3melmmmiahiii r&c&SSKJn [Ulg)a The old pydantic plugin API required managing state between event handler methods. This was messy, especially in a way that handles concurrency and nested validation: see https://pydantic.slack.com/archives/C05AF4A4WRM/p1710503400257589. The 'new API' simply requires decorating the validation methods, returning a new wrapper function. At the time of writing, this API doesn't actually exist yet in pydantic. We patch it here so that this will also work for older versions of pydantic without needing to support both APIs. r_schema_validatorN)pydantic.pluginr_build_wrapper build_wrapperrs r'rrs2&4#r&cSSKJn [R"UR5R 5SR 5:Xa SSjnXlgg)zPatch a 'bug' in PluggableSchemaValidator. Getting an attribute before proper initializing (e.g. when using cloudpickle) leads to infinite recursion trying to get _schema_validator. r)PluggableSchemaValidatorzg def __getattr__(self, name: str) -> Any: return getattr(self._schema_validator, name) cPUS:Xa [U5e[URU5$)Nr)AttributeErrorgetattrr)r>rs r' __getattr__4_patch_PluggableSchemaValidator..__getattr__s+**$T**41148 8r&N)r>rrr<rfr)!pydantic.plugin._schema_validatorrinspect getsourcerstrip)rrs r'rrsMK 2>>?EEG     90;,# r&PRcxUH3n[X5nU(aUnM[U5(dM+U"U5nM5 U$N)_wrap_with_old_handlercallable)funcevent_handlershandler old_wrappeds r'rrs;!-T; D g  4=D" Kr&cgrr)rrs r'_nooprs r&c^^^^^^SSKJm [US5m[US5m[US5m[US5mTTs=LaTs=LaTs=La [Lag [R "T5SUUUUUU4Sjj5nU$) Nrron_enter on_successon_error on_exceptionc>T"U0UD6 T"U0UD6nT "U5 U$!TanT"U5 eSnAf[anT "U5 eSnAff=fr)rO) rRrSrUrVrWrrrrrrs r'wrapper'_wrap_with_old_handler..wrappersc$!&! 4*6*F v M  UO    #  sA , A AA)rRzP.argsrSzP.kwargsrfr )rgr_get_handler_methodrrhri)rrrrrrrrs` @@@@@r'rrs("7J7H$Wl;J"7J7H&w?L:BB\BUBC__T    Nr&c\[XS5nUc[$URS:Xa[$U$)Nzpydantic.plugin)rrr )r method_names r'r r s1gD1G   0 0 r&)r?rrfr<)rfr)rrrfr)rBrrfr)rCallable[P, R]rz list[Any]rfr#)rrrr)rr#rrrfzCallable[P, R] | None)rrr"r<rfzCallable[..., None])Cr# __future__rbuiltinsrl_pytest.assertion.rewrite assertionrewriterjrhr rr dataclassesrrtypingrrrr r r rgtyping_extensionsr rr _internal.configrr_internal.utilsrrrrr pydantic_corerr_meter_provider get_meterMETERcreate_counterrrrr1r8rpluginrr$tuplerrrrrrrr r rrrr rr&r'r5sS4" !LL'<)(:4%%//0BC))*@A0Ye0*iu$w w t!H A$A$ A$H  $JI+00\O0\+\\7;4;;2 *  5  5 ; ;:cN CL <r&