Skip to content

Commit 6404bd7

Browse files
committed
Fix batch creation to match new gocql
`gocql.NewBatch` is now deprecated (and broken) switching to use `session.NewBatch` Fixes: #31
1 parent 2c94d92 commit 6404bd7

File tree

1 file changed

+1
-1
lines changed

1 file changed

+1
-1
lines changed

modes.go

Lines changed: 1 addition & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -438,7 +438,7 @@ func DoBatchedWrites(session *gocql.Session, resultChannel chan Result, workload
438438
request := fmt.Sprintf("INSERT INTO %s.%s (pk, ck, v) VALUES (?, ?, ?)", keyspaceName, tableName)
439439

440440
RunTest(resultChannel, workload, rateLimiter, func(rb *ResultBuilder) (error, time.Duration) {
441-
batch := gocql.NewBatch(gocql.UnloggedBatch)
441+
batch := session.NewBatch(gocql.UnloggedBatch)
442442
batchSize := 0
443443

444444
currentPk := workload.NextPartitionKey()

0 commit comments

Comments
 (0)