python/ray/_private/test_utils.py
def init_error_pubsub():
    """Initialize error info pub/sub"""
    s = GcsErrorSubscriber(address=ray.worker.global_worker.gcs_client.address)
    s.subscribe()
    return s
Initialize error info pub/sub
Initialize error info pub/sub
Initialize error info pub / sub
def init_error_pubsub():
    s = GcsErrorSubscriber(address=ray.worker.global_worker.gcs_client.address)
    s.subscribe()
    return s
def init_error_pubsub ( ) : s = GcsErrorSubscriber ( address = ray . worker . global_worker . gcs_client . address ) s . subscribe ( ) return s
Initialize error info pub/sub
Initialize error info pub / sub
"""Initialize error info pub/sub"""