setup calibration on start

brewblox_tilt/app_factory.py

@@ -4,8 +4,7 @@
 
 from fastapi import FastAPI
 
-from . import broadcaster, mqtt, parser, scanner, utils
-from .stored import devices
+from . import broadcaster, mqtt, parser, scanner, stored, utils
 
 LOGGER = logging.getLogger(__name__)
 
@@ -44,7 +43,7 @@ def create_app() -> FastAPI:
 
     # Call setup functions for modules
     mqtt.setup()
-    devices.setup()
+    stored.setup()
     parser.setup()
     scanner.setup()
 

brewblox_tilt/broadcaster.py

@@ -100,7 +100,7 @@ async def repeat(self):
                 await asyncio.sleep(self.scan_interval)
                 await self.run()
             except Exception as ex:
-                LOGGER.error(ex, exc_info=config.debug)
+                LOGGER.error(utils.strex(ex), exc_info=config.debug)
                 await asyncio.sleep(EXCEPTION_DELAY_S)
 
 

brewblox_tilt/stored/__init__.py

@@ -0,0 +1,6 @@
+from . import calibration, devices
+
+
+def setup():
+    calibration.setup()
+    devices.setup()

brewblox_tilt/utils.py

@@ -1,4 +1,5 @@
 import time
+import traceback
 from functools import lru_cache
 
 from .models import ServiceConfig
@@ -11,3 +12,16 @@ def get_config() -> ServiceConfig:  # pragma: no cover
 
 def time_ms():
     return time.time_ns() // 1000000
+
+
+def strex(ex: Exception, tb=False):
+    """
+    Generic formatter for exceptions.
+    A formatted traceback is included if `tb=True`.
+    """
+    msg = f'{type(ex).__name__}({str(ex)})'
+    if tb:
+        trace = ''.join(traceback.format_exception(None, ex, ex.__traceback__))
+        return f'{msg}\n\n{trace}'
+    else:
+        return msg