code: def _dvc_stage_op_filter(stage, run_id_prefix, status):
      assert stage
      assert status
  
      # If full run ID specified, select matching run regardless of
      # stage and status.
      if run_id_prefix and len(run_id_prefix) == 32:
          return lambda run: run.id == run_id_prefix
  
      def f(run):
          return (
              _filter_run_id(run, run_id_prefix)  #
              and _filter_run_dvc_stage(run, stage)  #
              and _filter_run_status(run, status)
          )
  
      return f
  
imports: import json
  import logging
  import os
  import subprocess
  import yaml
  from guild import util
  from guild import var
label_desc: Use image node_id 15 for calling a global function with example usage: _dvc_stage_op_filter(stage, run_id_prefix, status) and returns: f, function, unknown