From 0b164f9dbb444a18b69e9eacd2f7510838e89b30 Mon Sep 17 00:00:00 2001 From: Robin Tang Date: Thu, 24 Oct 2024 10:43:24 -0700 Subject: [PATCH] Support. --- clients/bigquery/storagewrite.go | 4 ++-- 1 file changed, 2 insertions(+), 2 deletions(-) diff --git a/clients/bigquery/storagewrite.go b/clients/bigquery/storagewrite.go index 925012723..adb4b07e6 100644 --- a/clients/bigquery/storagewrite.go +++ b/clients/bigquery/storagewrite.go @@ -187,8 +187,8 @@ func rowToMessage(row map[string]any, columns []columns.Column, messageDescripto case ext.DateKindType: daysSinceEpoch := _time.Unix() / (60 * 60 * 24) message.Set(field, protoreflect.ValueOfInt32(int32(daysSinceEpoch))) - case ext.TimestampTZKindType: - if err := timestamppb.New(_time).CheckValid(); err != nil { + case ext.TimestampTZKindType, ext.TimestampNTZKindType: + if err = timestamppb.New(_time).CheckValid(); err != nil { return nil, err } message.Set(field, protoreflect.ValueOfInt64(_time.UnixMicro()))