code: def test_async_execution(workflow_start_regular_shared):
      @ray.remote
      def blocking():
          time.sleep(10)
          return 314
  
      start = time.time()
      output = workflow.run_async(blocking.bind())
      duration = time.time() - start
      assert duration < 5  # workflow.run is not blocked
      assert ray.get(output) == 314
  
file_path: ray/python/ray/workflow/tests/test_basic_workflows.py
imports: import time
  from ray.tests.conftest import *
  from filelock import FileLock
  import pytest
  import ray
  from ray import workflow
label_desc: Use image node_id 2 for calling a global function with example usage: test_async_execution(workflow_start_regular_shared) and returns: int