replace sqlite version query

This commit is contained in:
Joel Wetzell
2026-05-13 19:21:22 -05:00
parent 526e3afa5f
commit 5d8df7ed2a
+2 -2
View File
@@ -21,7 +21,7 @@ func TestDbQueryFromRegistry(t *testing.T) {
Type: "db.query", Type: "db.query",
Params: map[string]any{ Params: map[string]any{
"module": "test", "module": "test",
"query": "SELECT sqlite_version();", "query": "SELECT 1;",
}, },
}) })
if err != nil { if err != nil {
@@ -33,7 +33,7 @@ func TestDbQueryFromRegistry(t *testing.T) {
} }
payload := "hello" payload := "hello"
expected := map[string]any{"sqlite_version()": "3.53.0"} expected := map[string]any{"1": int64(1)}
got, err := processorInstance.Process(t.Context(), common.WrappedPayload{ got, err := processorInstance.Process(t.Context(), common.WrappedPayload{
Payload: payload, Payload: payload,