From 57262c3377c1e8e828e410aadd74c3fce6c31d75 Mon Sep 17 00:00:00 2001 From: Joel Wetzell Date: Wed, 18 Mar 2026 20:54:42 -0500 Subject: [PATCH] actually use value template in Set --- internal/processor/kv-set.go | 11 ++++++++++- 1 file changed, 10 insertions(+), 1 deletion(-) diff --git a/internal/processor/kv-set.go b/internal/processor/kv-set.go index 43051e3..7d77ba1 100644 --- a/internal/processor/kv-set.go +++ b/internal/processor/kv-set.go @@ -1,6 +1,7 @@ package processor import ( + "bytes" "context" "errors" "fmt" @@ -38,7 +39,15 @@ func (kvs *KVSet) Process(ctx context.Context, wrappedPayload common.WrappedPayl return wrappedPayload, fmt.Errorf("kv.set module with id %s is not a KeyValueModule", kvs.ModuleId) } - err := kvModule.Set(kvs.Key, wrappedPayload.Payload) + var valueBuffer bytes.Buffer + err := kvs.Value.Execute(&valueBuffer, wrappedPayload) + + if err != nil { + wrappedPayload.End = true + return wrappedPayload, err + } + + err = kvModule.Set(kvs.Key, valueBuffer.String()) if err != nil { wrappedPayload.End = true return wrappedPayload, fmt.Errorf("kv.set error setting key: %w", err)