[+] fix periodic retrieval

This commit is contained in:
Siarhei Siniak 2025-07-11 10:55:36 +03:00
parent 10c012aba2
commit 7103f3a089

@ -102,7 +102,7 @@ class Emcont:
assert store_timeout >= 0 assert store_timeout >= 0
request_period_timedelta = datetime.timedelta( request_period_timedelta = datetime.timedelta(
seconds=request_timeout seconds=request_period,
) )
while True: while True:
@ -135,6 +135,8 @@ class Emcont:
next_retrieval = last_retrieval next_retrieval = last_retrieval
def wait_interval(): def wait_interval():
nonlocal next_retrieval
return ( return (
next_retrieval - datetime.datetime.now() next_retrieval - datetime.datetime.now()
).total_seconds() ).total_seconds()
@ -144,7 +146,7 @@ class Emcont:
if ( if (
wait_interval() > 0 or wait_interval() > 0 or
wait_interval() > request_period_timedelta.total_seconds() / 4 wait_interval() > -request_period_timedelta.total_seconds() / 4
): ):
break break
else: else: