code: def non_terminated_nodes(self, tag_filters):
      self.num_non_terminated_nodes_calls += 1
      with self.lock:
          if self.throw:
              raise Exception("oops")
          return [
              n.node_id
              for n in self.mock_nodes.values()
              if n.matches(tag_filters)
              and n.state not in ["stopped", "terminated"]
          ]
  
imports: import re
  import threading
  from subprocess import CalledProcessError
  from typing import Callable, Dict, List, Optional
  from ray.autoscaler.node_provider import NodeProvider
label_desc: Use image node_id 2 for calling the MockProvider obj's underlying member method code with example usage: obj.non_terminated_nodes(tag_filters) and returns: unknown