liddlmZmZddlmZmZmZddlmZddl m Z m Z ddl m Z mZddlmZddlmZmZmZmZmZedd d Gd d eZy )) dataclassfield) FrozenSetListOptional) BaseRelation)RelationConfig RelationType)RelationConfigChangeActionRelationResults)DbtRuntimeError)MAX_CHARACTERS_IN_IDENTIFIERPostgresIndexConfigPostgresIndexConfigChangePostgresMaterializedViewConfig.PostgresMaterializedViewConfigChangeCollectionTF)frozeneqreprceZdZUedZeeed<edZeeed<dZ dZ de d e d e efd Zd eed eed eefdZy)PostgresRelationcTttjtjhSN frozensetr ViewTablec/var/www/html/strategist-ai/venv_dbt/lib/python3.12/site-packages/dbt/adapters/postgres/relation.pyzPostgresRelation." !!"" ! r)default_factoryrenameable_relationscTttjtjhSrrrrr r!zPostgresRelation. r"rreplaceable_relationsc|j^|jQt|j|jkDr*t d|jd|jdyyy)NzRelation name 'z' is longer than z characters) identifiertypelenrelation_max_name_lengthr selfs r __post_init__zPostgresRelation.__post_init__(sw OO ' %DOO$t'D'D'FF!!$//!23""&"?"?"A!B+O G& (rctSr)rr,s r r+z)PostgresRelation.relation_max_name_length5s++rrelation_resultsrelation_configreturnct}tj|}tj|}|j |j |j |_|j r|Syr)rrfrom_relation_results from_config_get_index_config_changesindexes has_changes)r-r0r1config_change_collectionexisting_materialized_viewnew_materialized_views r .get_materialized_view_config_change_collectionz?PostgresRelation.get_materialized_view_config_change_collection8so$R#S %C%Y%Y & "!? J J? [+/+I+I & . .0E0M0M,  ( $ / /+ +rexisting_indexes new_indexesc(|j|Dcgc](}tjtj|d*}}|j|Dcgc](}tjtj |d*}}||zScc}wcc}w)a~ Get the index updates that will occur as a result of a new run There are four scenarios: 1. Indexes are equal -> don't return these 2. Index is new -> create these 3. Index is old -> drop these 4. Indexes are not equal -> drop old, create new -> two actions *Note:* The order of the operations matters here because if the same index is dropped and recreated (e.g. via --full-refresh) then we need to drop it first, then create it. Returns: an ordered list of index updates in the form {"action": "drop/create", "context": } )actioncontext) differencer from_dictr dropcreate)r-r=r>index drop_changescreate_changess r r6z*PostgresRelation._get_index_config_changesNs2*44[A   & / /5::uM   %//0@A   & / /5<<O   n,,  s -B -BN)__name__ __module__ __qualname__rr$rr __annotations__r&r.r+r r rrr<rrrr6rrr rrs49 5)L16; 69\2 , /BP @ A,!-#$78!-23!- ' ( !-rrN) dataclassesrrtypingrrrdbt.adapters.base.relationrdbt.adapters.contracts.relationr r dbt.adapters.relation_configsr r dbt_common.exceptionsr &dbt.adapters.postgres.relation_configsrrrrrrrrr rTsO(,,3H2 $5u-Y-|Y-.Y-r