Add back registers

apache · Apr 27, 2024 · 4239007 · 4239007
1 parent 485bb4f
commit 4239007
Showing 1 changed file with 3 additions and 0 deletions.
diff --git a/sdks/go/pkg/beam/io/webapi/webapi.go b/sdks/go/pkg/beam/io/webapi/webapi.go
@@ -25,6 +25,9 @@ import (
 )
 
 func init() {
+	beam.RegisterType(reflect.TypeOf((*wrappedCallerOnlyUserType)(nil)).Elem())
+	beam.RegisterType(reflect.TypeOf((*Request)(nil)).Elem())
+	beam.RegisterType(reflect.TypeOf((*Response)(nil)).Elem())
 	register.Emitter1[*Response]()
 	register.DoFn3x1[context.Context, *Request, func(*Response), error](&callerFn{})
 }