Needs to expressed in Civil time.

artie-labs · Oct 24, 2024 · e8f7335 · e8f7335
1 parent 0b164f9
commit e8f7335
Showing 1 changed file with 4 additions and 1 deletion.
diff --git a/clients/bigquery/storagewrite.go b/clients/bigquery/storagewrite.go
@@ -187,11 +187,14 @@ 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, ext.TimestampNTZKindType:
+			case ext.TimestampTZKindType:
 				if err = timestamppb.New(_time).CheckValid(); err != nil {
 					return nil, err
 				}
 				message.Set(field, protoreflect.ValueOfInt64(_time.UnixMicro()))
+			case ext.TimestampNTZKindType:
+				civilLayout := "2006-01-02 15:04:05.999999"
+				message.Set(field, protoreflect.ValueOfString(_time.Format(civilLayout)))
 			default:
 				return nil, fmt.Errorf("unsupported extended time details: %q", column.KindDetails.ExtendedTimeDetails.Type)
 			}