dplutils.observer.ray.RayActorWrappedObserver

class dplutils.observer.ray.RayActorWrappedObserver(cls, *args, **kwargs)

Create actor from another observer

For use with stateful observers that should not have multiple instances. Each call to this observer does a remote call to the actor-based observer.

Parameters:

• cls – The observer class to start as actor

• *args – Args to pass to cls instantiation

• **kwargs – Keyword args to pass to cls instantiation

__init__(cls, *args, **kwargs)

Methods

__init__(cls, *args, **kwargs)
increment(name[, value])	Increment a counter
observe(name, value, **kwargs)	Observe a metric value
param(name, value, **kwargs)	Record a run parameter
timer(name, **kwargs)	Return a timer context manager recoding to this observer