code: def drain_queues(self):
      # type: () -> None
      assert self.is_tick_used
      self.drain_queue(self.normal_queue)
      self.reset()
      self.have_drained_queues = True
      self.drain_queue(self.late_queue)
  
imports: from collections import deque
  from threading import local
label_desc: Use image node_id 15 for calling the Async obj's underlying member method code with example usage: obj.drain_queues() without return types