lenskit.logging.worker

Old home of the LensKit logging worker logic.

Deprecated since version 2025.3: This module is deprecated. Import from lenskit.logging.multiprocess.

class lenskit.logging.worker.WorkerContext(config, *, driver=False, zmq=None)

Bases: object

Activate (and deactivate) a worker context. This handles setup and teardown of logging, etc.

Only one worker context can be active, regardless of how many threads are active.

Stability:

Internal (see Stability Levels).

Parameters:

• config (WorkerLogConfig)

• driver (bool)

• zmq (Context[Socket[bytes]])

send_progress(update)

Send a progress update event.

Parameters:

update (ProgressMessage)

send_record(sink_id, record)

Send a record to a record sink.

Parameters:

• sink_id (UUID)

• record (Any)

start()

Start the logging context.

class lenskit.logging.worker.WorkerLogConfig(address, level, authkey=None)

Bases: object

Configuration for worker logging.

Parameters:

• address (str)

• level (int)

• authkey (bytes | None)

classmethod current(*, from_monitor=True)

Get the current worker logging configuration.

Parameters:

from_monitor (bool)