code: def CreateTrial(self, request, context):
      trial = self.oracle.create_trial(request.tuner_id)
      if trial.status == trial_module.TrialStatus.STOPPED:
          self.stop_triggered = True
      return protos.get_service().CreateTrialResponse(
          trial=trial.to_proto()
      )
  
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 4 for calling the OracleServicer obj's underlying member method code with example usage: obj.CreateTrial(request, context) and returns: protos