diff --git a/modules/scylladb/helper.go b/modules/scylladb/helper.go index 0f7a01a..6d6e4d2 100644 --- a/modules/scylladb/helper.go +++ b/modules/scylladb/helper.go @@ -35,7 +35,7 @@ func TableCleaner() { if len(expiredUserSignUpProcesses) > 0 { batch := Session.NewBatch(gocql.UnloggedBatch) - q := "DELETE FROM clicknjoin.user_sign_up_process WHERE x_token = ?" + q := "DELETE FROM " + Cluster.Keyspace + "." + gocnjhelper.DbMUserSignUpProcess.Name() + " WHERE x_token = ?" for _, us := range expiredUserSignUpProcesses { batch.Query(q, us.XToken)