code: def test_workflow_lifetime_1(workflow_start_cluster):
      # Case 1: driver exits normally
      address, storage_uri = workflow_start_cluster
      with patch.dict(os.environ, {"RAY_ADDRESS": address}):
          ray.init()
          run_string_as_driver(driver_script.format(5))
          assert workflow.get_output("driver_terminated") == 20
  
file_path: ray/python/ray/workflow/tests/test_lifetime.py
imports: import os
  import ray
  import time
  import pytest
  from ray._private.test_utils import run_string_as_driver_nonblocking, run_string_as_driver
  from ray.tests.conftest import *
  from ray import workflow
  from unittest.mock import patch
label_desc: Use image node_id 1 for calling a global function with example usage: test_workflow_lifetime_1(workflow_start_cluster) without return types