code: def create_user(check_original_docker_image):
      try:
          subprocess.check_output(
              [
                  "sudo",
                  "useradd",
                  "-m",
                  TEST_USER,
                  "-g",
                  str(os.getegid()),
              ],
              stderr=subprocess.STDOUT,
          )
      except subprocess.CalledProcessError as e:
          command = e.cmd[1]
          if e.returncode != 9:  # pass: username already exists
              raise pytest.skip(
                  f"{e} Skipping tests.\n"
                  f"Does command {command!r} exists and the current user have permission to run "
                  f"{command!r} without a password prompt (check sudoers file)?\n"
                  f"{e.stdout.decode() if e.stdout else ''}"
              )
      yield TEST_USER
      subprocess.check_call(["sudo", "userdel", "-r", TEST_USER])
  
imports: from __future__ import annotations
  import contextlib
  import logging
  import os
  import subprocess
  import sys
  import tempfile
  from pathlib import Path
  import pytest
  from airflow.configuration import conf
  from airflow.jobs.backfill_job_runner import BackfillJobRunner
  from airflow.jobs.job import Job, run_job
  from airflow.models import DagBag, DagRun, TaskInstance
  from airflow.utils.db import add_default_pool_if_not_exists
  from airflow.utils.state import State
  from airflow.utils.timezone import datetime
  from airflow.utils.types import DagRunType
  from tests.test_utils import db
label_desc: Use image node_id 3 for calling a global function with example usage: create_user(check_original_docker_image) without return types