Fix data deletion not being enableable
This commit is contained in:
parent
fb7e0d14e2
commit
b1f18c0b13
|
@ -172,14 +172,14 @@ struct SlotsProcessing {
|
||||||
|
|
||||||
impl SlotsProcessing {
|
impl SlotsProcessing {
|
||||||
fn new(tables: &Vec<String>, delete_old_data: bool) -> Self {
|
fn new(tables: &Vec<String>, delete_old_data: bool) -> Self {
|
||||||
let cleanup_table_sql = Vec::<String>::new();
|
let mut cleanup_table_sql = Vec::<String>::new();
|
||||||
|
|
||||||
if delete_old_data {
|
if delete_old_data {
|
||||||
// Delete:
|
// Delete:
|
||||||
// 1. account writes that came before the newest rooted write
|
// 1. account writes that came before the newest rooted write
|
||||||
// 2. account writes that came after the newest rooted write but before
|
// 2. account writes that came after the newest rooted write but before
|
||||||
// the newest rooted slot (like processed writes that never confirmed)
|
// the newest rooted slot (like processed writes that never confirmed)
|
||||||
let mut cleanup_table_sql: Vec<String> = tables
|
cleanup_table_sql = tables
|
||||||
.iter()
|
.iter()
|
||||||
.map(|table_name| {
|
.map(|table_name| {
|
||||||
format!(
|
format!(
|
||||||
|
|
Loading…
Reference in New Issue