
    AHjR                     n    d dl mZ d dl mZ  G d de      ZdZdedefdZdede	e
e   e
e   ef   fd	Zy
)    )
Connection)Redisc                       e Zd Zy)NoRedisConnectionExceptionN)__name__
__module____qualname__     F/root/tools/cai/cai_env/lib/python3.12/site-packages/rq/connections.pyr   r      s    r   r   )maint_notifications_config maint_notifications_pool_handlerevent_dispatcherorig_host_addressorig_socket_timeoutorig_socket_connect_timeout
connectionreturnc                     | j                   j                  j                         }t        D ]  }|j	                  |d        |j                         D ci c]  \  }}t        |      t        us|| c}}S c c}}w )zTReturn pool kwargs suitable for rebuilding this Redis connection in a child process.N)connection_poolconnection_kwargscopyREDIS_RUNTIME_CONNECTION_KWARGSpopitemstypeobject)r   kwargskeyvalues       r   get_connection_kwargsr!      sh    ''99>>@F. 

3
 *0U:34;f;TCJUUUs   A8/A8c                 b    t        |       }| j                  j                  }| j                  ||fS )N)r!   r   connection_class	__class__)r   connection_pool_kwargsconnection_pool_classs      r   parse_connectionr'   "   s4    2:>&66GG!68NNNr   N)redisr   RedisConnectionr   	Exceptionr   r   dictr!   tupler   r'   r
   r   r   <module>r-      sa    / 	 	# Ve V VO O5ed?>SUY1Y+Z Or   