Improve concrete error message (apache#22536)

iemejia · Jul 29, 2022 · e5e3cb2 · e5e3cb2
1 parent 12088cb
commit e5e3cb2
Showing 1 changed file with 2 additions and 2 deletions.
diff --git a/sdks/go/pkg/beam/validate.go b/sdks/go/pkg/beam/validate.go
@@ -71,8 +71,8 @@ func makeTypedefs(list []TypeDefinition) (map[string]reflect.Type, error) {
 		if !typex.IsUniversal(v.Var) {
 			return nil, errors.Errorf("type var %s must be a universal type", v.Var)
 		}
-		if !typex.IsConcrete(v.T) {
-			return nil, errors.Errorf("type value %s must be a concrete type", v.T)
+		if ok, err := typex.CheckConcrete(v.T); !ok {
+			return nil, errors.Wrapf(err, "type value %s must be a concrete type", v.T)
 		}
 		typedefs[v.Var.Name()] = v.T
 	}