
    2i.                     B    d dl mZ d dlmZ d dlZd Z	 	 	 	 	 	 	 	 ddZy)    )RedisClusterNc                 B    | j                  d      }d|v xr |d   dk(  S )Nserver)section
redis_modecluster)info)connr	   s     Z/mnt/e/genesis-system/.venvs/voice-bridge/lib/python3.12/site-packages/falkordb/cluster.py
Is_Clusterr      s,    99X9&D4CD$6)$CC    c
                    | j                   j                  }
|
j                  d      }|
j                  d      }|
j                  d      }|
j                  d      }|
j                  dd       }|
j                  dd       }|
j                  dt        t        t
        t        j                  t        j                  g      }t        di d|d|d|d|dd	d
|d|d|d|d|d|d|d|d|d|	d|d|S )Nhostportusernamepasswordretryretry_on_timeoutretry_on_errordecode_responsesTsslrequire_full_coveragereinitialize_stepsread_from_replicasdynamic_startup_nodesurladdress_remapstartup_nodescluster_error_retry_attempts )
connection_poolconnection_kwargspopConnectionRefusedErrorConnectionErrorTimeoutErrorsockettimeoutredis_exceptionsr   )r
   r   r   r   r   r   r   r   r   r   r"   r   r   r   r   r   r   r   s                     r   Cluster_Connr*      sc    ,,>>  (D  (D $$Z0H $$Z0H!!'40E(,,-?F&**"NN,,	
	N    	
    * & 4 . . 4  $  $!" &B# r   )   NF   FTNN)redis.clusterr   redis.exceptions
exceptionsr)   r'   r   r*   r    r   r   <module>r0      s3    & + D "#0r   