dtourolle/KPN
1
0
Fork 0
Code Issues Pull Requests Actions Packages Projects Releases Wiki Activity

feat: persistent-pipeline reuse — push_blocking, node introspection, stateful wrapper #2

Merged
dtourolle merged 1 commits from feature/persistent-pipeline-reuse into master 2026-07-19 16:11:28 +00:00
Conversation 0 Commits 1 Files Changed 4
+205 -3
dtourolle commented 2026-07-19 16:02:11 +00:00
Owner
Copy Link
Copy Source

Adds three pieces needed to build one KPN network and reuse it across many
replays/configs instead of tearing down and rebuilding per run:

  • Channel::push_blocking (+ IVariantChannel/VariantChannel forwarding):
    lossless backpressure push that waits for space instead of dropping when
    the ring is full. PyNode's run_loop now uses it so a downstream consumer
    lagging behind never silently drops a frame.
  • PyNetwork::node_ptr / node_stats: raw node handle by name (for a binding
    to dynamic_cast to a concrete wrapper and call functor-specific runtime
    setters) and a per-node timing snapshot for profiling.
  • ObjectVariantNodeWrapper: variant-node adapter for functors that need
    runtime-constructed state (a Config, a loaded gallery), mirroring
    VariantNodeWrapper's channel plumbing but backed by ObjectNode.

Built and used downstream in scene-actor-extraction's sae_kpn Python replay
bindings for repeated threshold-sweep evaluation of the same pipeline.

Adds three pieces needed to build one KPN network and reuse it across many replays/configs instead of tearing down and rebuilding per run: - Channel<T>::push_blocking (+ IVariantChannel/VariantChannel forwarding): lossless backpressure push that waits for space instead of dropping when the ring is full. PyNode's run_loop now uses it so a downstream consumer lagging behind never silently drops a frame. - PyNetwork::node_ptr / node_stats: raw node handle by name (for a binding to dynamic_cast to a concrete wrapper and call functor-specific runtime setters) and a per-node timing snapshot for profiling. - ObjectVariantNodeWrapper: variant-node adapter for functors that need runtime-constructed state (a Config, a loaded gallery), mirroring VariantNodeWrapper's channel plumbing but backed by ObjectNode<Obj>. Built and used downstream in scene-actor-extraction's sae_kpn Python replay bindings for repeated threshold-sweep evaluation of the same pipeline.
dtourolle added 1 commit 2026-07-19 16:02:12 +00:00
feat: persistent-pipeline reuse — push_blocking, node introspection, stateful wrapper
🚦 CI / changes (pull_request) Successful in 17s
Details
🚦 CI / docker (pull_request) Has been skipped
Details
🚦 CI / test (pull_request) Successful in 4m42s
Details
🚦 CI / tsan (pull_request) Successful in 2m56s
Details
🚦 CI / docs (pull_request) Has been skipped
Details
4b6e498ba7 
Adds three pieces needed to build one KPN network and reuse it across many
replays/configs instead of tearing down and rebuilding per run:

- Channel<T>::push_blocking (+ IVariantChannel/VariantChannel forwarding):
  lossless backpressure push that waits for space instead of dropping when
  the ring is full. PyNode's run_loop now uses it so a downstream consumer
  lagging behind never silently drops a frame.
- PyNetwork::node_ptr / node_stats: raw node handle by name (for a binding
  to dynamic_cast to a concrete wrapper and call functor-specific runtime
  setters) and a per-node timing snapshot for profiling.
- ObjectVariantNodeWrapper: variant-node adapter for functors that need
  runtime-constructed state (a Config, a loaded gallery), mirroring
  VariantNodeWrapper's channel plumbing but backed by ObjectNode<Obj>.

Built and used downstream in scene-actor-extraction's sae_kpn Python replay
bindings for repeated threshold-sweep evaluation of the same pipeline.
dtourolle merged commit 75b34f31bb into master 2026-07-19 16:11:28 +00:00
Sign in to join this conversation.
Reviewers
No Reviewers
Labels
No items
No labels
Milestone
No items
No Milestone
Projects
Clear projects
No projects
Assignees
Clear assignees
maverick-in-boots dtourolle (Duncan Tourolle)
No Assignees
1 Participants
Notifications
Due Date
No due date set.
Dependencies

No dependencies set.

Reference: dtourolle/KPN#2