Skip to content

Commit 8cc61d3

Browse files
committed
Update destination.go
1 parent fe2e64e commit 8cc61d3

File tree

1 file changed

+2
-1
lines changed

1 file changed

+2
-1
lines changed

clients/destination/v0/destination.go

Lines changed: 2 additions & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -260,11 +260,12 @@ func (c *Client) Write(ctx context.Context, source string, syncTime time.Time, r
260260
if err != nil {
261261
return 0, fmt.Errorf("failed to call Write: %w", err)
262262
}
263+
syncTime = syncTime.Truncate(time.Microsecond)
263264
for resource := range resources {
264265
if err := saveClient.Send(&pb.Write_Request{
265266
Resource: resource,
266267
Source: source,
267-
Timestamp: timestamppb.New(syncTime.Truncate(time.Microsecond)),
268+
Timestamp: timestamppb.New(syncTime),
268269
}); err != nil {
269270
if err == io.EOF {
270271
// don't send write request if the channel is closed

0 commit comments

Comments
 (0)