fix go fs

FunctionStream · Aug 6, 2024 · 99f1934 · 99f1934
1 parent 141825d
commit 99f1934
Showing 1 changed file with 1 addition and 0 deletions.
diff --git a/clients/gofs/gofs.go b/clients/gofs/gofs.go
@@ -48,6 +48,7 @@ func Register[I any, O any](process func(*I) *O) error {
 		err = json.Unmarshal(payload, input)
 		if err != nil {
 			fmt.Fprintf(os.Stderr, "Failed to parse JSON: %s %s", err, payload)
+			return nil
 		}
 		output := process(input)
 		outputPayload, _ := json.Marshal(output)