def METHOD_NAME(self,
               fn: Callable[[Any], Any],
               args: Optional[List] = None,
               kwargs: Optional[Dict] = None,
               callbacks: Optional[List[Callable]] = None):
    """Executes the provided function on all workers.
    Args:
        fn: Target function that can be executed with arbitrary
            args and keyword arguments.
        args: List of arguments to be passed into the target function.
        kwargs: Dictionary of keyword arguments to be
            passed into the target function.
    Returns:
        list: List of ObjectRefs that you can run `ray.get` on to
            retrieve values.
    """
    raise NotImplementedError("Method must be implemented in a subclass")