Make environment error message be a non-empty string or None

docs/reference/openapi.yaml

@@ -39,6 +39,7 @@ components:
       properties:
         error_message:
           description: If present - error loading context
+          minLength: 1
           title: Error Message
           type: string
         initialized:

src/blueapi/service/model.py

@@ -145,5 +145,7 @@ class EnvironmentResponse(BlueapiBaseModel):
 
     initialized: bool = Field(description="blueapi context initialized")
     error_message: str | None = Field(
-        default=None, description="If present - error loading context"
+        default=None,
+        description="If present - error loading context",
+        min_length=1,
     )

src/blueapi/service/runner.py

@@ -7,9 +7,7 @@
 
 from blueapi.config import ApplicationConfig
 from blueapi.service.interface import InitialisationException, start_worker, stop_worker
-from blueapi.service.model import (
-    EnvironmentResponse,
-)
+from blueapi.service.model import EnvironmentResponse
 
 # The default multiprocessing start method is fork
 set_start_method("spawn", force=True)
@@ -39,7 +37,7 @@ def __init__(
         self._config = config or ApplicationConfig()
         self._subprocess = None
         self._use_subprocess = use_subprocess
-        self._state = EnvironmentResponse(initialized=False, error_message="")
+        self._state = EnvironmentResponse(initialized=False)
 
     def start(self):
         if self._subprocess is None and self._use_subprocess:
@@ -55,11 +53,11 @@ def start(self):
             )
             LOGGER.exception(self._state.error_message)
             return
-        self._state = EnvironmentResponse(initialized=True, error_message="")
+        self._state = EnvironmentResponse(initialized=True)
 
     def stop(self):
         if self._subprocess is not None:
-            self._state = EnvironmentResponse(initialized=False, error_message="")
+            self._state = EnvironmentResponse(initialized=False)
             try:
                 self._subprocess.apply(stop_worker)
             except InitialisationException:
@@ -71,7 +69,7 @@ def stop(self):
         if (not self._use_subprocess) and (
             self._state.initialized or self._state.error_message
         ):
-            self._state = EnvironmentResponse(initialized=False, error_message="")
+            self._state = EnvironmentResponse(initialized=False)
             stop_worker()
 
     def reload_context(self):

tests/service/test_rest_api.py

@@ -12,12 +12,7 @@
 
 from blueapi.core.bluesky_types import Plan
 from blueapi.service import main
-from blueapi.service.model import (
-    DeviceModel,
-    PlanModel,
-    StateChangeRequest,
-    WorkerTask,
-)
+from blueapi.service.model import DeviceModel, PlanModel, StateChangeRequest, WorkerTask
 from blueapi.worker.event import WorkerState
 from blueapi.worker.task import Task
 from blueapi.worker.worker import TrackableTask
@@ -546,7 +541,7 @@ def test_set_state_invalid_transition(
 def test_get_environment_idle(client: TestClient) -> None:
     assert client.get("/environment").json() == {
         "initialized": True,
-        "error_message": "",
+        "error_message": None,
     }
 
 

tests/service/test_runner.py

@@ -86,4 +86,4 @@ def test_can_reload_after_an_error(pool_mock: MagicMock):
 
     runner.reload_context()
 
-    assert runner.state == EnvironmentResponse(initialized=True, error_message="")
+    assert runner.state == EnvironmentResponse(initialized=True, error_message=None)