code: def test_simple_large_intermediate(workflow_start_regular_shared):
      @ray.remote
      def large_input():
          return np.arange(2**24)
  
      @ray.remote
      def identity(x):
          return x
  
      @ray.remote
      def average(x):
          return np.mean(x)
  
      @ray.remote
      def simple_large_intermediate():
          x = large_input.bind()
          y = identity.bind(x)
          return workflow.continuation(average.bind(y))
  
      start = time.time()
      outputs = workflow.run(simple_large_intermediate.bind())
      print(f"duration = {time.time() - start}")
      assert np.isclose(outputs, 8388607.5)
  
imports: import time
  import pytest
  from ray.tests.conftest import *
  import numpy
  import ray
  from ray import workflow
label_desc: Use image node_id 1 for calling a global function with example usage: test_simple_large_intermediate(workflow_start_regular_shared) and returns: np, x, np, workflow