code: def test_ray_init_from_workers(ray_start_cluster):
      cluster = ray_start_cluster
      # add first node
      node1 = cluster.add_node(node_ip_address="127.0.0.2")
      # add second node
      node2 = cluster.add_node(node_ip_address="127.0.0.3")
      address = cluster.address
      password = cluster.redis_password
      assert address.split(":")[0] == "127.0.0.2"
      assert node1.node_manager_port != node2.node_manager_port
      info = ray.init(
          address,
          _redis_password=password,
          _node_ip_address="127.0.0.3",
      )
      assert info["node_ip_address"] == "127.0.0.3"
  
      node_info = ray._private.services.get_node_to_connect_for_driver(
          cluster.gcs_address, "127.0.0.3"
      )
      assert node_info["node_manager_port"] == node2.node_manager_port
  
imports: import logging
  import os
  import sys
  import unittest.mock
  import tempfile
  import shutil
  from unittest.mock import patch
  import pytest
  import ray
  from ray._private.ray_constants import RAY_OVERRIDE_DASHBOARD_URL, DEFAULT_RESOURCES
  from ray.air.util.node import _get_node_id_from_node_ip
  import ray._private.services
  from ray._private.services import get_node_ip_address
  from ray.dashboard.utils import ray_address_to_api_server_url
  from ray._private.test_utils import get_current_unused_port, run_string_as_driver, wait_for_condition
  from ray.util.client.ray_client_helpers import ray_start_client_server
label_desc: Use image node_id 16 for calling a global function with example usage: test_ray_init_from_workers(ray_start_cluster) without return types