dplutils.observer.ray.RayMetricsObserver

class dplutils.observer.ray.RayMetricsObserver

Observer implemented using ray metrics

Ray metrics are implemented in the raylet and exposed as a prometheus endpoint. While there is some state to store the underlying ray metric objects, this can be used directly having copies per worker (so does not need to be wrapped in actor).

__init__()

Methods

__init__()
increment(name[, value])	Increment a counter
observe(name, value, **kwargs)	Observe a metric value
param(name, value, **kwargs)	Not yet implemented
timer(name, **kwargs)	Return a timer context manager recoding to this observer