Dashboard
PHP:
8.2.30
OS:
Linux
User:
dh_nv8b2m
/
/
usr
/
local
/
lib
/
python3.10
/
dist-packages
/
sqlalchemy
/
orm
/
__pycache__
📤 Upload
📝 New File
📁 New Folder
Close
Editing: strategies.cpython-310.pyc
o [�h S � @ s� d Z ddlmZ ddlZddlZddlmZ ddlmZ ddlm Z ddlm Z dd lm Z dd lm Z dd lm Z dd lmZ dd lmZ ddlmZ ddl mZ ddl mZ ddlmZ ddlmZ ddlmZ ddlmZ ddlmZ ddlmZ ddlm Z ddlm Z ddlm Z dd lmZ dd l mZ ddl m!Z! dKd d �Z"e j#j$ddd �G d d � d e��Z%e j&e j#j$d!dd �G d"d#� d#e���Z'e j&e j#j$d!d$�G d%d&� d&e'���Z(e j&e j#j$d!d!d'�e j#j$d!d(�G d)d*� d*e����Z)G d+d,� d,e*�Z+G d-d.� d.e�Z,e j&e j-j$d!d(�G d/d0� d0e���Z.e j&e j-j$d1d2�e j-j$dd2�G d3d4� d4e,����Z/e j&e j-j$d!d2�e j-j$d5d2�e j-j$d6d2�e j-j$d7d2�e j-j$d8d2�G d9d:� d:e,ej0�������Z1G d;d<� d<e*�Z2e j-j$d=d2�G d>d?� d?e,��Z3e j&e j-j$d@d2�G dAdB� dBe,���Z4e j&e j-j$dCd2�e j-j$dd2�G dDdE� dEe,����Z5e j&e j-j$dFd2�G dGdH� dHe,ej0���Z6dIdJ� Z7dS )LzWsqlalchemy.orm.interfaces.LoaderStrategy implementations, and related MapperOptions.� )�absolute_importN� )� attributes)�exc)� interfaces)�loading)� properties)�query)� unitofwork)�util)�_DEFER_FOR_STATE)�_SET_DEFERRED_EXPIRED)�LoaderStrategy)�StrategizedProperty)�_state_session)� InstanceState)� _none_set)�aliased� )�event)�inspect)�log)�sql)�visitorsFc s0 t tj| jg d��} g } |o| j�|r| jr| �t� | j| j j v r5| j j | j \��| ���fdd�� |r=| �t j � |rN| j � � rN| �� �fdd�� |jD ]D} | | j�| j�u r�| j�| j�s�tj| j| jf| �||| |oy| jpy| jtju ||||| p�| j | jd� | ��} | D ]}|| | � q�qQd S )N)�defaultc s t j| |j� fi ���S �N)�orm_util�_validator_events�key��desc�prop)�fn�opts� �D/usr/local/lib/python3.10/dist-packages/sqlalchemy/orm/strategies.py�<lambda>B s ��z%_register_attribute.<locals>.<lambda>c s t �| � ��S r )r �backref_listenersr )�backref�uselistr$ r% r& P s �) � parent_tokenr) �compare_function� useobject� extension� trackparent� typecallable� callable_�active_history� impl_class�send_modified_events�doc)�listr �to_listr- r) � single_parent�append�single_parent_validatorr �parent� validatorsr �track_cascade_events�back_populates�self_and_descendants�_props�get� class_manager�_attr_has_implr �register_attribute_impl�class_� directionr � ONETOMANY�viewonlyr4 )r! �mapperr, r+ r/ r0 �proxy_propertyr1 r2 �kw� attribute_ext� listen_hooks�mr �hookr$ )r( r" r# r) r% �_register_attribute) sb � � � �� �� ��rO )� instrument�deferredc s8 e Zd ZdZdZ� fdd�Z d dd�Zdd � Z� ZS ) �UninstrumentedColumnLoaderz�Represent a non-instrumented MapperProperty. The polymorphic_on argument of mapper() often results in this, if the argument is against the with_polymorphic selectable. ��columnsc � t t| ��||� | jj| _d S r )�superrR �__init__�parent_propertyrT ��selfr: � strategy_key�� __class__r$ r% rW � � z#UninstrumentedColumnLoader.__init__Nc K s( | j D ]}|r |j | }|�|� qd S r )rT r8 ) rZ �context� query_entity�path�loadopt�adapter�column_collection�kwargs�cr$ r$ r% � setup_query� s �z&UninstrumentedColumnLoader.setup_queryc C � d S r r$ )rZ r_ ra rb rH �resultrc � populatorsr$ r$ r% �create_row_processor� s z/UninstrumentedColumnLoader.create_row_processorr ) �__name__� __module__� __qualname__�__doc__� __slots__rW rg rk � __classcell__r$ r$ r\ r% rR s �rR Tc s< e Zd ZdZdZ� fdd�Zdd� Zdd� Zd d � Z� Z S ) � ColumnLoaderz8Provide loading behavior for a :class:`.ColumnProperty`.)rT � is_compositec s. t t| ��||� | jj| _t| jd�| _d S )N�composite_class)rV rr rW rX rT �hasattrrs rY r\ r$ r% rW � s zColumnLoader.__init__c K sJ | j D ]} |r |j | } |�| � q| j d } |r |j | } | || j< d S �Nr )rT r8 rX ) rZ r_ r` ra rb rc rd �memoized_populatorsre rf �fetchr$ r$ r% rg � s zColumnLoader.setup_queryc C sP d| _ | jd j}| jjp| jd jp|jt| j�v }t| j|d|j |d� d S )NTr F)r, r+ r1 ) �is_class_levelrT �typerX r1 � primary_key�version_id_col�setrO �compare_values)rZ rH �coltyper1 r$ r$ r% �init_class_attribute� s �� �z!ColumnLoader.init_class_attributec C s\ | j D ] }|r |j | }|�|d�} | r!|d �| j| f� d S q|d �| jdf� d S )NF�quick�expireT)rT �_getterr8 r ) rZ r_ ra rb rH ri rc rj �col�getterr$ r$ r% rk � s �z!ColumnLoader.create_row_processor) rl rm rn ro rp rW rg r� rk rq r$ r$ r\ r% rr � s rr )�query_expressionc s4 e Zd Z� fdd�Zdd� Zdd� Zdd� Z� ZS ) �ExpressionColumnLoaderc s t t| ��||� d S r )rV r� rW rY r\ r$ r% rW � s z ExpressionColumnLoader.__init__c K sh |r0d|j v r2|j d g} | D ]} |r|j| } |�| � q| d } |r)|j| } | || j< d S d S d S )N� expressionr )� local_optsrT r8 rX ) rZ r_ r` ra rb rc rd rw re rT rf rx r$ r$ r% rg � s �z"ExpressionColumnLoader.setup_queryc C s| |r:d|j v r<|j d g}|D ] } |r|j| } |�| d�} | r-|d �| j| f� d S q|d �| jdf� d S d S d S )Nr� Fr� r� T)r� rT r� r8 r ) rZ r_ ra rb rH ri rc rj rT r� r� r$ r$ r% rk s ��z+ExpressionColumnLoader.create_row_processorc C s( d| _ t| j|d| jd jjdd� d S )NTFr )r, r+ �accepts_scalar_loader)ry rO rX rT rz r~ �rZ rH r$ r$ r% r� s �z+ExpressionColumnLoader.init_class_attribute)rl rm rn rW rg rk r� rq r$ r$ r\ r% r� � s r� )rQ rP )� do_nothingc sH e Zd ZdZdZ� fdd�Zdd� Zdd� Z dd d �Zd d � Z � Z S )�DeferredColumnLoaderzAProvide loading behavior for a deferred :class:`.ColumnProperty`.)rT �groupc s> t t| ��||� t| jd�rtd��| jj| _| jj| _d S )Nrt z8Deferred loading for composite types not implemented yet)rV r� rW ru rX �NotImplementedErrorrT r� rY r\ r$ r% rW , s � z DeferredColumnLoader.__init__c C s> | j s| jj}|d �| j|f� d S |d �| jdf� d S )N�newr� F)ry rX �_deferred_column_loaderr8 r ) rZ r_ ra rb rH ri rc rj � set_deferred_for_local_stater$ r$ r% rk 5 s �z)DeferredColumnLoader.create_row_processorc C s, d| _ t| j|d| jd jj| jdd� d S )NTFr )r, r+ r0 �expire_missing)ry rO rX rT rz r~ �_load_for_stater� r$ r$ r% r� E s �z)DeferredColumnLoader.init_class_attributeNc K s� |rd|j v rt| j��| jj�s'|r | jr |j �d| j d�s'|r<| j|v r<| j � d�j |||||||fi | �� d S | j rFt || j < d S t|| j < d S )N� undefer_pkszundefer_group_%sF))rQ F)rP T)r� r} rT � intersectionr: �_should_undefer_in_wildcardr� r@ r rX � _get_strategyrg ry r r ) rZ r_ r` ra rb rc rd rw �only_load_propsrJ r$ r$ r% rg Q sF � ���� �� � �� � z DeferredColumnLoader.setup_queryc s� �j stjS |tj@ stjS �jj}� jr � fdd�|jD �}n� j g}�fdd�|D �}t ��}|d u rBt � dt � ��� j f ��|�|�}tj|�j |�d�d u rXt ����tjS )Nc s4 g | ]}t |t�rt |jt�r|j� jkr|j�qS r$ )� isinstancer �strategyr� r� r )�.0�p�rZ r$ r% � <listcomp>� s � � �z8DeferredColumnLoader._load_for_state.<locals>.<listcomp>c s g | ] }|� j v r|�qS r$ )� unmodified)r� �k��stater$ r% r� � s zfParent instance %s is not bound to a Session; deferred load operation of attribute '%s' cannot proceed)r� � refresh_state)r r � ATTR_EMPTY�SQL_OK�PASSIVE_NO_RESULT�managerrH r� �iterate_propertiesr �orm_exc�DetachedInstanceErrorr � state_strr r � load_on_ident�ObjectDeletedError� ATTR_WAS_SET)rZ r� �passive� localparent�toloadr� �sessionr r$ )rZ r� r% r� � s4 ��� �� z$DeferredColumnLoader._load_for_stater ) rl rm rn ro rp rW rk r� rg r� rq r$ r$ r\ r% r� $ s �/r� c @ �& e Zd ZdZdd� Zejfdd�ZdS )�LoadDeferredColumnsz7serializable loader object used by DeferredColumnLoaderc C � || _ d S r �r )rZ r r$ r$ r% rW � � z LoadDeferredColumns.__init__c C s. | j }|jj}|j| }|jt }|�||�S r )r r� rH r? � _strategiesr� r� )rZ r� r� r r� r! r� r$ r$ r% �__call__� s z LoadDeferredColumns.__call__N�rl rm rn ro rW r � PASSIVE_OFFr� r$ r$ r$ r% r� � s r� c s$ e Zd ZdZdZ� fdd�Z� ZS )�AbstractRelationshipLoaderz0LoaderStratgies which deal with related objects.)rH �targetr) �entityc s> t t| ��||� | jj| _| jj| _| jj| _| jj| _d S r )rV r� rW rX rH r� r� r) rY r\ r$ r% rW � s z#AbstractRelationshipLoader.__init__)rl rm rn ro rp rW rq r$ r$ r\ r% r� � s r� c @ s e Zd ZdZdS )�DoNothingLoaderz�Relationship loader that makes no change to the object's state. Compared to NoLoader, this loader does not initialize the collection/attribute to empty/none; the usual default LazyLoader will take effect. N)rl rm rn ro r$ r$ r$ r% r� � s r� �noload)�lazyc @ s$ e Zd ZdZdZdd� Zdd� ZdS )�NoLoaderzYProvide loading behavior for a :class:`.RelationshipProperty` with "lazy=None". r$ c C s d| _ t| j|d| jjd� d S )NT)r, r/ )ry rO rX �collection_classr� r$ r$ r% r� � s �z NoLoader.init_class_attributec �$ � fdd�}|d � � j|f� d S )Nc s. � j r| j�� j��| |� d S d |� j< d S r )r) r� �get_implr � initialize�r� �dict_�rowr� r$ r% �invoke_no_load� s z5NoLoader.create_row_processor.<locals>.invoke_no_loadr� �r8 r ) rZ r_ ra rb rH ri rc rj r� r$ r� r% rk � s z NoLoader.create_row_processorN)rl rm rn ro rp r� rk r$ r$ r$ r% r� � s r� �select�raise� raise_on_sql� baked_selectc s� e Zd ZdZdZ� fdd�Zdd� Zdd� Zd d � Zd d � Z d d� Z dd� Z e � d�dd� �Ze � d�dd� �Zdd� Z� ZS )� LazyLoaderz|Provide loading behavior for a :class:`.RelationshipProperty` with "lazy=True", that is loads when first accessed. ) � _lazywhere�_rev_lazywhere�use_get�is_aliased_class� _bind_to_col�_equated_columns�_rev_bind_to_col�_rev_equated_columns�_simple_lazy_clause� _raise_always� _raise_on_sql�_bakeryc s t t| ��||� | jd dk| _| jd dk| _t| j�j| _| j j }|� � \| _ | _ | _|j dd�\| _| _| _| j�d| | j � | j oY| j oY| jjd j| j d| jjd�| _| jr�t| j�D ]}|| jjv r|| jj| D ] }| j| | j|< qqqc| j�d | � d S d S ) Nr� r� r� T)�reverse_directionz%s lazy loading clause %sr �� use_proxies� equivalentsz2%s will use query.get() to optimize instance loads)rV r� rW � strategy_optsr� r� r r� r� rX �_join_condition�create_lazy_clauser� r� r� r� r� r� �logger�infor) � _get_clause�comparerH �_equivalent_columnsr� r5 )rZ r: r[ �join_conditionr� rf r\ r$ r% rW sF � � � �� ���zLazyLoader.__init__c C sD d| _ | jjp| jjtjup| j }t| j|d| j| jj |d� d S )NT)r, r0 r/ r1 ) ry rX r1 rE r � MANYTOONEr� rO r� r� )rZ rH r1 r$ r$ r% r� @ s �� �z LazyLoader.init_class_attributec sT | j | j}� g �dd� }t�|i d|i� � �fdd�}t�|i d|i�}|�fS )Nc S s d| _ d S �NF)�unique�� bindparamr$ r$ r% �visit_bindparam] r� zFLazyLoader._memoized_attr__simple_lazy_clause.<locals>.visit_bindparamr� c sL | j � v r��| j� | j d f� d S | jd u r$��| jd | jf� d S d S r )�_identifying_keyr8 r �callable�valuer� �� bind_to_col�paramsr$ r% r� b s �� �)r� r� r �traverse�cloned_traverse)rZ � criterionr� r$ r� r% �"_memoized_attr__simple_lazy_clauseX s �z-LazyLoader._memoized_attr__simple_lazy_clausec C s� | j \}}|d u rt�|dd� |D ��S | jj}|�� }t�|�}|tj@ r+|tjN }i }|D ]%\} } } | d urP|rH|tj @ rH|� ||| |�} n|� ||| |�} | || < q/||fS )Nc S s g | ]\}}}|�qS r$ r$ )r� r �identr� r$ r$ r% r� y � z4LazyLoader._generate_lazy_clause.<locals>.<listcomp>) r� �sql_util�adapt_criterion_to_nullrX r: �objr � instance_dict�INIT_OK�LOAD_AGAINST_COMMITTED�#_get_committed_state_attr_by_column�_get_state_attr_by_column) rZ r� r� r� � param_keysrH �or� r� r r� r� r$ r$ r% �_generate_lazy_clauset s, � �� z LazyLoader._generate_lazy_clausec C s t �d| |f ��)Nz&'%s' is not available due to lazy='%s')�sa_exc�InvalidRequestError)rZ r� r� r� r$ r$ r% �_invoke_raise_load� s �z LazyLoader._invoke_raise_loadc C sD |j s| jjs |jr |jstjS |j }d }|tj@ s | jr%|tj @ s(|r(tj S | j r?|tj @ s?| jr8|tj @ r?| �||d� t|�}|sZ|tj @ rMtj S t�dt�|�| j f ��| jr�| �|||�}tj |v rltj S tj|v rttjS t�|�r{d S |�� j| j|||d�}|d ur�|S |tj@ r�|tj @ s�tj S | �||||�S )Nr� zbParent instance %s is not bound to a Session; lazy load operation of attribute '%s' cannot proceed)r� �lazy_loaded_from) r rX �load_on_pending� _load_pending� session_idr r� r� r� �NON_PERSISTENT_OKr� r� �NO_RAISE�RELATED_OBJECT_OKr r r� r� r r� �_get_ident_for_use_get� NEVER_SETr � issupersetr �_identity_lookupr� �_emit_lazyload)rZ r� r� �pending�primary_key_identityr� �instancer$ r$ r% r� � sx ������� � � ��� ����zLazyLoader._load_for_statec sD �j j}�tj@ r |j�n|j��j� � ����fdd��jjD �S )Nc s" g | ] }��� �j | �d ��qS )�r� �r� �r� �pk�r� �get_attrr� rZ r� r$ r% r� � s ��z5LazyLoader._get_ident_for_use_get.<locals>.<listcomp>)r� rH r r r r �dictr{ )rZ r� r� r� �instance_mapperr$ r r% r � s �z!LazyLoader._get_ident_for_use_get�sqlalchemy.ext.bakedc C � |j dd�S �N�2 )�size��bakery�rZ �bakedr$ r$ r% �_memoized_attr__bakery� � z!LazyLoader._memoized_attr__bakeryz sqlalchemy.orm.strategy_optionsc s �� �fdd���}|�dd� �j� �jjs |jdd� �jjd ur,|��fdd�� �j }|s7|tj@ r>|�dd� � �j rN�j �j }|� �j |� �j rn�j r[���|d� ||���fd d���|��j�|�S �jjr{|��fd d�� �jjD ]��jtju r��jr�t�jt�s�|���fd d�� q�� �|�\� �|r�t � t j ��!� �r�d S n t � t j"��!� �r�d S �j rƈ��|d� |�� fd d�� �fd d�} ||���fdd���| ��#� } �j$r�| S t%| �} | �r| dkr�t �&d�j � | d S d S )Nc s | � � j�S r )r r� �r� r� r$ r% r& � z+LazyLoader._emit_lazyload.<locals>.<lambda>c S s | � � �d�S r� )�_adapt_all_clauses�_with_invoke_all_eagers��qr$ r$ r% r& s T)�fullc s | � � j� jj�S r )� select_fromrH rX � secondaryr1 r� r$ r% r& ( s �c S s | � d�S r� )� autoflushr1 r$ r$ r% r& 1 � r� c � | � � �S r ��_set_lazyload_fromr1 r� r$ r% r& C r7 c s | j t�� jj �� S r )�order_byr r6 rX r1 r� r$ r% r& K s �c s" | � �j�| j� j ��� j��S r )�options�Load�for_existing_path� _current_pathr: �lazyloadr r1 )�rev�strategy_optionsr$ r% r& Z s ��c r8 r )�filterr1 )� lazy_clauser$ r% r& m r7 c s � � | j� � | _| S r )�update�_paramsr1 )r� r$ r% �set_default_paramsq s z5LazyLoader._emit_lazyload.<locals>.set_default_paramsc r8 r r9 r1 r� r$ r% r& x r7 r zKMultiple rows returned with uselist=False for lazily-loaded attribute '%s' r )'r� � add_criteriarX � bake_queries�spoilr5 r r � NO_AUTOFLUSH� load_options� load_path�_add_lazyload_optionsr� r� r �with_post_criteria�_load_on_pk_identityr rH r; �_reverse_propertyrE r r� �_use_getr� r� r� r r �has_intersectionr r �values� _never_set�allr) �len�warn) rZ rB r� r� r r� r2 r �effective_pathrG ri �lr$ )rD r� rA rZ r� rB r% r s� � � �� � � � ��� ���zLazyLoader._emit_lazyloadc sn | j � | js t�|jt� | �� �}|d �| j |f� d S |js#|jr5� fdd�} |d �| j | f� d S d S )Nr� c s | � |� � d S r )�_resetr� r� r$ r% �reset_for_lazy_callable� s z@LazyLoader.create_row_processor.<locals>.reset_for_lazy_callable) r ry r �"_instance_level_callable_processorrA �LoadLazyAttributer8 �populate_existing�always_refresh) rZ r_ ra rb rH ri rc rj �set_lazy_callabler\ r$ r� r% rk � s �� �z LazyLoader.create_row_processor)rl rm rn ro rp rW r� r� r r r� r r � dependenciesr+ r rk rq r$ r$ r\ r% r� � s 1 U r� c @ r� )r^ z-serializable loader object used by LazyLoaderc C s || _ |j| _d S r )r r[ )rZ r �initiating_strategyr$ r$ r% rW � s zLoadLazyAttribute.__init__c C s0 | j }|jj}|j| }|j| j }|�||�S r )r r� rH r? r� r[ r� )rZ r� r� r r! r! r� r$ r$ r% r� � s zLoadLazyAttribute.__call__Nr� r$ r$ r$ r% r^ � s r^ � immediatec @ s. e Zd ZdZdd� Z d dd�Zdd� ZdS ) �ImmediateLoaderr$ c C � | j �d��|� d S �N�)r� r� �rX r� r� r� r$ r$ r% r� � � � z$ImmediateLoader.init_class_attributeNc K rh r r$ ) rZ r_ r� ra rb rc rd � parentmapperre r$ r$ r% rg � s zImmediateLoader.setup_queryc r� )Nc s | � � j��| |� d S r )r� r r@ r� r� r$ r% �load_immediate� s z<ImmediateLoader.create_row_processor.<locals>.load_immediate�delayedr� ) rZ r_ ra rb rH ri rc rj rl r$ r� r% rk � s z$ImmediateLoader.create_row_processor�NN)rl rm rn rp r� rg rk r$ r$ r$ r% re � s � re �subqueryc s� e Zd ZdZ� fdd�Zdd� Z d dd�Zd d � Zd d � Zd d� Z dd� Z dd� Z dd� Z G dd� de �Zdd� Zdd� Zdd � Z� ZS ) �SubqueryLoader)� join_depthc rU r )rV rp rW rX rq rY r\ r$ r% rW � r^ zSubqueryLoader.__init__c C rf rg ri r� r$ r$ r% r� � rj z#SubqueryLoader.init_class_attributeNc K s~ |j jsd S |j jr|j �d� || j }|�|jdd �} | d ur$| } n| j} |j�dtj j �} | | } |� |jd�s\| j rT|j j rG|j j jnd|j d | j krSd S n| �| j�r\d S | �| �\} } }|j�dtf|j �}| �|| | ||j�}|j� | �}dtf|d| i|_|�d�}| �|| �\}}}|j|� }|j|� }| �||||| �}| � || || �}| � |�}|� |jd|� d S ) Nro �path_with_polymorphic)� subquery_pathN�loaderr r � orig_queryF) r �_enable_eagerloads� _yield_per� _no_yield_perrX r@ r r� r � PathRegistry�root�containsrq r? �length�contains_mapperrH � _get_leftmostrp � _generate_from_original_query� entity_zeror� � _attributes�_set_enable_single_crit�_prep_for_joinsr; � add_columns� _apply_joins�_setup_options�_setup_outermost_orderbyr} )rZ r_ r� ra rb rc rd rk re �with_poly_entity�effective_entity� subq_path�leftmost_mapper� leftmost_attr�leftmost_relationshipru � left_aliasr2 �to_join� local_attr� parent_aliasr$ r$ r% rg � sz �� ����� � �� � � � zSubqueryLoader.setup_queryc sp �j �t��d �}| j�|�r | j�d u r | j| j� }n|�d � }|j}� �fdd�|D �}� ||fS )Nr r c s$ g | ]}t �d j� j| j��qS �r )�getattrr� �_columntopropertyr �r� rf �r� r� r$ r% r� ^ s ���z0SubqueryLoader._get_leftmost.<locals>.<listcomp>)ra r �_class_to_mapperr: �isarX � local_columns)rZ r� � subq_mapper� leftmost_prop� leftmost_colsr� r$ r� r% r~ O s � � z SubqueryLoader._get_leftmostc C s� |� � �d �}|js|�ttdd� |jD ���d� |�|�}|�|� |j }|du r/d|_ n |d u rLtdd� |D ��D ]} t|�� | j �sKd|_ nq<|j du rU|j|_ |jd u rb|jd u rbd |_ |�� �� } tj|| dd�} | S )Nc S s g | ] }|d dur|d �qS )r� Nr$ )r� �entr$ r$ r% r� { s �z@SubqueryLoader._generate_from_original_query.<locals>.<listcomp>FTc s s � | ]}|j V qd S r )�tabler� r$ r$ r% � <genexpr>� s � z?SubqueryLoader._generate_from_original_query.<locals>.<genexpr>��use_mapper_path)�_clone� correlate� _from_obj�_set_select_fromr5 r} �column_descriptions�_adapt_col_list� _set_entities�distinct_target_key� _distinctr r{ � _order_byr; �_limit�_offset� with_labelsro r � AliasedClass) rZ ru r� r� r� � orig_entityr2 � target_colsr� �t�embed_qr� r$ r$ r% r g s@ ��� � � �z,SubqueryLoader._generate_from_original_queryc s� g }t |�� �}t|�D ]'\}\}}|dkr)||d d j}|�|�r&|n|} n|} |�| |jf� q t|�dk r=|� nt|d d �} | j rL| j � nt j | j dd�� �j j} � �fdd�| D �} || � fS ) Nr r r ���Tr� c s g | ] }t � �jj| j��qS r$ )r� r: r� r r� �r� rZ r$ r% r� � s ��z2SubqueryLoader._prep_for_joins.<locals>.<listcomp>)r5 �pairs� enumeraterH r� r8 r rW r r� r� r r� rX r� ) rZ r� r� r� r� �irH r! � prev_mapper� to_appendr� � local_colsr� r$ r� r% r� � s* � � z SubqueryLoader._prep_for_joinsc C s2 t |�}|dkrt||d d ��|�g}nu|dkr3t||d d ��|�t||d d ��|�g}nX|dkr�dd� |dd� D �}g }|rl|�d�} t| d | d �} |r`| �|d d �} n| �|�} |�| � |sFt||d d ��|d j�g| t||d d ��|�g }|D ] } |j| dd�}q�|S ) Nr r r r� c S s: g | ]}t |d �jst�|d �n|d j|d f�qS )r r )r r� r r� r� )r� �itemr$ r$ r% r� � s ����z/SubqueryLoader._apply_joins.<locals>.<listcomp>T)�from_joinpoint)rW r� �of_type�popr8 r: �join) rZ r2 r� r� r� r� �ltj�middle�innerr� �attrr$ r$ r% r� � sF ��� � � ����� zSubqueryLoader._apply_joinsc C s( |� |�}|j|j� }|jr|j|_|S r )�_with_current_path�_conditional_options� _with_options�_populate_existing)rZ r2 r� ru r� r$ r$ r% r� s z SubqueryLoader._setup_optionsc C s6 | j jr|jd }|j�t�| j j��}|j|� }|S rv )rX r; r� �_target_adapter�copy_and_processr r6 )rZ r2 � eagerjoin�eager_order_byr$ r$ r% r� s � z'SubqueryLoader._setup_outermost_orderbyc @ s4 e Zd ZdZdZdd� Zdd� Zdd� Zd d � ZdS ) z SubqueryLoader._SubqCollectionsz�Given a :class:`.Query` used to emit the "subquery load", provide a load interface that executes the query at the first moment a value is needed. Nc C r� r )�subq)rZ r� r$ r$ r% rW , r� z(SubqueryLoader._SubqCollections.__init__c C s | j d u r | �� | j �||�S r )�_data�_loadr@ )rZ r r r$ r$ r% r@ / s z#SubqueryLoader._SubqCollections.getc C s& t dd� t�| jdd� �D ��| _d S )Nc s s& � | ]\}}|d d� |D �fV qdS )c S � g | ]}|d �qS r� r$ �r� �vvr$ r$ r% r� 6 � zCSubqueryLoader._SubqCollections._load.<locals>.<genexpr>.<listcomp>Nr$ �r� r� �vr$ r$ r% r� 5 s � � �z8SubqueryLoader._SubqCollections._load.<locals>.<genexpr>c S s | dd � S )Nr r$ ��xr$ r$ r% r& 7 r. z7SubqueryLoader._SubqCollections._load.<locals>.<lambda>)r � itertools�groupbyr� r� r� r$ r$ r% r� 4 s �z%SubqueryLoader._SubqCollections._loadc C s | j d u r | �� d S d S r )r� r� )rZ r� r� r� r$ r$ r% rt : s �z&SubqueryLoader._SubqCollections.loader) rl rm rn ro r� rW r@ r� rt r$ r$ r$ r% �_SubqCollections# s r� c s� | j j| j jjst�d| ��|| j }|�|j d�}|d u r"d S |j |j u s,J d��| jj } |�|j d�} | d u rH| � |�} |� |j d| � � rS� fdd�| D �} | jr`| �|| | |� d S | �|| | |� d S )N�J'%s' does not support object population - eager loading cannot be applied.ro zlSubquery session doesn't refer to that of our context. Are there broken context caching schemes being used?� collectionsc � g | ]}� j | �qS r$ rS r� �rc r$ r% r� _ r� z7SubqueryLoader.create_row_processor.<locals>.<listcomp>)r: rA r �impl�supports_populationr r rX r@ r r� r� r� r} r) �_create_collection_loader�_create_scalar_loader) rZ r_ ra rb rH ri rc rj r� r� r� r$ r� r% rk > s6 �� � ��z#SubqueryLoader.create_row_processorc �j � ��fdd����fdd�}|d � �j�f� |d � �j|f� |jr3|d � �j� jf� d S d S )Nc s8 �� t� fdd��D ��d�}| ��j��| ||� d S )Nc � g | ]}� | �qS r$ r$ �r� r� �r� r$ r% r� o r� z_SubqueryLoader._create_collection_loader.<locals>.load_collection_from_subq.<locals>.<listcomp>r$ )r@ �tupler� r �set_committed_value)r� r� r� � collection�r� r� rZ r� r% �load_collection_from_subqm s � �zKSubqueryLoader._create_collection_loader.<locals>.load_collection_from_subqc � �j |vr � | ||� d S d S r r� r� )r� rZ r$ r% �&load_collection_from_subq_existing_rowu � �zXSubqueryLoader._create_collection_loader.<locals>.load_collection_from_subq_existing_rowr� �existing�eager�r8 r �invoke_all_eagersrt )rZ r_ r� r� rj r� r$ )r� r� r� rZ r% r� j s ��z(SubqueryLoader._create_collection_loaderc r� )Nc sZ �� t� fdd��D ��d�}t|�dkr t�d� � |d }| ��j��| ||� d S )Nc r� r$ r$ r� r� r$ r% r� � r� zWSubqueryLoader._create_scalar_loader.<locals>.load_scalar_from_subq.<locals>.<listcomp>r r �LMultiple rows returned with uselist=False for eagerly-loaded attribute '%s' r )r@ r� rW r rX r� r r� )r� r� r� r� �scalarr� r� r% �load_scalar_from_subq� s � ��zCSubqueryLoader._create_scalar_loader.<locals>.load_scalar_from_subqc r� r r� r� )r� rZ r$ r% �"load_scalar_from_subq_existing_row� r� zPSubqueryLoader._create_scalar_loader.<locals>.load_scalar_from_subq_existing_rowr� r� r� r� )rZ r_ r� r� rj r� r$ )r� r� r� rZ r% r� � s ��z$SubqueryLoader._create_scalar_loaderrn )rl rm rn rp rW r� rg r~ r r� r� r� r� �objectr� rk r� r� rq r$ r$ r\ r% rp � s" �cA/4 ,rp �joinedc s� e Zd ZdZdZ� fdd�Zdd� Z d d d �Zd d � Zd d� Z dd� Z dd� Z dd� Z d dd�Z dd� Zdd� Zdd � Zd d � Z� ZS )!� JoinedLoaderzcProvide loading behavior for a :class:`.RelationshipProperty` using joined eager loading. )rq �_aliased_class_poolc s& t t| ��||� | jj| _g | _d S r )rV r� rW rX rq r� rY r\ r$ r% rW � s zJoinedLoader.__init__c C rf rg ri r� r$ r$ r% r� � rj z!JoinedLoader.init_class_attributeNFc K s> |j jsdS |j jr| jr|j �d� || j }d} |r"| �||�nd} | dur5| �||||| �\} }} n-|�|j d�sR| j rJ|j d | j krIdS n|� | j �rRdS | �||||||||�\} }} }|�|j dd�}|durtt|�j} nd} || j }tj|| j ||| | | | j |d� |dur�dt|j�v r�t�d��dS dS ) z@Add a left outer join to the statement that's being constructed.Nzjoined collectionFrt r rr )�with_polymorphicrk �chained_from_outerjoinz�Detected unaliased columns when generating joined load. Make sure to use aliased=True or flat=True when using joined loading with with_polymorphic().)r rv rw r) rx rX � _init_user_defined_eager_proc�$_setup_query_on_user_defined_adapterr{ r rq r| r} rH �_generate_row_adapterr@ r �with_polymorphic_mappersr� r �_setup_entity_queryr} �secondary_columnsr r )rZ r_ r` ra rb rc rd rk r� re r� �user_defined_adapter�clauses�add_to_collectionr� r$ r$ r% rg � s� �� ��� �� ��� � ���zJoinedLoader.setup_queryc C s� d|j vrdS |jj}|�|jdd�}|dur|S |j d }|dd � \}}|d ur?t|t�r5|j�|�}t j ||j j d�}n!|� |jd�rW|�|jd�}tj||j j d�}n |jj�|j d �}|�|jd|� |S )N�eager_from_aliasF� user_defined_eager_row_processor���)r� rr )r� ra r: r@ r r� �strr� �aliasr� � ColumnAdapterrH r� r{ r � ORMAdapterr �_polymorphic_adaptersr} ) rZ rb r_ ra rc r � root_mapperr! r� r$ r$ r% r� s> � �����z*JoinedLoader._init_user_defined_eager_procc C sZ |� |j|�}|r|r|�|�}|�|jd|� n |r%|}|�|jd|� |j}|||fS )Nr )�_get_entity_clausesr �wrapr} r �primary_columns)rZ r_ r� ra rc r r r$ r$ r% r� A s" �� z1JoinedLoader._setup_query_on_user_defined_adapterc C s� t | j�jr t | j�j}nd }d| f}||jvr d |j|< }n |j| d |j|< }|t| j�krStj| j |d urA|j dd�nd ddd�}t |�jj | j� |� | j| S )N�joinedloader_acr r T)�flat)r r r� ) r r� r� � selectabler rW r� r r� rH r rf r8 )rZ r_ �alt_selectabler �idx�to_adaptr$ r$ r% �_gen_pooled_aliased_class[ s& �� z&JoinedLoader._gen_pooled_aliased_classc C s� |� |jdd �} | r | } n| �|�} t| �jd| ftj| | jjdddd�} | j d us,J �| j j r3d|_ |d ur@|j � d| j j�n| j j} | sHd}|j�| j||||| | |f� |j} |�|jd| � | || |fS )Nrr �joinedloader_ormadapterTF)r� �adapt_required�allow_label_resolve�anonymize_labels� innerjoin�eager_row_processor)r@ r r r �_memor r rH r� � aliased_classrX r) �multi_row_eager_loadersr� r �create_eager_joinsr8 �_create_eager_joinr r} )rZ r_ r� ra rb rc rd rk r� r� r r r r r$ r$ r% r� ~ sL � � ���� z"JoinedLoader._generate_row_adapterc C s |d u r|j } n|} |jo|jj} d } ||jvr@| s@|jr@t�|j|j�} t | �dkr0t � d��| r@|j| d } | d | } }| d u rJ||j} }|j� | |�}|r�t |dd �rtt|j��| �| j�rf| n| j�}t |j| j| j�}nt tj| j|jdd�| j| j�}n| j}|jd us�J �| p�| p�|dkp�|jj}|r�tj||j|| p�|jjp�|o�t|t j �| j| j d�}n| � ||||�}||j| < |j|_ |s�t� | jj!�D ]}| j"j#�$|�r�|r�|j%| }|j&�'|� q�| jj(�r| j)|j*�+t,�-| jj(��7 _)d S d S ) Nr z�Can't identify which query entity in which to joined eager load from. Please use an exact match when specifying the join path.r r Tr� �unnested��isouter� _left_memo� _right_memo).rH r! r �_should_nest_selectable� eager_joins� from_clauser� �#find_left_clause_that_matches_givenr rW r r � setdefaultr� r r �_entity_for_mapperr� r: r� r rX r r� r� �represents_outer_join�_ORMJoinr� r �Join�_splice_nested_inner_join�stop_on� _find_columns� primaryjoin�persist_selectablerf �contains_columnrT r r8 r; r� r� r� r r6 )rZ r_ r` ra rc rk r r r� r� �should_nest_selectable�query_entity_key�indexes�clause�default_towrap�towrap�efm�onclause�attach_on_outsider� r� r$ r$ r% r# � s� � ��� ��� �� �� ����� � � � � ��z JoinedLoader._create_eager_joinc C s2 |du r t |tj�s J �n.t |tjj�r | �||j|||�S t |tj�s;|d |u r9tj||j|d||d j d�S d S | �||j |||j �}|d u rfd}| �||j |||j �}|d u re|duscJ d��d S nd}|r�|jsv|jsv|�|�}n tj|j ||j|j|j d�}ntj||j |j|j|j d�}|j|_|S ) NFr r� r% z9assertion failed attempting to produce joined eager loadsT)r& r' )r& r( )r� r r0 r r � FromGroupingr2 �elementr rH �rightr( �leftr' r& �_splice_into_centerr? r� ) rZ ra �join_objr r? �splicing� target_join� right_splicer� r$ r$ r% r2 L sf � � �� �� ��z&JoinedLoader._splice_nested_inner_joinc C sv |r| � ||�nd}|dur#|}|jr |r |�|j�}n|jr"|j}n |�|jd�}|d u r0dS | j�||�r9|S dS )NFr )r� rc r r@ r rH �_result_has_identity_key)rZ r_ ri rc ra rb r � decoratorr$ r$ r% �_create_eager_adapter� s" �� �z"JoinedLoader._create_eager_adapterc C s� | j j| j jjst�d| ��|| j }| �|||||�} | durI| j} t � | j |||| j | �} | j s?| �|| | |� d S | �|| | |� d S | j�d��|||||||� d S )Nr� Frh )r: rA r r� r� r r rX rL r �_instance_processorrH r� r) r� r� r� rk ) rZ r_ ra rb rH ri rc rj �our_path� eager_adapterr � _instancer$ r$ r% rk � s< �� �����z!JoinedLoader.create_row_processorc sv � ��fdd�}� ��fdd�}� fdd�}|d � | j|f� |d � | j|f� �jr9|d � | j|f� d S d S ) Nc sJ t �| |��}t�|d�}|�j | �f< � |�}|d ur#|�|� d S d S �N�append_without_event�r �init_state_collectionr �UniqueAppenderr8 )r� r� r� r� � result_list�inst�rP r_ r r$ r% �#load_collection_from_joined_new_row� s ��zSJoinedLoader._create_collection_loader.<locals>.load_collection_from_joined_new_rowc sh | �f�j v r�j | �f }nt �| |��}t�|d�}|�j | �f< � |�}|d ur2|�|� d S d S rQ rS )r� r� r� rV r� rW rX r$ r% �(load_collection_from_joined_existing_row� s ���zXJoinedLoader._create_collection_loader.<locals>.load_collection_from_joined_existing_rowc � � |� d S r r$ r� �rP r$ r% � load_collection_from_joined_exec� � zPJoinedLoader._create_collection_loader.<locals>.load_collection_from_joined_execr� r� r� �r8 r r� )rZ r_ r rP rj rY rZ r] r$ rX r% r� � s ����z&JoinedLoader._create_collection_loaderc st � �fdd�}� ��fdd�}� fdd�}|d � �j|f� |d � �j|f� |jr8|d � �j|f� d S d S ) Nc s � |�|�< d S r r$ r� )rP r r$ r% � load_scalar_from_joined_new_row s zKJoinedLoader._create_scalar_loader.<locals>.load_scalar_from_joined_new_rowc s> � |�}�|v r||� urt �d� � d S d S ||�< d S )Nr� )r rX )r� r� r� r� �rP r rZ r$ r% �$load_scalar_from_joined_existing_row s ��� zPJoinedLoader._create_scalar_loader.<locals>.load_scalar_from_joined_existing_rowc r[ r r$ r� r\ r$ r% � load_scalar_from_joined_exec r^ zHJoinedLoader._create_scalar_loader.<locals>.load_scalar_from_joined_execr� r� r� r_ )rZ r_ r rP rj r` rb rc r$ ra r% r� s ���z"JoinedLoader._create_scalar_loader)NNF)F)rl rm rn ro rp rW r� rg r� r� r r� r# r2 rL rk r� r� rq r$ r$ r\ r% r� � s* �`/#? �F ',r� �selectinc s� e Zd ZdZe�dg d��ZdZ� fdd�Zdd� Z d d � Z d d � Z d d� Z e �d�dd� �Zdd� Ze �d�dd� �Zdd� Zdd� Z� ZS )�SelectInLoader)rq � omit_join� _parent_alias� _query_info�_fallback_query_infor� � queryinfo)�load_only_child�load_with_join�in_expr�pk_cols�zero_idx�child_lookup_colsi� c s� t t| ��||� | jj| _| jjtju }| jjd ur!| jj| _n | j� d�}|r.|j | _n| j j d j |jd| j jd�| _| jrV|rO| �� | _| �� | _d S | �� | _d S | �� | _d S )Nrh r Tr� )rV re rW rX rq rE r r� rf r� r� r: r� r� r� r� �_init_for_omit_join_m2orh �_init_for_joinri �_init_for_omit_join)rZ r: r[ �is_m2o� lazyloaderr\ r$ r% rW A s* � � zSelectInLoader.__init__c s� t �jjj�� � �� �fdd�t� �D �� � fdd��jjD � }}t|�dkr1t j |� }d}n|d }d}�� dd|||d �S ) Nc 3 s2 � | ]}�j j�|d �D ] }|� | fV q qdS )r$ N)r: r� r@ )r� r� �equiv��pk_to_fkrZ r$ r% r� b s � � � �z5SelectInLoader._init_for_omit_join.<locals>.<genexpr>c s g | ] }|� v r� | �qS r$ r$ r� )rx r$ r% r� h s z6SelectInLoader._init_for_omit_join.<locals>.<listcomp>r Fr T) r rX r� �local_remote_pairsrE r5 r: r{ rW r �tuple_� query_info)rZ rn �fk_colsrm ro r$ rw r% rs ^ s �� � z"SelectInLoader._init_for_omit_joinc sb | j j}t|�dkrtj|� }d}n|d }d}| j�d�� � fdd�|D �}| �dd||||�S )Nr Fr Trh c r� r$ r r �ru r$ r% r� ~ r� z:SelectInLoader._init_for_omit_join_m2o.<locals>.<listcomp>)rH r{ rW r rz rX r� r{ )rZ rn rm ro � lookup_colsr$ r} r% rq t s �z&SelectInLoader._init_for_omit_join_m2oc sj t | jj�| _t| j�� � fdd�| jjD �}t|�dkr%tj|� }d}n|d }d}| � dd|||d �S )Nc � g | ]}� � |��qS r$ ��_adapt_elementr� ��pa_inspr$ r% r� � � �z1SelectInLoader._init_for_join.<locals>.<listcomp>r Fr T) r r: rD rg r r{ rW r rz r{ )rZ rn rm ro r$ r� r% rr � s � z SelectInLoader._init_for_joinc C rf rg ri r� r$ r$ r% r� � rj z#SelectInLoader.init_class_attributer" c C r# r$ r' r) r$ r$ r% r+ � r, z%SelectInLoader._memoized_attr__bakeryc C s� | j j| j jjst�d| ��|jjpt j j | }t � |d | j �s%d S t j�||| j�r0d S || j } || j } | �|jdd �} | d urI| } n| j} | �|jd�si| jra| jd | jkr`d S n| �| j�rid S t j�||| j | j| j| � d S )Nr� r� rr rt r )r: rA r r� r� r r r r? r ry rz � _entity_isar �PostLoad� path_existsrX r@ r r� r{ rq r| r} rH �callable_for_path�_load_for_path) rZ r_ ra rb rH ri rc rj � selectin_path� path_w_prop�selectin_path_w_propr� r� r$ r$ r% rk � sH ��� �� �z#SelectInLoader.create_row_processorc s: |r �j |vr d S �j}|jrRt�t�}g } �j�|D ]6\�} �j� t��� fdd�|j D ��} t j | v r:�j } nd | vrI|| � �� | f� q| � �� | f� q|js\dd� |D �}|j�|j�|js�t����jr��fdd��D ��������fdd��D ������fdd���} |js�| ��fd d�� n�j�| ����fd d�� |jr�| ��fd d�� n | ���fd d�� |j} | �| j|�j � | jr�| �d d� � �jj �r|js��jj � �jr�fdd�� D �� | �� fdd�� n �fdd�}| �|� |j�r�� || || |� d S �� ||| |� d S )Nc 3 s$ � | ] }� j ��|tjd �V qdS )r N)r r �PASSIVE_NO_FETCH)r� �lk)rH r� � state_dictr$ r% r� � s � �� �z0SelectInLoader._load_for_path.<locals>.<genexpr>c S s$ g | ]\}}|j d ||j|f�qS �r )r r )r� r� � overwriter$ r$ r% r� � s ��z1SelectInLoader._load_for_path.<locals>.<listcomp>c r r$ r� r� ��inspr$ r% r� r� c r r$ r� r� r� r$ r% r� r� c s | � t jdg��R � � �S )Nr )r �Bundler- )r� rn r$ r% r& � �z/SelectInLoader._load_for_path.<locals>.<lambda>c r8 r )r4 r1 )r� r$ r% r& r7 c s | � ���t��jj��� ��S r )r4 r� r� rX r r� r1 )r� �parZ r$ r% r& $ s ��c s | � � �tjddd���S �N� primary_keysT)� expanding)rC �in_r r� r1 )rm r$ r% r& - r� c s | � � �tjddd���j�� S r� )rC r� r r� r; r1 )rm rn r$ r% r& 3 s ��c S s | � � S r )r_ r1 r$ r$ r% r& ? � c r r$ r� )r� �elemr� r$ r% r� E r� c s | j � � S r )r; r1 )r� r$ r% r& H r7 c s& | j d }| j|j�t�� jj��� S rv )r� r; r� r� r r6 rX )r2 r� r� r$ r% r� K s ��z?SelectInLoader._load_for_path.<locals>._setup_outermost_orderby) r rh rk r� � defaultdictr5 r: r r� rp r r� ri r8 rn rm rl r r� r� r� rH rg r rN r� rX r� r; �_load_via_child�_load_via_parent)rZ r* r_ ra �states� load_onlyr� r{ � our_states� none_statesr� � related_identr2 ru r� r$ ) r� r� rm r� rH r� rn rZ r� r� r% r� � s� � �� �� � � � � �z SelectInLoader._load_for_pathc s� | j }t|�}|r[|d| j� }|| jd � }dd� ||j�j� fdd�|D �d�D �} |D ]*} | �| d �} || D ] \} } }|sG| j| v rGq:| �| j��| | |sS| n| g� q:q.|s |D ]\} } }|sj| j| v rjq]| �| j��| | d � q]d S )Nr c S s i | ]\}}||�qS r$ r$ r� r$ r$ r% � <dictcomp>g s ��z2SelectInLoader._load_via_child.<locals>.<dictcomp>c s g | ] }� j r |d n|�qS r� �ro )r� r �r{ r$ r% r� j s �z2SelectInLoader._load_via_child.<locals>.<listcomp>�r� ) r) �sorted� _chunksizer� r� r@ r r� r� )rZ r� r� r{ r2 r_ r) �our_keys�chunk�datar � related_objr� r� r� r$ r� r% r� _ s: ��� ��� �z SelectInLoader._load_via_childc s� | j }|rdnd }|r{|d| j� }|| jd � }� fdd�|D �}dd� t�||j�j|d�dd � �D �} |D ]>\} } } } | sF| j| v rFq8| �| |�}|sk|rkt|�d kr]t � d | � | � | j�� | | |d � q8| � | j�� | | |� q8|s d S d S ) Nr$ r c s& g | ]\}}}}� j r|d n|�qS r� r� )r� r r� r� r� r� r$ r% r� � s ��z3SelectInLoader._load_via_parent.<locals>.<listcomp>c S s i | ] \}}|d d� |D ��qS )c S r� r� r$ r� r$ r$ r% r� � r� z>SelectInLoader._load_via_parent.<locals>.<dictcomp>.<listcomp>r$ r� r$ r$ r% r� � s ��z3SelectInLoader._load_via_parent.<locals>.<dictcomp>r� c S s | d S rv r$ r� r$ r$ r% r& � r� z1SelectInLoader._load_via_parent.<locals>.<lambda>r r� ) r) r� r� r� r� r� r r@ rW r rX r� r� )rZ r� r{ r2 r_ r) � _empty_resultr� r� r� r r� r� r� r� r$ r� r% r� � s@ ��� �� � � �z SelectInLoader._load_via_parent)rl rm rn rp r� � namedtupler{ r� rW rs rq rr r� r rb r+ rk r� r� r� rq r$ r$ r\ r% re ' s( � 1 *re c sT �fdd�� � fdd�}� fdd�}t j| d|dddd � t j| d |dddd � d S ) Nc sP |d ur&|j � j kr&|�t�|��}|r&||ur&t�dt�|�| j� f ��|S )NzsInstance %s is already associated with an instance of %s via its %s attribute, and is only allowed a single parent.) r � hasparentr �instance_stater r r � instance_strrD )r� r� �oldvalue� initiatorr� )r! r$ r% � _do_check� s ��z*single_parent_validator.<locals>._do_checkc s � | |d |�S r r$ )r� r� r� �r� r$ r% r8 � � z'single_parent_validator.<locals>.appendc s � | |||�S r r$ )r� r� r� r� r� r$ r% �set_� r� z%single_parent_validator.<locals>.set_r8 T)�raw�retvalr1 r} )r �listen)r r! r8 r� r$ )r� r! r% r9 � s �r9 )NNNNFN)8ro � __future__r r� r� � r r r� r r r r r r r �baser r r r r� r r� r r r r r r r r r� r rO �ColumnProperty� strategy_forrR � class_loggerrr r� r� r� r� r� �RelationshipPropertyr� r� � MemoizedSlotsr� r^ re rp r� re r9 r$ r$ r$ r% �<module> s� �V#B ; 8 @
Save
Cancel