koi_net.components.kobj_worker

Classes

End()	Class for STOP_WORKER sentinel pushed to worker queues.
KnowledgeProcessingWorker(log, ...)	Thread worker that processes the kobj_queue.

class koi_net.components.kobj_worker.End

Bases: object

Class for STOP_WORKER sentinel pushed to worker queues.

class koi_net.components.kobj_worker.KnowledgeProcessingWorker(log, logging_context, shutdown_signal, exception_queue, config, kobj_queue, pipeline)

Bases: ThreadedComponent

Thread worker that processes the kobj_queue.

Parameters:

• log (Logger)

• logging_context (LoggingContext)

• shutdown_signal (Event)

• exception_queue (Queue[Exception])

• config (BaseNodeConfig)

• kobj_queue (KobjQueue)

• pipeline (KnowledgePipeline)

config: BaseNodeConfig

kobj_queue: KobjQueue

pipeline: KnowledgePipeline

run()

Processing loop for thread.

stop()