
    Pqh                    T   d dl mZ d dlmZ d dlmZ d dlZd dlZd dlZd dl	m
Z
 d dl	mZ d dl	mZ d dlZd dlmZ d	d
lmZ  ej$                  e      Z ej$                  d      j+                   ej,                                	 d dlZd dlZd dlZ ej4                  d ej6                   ej8                  dd d d d             Z ej:                  de      \  ZZZ Z!ed k  rdZdd	 	 	 	 	 	 	 ddZ$eddd       Z%dddZ&ddZ'dddZ(	 d	 	 	 	 	 	 	 	 	 ddZ)d dZ*y# e"e#f$ r dZY Ew xY w)!    )annotations)Iterable)contextmanagerN)Optional)TextIO)Union)url   )sqla_compatalembicHHHHFquietc                   |ry t        | dd      xs d}|D ]G  }t        |t              s|j                  |d      }|j	                  |      }	 | j                  |       I y # t        $ r Y  y w xY w)Nencodingasciireplace)getattr
isinstancebytesencodedecodewriteOSError)streamr   textr   ts        W/srv/www/ollama/chat-ollama/venv/lib/python3.12/site-packages/alembic/util/messaging.pywrite_outstreamr   $   sz     vz73>wH 
!U#9-AHHX	LLO
  	 		s   A""	A/.A/c              #     K   t        | dz   |d|       	 d  |st        t        j                  d       y y #  |st        t        j                  d        xY ww)Nz ...T)flushr   z  done
z	  FAILED
)msgr   sysstdout)
status_msgnewliner   s      r   statusr'   7   sS     
VWD>4 CJJ
3 CJJ5s   A8 AAAc                x    t         j                  |        t        d|  |       t        j                  d       y )NzFAILED: r   )logerrorr"   r#   exit)messager   s     r   errr.   E   s*    IIg(7)E*HHRL    c                Z    t        j                  |       }t        j                  |d      S )NT)hide_password)r	   make_urlr   url_render_as_string)	input_urlus     r   obfuscate_url_pwr6   K   s#    YA++ATBBr/   c                <    t        j                  | t        |       y )N)
stacklevel)warningswarnUserWarning)r"   r8   s     r   r:   r:   P   s    MM#{z:r/   c                   |ry t         7t        t        j                  |        |rt        t        j                  d       nqt	        j
                  | t               }t        |      dkD  r&|dd D ]  }t        t        j                  d|d         t        t        j                  d|d   |rdnd       |rt        j                  j                          y y )N
r
   r   r)   z   )	TERMWIDTHr   r#   r$   textwrapwraplenr!   )r"   r&   r!   r   lineslines         r   r"   r"   T   s     

C(CJJ- c9-u:>a >

D$=>

D%)gd2O

 r/   c                    | yt        | t              r| S t        | t              rdj                  |       S t	        d| z        )Nr>   z, z!Don't know how to comma-format %r)r   strr   join
ValueError)values    r   format_as_commarJ   h   sC    }	E3		E8	$yy<uDEEr/   )r   r   r   zUnion[str, bytes]r   boolreturnNone)FF)r%   rF   r&   rK   r   rK   )F)r-   rF   r   rK   )r4   rF   rL   rF   )   )r"   rF   r8   intrL   rM   )TFF)
r"   rF   r&   rK   r!   rK   r   rK   rL   rM   )rI   z#Optional[Union[str, Iterable[str]]]rL   rF   )+
__future__r   collections.abcr   
contextlibr   loggingr#   r@   typingr   r   r   r9   sqlalchemy.enginer	   r>   r   	getLogger__name__r*   
addHandlerNullHandlerfcntltermiosstructioctl
TIOCGWINSZpackunpack_hr?   _hp_wpImportErrorr   r   r'   r.   r6   r:   r"   rJ    r/   r   <module>rf      sk   " $ %  
      ! g!   )  ' '(;(;(;(= >
EKK7--{v{{61aA/NOE+fmmFE:B	3A~	 =B,59	& 
4 
4C
;
 HM	+/@D	(FQ 	W Is   AD 	D'&D'