o
    EDi#                     @   s(   d dl Zd dlZd dlmZ dd ZdS )    N)ExtensionArrayc                 #   sr    | D ]}t |tjtjtfstdt|q fdd| D }	 dd |D }t	dd |D s5d S |V  q#)NzNUnsupported column type: {}. ndarray/DatetimeIndex/ExtensionArray is expected.c                    s6   g | ]}t t| krt|t|  n|gqS  )iterlennparray_split).0cnr   X/var/www/Datamplify/venv/lib/python3.10/site-packages/clickhouse_driver/numpy/helpers.py
<listcomp>   s    (z!column_chunks.<locals>.<listcomp>Tc                 S   s   g | ]}t |g qS r   )next)r   columnr   r   r   r      s    c                 s   s    | ]}t |V  qd S )N)r   )r   xr   r   r   	<genexpr>   s    z column_chunks.<locals>.<genexpr>)

isinstancer   ndarraypdDatetimeIndexr   	TypeErrorformattypeany)columnsr   r   chunkeditemr   r
   r   column_chunks   s&   


r   )numpyr   pandasr   pandas.core.arraysr   r   r   r   r   r   <module>   s    