def set_last_position(self, last_position):
        """
        Called from the manager, it is in charge of updating the last position of data commited
        by the writer, in order to have resume support
        """
        last_position = last_position or {}
        last_position.setdefault('readed_streams', [])
        last_position.setdefault('stream_offset', {})
        self.last_position = last_position
def set_last_position ( self , last_position ) : last_position = last_position or { } last_position . setdefault ( 'readed_streams' , [ ] ) last_position . setdefault ( 'stream_offset' , { } ) self . last_position = last_position
Called from the manager, it is in charge of updating the last position of data commited
        by the writer, in order to have resume support