code: def _function_to_async(self, func):
      async def wrapper(*args, **kwargs):
          return await self.loop.run_in_executor(
              self.executor, func, *args, **kwargs
          )
  
      return wrapper
  
file_path: ray/python/ray/_private/gcs_aio_client.py
imports: import logging
  from typing import Dict, List, Optional
  from concurrent.futures import ThreadPoolExecutor
  from ray._raylet import GcsClient
  from ray.core.generated import gcs_pb2
  import ray._private.utils
  from ray._private.ray_constants import env_integer
label_desc: Use image node_id 2 for calling the AsyncProxy obj's underlying member method code with example usage: obj._function_to_async(func) and returns: wrapper, unknown