From e4a5534eddd49a282d9c8a0c64725592a906f741 Mon Sep 17 00:00:00 2001 From: localhost_frssoft Date: Wed, 12 Oct 2022 19:45:05 +0300 Subject: [PATCH] Reduce call thread-context api, after scan done --- src/listener_context.py | 4 ++++ 1 file changed, 4 insertions(+) diff --git a/src/listener_context.py b/src/listener_context.py index 8dfccaf..f064075 100644 --- a/src/listener_context.py +++ b/src/listener_context.py @@ -37,6 +37,7 @@ def scan_context_thread(): poll_created = get_state('poll_status_id') stop_thread_scan = get_state('stop_thread_scan') time_now = int(time.time()) + reserve_time = False while status_id is None or stop_thread_scan is None: fail_limit = Counter() status_id = get_state('last_thread_id') @@ -44,6 +45,7 @@ def scan_context_thread(): time.sleep(1) if time_now >= int(stop_thread_scan): + reserve_time = True logger.debug('Сбор завершён, сканирование треда на опоздавших') if poll_created is None: create_poll_movies() @@ -54,6 +56,8 @@ def scan_context_thread(): else: endings = int(stop_thread_scan) - time_now logger.debug(f'Осталось до закрытия сбора: {endings}') + if reserve_time: # Reduce instance load + time.sleep(30) descendants = get_status_context(status_id)['descendants'] replyed = [] for status in descendants: