adelorenzo/stable
1
0
Fork 0
Code Issues Pull Requests Packages Projects Releases Wiki Activity

Make throttle start time an worker object attribute

Browse Source
This commit is contained in:
hroff-1902 2020-02-21 03:52:14 +03:00
parent 04aa74e5ad
commit e0800b7c29
1 changed files with 4 additions and 2 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

6
freqtrade/worker.py
View File

@ -32,6 +32,8 @@ class Worker:
self._config = config self._config = config
self._init(False) self._init(False)
self.last_throttle_start_time: float = None
# Tell systemd that we completed initialization phase # Tell systemd that we completed initialization phase
if self._sd_notify: if self._sd_notify:
logger.debug("sd_notify: READY=1") logger.debug("sd_notify: READY=1")
@ -107,10 +109,10 @@ class Worker:
:param min_secs: minimum execution time in seconds :param min_secs: minimum execution time in seconds
:return: Any :return: Any
""" """
start = time.time() self.last_throttle_start_time = time.time()
logger.debug("========================================") logger.debug("========================================")
result = func(*args, **kwargs) result = func(*args, **kwargs)
time_passed = time.time() - start time_passed = time.time() - self.last_throttle_start_time
sleep_duration = max(min_secs - time_passed, 0.0) sleep_duration = max(min_secs - time_passed, 0.0)
logger.debug(f"Throttling with '{func.__name__}()': sleep for {sleep_duration:.2f} s, " logger.debug(f"Throttling with '{func.__name__}()': sleep for {sleep_duration:.2f} s, "
f"last iteration took {time_passed:.2f} s.") f"last iteration took {time_passed:.2f} s.")