Skip to content

Commit 344b101

Browse files
committed
fix: ensure endpoint properties are always set for replication streams
1 parent 1995ef8 commit 344b101

1 file changed

Lines changed: 6 additions & 6 deletions

File tree

core/sling/replication.go

Lines changed: 6 additions & 6 deletions
Original file line numberDiff line numberDiff line change
@@ -444,13 +444,13 @@ func (rd *ReplicationConfig) ProcessWildcards() (err error) {
444444
if stream != nil && stream.Disabled {
445445
continue
446446
}
447-
// leave as is for order to be respected
448-
if len(endpoint.DependsOn) > 0 {
449-
if stream == nil {
450-
stream = &ReplicationStreamConfig{}
451-
}
452-
setEndpointProps(stream) // set overrides
447+
// always set endpoint props (overrides, primary_key, description, dependsOn)
448+
if stream == nil {
449+
stream = &ReplicationStreamConfig{}
450+
setEndpointProps(stream)
453451
rd.AddStream(key, stream)
452+
} else {
453+
setEndpointProps(stream)
454454
}
455455
matched = false
456456
continue

0 commit comments

Comments
 (0)