Attempt 2.

artie-labs · Jan 23, 2025 · 1e7f35e · 1e7f35e
1 parent 71213da
commit 1e7f35e
Showing 1 changed file with 1 addition and 1 deletion.
diff --git a/clients/bigquery/storagewrite.go b/clients/bigquery/storagewrite.go
@@ -132,7 +132,7 @@ func encodePacked64DatetimeMicros(dateTime time.Time) int64 {
 func rowToMessage(row map[string]any, columns []columns.Column, messageDescriptor protoreflect.MessageDescriptor) (*dynamicpb.Message, error) {
 	message := dynamicpb.NewMessage(messageDescriptor)
 	for _, column := range columns {
-		field := message.Descriptor().Fields().ByTextName(column.Name())
+		field := message.Descriptor().Fields().ByName(protoreflect.Name(column.Name()))
 		if field == nil {
 			return nil, fmt.Errorf("failed to find a field named %q", column.Name())
 		}