def flush_profile_data(self):
        """Push the logged profiling data to the global control store."""
        with self.lock:
            events = self.events
            self.events = []

        if self.worker.mode == ray.WORKER_MODE:
            component_type = "worker"
        else:
            component_type = "driver"

        self.worker.raylet_client.push_profile_events(
            component_type, ray.UniqueID(self.worker.worker_id),
            self.worker.node_ip_address, events)
def flush_profile_data ( self ) : with self . lock : events = self . events self . events = [ ] if self . worker . mode == ray . WORKER_MODE : component_type = "worker" else : component_type = "driver" self . worker . raylet_client . push_profile_events ( component_type , ray . UniqueID ( self . worker . worker_id ) , self . worker . node_ip_address , events )
Push the logged profiling data to the global control store.