code: def _run_kaggle_command(command_args, competition_name):
    
    try:
      output = sp.check_output(command_args)
      return tf.compat.as_text(output)
    except sp.CalledProcessError as err:
      output = err.output
      _log_command_output(output, error=True)
      if output.startswith(b"404"):
        logging.error(_NOT_FOUND_ERR_MSG, competition_name)
        raise
      logging.error(_ERR_MSG, competition_name)
      raise
docs: Run kaggle command with subprocess.