code: def start_server(oracle):
      """Starts the `OracleServicer` used to manage distributed requests."""
      ip_addr = os.environ["KERASTUNER_ORACLE_IP"]
      port = os.environ["KERASTUNER_ORACLE_PORT"]
      server = grpc.server(futures.ThreadPoolExecutor(max_workers=1))
      oracle_servicer = OracleServicer(oracle)
      protos.get_service_grpc().add_OracleServicer_to_server(
          oracle_servicer, server
      )
      server.add_insecure_port(f"{ip_addr}:{port}")
      server.start()
      while True:
          # The server does not block otherwise.
          time.sleep(1)
  
          if oracle_servicer.stop_triggered:
              while not exit_chief(oracle):
                  time.sleep(20)  # pragma: no cover
              break
  
imports: import os
  import time
  from concurrent import futures
  import grpc
  from keras_tuner import protos
  from keras_tuner.engine import hyperparameters
  from keras_tuner.engine import trial
  from keras_tuner.engine.oracle import synchronized
label_desc: Use image node_id 2 for calling a global function with example usage: start_server(oracle) without return types