diff --git a/internal/processor/test/db-query_test.go b/internal/processor/test/db-query_test.go
index 9a83337..b61c9bb 100644
--- a/internal/processor/test/db-query_test.go
+++ b/internal/processor/test/db-query_test.go
@@ -88,6 +88,15 @@ func TestGoodDbQuery(t *testing.T) {
 				{"id": int64(2), "value": "test-2"},
 			},
 		},
+		{
+			name: "no rows",
+			params: map[string]any{
+				"module": "test",
+				"query":  "select * from test where id = -1;",
+			},
+			payload:  "",
+			expected: nil,
+		},
 	}
 	for _, test := range tests {
 		t.Run(test.name, func(t *testing.T) {