'Fetch all the requests with a status message queued for them.'

def FetchCompletedRequests(self, session_id, timestamp=None):

    if (timestamp is None):
        timestamp = (0, (self.frozen_timestamp or rdfvalue.RDFDatetime.Now()))
    for (request, status) in self.data_store.ReadCompletedRequests(session_id, timestamp=timestamp, limit=self.request_limit, token=self.token):
        (yield (request, status))
