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   ]/home/ubuntu/veenaModal/venv/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    