fix test

Signed-off-by: Song Gao <[email protected]>
lf-edge · Jan 20, 2025 · 0e4a87d · 0e4a87d
1 parent 4f9499a
commit 0e4a87d
Showing 1 changed file with 3 additions and 0 deletions.
diff --git a/internal/topo/node/source_node.go b/internal/topo/node/source_node.go
@@ -65,6 +65,9 @@ func NewSourceNode(name string, st ast.StreamType, op UnOperation, options *ast.
 }
 
 func extractBufferLength(props map[string]any, originValue int) int {
+	if props == nil {
+		return originValue
+	}
 	if c, ok := props["bufferLength"]; ok {
 		t, err := cast.ToInt(c, cast.STRICT)
 		if err == nil {