Skip to content

Commit

Permalink
feat(restoretest): enable --unpin-agent-cpu, --stream-to-all-replicas…
Browse files Browse the repository at this point in the history
… and --table-parallel flags
  • Loading branch information
Michal-Leszczynski committed Aug 28, 2024
1 parent 81febdc commit c14c3dd
Showing 1 changed file with 16 additions and 8 deletions.
24 changes: 16 additions & 8 deletions pkg/service/restore/service_restore_integration_test.go
Original file line number Diff line number Diff line change
Expand Up @@ -546,10 +546,13 @@ func TestRestoreTablesSmokeIntegration(t *testing.T) {
Path: testBucket,
},
},
Keyspace: []string{testKeyspace},
BatchSize: testBatchSize,
Parallel: testParallel,
RestoreTables: true,
Keyspace: []string{testKeyspace},
BatchSize: testBatchSize,
Parallel: testParallel,
RestoreTables: true,
StreamToAllReplicas: true,
UnpinAgentCPU: true,
TableParallel: 2,
}

smokeRestore(t, target, testKeyspace, testLoadCnt, testLoadSize, testUser, "{'class': 'NetworkTopologyStrategy', 'dc1': 2}")
Expand Down Expand Up @@ -718,6 +721,8 @@ func TestRestoreTablesResumeIntegration(t *testing.T) {
BatchSize: testBatchSize,
Parallel: testParallel,
RestoreTables: true,
UnpinAgentCPU: true,
TableParallel: 2,
Continue: true,
}

Expand Down Expand Up @@ -1327,10 +1332,13 @@ func TestRestoreFullIntegration(t *testing.T) {
}

tablesTarget := Target{
Location: locs,
BatchSize: testBatchSize,
Parallel: testParallel,
RestoreTables: true,
Location: locs,
BatchSize: testBatchSize,
Parallel: testParallel,
RestoreTables: true,
StreamToAllReplicas: true,
UnpinAgentCPU: true,
TableParallel: 2,
}

restoreAllTables(t, schemaTarget, tablesTarget, testKeyspace, testLoadCnt, testLoadSize, testUser)
Expand Down

0 comments on commit c14c3dd

Please sign in to comment.