o
    ٷi                  
   @   s   d dl mZmZmZ d dlZd dlmZ d dlmZ ee	Z
dedeeejj ee f fddZ				dded
ededeejj fddZdS )    )ListOptionalTupleN)DiffusionPipeline)init_loggerpipereturnc                 C   sh   | j j}t| dr|ds|dst| ddfS t| dr&t| ddfS t| dr2t| ddfS dS )Ntext_encoder_2Hunyuan	Kandinskytext_encoder_3text_encoder)NN)	__class____name__hasattr
startswithgetattr)r   pipe_cls_name r   I/home/ubuntu/.local/lib/python3.10/site-packages/cache_dit/serve/utils.pyget_text_encoder_from_pipe	   s   

r   Fparallel_text_encoderparallel_vaec                 C   s   g }|r't | \}}|d ur"|| td| d|jj d ntd |rLt| drG| jd urG|| j td| jjj d |S td |S )NzAdded z (z) to extra_parallel_moduleszKparallel_text_encoder is enabled but no text encoder found in the pipeline.vaezAdded vae (z9parallel_vae is enabled but no VAE found in the pipeline.)	r   appendloggerinfor   r   warningr   r   )r   r   r   extra_parallel_modulesr   encoder_namer   r   r   prepare_extra_parallel_modules   s$   

r    )FF)typingr   r   r   torch	diffusersr   cache_dit.loggerr   r   r   nnModulestrr   boolr    r   r   r   r   <module>   s*    

