          cdef int nr_class = self.moves.n_moves
          cdef int nr_feat = self.model.nr_feat
          queue = []
          for doc in stream:
              doc_ptr[len(queue)] = doc.c
              lengths[len(queue)] = doc.length
              queue.append(doc)
 
</s> remove                 for i in cython.parallel.prange(batch_size, nogil=True,
                                                num_threads=n_threads):
                    self.parseC(doc_ptr[i], lengths[i], nr_feat, nr_class)
 </s> add                 with nogil:
                    for i in cython.parallel.prange(batch_size, num_threads=n_threads):
                        status = self.parseC(doc_ptr[i], lengths[i], nr_feat, nr_class)
                        if status != 0:
                            with gil:
                                sent_str = queue[i].text
                                raise ValueError("Error parsing doc: %s" % sent_str) </s> remove     cdef void parseC(self, TokenC* tokens, int length, int nr_feat, int nr_class) nogil:
 </s> add     cdef int parseC(self, TokenC* tokens, int length, int nr_feat, int nr_class) nogil: </s> remove         for i in range(batch_size):
            self.parseC(doc_ptr[i], lengths[i], nr_feat, nr_class)
            for doc in queue:
                doc.is_parsed = True
                yield doc
 </s> add         with nogil:
            for i in cython.parallel.prange(batch_size, num_threads=n_threads):
                status = self.parseC(doc_ptr[i], lengths[i], nr_feat, nr_class)
                if status != 0:
                    with gil:
                        sent_str = queue[i].text
                        raise ValueError("Error parsing doc: %s" % sent_str)
        for doc in queue:
            doc.is_parsed = True
            yield doc </s> remove                     raise ValueError("Illegal action: %s" % move_name)
 </s> add                     return 1
        cdef int status
          cdef int nr_class = self.moves.n_moves
          cdef int nr_feat = self.model.nr_feat
        cdef int status
          queue = []
          for doc in stream:
              doc_ptr[len(queue)] = doc.c
              lengths[len(queue)] = doc.length
              queue.append(doc)
keep add keep keep keep keep keep
 * Check for errors in parser, and parallelise the left-over batch 
spacy/syntax/parser.pyx