python/ray/util/client/dataclient.py
def _acknowledge(self, req_id: int) -> None:
        """
        Puts an acknowledge request on the request queue periodically.
        Lock should be held before calling this. Used when an async or
        blocking response is received.
        """
        if not self.client_worker._reconnect_enabled:
            # Skip ACKs if reconnect isn't enabled
            return
        assert self.lock.locked()
        self._acknowledge_counter += 1
        if self._acknowledge_counter % ACKNOWLEDGE_BATCH_SIZE == 0:
            self.request_queue.put(
                ray_client_pb2.DataRequest(
                    acknowledge=ray_client_pb2.AcknowledgeRequest(req_id=req_id)
                )
            )

        Puts an acknowledge request on the request queue periodically.
        Lock should be held before calling this. Used when an async or
        blocking response is received.
        
Puts an acknowledge request on the request queue periodically.
Lock should be held before calling this. Used when an async or
blocking response is received.
Puts an acknowledge request on the request queue periodically . Lock should be held before calling this . Used when an async or blocking response is received .
def _acknowledge(self, req_id: int) -> None:
        if not self.client_worker._reconnect_enabled:
            return
        assert self.lock.locked()
        self._acknowledge_counter += 1
        if self._acknowledge_counter % ACKNOWLEDGE_BATCH_SIZE == 0:
            self.request_queue.put(
                ray_client_pb2.DataRequest(
                    acknowledge=ray_client_pb2.AcknowledgeRequest(req_id=req_id)
                )
            )
def _acknowledge ( self , req_id : int ) -> None : if not self . client_worker . _reconnect_enabled : return assert self . lock . locked ( ) self . _acknowledge_counter += 1 if self . _acknowledge_counter % ACKNOWLEDGE_BATCH_SIZE == 0 : self . request_queue . put ( ray_client_pb2 . DataRequest ( acknowledge = ray_client_pb2 . AcknowledgeRequest ( req_id = req_id ) ) )
Puts an acknowledge request on the request queue periodically.
Puts an acknowledge request on the request queue periodically .
"""
        Puts an acknowledge request on the request queue periodically.
        Lock should be held before calling this. Used when an async or
        blocking response is received.
        """ # Skip ACKs if reconnect isn't enabled
self
req_id
int