§
    &`ƒiÝ   ã                   ó.   — d dl mZ  G d„ de¦  «        ZdS )é    )ÚABCc                   ó&   — e Zd Zd„ Zdefd„Zd„ ZdS )ÚTaskConsumerWrapperc                 ó   — d S ©N© )ÚselfÚargsÚkwargss      út/home/jaya/work/projects/VOICE-AGENT/VIET/agent-env/lib/python3.11/site-packages/ray/serve/_private/task_consumer.pyÚ__init__zTaskConsumerWrapper.__init__   ó   € Øˆó    Úconsumer_concurrencyc                 ó   — d S r   r   )r	   r   s     r   Úinitialize_callablez'TaskConsumerWrapper.initialize_callable   r   r   c                 ó   — d S r   r   )r	   s    r   Ú__del__zTaskConsumerWrapper.__del__   r   r   N)Ú__name__Ú
__module__Ú__qualname__r   Úintr   r   r   r   r   r   r      sM   € € € € € ðð ð ð¸ð ð ð ð ðð ð ð ð r   r   N)Úabcr   r   r   r   r   ú<module>r      sK   ðØ Ð Ð Ð Ð Ð ðð ð ð ð ˜#ñ ô ð ð ð r   