fix ds.Metadata.StreamURL [nt]

flarco · Nov 10, 2023 · 8c9fbef · 8c9fbef
1 parent ecc7aac
commit 8c9fbef
Showing 1 changed file with 4 additions and 0 deletions.
diff --git a/iop/datastream.go b/iop/datastream.go
@@ -658,8 +658,12 @@ func (ds *Datastream) Rows() chan []any {
 
 func (ds *Datastream) SetMetadata(jsonStr string) {
 	if jsonStr != "" {
+		streamValue := ds.Metadata.StreamURL.Value
 		g.Unmarshal(jsonStr, &ds.Metadata)
 		ds.Metadata.LoadedAt.Value = cast.ToInt64(ds.Metadata.LoadedAt.Value)
+		if ds.Metadata.StreamURL.Value == nil {
+			ds.Metadata.StreamURL.Value = streamValue
+		}
 	}
 }