kfickel/streamd
1
0
Fork 0
Code Issues 10 Pull requests 3 Projects 1 Wiki Activity Actions

feat: better localization of shards

Browse source 
Signed-off-by: Konstantin Fickel <mail@konstantinfickel.de>
This commit is contained in:
Konstantin Fickel 2026-01-31 17:54:50 +01:00
parent 79095bad4a
commit 4dbd142c74
Signed by: kfickel
GPG key ID: A793722F9933C1A5
3 changed files with 61 additions and 14 deletions
Download patch file Download diff file Expand all files Collapse all files

18
src/streamer/localize/localize.py
View file

@ -22,16 +22,18 @@ def localize_shard(
adjusted_moment: datetime = extract_datetime_from_marker_list(shard.markers, moment)
for marker in shard.markers:
normalized_marker = marker.lower()
if marker in config.markers:
marker_definition = config.markers[marker]
for placement in marker_definition.placements:
if set(placement.if_with) <= set(shard.markers):
dimension = config.dimensions[placement.dimension]
if marker_definition := config.markers[normalized_marker]:
dimension_name = marker_definition.dimension
dimension = config.dimensions[marker_definition.dimension]
value = placement.value or marker
if dimension.propagate:
position[dimension_name] = normalized_marker
else:
private_position[dimension_name] = normalized_marker
if dimension.propagate:
position[placement.dimension] = value
else:
private_position[placement.dimension] = value
children = [
localize_shard(child, config, position, adjusted_moment)