diff --git a/sdks/go/pkg/beam/util/starcgenx/starcgenx.go b/sdks/go/pkg/beam/util/starcgenx/starcgenx.go index 22d2be6e43f1..b3231fd41274 100644 --- a/sdks/go/pkg/beam/util/starcgenx/starcgenx.go +++ b/sdks/go/pkg/beam/util/starcgenx/starcgenx.go @@ -521,6 +521,7 @@ func (e *Extractor) extractFromTuple(tuple *types.Tuple) { if pkg := at.Obj().Pkg(); pkg != nil { e.imports[pkg.Path()] = struct{}{} } + e.extractType(at.Obj()) } if t, ok := t.(*types.Named); ok { if pkg := t.Obj().Pkg(); pkg != nil {