code: async def checked_run(*cmd):
    
  
    # Start the subprocess.
    logging.info('Running: %s', expand_cmd_str(cmd))
    with logged_timer('{} finished'.format(get_cmd_name(cmd))):
      p = await asyncio.create_subprocess_exec(
          *cmd, stdout=asyncio.subprocess.PIPE, stderr=asyncio.subprocess.STDOUT)
  
      # Stream output from the process stdout.
      chunks = []
      while True:
        chunk = await p.stdout.read(16 * 1024)
        if not chunk:
          break
        chunks.append(chunk)
  
      # Wait for the process to finish, check it was successful & build stdout.
      await p.wait()
      stdout = b''.join(chunks).decode()[:-1]
      if p.returncode:
        raise RuntimeError('Return code {} from process: {}\n{}'.format(
            p.returncode, expand_cmd_str(cmd), stdout))
  
      return stdout
docs: Run the given subprocess command in a coroutine.
  
    Args:
      *cmd: the command to run and its arguments.
  
    Returns:
      The output that the command wrote to stdout.
  
    Raises:
      RuntimeError: if the command returns a non-zero result.