Skip to content

Commit 3d362a6

Browse files
committed
fix: correctly set dependsOn field when adding a stream configuration
1 parent ddfc3f8 commit 3d362a6

File tree

1 file changed

+2
-2
lines changed

1 file changed

+2
-2
lines changed

core/sling/replication.go

Lines changed: 2 additions & 2 deletions
Original file line numberDiff line numberDiff line change
@@ -761,8 +761,8 @@ func (rd *ReplicationConfig) ProcessChunks() (err error) {
761761

762762
func (rd *ReplicationConfig) AddStream(key string, cfg *ReplicationStreamConfig) {
763763
newCfg := ReplicationStreamConfig{}
764-
g.Unmarshal(g.Marshal(cfg), &newCfg) // copy config over
765-
newCfg.dependsOn = cfg.dependsOn // set dependsOn since not marshalled
764+
g.Unmarshal(g.Marshal(cfg), &newCfg) // copy config over
765+
newCfg.dependsOn = g.PtrVal(cfg).dependsOn // set dependsOn since not marshalled
766766
rd.Streams[key] = &newCfg
767767
rd.streamsOrdered = append(rd.streamsOrdered, key)
768768

0 commit comments

Comments
 (0)