
    Ih                        d Z ddlmZ ddlZddlmZmZmZmZm	Z	m
Z
mZmZmZmZ ddlmZ ddlmZ 	 ddlmZmZ i Z e       Z eee      Z G d	 d
      Z G d d      Zy# e$ r ddlmZmZ Y 7w xY w)z6Kombu transport using SQLAlchemy as the message store.    )annotationsN)
BooleanColumnDateTime
ForeignKeyIndexIntegerSequenceSmallIntegerStringTextrelationship)MetaData)declarative_basedeclared_attr)metadataclass_registryc                  z    e Zd ZdZdddZ ee ed      dd      Z e e	d      d      Z
d	 Zd
 Zed        Zy)QueuezThe queue class.TInnoDBsqlite_autoincrementmysql_enginequeue_id_sequenceprimary_keyautoincrement   )uniquec                    || _         y Nname)selfr$   s     Z/var/www/html/planif/env/lib/python3.12/site-packages/kombu/transport/sqlalchemy/models.py__init__zQueue.__init__    s	    	    c                "    d| j                    dS )Nz<Queue(z)>r#   r%   s    r&   __str__zQueue.__str__#   s    2&&r(   c                    t        ddd      S )NMessagequeuenoload)backreflazyr   )clss    r&   messageszQueue.messages&   s    IwXFFr(   N)__name__
__module____qualname____doc____table_args__r   r	   r
   idr   r$   r'   r+   r   r3    r(   r&   r   r      sX    .2HMN	"56D"
$B&+d+D' G Gr(   r   c                      e Zd ZdZ eddd      dddfZ ee ed      dd	      Z	 ee
dd
      Z ededdej                  j                        Z eed      Z eedd      ZdeiZd Zd Zed        Zy)r-   zThe message class.ix_kombu_message_timestamp_id	timestampr9   Tr   r   message_id_sequencer   )defaultindex)nullabler@   onupdateF)rA      )rA   r?   version_id_colc                     || _         || _        y r"   )payloadr.   )r%   rF   r.   s      r&   r'   zMessage.__init__=   s    
r(   c                $    dj                  |       S )Nz/<Message: {0.sent_at} {0.payload} {0.queue_id}>)formatr*   s    r&   r+   zMessage.__str__A   s    @GGMMr(   c                `    t        t        t        dt        d   j                  z  d            S )Nz%s.idr   FK_kombu_message_queuer#   )r   r	   r   r   __tablename__r*   s    r&   queue_idzMessage.queue_idD   s0    .1???-
 	
r(   N)r4   r5   r6   r7   r   r8   r   r	   r
   r9   r   visibler   datetimenowsent_atr   rF   r   version__mapper_args__r'   r+   r   rL   r:   r(   r&   r-   r-   +   s     	-{DA!%x@N
 
"78 
6BWd$7G[(T&//335GTE*G\E1=G'1ON 
 
r(   r-   )r7   
__future__r   rN   
sqlalchemyr   r   r   r   r   r	   r
   r   r   r   sqlalchemy.ormr   sqlalchemy.schemar   r   r   ImportErrorsqlalchemy.ext.declarativer   r   	ModelBaser   r-   r:   r(   r&   <module>rZ      su    < " > > > ' &K>
 :h~N	G G(!
 !
;  KJJKs   A" "A21A2