added table cleaner for user sign up processes
parent
ee148b1843
commit
cedfd94aa4
|
@ -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)
|
||||
|
|
Loading…
Reference in New Issue