code: def test_dedupe_download_raw_ref(workflow_start_regular):
      with tempfile.TemporaryDirectory() as temp_dir:
          debug_store = DebugStorage(temp_dir)
          utils._alter_storage(debug_store)
  
          ref = ray.put("hello")
          workflows = [identity.bind(ref) for _ in range(100)]
  
          workflow.run(gather.bind(*workflows))
  
          ops = debug_store._logged_storage.get_op_counter()
          get_objects_count = 0
          for key in ops["get"]:
              if "objects" in key:
                  get_objects_count += 1
          assert get_objects_count == 1
  
imports: import subprocess
  import tempfile
  import time
  from ray.tests.conftest import *
  import pytest
  from filelock import FileLock
  import ray
  from ray._private.test_utils import run_string_as_driver_nonblocking
  from ray import workflow
  from ray.workflow import workflow_storage
  from ray.workflow.storage.debug import DebugStorage
  from ray.workflow.tests import utils
  from ray.workflow.exceptions import WorkflowNotResumableError
label_desc: Use image node_id 4 for calling a global function with example usage: test_dedupe_download_raw_ref(workflow_start_regular) without return types