code: def initialize_grpc_port_and_server(grpc_ip, grpc_port):
      try:
          from grpc import aio as aiogrpc
      except ImportError:
          from grpc.experimental import aio as aiogrpc
  
      import ray._private.tls_utils
  
      aiogrpc.init_grpc_aio()
  
      server = aiogrpc.server(options=(("grpc.so_reuseport", 0),))
  
      grpc_port = ray._private.tls_utils.add_port_to_grpc_server(
          server, f"{grpc_ip}:{grpc_port}"
      )
  
      return server, grpc_port
  
imports: import asyncio
  import logging
  import os
  from pathlib import Path
  import threading
  from concurrent.futures import Future
  from queue import Queue
  import ray.dashboard.consts
  import ray.dashboard.utils
  import ray.experimental.internal_kv
  from ray._private.usage.usage_lib import TagKey, record_extra_usage_tag
  from ray._private import ray_constants
  from ray.dashboard.utils import DashboardHeadModule
  from ray._raylet import GcsClient, check_health
  from ray.dashboard.datacenter import DataOrganizer
  from ray.dashboard.utils import async_loop_forever
  from ray.dashboard.consts import DASHBOARD_METRIC_PORT
  from ray.dashboard.dashboard_metrics import DashboardPrometheusMetrics
  from typing import Optional, Set
label_desc: Use image node_id 1 for calling a global function with example usage: initialize_grpc_port_and_server(grpc_ip, grpc_port) and returns: server,  grpc_port