code: def _publish_estimator(self, mlops_connection, project):
      if not _is_model_published(
          mlops_connection, project, self.model_id
      ):
          mojo_file_path = self.save_mojo(
              TEMPORARY_DIRECTORY_FOR_MOJO_MODELS
          )
          try:
              artifact = _upload_artifact(
                  mlops_connection, project, mojo_file_path
              )
              _create_experiment(
                  self, mlops_connection, project, artifact
              )
              print(
                  "The model '%s' has been published to MLOps instance."
                  % self.model_id
              )
              return True
          finally:
              os.remove(mojo_file_path)
      else:
          warnings.warn(
              "The model '%s' has already been published."
              % self.model_id
          )
      return False
  
imports: import h2o.h2o
  from .connect import *
  from .utils import *
  from .status import _is_model_published
  from .deploy import deploy
  import warnings
  import os
  import mimetypes
  import h2o_mlops_client
  import h2o_cloud_extensions
label_desc: Use image node_id 3 for calling a global function with example usage: _publish_estimator(mlops_connection, project) and returns: False, True