From af58f273b3d4f1640a550ee27a019ae3e7439c90 Mon Sep 17 00:00:00 2001 From: Matthew Honnibal Date: Fri, 5 Feb 2016 12:20:29 +0100 Subject: [PATCH] * Fix spacy.language.pipe --- spacy/language.py | 10 +++++----- 1 file changed, 5 insertions(+), 5 deletions(-) diff --git a/spacy/language.py b/spacy/language.py index 58d137e2e..29a844c13 100644 --- a/spacy/language.py +++ b/spacy/language.py @@ -271,19 +271,19 @@ class Language(object): def pipe(self, texts, tag=True, parse=True, entity=True, n_threads=2, batch_size=1000): - stream = self.tokenizer.stream(texts, + stream = self.tokenizer.pipe(texts, n_threads=n_threads, batch_size=batch_size) if self.tagger and tag: - stream = self.tagger.stream(stream, + stream = self.tagger.pipe(stream, n_threads=n_threads, batch_size=batch_size) if self.matcher and entity: - stream = self.matcher.stream(stream, + stream = self.matcher.pipe(stream, n_threads=n_threads, batch_size=batch_size) if self.parser and parse: - stream = self.parser.stream(stream, + stream = self.parser.pipe(stream, n_threads=n_threads, batch_size=batch_size) if self.entity and entity: - stream = self.entity.stream(stream, + stream = self.entity.pipe(stream, n_threads=n_threads, batch_size=batch_size) for doc in stream: yield doc