'Compiles and returns the complete list of (success_rows, error_rows) for
the given batched_rows and context.'

def _compile(self, context, batched_rows):

    (success_rows, error_rows) = izip(*batched_rows)
    success_rows = list(chain(*success_rows))
    error_rows = list(chain(*error_rows))
    context.task_progress.succeeded = len(success_rows)
    context.task_progress.failed = len(error_rows)
    context.task_progress.attempted = (context.task_progress.succeeded + context.task_progress.failed)
    context.task_progress.total = context.task_progress.attempted
    return (success_rows, error_rows)
