diff --git a/evt_prefetch.py b/evt_prefetch.py index 5e2a300..17dfea2 100644 --- a/evt_prefetch.py +++ b/evt_prefetch.py @@ -1,7 +1,7 @@ import os import mysql.connector from mysql.connector import Error -from datetime import datetime, timedelta, timezone +from datetime import datetime, timezone from dotenv import load_dotenv # Загрузка переменных окружения @@ -18,7 +18,6 @@ def prefetch_all_events(): для записей, которые: - имеют флаг is_visible = 1 - не имеют флага marked_to_publication = 1 - - modified более часа назад от текущего времени (UTC) """ try: # Подключение к базе данных @@ -36,21 +35,16 @@ def prefetch_all_events(): cursor = connection.cursor() - # Текущее время в UTC - current_time_utc = datetime.now(timezone.utc).replace(tzinfo=None) - one_hour_ago = current_time_utc - timedelta(hours=1) - # SQL запрос для обновления записей update_query = """ UPDATE events SET marked_to_publication = 1 WHERE is_visible = 1 - AND marked_to_publication = 0 - AND modified < %s + AND marked_to_publication = 0 """ # Выполнение запроса - cursor.execute(update_query, (one_hour_ago,)) + cursor.execute(update_query) updated_count = cursor.rowcount # Фиксация изменений