code: def test_simple(init):
      @ray.remote
      def f():
          time.sleep(1)
          return np.zeros(1024 * 1024, dtype=np.uint8)
  
      future = f.remote().as_future()
      result = get_or_create_event_loop().run_until_complete(future)
      assert isinstance(result, np.ndarray)
  
imports: import asyncio
  import concurrent.futures
  import sys
  import time
  import numpy
  import pytest
  import ray
  from ray._private.async_compat import is_async_func
  from ray._private.test_utils import wait_for_condition
  from ray._private.utils import get_or_create_event_loop, run_background_task, background_tasks
label_desc: Use image node_id 4 for calling a global function with example usage: test_simple(init) and returns: np