qdrant_client.parallel_processor module

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

Bases: object

check_worker_health() → None[source]

Checks if any worker process has terminated unexpectedly

join() → None[source]

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

Emergency shutdown @param timeout: @return:

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

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

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(*args: Any, **kwargs: Any) → Worker[source]