koi_net.components.kobj_queue

Classes

KobjQueue(log, shutdown_signal)

Queue for knowledge objects entering the processing pipeline.
class koi_net.components.kobj_queue.KobjQueue(log, shutdown_signal)[source]

Bases: object

Queue for knowledge objects entering the processing pipeline.

Parameters:

  • log (Logger)

  • shutdown_signal (Event)

log: Logger
push(*, rid=None, manifest=None, bundle=None, event=None, kobj=None, event_type=None, source=None)[source]

Pushes knowledge object to queue.

Input may take the form of an RID, manifest, bundle, event, or knowledge object (with an optional event type for RID, manifest, or bundle objects). All objects will be normalized to knowledge objects and queued.

Parameters:

  • rid (RID | None)

  • manifest (Manifest | None)

  • bundle (Bundle | None)

  • event (Event | None)

  • kobj (KnowledgeObject | None)

  • event_type (EventType | None)

  • source (KoiNetNode | None)

q: Queue[KnowledgeObject]
shutdown_signal: Event
wait()[source]

Safe join, prevents deadlock if kobj_worker fails.