def _run_queries(self, agent_strs, stmt_types, params, persist):
        """Use paging to get all statements requested."""
        self._query_over_statement_types(agent_strs, stmt_types, params)

        assert len(self.__done_dict) == len(stmt_types) \
            or None in self.__done_dict.keys(), \
            "Done dict was not initiated for all stmt_type's."

        # Check if we want to keep going.
        if not persist:
            self._compile_statements()
            return

        # Get the rest of the content.
        while not self._all_done():
            self._query_over_statement_types(agent_strs, stmt_types, params)

        # Create the actual statements.
        self._compile_statements()
        return
def _run_queries ( self , agent_strs , stmt_types , params , persist ) : self . _query_over_statement_types ( agent_strs , stmt_types , params ) assert len ( self . __done_dict ) == len ( stmt_types ) or None in self . __done_dict . keys ( ) , "Done dict was not initiated for all stmt_type's." if not persist : self . _compile_statements ( ) return while not self . _all_done ( ) : self . _query_over_statement_types ( agent_strs , stmt_types , params ) self . _compile_statements ( ) return
Use paging to get all statements requested.