docs: def flush(self):
          """Empty the local queue and send its elements to be executed remotely.
          """
          for elem in self:
              if elem.id[0] != scoop.worker:
                  elem._delete()
              self.socket.sendFuture(elem)
          self.ready.clear()
          self.movable.clear()