Compare commits

...

2 commits

Author SHA1 Message Date
1f24d7486b fix docstrings 2022-02-22 00:12:38 +01:00
ce1b61b952 Bump version: 0.1.4 → 0.1.5 2022-02-09 15:52:21 +01:00
6 changed files with 31 additions and 10 deletions

View file

@ -1,5 +1,5 @@
[bumpversion] [bumpversion]
current_version = 0.1.4 current_version = 0.1.5
commit = True commit = True
tag = True tag = True

View file

@ -6,7 +6,7 @@ with open('README.rst') as f:
setuptools.setup( setuptools.setup(
name='TSGRain Controller', name='TSGRain Controller',
version='0.1.4', version='0.1.5',
author='ThetaDev', author='ThetaDev',
description='TSGRain irrigation controller', description='TSGRain irrigation controller',
long_description=README, long_description=README,

View file

@ -1 +1 @@
__version__ = '0.1.4' __version__ = '0.1.5'

View file

@ -176,6 +176,7 @@ class Application(models.AppInterface):
systimecfg.set_system_timezone(tz, self.cfg.cmd_set_timezone) systimecfg.set_system_timezone(tz, self.cfg.cmd_set_timezone)
def start(self): def start(self):
"""Starte die Anwendung"""
logging.info('Starting application') logging.info('Starting application')
self._running = True self._running = True
self.io.start() self.io.start()
@ -185,6 +186,7 @@ class Application(models.AppInterface):
self.grpc_server.start() self.grpc_server.start()
def stop(self): def stop(self):
"""Stoppe die Anwendung"""
logging.info('Stopping application') logging.info('Stopping application')
self._running = False self._running = False
self.grpc_server.stop(None) self.grpc_server.stop(None)

View file

@ -96,6 +96,10 @@ class Job:
) )
def validate(self, app: 'AppInterface'): def validate(self, app: 'AppInterface'):
"""
Prüfe, ob der Task gültige Daten enthält
(Zonen existieren, Bewässerungszeit > 0)
"""
if not self.zones: if not self.zones:
raise util.InvalidInputException('No zones set') raise util.InvalidInputException('No zones set')
if self.duration < 1: if self.duration < 1:

View file

@ -129,9 +129,20 @@ class StoppableThread(threading.Thread):
pass pass
def run_cycle(self): def run_cycle(self):
pass """
Führe einen Durchlauf des Threads aus.
Diese Funktion darf nicht blockieren, sonst kann der
Thread nicht gestoppt werden.
"""
def run(self): def run(self):
"""
Führe die ``run_cycle()``-Funktion in
Endlosschleife aus, mit einer durch das
``interval``-Attribut bestimmten Verzögerung zwischen
den Durchläufen.
"""
try: try:
self.setup() self.setup()
@ -146,6 +157,10 @@ class StoppableThread(threading.Thread):
sys.excepthook(*sys.exc_info()) sys.excepthook(*sys.exc_info())
def stop(self): def stop(self):
"""
Stoppe den Thread und warte bis er beendet. Dies dauert
maximal ``interval`` + Durchlaufzeit von ``run_cycle()``.
"""
self._stop_signal.set() self._stop_signal.set()
try: try:
self.join() self.join()