medcat.pipeline.pipe_runner

Module Contents

Classes

PipeRunner

Attributes

logger

medcat.pipeline.pipe_runner.logger

class medcat.pipeline.pipe_runner.PipeRunner(workers)

Bases: spacy.pipeline.Pipe

Parameters:

workers (int) –

_execute

_delayed

_time_out_in_secs = 3600

__init__(workers)

Parameters:

workers (int) –

abstract __call__(doc)

Parameters:

doc (spacy.tokens.Doc) –

pipe(stream, batch_size, **kwargs)

Parameters:

• stream (Iterable[spacy.tokens.Doc]) –

• batch_size (int) –

Return type:

Union[Generator[spacy.tokens.Doc, None, None], Iterator[spacy.tokens.Doc]]

static serialize_entities(doc)

Parameters:

doc (spacy.tokens.Doc) –

static deserialize_entities(doc)

Parameters:

doc (spacy.tokens.Doc) –

static _run_pipe_on_one(call, doc, underscore_state)

Parameters:

• call (Callable) –

• doc (spacy.tokens.Doc) –

• underscore_state (Tuple) –

Return type:

spacy.tokens.Doc

_lazy_init_pool()

Return type:

Tuple