lenskit.parallel.worker

Functions

initalize(cfg, ctx)
worker(arg)

Classes

WorkerConfig(threads, seed)
WorkerContext(func, model, progress)

class lenskit.parallel.worker.WorkerConfig(threads, seed)

Bases: NamedTuple

Parameters:

• threads (int)

• seed (SeedSequence)

threads: int

Alias for field number 0

seed: SeedSequence

Alias for field number 1

class lenskit.parallel.worker.WorkerContext(func, model, progress)

Bases: NamedTuple, Generic[M, A, R]

Parameters:

• func (Callable[[M, A], R])

• model (M)

• progress (UUID)

func: Callable[[M, A], R]

Alias for field number 0

model: M

Alias for field number 1

progress: UUID

Alias for field number 2