diff --git a/example_test.go b/example_test.go index 256a9fb..6283eb7 100644 --- a/example_test.go +++ b/example_test.go @@ -631,6 +631,7 @@ func lwtLock(t *testing.T, session gocqlx.Session) { If(qb.Eq("owner")). TTLNamed("ttl"). Query(session). + SerialConsistency(gocql.Serial). BindStruct(lock) applied, err := q.ExecCASRelease() @@ -652,6 +653,7 @@ func lwtLock(t *testing.T, session gocqlx.Session) { TTLNamed("ttl"). Unique(). Query(session). + SerialConsistency(gocql.Serial). BindStruct(lock) applied, err = q.GetCASRelease(&prev)