ۇeh,$ddlZddlZddlZdZdZGddeZGddeZGd d eeZ Gd d e Z Gd de Z GddZ Gdde eZ Gdde eZGdde eZGdde ZGdde ZGdde eZGddeZGdd eZGd!d"eZGd#d$eZGd%d&eZdS)'N) PostgresErrorFatalPostgresErrorUnknownPostgresErrorInterfaceErrorInterfaceWarningPostgresLogMessageClientConfigurationErrorInternalClientErrorOutdatedSchemaCacheError ProtocolErrorUnsupportedClientFeatureErrorTargetServerAttributeNotMatchedUnsupportedServerFeatureErrorcF|j}|dkp|dS)Nasyncpgzasyncpg.) __module__ startswith)clsmodnames J/var/www/api/venv/lib/python3.11/site-packages/asyncpg/exceptions/_base.py_is_asyncpg_classrs'nG i  A7#5#5j#A#AAceZdZiZiddddddddd d d d d ddddddddddddddddddd d!d"d#d$iZfd%Zed&ZxZS)'PostgresMessageMetaSseverityV severity_enCsqlstateMmessageDdetailHhintPpositionpinternal_positionqinternal_queryWcontexts schema_namet table_namec column_nameddata_type_namenconstraint_nameFserver_source_filenameLserver_source_lineRserver_source_functioncPt||||}|j|jkr3|dkr-|jD]}t ||dt |rItj|j}t||r"td || d}|N|j |}|(td ||j||j |<|S)NPostgresMessagez exception class redefinition: {}r z={} has duplicate SQLSTATE code, which isalready defined by {})super__new__r _field_mapvaluessetattrrsysmoduleshasattr RuntimeErrorformatget _message_map TypeError__name__) mclsnamebasesdctrfmodcodeexisting __class__s rrBzPostgresMessageMeta.__new__2s9ggoodD%55 >T_ , ,9J1J1J_++-- & &Q%%%% S ! ! +cn-CsD!! "#E#L#L$$wwz""  (,,T22H#!88>$((*;9=9=>>>'*D d # rcB|j|tSN)rLrKr)rOrUs rget_message_class_for_sqlstatez2PostgresMessageMeta.get_message_class_for_sqlstateIs $$T+?@@@r) rNr __qualname__rLrCrB classmethodrZ __classcell__rWs@rrrsFL Z ] Z Y  X  V  Z   Y ] \ ]   %!" !#$ %%J*.AA[AAAAArrcXeZdZedZedZeddZdZdS)r@cp|d}t||S)Nr)rKtyperZ)rfieldsr s r_get_error_classz PostgresMessage._get_error_classPs+::c??Cyy77AAArcd|i}t|j}|D]!\}}||}|r|||<"|S)Nquery)rarCitemsrK)rrbrerR field_mapkvfields r_get_error_dictzPostgresMessage._get_error_dictUsc U II( LLNN  DAqMM!$$E E  rNc|||}||}|dd}|jdko't |o|ddk}|r t j|j}|j}d}|jdvot |}|r2|dd} | tj d z } | |d<|||fS) Nr"FeatureNotSupportedErrorr>RevalidateCachedQueryzQcached statement plan is invalid due to a database schema or configuration change)DuplicatePreparedStatementErrorInvalidSQLStatementNameErrorr&a NOTE: pgbouncer with pool_mode set to "transaction" or "statement" does not support prepared statements properly. You have two options: * if you are using pgbouncer for connection pooling to a single server, switch to the connection pool functionality provided by asyncpg, it is a much better option for this purpose; * if you have no option of avoiding the use of pgbouncer, then you can set statement_cache_size to 0 when creating the asyncpg connection object. ) rkrcrKrNrrFrGrInvalidCachedStatementErrortextwrapdedent) rrbrerRexcclsr"is_icse exceptionsis_prepared_stmt_errorr&s r_make_constructorz!PostgresMessage._make_constructorcs!!&%00%%f--'')R(( O9 9 I f % % I GG, - -1H H   9V%67J;F8G O @ @ & f % %  " 7762&&D HO% D CKw##rci}t|jD]}t||}||||<|SrY)rarCrDgetattr)selfrRrSvals ras_dictzPostgresMessage.as_dictsNd&--//  A$""CA rrY)rNrr[r\rcrkryr~rrr@r@Ns{BB[B  [ 6$6$6$[6$prr@) metaclassc0eZdZdZdZeddZdS)rz#Base class for all Postgres errors.c|jd}|jr|d|jz }|jr|d|jz }|SNrz DETAIL: {}z HINT: {}argsr$rJr&r|msgs r__str__zPostgresError.__str__Zil ; 7 ?))$+66 6C 9 3 ='' 22 2C rNc|||\}}}||}|j||SrY)ry__dict__update)rrbrerur"rRexs rnewzPostgresError.newsF"44VUCC VG__ 3 rrY)rNrr[__doc__rr\rrrrrrsI--[rrceZdZdZdS)rz9A fatal error that should result in server disconnection.NrNrr[rrrrrrsCCCCrrceZdZdZdS)rz'An error with an unknown SQLSTATE code.Nrrrrrr1111rrc"eZdZddddZdZdS)InterfaceMessageNr$r&c"||_||_dSrYr)r|r$r&s r__init__zInterfaceMessage.__init__s  rc|jd}|jr|d|jz }|jr|d|jz }|Srrrs rrzInterfaceMessage.__str__rr)rNrr[rrrrrrrsA!%Drrc&eZdZdZddddZdZdS)rz/An error caused by improper use of asyncpg API.Nrcvt|||t||dSNr)rr Exceptionr|rr$r&s rrzInterfaceError.__init__s9!!$vD!AAA4%%%%%rc|t|||j|j|jSr)rar$r&with_traceback __traceback__rs rwith_msgzInterfaceError.with_msgsEtDzz ;    .     r)rNrr[rrrrrrrrsG99&*&&&&&     rrceZdZdZdS)r z1An error caused by improper client configuration.Nrrrrr r s;;;;rr ceZdZdZdS) DataErrorz'An error caused by invalid query input.NrrrrrrrrrceZdZdZdS)r z,Requested feature is unsupported by asyncpg.Nrrrrr r s6666rr ceZdZdZdS)rz6Requested feature is unsupported by PostgreSQL server.Nrrrrrrs@@@@rrc eZdZdZddddZdS)rz3A warning caused by an improper use of asyncpg API.Nrcvt|||t||dSr)rr UserWarningrs rrzInterfaceWarning.__init__s9!!$vD!AAAT3'''''r)rNrr[rrrrrrrs8==&*(((((((rrceZdZdZdS)r z/All unexpected errors not classified otherwise.Nrrrrr r s9999rr ceZdZdZdS)r zBUnexpected condition in the handling of PostgreSQL protocol input.Nrrrrr r sLLLLrr ceZdZdZdS)rzECould not find a host that satisfies the target attribute requirementNrrrrrrsOOOOrrc,eZdZdZddddfd ZxZS)r zEA value decoding error caused by a schema change before row fetching.N)schema data_typer(ctt|||_||_||_dSrY)rArr0r6r()r|rrrr(rWs rrz!OutdatedSchemaCacheError.__init__s6 !'  r)rNrr[rrr]r^s@rr r sOOO&*dT!!!!!!!!!!!rr c6eZdZdZdZdZeddZdS)rz+A base class for non-error server messages.c\dt|j|jS)Nz{}: {})rJrarNr")r|s rrzPostgresLogMessage.__str__s!tDzz2DLAAArcjtdt|j)Nzinstances of {} are immutable)rMrJrarN)r|rPr}s r __setattr__zPostgresLogMessage.__setattr__s37>> JJ !!"" "rNc|||\}}}|turt}|turP|dp|d}|r$|dkr t j}t|ttfr ||}n |}|j ||S)NrrWARNING) ryrrrKupperrPostgresWarning issubclass BaseExceptionWarningrr)rrbreru message_textrRrrs rrzPostgresLogMessage.news$'$9$9&%$H$H! c ) ) )'F ' ' 'ww}--D1D1DH 1HNN,, 99 0 f}g6 7 7 &&&CC&((C C    rrY)rNrr[rrrr\rrrrrrs[55BBB"""[rr)rrFrs__all__rrarr@rrrrrr ValueErrorr rr rrrr r rr rrrrrsV  ,BBB 1A1A1A1A1A$1A1A1AhTTTTT 3TTTTnOY(DDDDDDDD22222-222             %y   "<<<<<~z<<<22222 22277777N777AAAAANAAA((((('(((:::::):::MMMMM'MMMPPPPP&9PPP!!!!!2!!!r