(self, page_info)
:param page_info: object with attributes:
                           - page: page number (int)
                           - path: path to raw data dump
                           - page_size: number of docs in raw data dump
:param page_info: object with attributes:
                           - page: page number (int)
                           - path: path to raw data dump
                           - page_size: number of docs in raw data dump
: param page_info : object with attributes : - page : page number ( int ) - path : path to raw data dump - page_size : number of docs in raw data dump
def process_page(self, page_info):
        """
        :param page_info: object with attributes:
                           - page: page number (int)
                           - path: path to raw data dump
                           - page_size: number of docs in raw data dump
        """
        attempts = page_info.retry_count + 1
        self.progress_queue.put(ProgressValue(page_info.page, 0, page_info.page_size))
        args = self.export_instance, page_info.page, page_info.path, page_info.page_size, attempts
        result = self.pool.apply_async(self.export_function, args=args)
        self.results.append(QueuedResult(result, page_info.page, page_info.path, page_info.page_size, attempts))
def process_page ( self , page_info ) : attempts = page_info . retry_count + 1 self . progress_queue . put ( ProgressValue ( page_info . page , 0 , page_info . page_size ) ) args = self . export_instance , page_info . page , page_info . path , page_info . page_size , attempts result = self . pool . apply_async ( self . export_function , args = args ) self . results . append ( QueuedResult ( result , page_info . page , page_info . path , page_info . page_size , attempts ) )