&`i[JddlmZddlmZdeededeefdZdS))Iterable)Blockblocksper_task_row_limitreturnc#Kd}|D]p}||krdSddlm}||}|}||z|kr |V||z }M||z }|d|d}|VdSdS)zDIterate over blocks, accumulating rows up to the per-task row limit.r) BlockAccessorT)copyN)ray.data.blockr for_blocknum_rowsslice) rr rows_readblockr accessor block_rowsremaining_rows sliced_blocks l/home/jaya/work/projects/VOICE-AGENT/VIET/agent-env/lib/python3.11/site-packages/ray/data/datasource/util.py_iter_sliced_blocksrsI * * * EE000000 **511&&(( z !%7 7 7KKK  #II0);N#>>!^$>GGL    EE#N)typingrr rintrrrrsg  UO14 e_r