qdrant_client.parallel_processor module

class ParallelWorkerPool(num_workers: int, worker: Type[Worker], start_method: Optional[str] = None)

Bases: object

join() → None

join_or_terminate(timeout: Optional[int] = 1) → None

Emergency shutdown @param timeout: @return:

start(**kwargs: Any) → None

unordered_map(stream: Iterable[Any], *args: Any, **kwargs: Any) → Iterable[Any]

class QueueSignals(value)

Bases: str, Enum

An enumeration.

confirm = 'confirm'

error = 'error'

stop = 'stop'

class Worker

Bases: object

process(items: Iterable[Any]) → Iterable[Any]

classmethod start(**kwargs: Any) → Worker