Add commit in that commit.

pull/669/head
Andrey 2022-09-14 15:51:38 +03:00
rodzic e8f787dcb0
commit 2b8e1f4b7b
1 zmienionych plików z 1 dodań i 0 usunięć

Wyświetl plik

@ -85,6 +85,7 @@ def clean_labels(
label_model.block_number < block_number - blocks_cutoff,
)
result = query.delete(synchronize_session=False)
db_session.commit()
logger.info(f"Removed {result} rows from {table}")
except Exception as e:
logger.error(f"Failed to remove labels: {e}")