code: def clean(self, timeout=0):
      while True:
          msg = self.dequeue(timeout=timeout)
          if not msg:
              break
  
file_path: studio/studio/pubsub_queue.py
imports: import os
  import json
  import time
  from google.api_core.exceptions import RetryError
  from studio.util.util import sixdecode, retry, parse_verbosity, check_for_kb_interrupt
  from studio.util import logs
label_desc: Use image node_id 2 for calling the PubsubQueue obj's underlying member method code with example usage: obj.clean(timeout) without return types