o
    `Û·iÝ   ã                   @   s    d dl mZ G dd„ deƒZdS )é    )ÚABCc                   @   s*   e Zd Zdd„ Zdefdd„Zdd„ ZdS )	ÚTaskConsumerWrapperc                 O   ó   d S ©N© )ÚselfÚargsÚkwargsr   r   úV/home/ubuntu/vllm_env/lib/python3.10/site-packages/ray/serve/_private/task_consumer.pyÚ__init__   ó   zTaskConsumerWrapper.__init__Úconsumer_concurrencyc                 C   r   r   r   )r   r   r   r   r
   Úinitialize_callable   r   z'TaskConsumerWrapper.initialize_callablec                 C   r   r   r   )r   r   r   r
   Ú__del__   r   zTaskConsumerWrapper.__del__N)Ú__name__Ú
__module__Ú__qualname__r   Úintr   r   r   r   r   r
   r      s    r   N)Úabcr   r   r   r   r   r
   Ú<module>   s    