Pure-Python DAG-based high-performance SHM-backed pub-sub and multi-processing pattern
15
stars
6
forks
source link
Add `key` field to AxisArray structure, with a Unit to set the key and another to filter on key #145
Closed
cboulay closed 2 months ago
(ignore array_chunker commits)
Closes #142
This PR adds a
.key
field to AxisArray then adds a couple functionalities related to it:AxisArray.concat(..., filter_key="some key")
will only concatenate messages with matching keysAxisArray.concat(..., filter_key=None)
(default) will not filter but will set key to""
(default) if keys are not matching.set_key
generator orSetKey
Unit sets the .key field to a new value.FilterOnKey
(Unit only) only allows through messages with matching .key value.