code: def _close_consumer(consumer):
      try:
          consumer.close()
      except RuntimeError:
          pass
  
imports: import asyncio
  from glob import glob
  import queue
  import os
  import time
  from tornado import gen
  import weakref
  from .core import Stream, convert_interval, RefCounter, sync
label_desc: Use image node_id 3 for calling a global function with example usage: _close_consumer(consumer) without return types