code: def run(
      op,
      quiet=False,
      pidfile=None,
      stop_after=None,
      extra_env=None,
      continue_on_deps_error=False,
  ):
      run = init_run(op)
      op_util.clear_run_marker(run, "STAGED")
      try:
          _resolve_deps(
              op, run, continue_on_error=continue_on_deps_error
          )
      finally:
          op_util.clear_run_pending(run)
      _callback("run_starting", op, run, pidfile)
      op_util.set_run_started(run)
      if pidfile:
          _run_op_in_background(
              run, op, pidfile, quiet, stop_after, extra_env
          )
          return run, None
      exit_status = _run_op(run, op, quiet, stop_after, extra_env)
      _callback("run_stopped", op, run, exit_status)
      return run, exit_status
  
imports: import logging
  import os
  import subprocess
  import time
  from guild import config
  from guild import exit_code
  from guild import log
  from guild import op_dep
  from guild import op_util
  from guild import run
  from guild import util
label_desc: Use image node_id 7 for calling a global function with example usage: run(op, quiet, pidfile, stop_after, extra_env, continue_on_deps_error) and returns: run,  exit_status, run,  None