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

Merge pull request #1815 from hroff-1902/fix-1810

Browse Source 
Fix for #1810
This commit is contained in:
Matthias 2019-04-30 19:31:23 +02:00 committed by GitHub
commit 97f2c74dd8
No known key found for this signature in database
GPG Key ID: 4AEE18F83AFDEB23
1 changed files with 7 additions and 7 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

14
freqtrade/worker.py
View File

@ -39,7 +39,7 @@ class Worker(object):
logger.debug("sd_notify: READY=1") logger.debug("sd_notify: READY=1")
self._sd_notify.notify("READY=1") self._sd_notify.notify("READY=1")
def _init(self, reconfig: bool): def _init(self, reconfig: bool) -> None:
""" """
Also called from the _reconfigure() method (with reconfig=True). Also called from the _reconfigure() method (with reconfig=True).
""" """
@ -63,17 +63,17 @@ class Worker(object):
return self.freqtrade.state return self.freqtrade.state
@state.setter @state.setter
def state(self, value: State): def state(self, value: State) -> None:
self.freqtrade.state = value self.freqtrade.state = value
def run(self): def run(self) -> None:
state = None state = None
while True: while True:
state = self._worker(old_state=state) state = self._worker(old_state=state)
if state == State.RELOAD_CONF: if state == State.RELOAD_CONF:
self.freqtrade = self._reconfigure() self._reconfigure()
def _worker(self, old_state: State, throttle_secs: Optional[float] = None) -> State: def _worker(self, old_state: Optional[State], throttle_secs: Optional[float] = None) -> State:
""" """
Trading routine that must be run at each loop Trading routine that must be run at each loop
:param old_state: the previous service state from the previous call :param old_state: the previous service state from the previous call
@ -148,7 +148,7 @@ class Worker(object):
# state_changed = True # state_changed = True
return state_changed return state_changed
def _reconfigure(self): def _reconfigure(self) -> None:
""" """
Cleans up current freqtradebot instance, reloads the configuration and Cleans up current freqtradebot instance, reloads the configuration and
replaces it with the new instance replaces it with the new instance
@ -174,7 +174,7 @@ class Worker(object):
logger.debug("sd_notify: READY=1") logger.debug("sd_notify: READY=1")
self._sd_notify.notify("READY=1") self._sd_notify.notify("READY=1")
def exit(self): def exit(self) -> None:
# Tell systemd that we are exiting now # Tell systemd that we are exiting now
if self._sd_notify: if self._sd_notify:
logger.debug("sd_notify: STOPPING=1") logger.debug("sd_notify: STOPPING=1")