async def METHOD_NAME(self, fn: Callable[..., T], *args, **kwargs) -> T:
    """
    run a callable :code:`fn` on an arbitrary worker node
    """
    fn_with_args = functools.partial(self._wrapped.METHOD_NAME, fn, *args, **kwargs)
    return await sync_to_async(fn_with_args, self._pool)