f**king sqlite error on threading...

This commit is contained in:
localhost_frssoft 2022-09-11 21:18:56 +03:00
parent cdd130b36d
commit fe6fc2a415

View file

@ -8,23 +8,19 @@ from dateutil.parser import parse as dateutilparse
from dateutil.relativedelta import relativedelta, TU, SU from dateutil.relativedelta import relativedelta, TU, SU
from loguru import logger from loguru import logger
lock = threading.Lock()
def get_control_mention(): def get_control_mention():
while True: while True:
time.sleep(30)
time_now = datetime.now() time_now = datetime.now()
now_week = time_now.weekday() now_week = time_now.weekday()
now_hour = time_now.hour now_hour = time_now.hour
if now_week not in (0, 6): if now_week not in (0, 6):
time.sleep(30)
continue continue
if now_week == 6 and now_hour <= fmn_next_watching_hour: # Предотвращение работы в холстую до начала сеанса if now_week == 6 and now_hour < fmn_next_watching_hour: # Предотвращение работы в холстую до начала сеанса
time.sleep(30)
continue continue
with lock: post_exists = get_state('last_thread_id')
post_exists = get_state('last_thread_id')
if post_exists: if post_exists:
time.sleep(30)
continue continue
logger.debug('Wait for from admin mention...') logger.debug('Wait for from admin mention...')
notif = get_notifications() notif = get_notifications()