diff --git a/daos/request.go b/daos/request.go index 6616b9f3..573b8100 100644 --- a/daos/request.go +++ b/daos/request.go @@ -59,7 +59,7 @@ func (dao *Dao) DeleteOldRequests(createdBefore time.Time) error { formattedDate := createdBefore.UTC().Format(types.DefaultDateLayout) expr := dbx.NewExp("[[created]] <= {:date}", dbx.Params{"date": formattedDate}) - _, err := dao.DB().Delete(tableName, expr).Execute() + _, err := dao.NonconcurrentDB().Delete(tableName, expr).Execute() return err }