Skip to content

Commit ca68fd7

Browse files
committed
PBM-1394: enable oplog slicer before making backup
1 parent 59969c2 commit ca68fd7

File tree

4 files changed

+7
-7
lines changed

4 files changed

+7
-7
lines changed

e2e-tests/pkg/tests/sharded/backuper.go

Lines changed: 1 addition & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -66,9 +66,9 @@ func NewPitr(c *Cluster) *Pitr {
6666
}
6767

6868
func (p *Pitr) Backup() {
69+
p.c.pitrOn()
6970
bcpName := p.c.LogicalBackup()
7071
p.started <- struct{}{}
71-
p.c.pitrOn()
7272
p.c.BackupWaitDone(context.TODO(), bcpName)
7373
p.sdone <- struct{}{}
7474

e2e-tests/pkg/tests/sharded/test_oplog_replay.go

Lines changed: 2 additions & 2 deletions
Original file line numberDiff line numberDiff line change
@@ -12,12 +12,12 @@ import (
1212
)
1313

1414
func (c *Cluster) OplogReplay() {
15-
bcpName := c.LogicalBackup()
16-
1715
c.pitrOn()
1816
log.Println("turn on PITR")
1917
defer c.pitrOff()
2018

19+
bcpName := c.LogicalBackup()
20+
2121
counters := make(map[string]shardCounter)
2222
for name, cn := range c.shards {
2323
c.bcheckClear(name, cn)

e2e-tests/pkg/tests/sharded/test_pitr_basic.go

Lines changed: 2 additions & 2 deletions
Original file line numberDiff line numberDiff line change
@@ -15,12 +15,12 @@ import (
1515
)
1616

1717
func (c *Cluster) PITRbasic() {
18-
bcpName := c.LogicalBackup()
19-
2018
c.pitrOn()
2119
log.Println("turn on PITR")
2220
defer c.pitrOff()
2321

22+
bcpName := c.LogicalBackup()
23+
2424
counters := make(map[string]shardCounter)
2525
for name, cn := range c.shards {
2626
c.bcheckClear(name, cn)

e2e-tests/pkg/tests/sharded/test_timeseries.go

Lines changed: 2 additions & 2 deletions
Original file line numberDiff line numberDiff line change
@@ -16,11 +16,11 @@ func (c *Cluster) Timeseries() {
1616

1717
ts1.gen()
1818

19-
bcpName := c.LogicalBackup()
20-
2119
c.pitrOn()
2220
defer c.pitrOff()
2321

22+
bcpName := c.LogicalBackup()
23+
2424
c.BackupWaitDone(context.TODO(), bcpName)
2525

2626
time.Sleep(time.Second)

0 commit comments

Comments
 (0)