async def METHOD_NAME(self):
    """
    Cleanup resources used by this executor, if any, including the wrapped executor.
    """
    res = await sync_to_async(self._wrapped.METHOD_NAME, self._pool)
    if self._pool:
        self._pool.shutdown()
    return res