Skip to content

Commit

Permalink
Reflect review comments
Browse files Browse the repository at this point in the history
Signed-off-by: Yusuke Suzuki <yusuke-suzuki@cybozu.co.jp>
  • Loading branch information
ysksuzuki committed Jul 6, 2021
1 parent 4b8905d commit 2ca8860
Show file tree
Hide file tree
Showing 2 changed files with 2 additions and 2 deletions.
2 changes: 1 addition & 1 deletion backup/backup.go
Original file line number Diff line number Diff line change
Expand Up @@ -418,7 +418,7 @@ func (bm *BackupManager) backupBinlog(ctx context.Context, op bkop.Operator) err
pw2 = nil

bw := &ByteCountWriter{}
key := calcKey(bm.cluster.Namespace, bm.cluster.Name, constants.BinlogFilename, lastBackup.Time.Time.UTC())
key := calcKey(bm.cluster.Namespace, bm.cluster.Name, constants.BinlogFilename, lastBackup.Time.Time)
if err := bm.bucket.Put(ctx, key, io.TeeReader(pr2, bw)); err != nil {
return fmt.Errorf("failed to put binlog.tar.zst: %w", err)
}
Expand Down
2 changes: 1 addition & 1 deletion backup/integration_test.go
Original file line number Diff line number Diff line change
Expand Up @@ -194,7 +194,7 @@ var _ = Describe("Backup/Restore", func() {
Expect(bc.contents).To(HaveLen(1))

time.Sleep(1100 * time.Millisecond)
restorePoint := time.Now().UTC()
restorePoint := time.Now()
time.Sleep(1100 * time.Millisecond)

newOperator = func(host string, port int, user, password string, threads int) (bkop.Operator, error) {
Expand Down

0 comments on commit 2ca8860

Please sign in to comment.