#NEWLINE# def DeleteFlowRequestStates( self , session_id , request_state ) : #NEWLINE# #INDENT# 'Deletes the request and all its responses from the flow state queue.' #NEWLINE# queue = self . to_delete . setdefault ( session_id . Add ( 'state' ) , [ ] ) #NEWLINE# queue . append ( ( self . FLOW_REQUEST_TEMPLATE % request_state . id ) ) #NEWLINE# queue . append ( ( self . FLOW_STATUS_TEMPLATE % request_state . id ) ) #NEWLINE# if ( request_state and request_state . HasField ( 'request' ) ) : #NEWLINE# #INDENT# self . DeQueueClientRequest ( request_state . client_id , request_state . request . task_id ) #NEWLINE# #UNINDENT# response_subject = self . GetFlowResponseSubject ( session_id , request_state . id ) #NEWLINE# self . data_store . DeleteSubject ( queue , token = self . token )