original_docstring: r"""Return a callable for the create training pipeline method over gRPC.
  
          Creates a TrainingPipeline. A created
          TrainingPipeline right away will be attempted to be run.
  
          Returns:
              Callable[[~.CreateTrainingPipelineRequest],
                      ~.TrainingPipeline]:
                  A function that, when called, will call the underlying RPC
                  on the server.
          
docstring: r"""Return a callable for the create training pipeline method over gRPC.
docstring_tokens: r " " " Return a callable for the create training pipeline method over gRPC .
code: def create_training_pipeline(
          self,
      ) -> Callable[
          [pipeline_service.CreateTrainingPipelineRequest],
          gca_training_pipeline.TrainingPipeline,
      ]:
          r"""Return a callable for the create training pipeline method over gRPC.
  
          Creates a TrainingPipeline. A created
          TrainingPipeline right away will be attempted to be run.
  
          Returns:
              Callable[[~.CreateTrainingPipelineRequest],
                      ~.TrainingPipeline]:
                  A function that, when called, will call the underlying RPC
                  on the server.
          """
          # Generate a "stub function" on-the-fly which will actually make
          # the request.
          # gRPC handles serialization and deserialization, so we just need
          # to pass in the functions for each.
          if "create_training_pipeline" not in self._stubs:
              self._stubs["create_training_pipeline"] = self.grpc_channel.unary_unary(
                  "/google.cloud.aiplatform.v1beta1.PipelineService/CreateTrainingPipeline",
                  request_serializer=pipeline_service.CreateTrainingPipelineRequest.serialize,
                  response_deserializer=gca_training_pipeline.TrainingPipeline.deserialize,
              )
          return self._stubs["create_training_pipeline"]
code_tokens: def create_training_pipeline ( self , ) -> Callable [ [ pipeline_service . CreateTrainingPipelineRequest ] , gca_training_pipeline . TrainingPipeline , ] : if "create_training_pipeline" not in self . _stubs : self . _stubs [ "create_training_pipeline" ] = self . grpc_channel . unary_unary ( "/google.cloud.aiplatform.v1beta1.PipelineService/CreateTrainingPipeline" , request_serializer = pipeline_service . CreateTrainingPipelineRequest . serialize , response_deserializer = gca_training_pipeline . TrainingPipeline . deserialize , ) return self . _stubs [ "create_training_pipeline" ]
short_docstring: r"""Return a callable for the create training pipeline method over gRPC.
short_docstring_tokens: r " " " Return a callable for the create training pipeline method over gRPC .
comment: r"""Return a callable for the create training pipeline method over gRPC.
  
          Creates a TrainingPipeline. A created
          TrainingPipeline right away will be attempted to be run.
  
          Returns:
              Callable[[~.CreateTrainingPipelineRequest],
                      ~.TrainingPipeline]:
                  A function that, when called, will call the underlying RPC
                  on the server.
          """$SEP$# Generate a "stub function" on-the-fly which will actually make$SEP$# the request.$SEP$# gRPC handles serialization and deserialization, so we just need$SEP$# to pass in the functions for each.