qdrant_client.parallel_processor module

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

Bases: object

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

Emergency shutdown @param timeout: @return:

start(**kwargs: Any) None[source]
unordered_map(stream: Iterable[Any], *args: Any, **kwargs: Any) Iterable[Any][source]
class QueueSignals(value)[source]

Bases: str, Enum

An enumeration.

confirm = 'confirm'
error = 'error'
stop = 'stop'
class Worker[source]

Bases: object

process(items: Iterable[Any]) Iterable[Any][source]
classmethod start(**kwargs: Any) Worker[source]


Learn more about Qdrant vector search project and ecosystem

Discover Qdrant

Similarity Learning

Explore practical problem solving with Similarity Learning

Learn Similarity Learning


Find people dealing with similar problems and get answers to your questions

Join Community