#NEWLINE# def FetchRequestsAndResponses( self , session_id ) : #NEWLINE# #INDENT# 'Well known flows do not have real requests.\n\n    This manages retrieving all the responses without requiring corresponding\n    requests.\n\n    Args:\n      session_id: The session_id to get the requests/responses for.\n\n    Yields:\n      A tuple of request (None) and responses.\n    ' #NEWLINE# subject = session_id . Add ( 'state/request:00000000' ) #NEWLINE# for ( _ , serialized , _ ) in sorted ( self . data_store . ResolvePrefix ( self , self . FLOW_RESPONSE_PREFIX , token = self . token , limit = self . response_limit , timestamp = ( 0 , ( self . frozen_timestamp or rdfvalue . RDFDatetime ( ) . Now ( ) ) ) ) ) : #NEWLINE# #INDENT# response = rdf_flows . GrrMessage ( serialized ) #NEWLINE# ( yield ( rdf_flows . RequestState ( id = 0 ) , [ response ] ) )