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

revert worker() changes

Browse Source
This commit is contained in:
gcarq 2018-03-21 19:27:30 +01:00
parent 9df5e09a82
commit b8f322d8f6
1 changed files with 7 additions and 6 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

13
freqtrade/freqtradebot.py
View File

@ -94,13 +94,14 @@ class FreqtradeBot(object):
:return: current service state :return: current service state
""" """
# Log state transition # Log state transition
if self.state != old_state: state = self.state
self.rpc.send_msg('*Status:* `{}`'.format(self.state.name.lower())) if state != old_state:
self.logger.info('Changing state to: %s', self.state.name) self.rpc.send_msg('*Status:* `{}`'.format(state.name.lower()))
self.logger.info('Changing state to: %s', state.name)
if self.state == State.STOPPED: if state == State.STOPPED:
time.sleep(1) time.sleep(1)
elif self.state == State.RUNNING: elif state == State.RUNNING:
min_secs = self.config.get('internals', {}).get( min_secs = self.config.get('internals', {}).get(
'process_throttle_secs', 'process_throttle_secs',
Constants.PROCESS_THROTTLE_SECS Constants.PROCESS_THROTTLE_SECS
@ -114,7 +115,7 @@ class FreqtradeBot(object):
self._throttle(func=self._process, self._throttle(func=self._process,
min_secs=min_secs, min_secs=min_secs,
nb_assets=nb_assets) nb_assets=nb_assets)
return self.state return state
def _throttle(self, func: Callable[..., Any], min_secs: float, *args, **kwargs) -> Any: def _throttle(self, func: Callable[..., Any], min_secs: float, *args, **kwargs) -> Any:
""" """