WIP.

lc525 · lc525 · commit 30d0ad512bb8 · 2025-10-07T17:33:13.000+01:00
diff --git a/scheduler/pkg/kafka/dataflow/server.go b/scheduler/pkg/kafka/dataflow/server.go
@@ -106,9 +106,9 @@ func NewChainerServer(
 		c.currentScalingConfig = scaling_config.DefaultScalingConfig
 	}
 
-	c.mu.Lock()
+	c.configUpdatesMutex.Lock()
 	scaling_config.LogWhenUsingDefaultScalingConfig(&c.currentScalingConfig, c.logger)
-	c.mu.Unlock()
+	c.configUpdatesMutex.Unlock()
 
 	return c, nil
 }

Original file line number	Diff line number	Diff line change
`@@ -106,9 +106,9 @@ func NewChainerServer(`
`106`	`106`	`c.currentScalingConfig = scaling_config.DefaultScalingConfig`
`107`	`107`	`}`
`108`	`108`
`109`		`- c.mu.Lock()`
	`109`	`+ c.configUpdatesMutex.Lock()`
`110`	`110`	`scaling_config.LogWhenUsingDefaultScalingConfig(&c.currentScalingConfig, c.logger)`
`111`		`- c.mu.Unlock()`
	`111`	`+ c.configUpdatesMutex.Unlock()`
`112`	`112`
`113`	`113`	`return c, nil`
`114`	`114`	`}`