From d4da5358af568402f490719c4f4a7417d21dd8a8 Mon Sep 17 00:00:00 2001 From: localhost_frssoft Date: Tue, 1 Nov 2022 19:05:18 +0300 Subject: [PATCH] Force commit before count --- src/fmn_database.py | 4 +++- src/fmn_poll.py | 3 ++- 2 files changed, 5 insertions(+), 2 deletions(-) diff --git a/src/fmn_database.py b/src/fmn_database.py index 655f4ee..d6f6b72 100644 --- a/src/fmn_database.py +++ b/src/fmn_database.py @@ -13,6 +13,9 @@ c.execute( conn.commit() +def force_commit(): + conn.commit() + def mark_as_watched_movie(original_name=None, ru_name=None, year=None): try: @@ -38,7 +41,6 @@ def get_already_watched(original_name=None, ru_name=None, year=None): def get_count_all_watched_movies(): - conn.commit() # May be fix wrong count return len(c.execute('SELECT * FROM watched_movies').fetchall()) diff --git a/src/fmn_poll.py b/src/fmn_poll.py index e271594..1419f92 100644 --- a/src/fmn_poll.py +++ b/src/fmn_poll.py @@ -1,12 +1,13 @@ from src.fedi_api import get_status, post_status, upload_attachment from src.fmn_states_db import add_state, get_state, clear_all_states -from src.fmn_database import get_movies_for_poll, write_votes, read_votes, mark_as_watched_movie, get_already_watched, rewrite_db, reset_poll, get_count_all_watched_movies +from src.fmn_database import get_movies_for_poll, write_votes, read_votes, mark_as_watched_movie, get_already_watched, rewrite_db, reset_poll, get_count_all_watched_movies, force_commit from collections import Counter from loguru import logger import time def text_create_poll(): + force_commit() count_poll = get_count_all_watched_movies() text_poll = f'''Друзья, {count_poll} голосование за следующий Fediverse Movie Night объявляю открытым!