From 69bf49f3a941bb9a59ec609537ce5cbad2cec7d7 Mon Sep 17 00:00:00 2001 From: gitadmin Date: Sun, 12 Oct 2025 12:59:24 +0300 Subject: [PATCH] =?UTF-8?q?=D1=83=D0=B1=D1=80=D0=B0=D1=82=D1=8C=20=D0=BF?= =?UTF-8?q?=D1=80=D0=BE=D0=B2=D0=B5=D1=80=D0=BA=D1=83=20=D0=B2=D1=80=D0=B5?= =?UTF-8?q?=D0=BC=D0=B5=D0=BD=D0=B8=20=D0=B2=20evt=5Fprefetch?= MIME-Version: 1.0 Content-Type: text/plain; charset=UTF-8 Content-Transfer-Encoding: 8bit --- evt_prefetch.py | 12 +++--------- 1 file changed, 3 insertions(+), 9 deletions(-) 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 # Фиксация изменений