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

feat: add overwrite configuration

Browse source 
Signed-off-by: Konstantin Fickel <mail@konstantinfickel.de>
This commit is contained in:
Konstantin Fickel 2026-02-01 12:09:38 +01:00
parent a088057b17
commit 260400fa34
Signed by: kfickel
GPG key ID: A793722F9933C1A5
3 changed files with 153 additions and 4 deletions
Download patch file Download diff file Expand all files Collapse all files

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

@ -30,10 +30,14 @@ def localize_shard(
value = placement.value or marker
if dimension.propagate:
position[placement.dimension] = value
else:
private_position[placement.dimension] = value
if placement.overwrites or (
placement.dimension not in position
and placement.dimension not in private_position
):
if dimension.propagate:
position[placement.dimension] = value
else:
private_position[placement.dimension] = value
children = [
localize_shard(child, config, position, adjusted_moment)