python/ray/_private/gcs_pubsub.py
def publish_error(self, key_id: bytes, error_info: ErrorTableData) -> None:
        """Publishes error info to GCS."""
        msg = pubsub_pb2.PubMessage(
            channel_type=pubsub_pb2.RAY_ERROR_INFO_CHANNEL,
            key_id=key_id,
            error_info_message=error_info,
        )
        req = gcs_service_pb2.GcsPublishRequest(pub_messages=[msg])
        self._gcs_publish(req)
Publishes error info to GCS.
Publishes error info to GCS.
Publishes error info to GCS .
def publish_error(self, key_id: bytes, error_info: ErrorTableData) -> None:
        msg = pubsub_pb2.PubMessage(
            channel_type=pubsub_pb2.RAY_ERROR_INFO_CHANNEL,
            key_id=key_id,
            error_info_message=error_info,
        )
        req = gcs_service_pb2.GcsPublishRequest(pub_messages=[msg])
        self._gcs_publish(req)
def publish_error ( self , key_id : bytes , error_info : ErrorTableData ) -> None : msg = pubsub_pb2 . PubMessage ( channel_type = pubsub_pb2 . RAY_ERROR_INFO_CHANNEL , key_id = key_id , error_info_message = error_info , ) req = gcs_service_pb2 . GcsPublishRequest ( pub_messages = [ msg ] ) self . _gcs_publish ( req )
Publishes error info to GCS.
Publishes error info to GCS .
"""Publishes error info to GCS."""
self
key_id
bytes
error_info
ErrorTableData