d87a82e8915f5bb3adc24b6f0f99ddece10be3ea,python/ray/monitor.py,Monitor,__init__,#Monitor#Any#Any#Any#Any#,83

Before Change

        worker.mode = 0
        // Keep a mapping from raylet client ID to IP address to use
        // for updating the load metrics.
        self.raylet_id_to_ip_map = {}
        head_node_ip = redis_address.split(":")[0]
        self.load_metrics = LoadMetrics(local_ip=head_node_ip)
        self.last_avail_resources = None
        self.event_summarizer = EventSummarizer()

After Change

            redis_address, password=redis_password)

        // Initialize the gcs stub for getting all node resource usage.
        gcs_address = self.redis.get("GcsServerAddress").decode("utf-8")
        gcs_channel = grpc.insecure_channel(gcs_address)
        self.gcs_node_resources_stub = \
            gcs_service_pb2_grpc.NodeResourceInfoGcsServiceStub(gcs_channel)

        // Set the redis client and mode so _internal_kv works for autoscaler.

Instances