Skip to content

Commit

Permalink
[bigquery] Log if we get an int for a typing.Integer column
Browse files Browse the repository at this point in the history
  • Loading branch information
nathan-artie committed Jun 22, 2024
1 parent 07e2392 commit 51b0d89
Showing 1 changed file with 2 additions and 0 deletions.
2 changes: 2 additions & 0 deletions clients/bigquery/storagewrite.go
Original file line number Diff line number Diff line change
Expand Up @@ -123,6 +123,8 @@ func rowToMessage(row map[string]any, columns []columns.Column, messageDescripto
case typing.Integer.Kind:
switch value := value.(type) {
case int:
// TODO: Remove int case if we don't see the following the the logs
slog.Warn("Received an int instead if an int32/64 for a Integer column")
message.Set(field, protoreflect.ValueOfInt64(int64(value)))
case int32:
message.Set(field, protoreflect.ValueOfInt64(int64(value)))
Expand Down

0 comments on commit 51b0d89

Please sign in to comment.