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

Use _throttle() in stopped state instead of sleep()

Browse Source
This commit is contained in:
hroff-1902 2020-02-20 15:18:26 +03:00
parent 56a06cbd33
commit 78ee36a8c6
1 changed files with 7 additions and 3 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

10
freqtrade/worker.py
View File

@ -87,7 +87,7 @@ class Worker:
logger.debug("sd_notify: WATCHDOG=1\\nSTATUS=State: STOPPED.") logger.debug("sd_notify: WATCHDOG=1\\nSTATUS=State: STOPPED.")
self._sd_notify.notify("WATCHDOG=1\nSTATUS=State: STOPPED.") self._sd_notify.notify("WATCHDOG=1\nSTATUS=State: STOPPED.")
time.sleep(throttle_secs) self._throttle(func=self._process_stopped, min_secs=throttle_secs)
elif state == State.RUNNING: elif state == State.RUNNING:
# Ping systemd watchdog before throttling # Ping systemd watchdog before throttling
@ -95,7 +95,7 @@ class Worker:
logger.debug("sd_notify: WATCHDOG=1\\nSTATUS=State: RUNNING.") logger.debug("sd_notify: WATCHDOG=1\\nSTATUS=State: RUNNING.")
self._sd_notify.notify("WATCHDOG=1\nSTATUS=State: RUNNING.") self._sd_notify.notify("WATCHDOG=1\nSTATUS=State: RUNNING.")
self._throttle(func=self._process, min_secs=throttle_secs) self._throttle(func=self._process_running, min_secs=throttle_secs)
return state return state
@ -116,7 +116,11 @@ class Worker:
time.sleep(duration) time.sleep(duration)
return result return result
def _process(self) -> None: def _process_stopped(self) -> None:
# Maybe do here something in the future...
pass
def _process_running(self) -> None:
try: try:
self.freqtrade.process() self.freqtrade.process()
except TemporaryError as error: except TemporaryError as error: