'Flushes the flow and all its requests to the data_store.'

def Close(self, sync=True):

    self.CheckLease()
    self.Save()
    self.WriteState()
    super(FlowBase, self).Close(sync=sync)
    self.FlushMessages()
