Handle missing broker/result backend errors

Author: mslaursen

fastapi_forge/dtos.py

@@ -330,6 +330,18 @@ def _validate_models(self) -> Self:
             msg = "Only one model can be an auth user."
             raise ValueError(msg)
 
+        if self.use_taskiq and not (self.use_redis and self.use_rabbitmq):
+            missing = []
+            if not self.use_rabbitmq:
+                missing.append("RabbitMQ")
+            if not self.use_redis:
+                missing.append("Redis")
+
+            if missing:
+                raise ValueError(
+                    "TaskIQ is enabled, but the following are missing and required "
+                    f"for its operation: {', '.join(missing)}."
+                )
         return self
 
     @model_validator(mode="after")

fastapi_forge/frontend/panels/project_config_panel.py

@@ -22,6 +22,7 @@ def __init__(self):
         super().__init__(value=True, elevated=False, bottom_corner=True)
         self._build()
         self._bind_state_to_ui()
+        self._update_taskiq_state()
 
     def _build(self) -> None:
         with (
@@ -83,13 +84,15 @@ def _build(self) -> None:
                 self.use_rabbitmq = ui.checkbox(
                     "RabbitMQ",
                     value=state.use_rabbitmq,
+                    on_change=self._update_taskiq_state,
                 ).classes("w-full")
 
             with ui.column().classes("w-full gap-2"):
                 ui.label("Task Queues").classes("text-lg font-bold")
                 self.use_taskiq = ui.checkbox(
                     "Taskiq",
                     value=state.use_taskiq,
+                    on_change=self._update_taskiq_state,
                 ).classes("w-full")
                 self.use_celery = (
                     ui.checkbox("Celery")
@@ -121,6 +124,7 @@ def _build(self) -> None:
                 self.use_redis = ui.checkbox(
                     "Redis",
                     value=state.use_redis,
+                    on_change=self._update_taskiq_state,
                 ).classes("w-full")
 
             with ui.column().classes("w-full gap-2"):
@@ -139,10 +143,24 @@ def _bind_state_to_ui(self) -> None:
         self.use_postgres.bind_value_to(state, "use_postgres")
         self.use_alembic.bind_value_to(state, "use_alembic")
         self.use_builtin_auth.bind_value_to(state, "use_builtin_auth")
-        self.use_rabbitmq.bind_value_to(state, "use_rabbitmq")
-        self.use_redis.bind_value_to(state, "use_redis")
+        self.use_rabbitmq.bind_value_to(state, "use_rabbitmq").on(
+            "change", self._update_taskiq_state
+        )
+        self.use_redis.bind_value_to(state, "use_redis").on(
+            "change", self._update_taskiq_state
+        )
         self.use_taskiq.bind_value_to(state, "use_taskiq")
 
+    def _update_taskiq_state(self, *_) -> None:
+        """Enable or disable Taskiq based on Redis and RabbitMQ."""
+        self.use_taskiq.set_enabled(self.use_redis.value and self.use_rabbitmq.value)
+        if (
+            not (self.use_redis.value and self.use_rabbitmq.value)
+            and self.use_taskiq.value
+        ):
+            self.use_taskiq.value = False
+            state.use_taskiq = False
+
     def _handle_builtin_auth_change(self, event: ValueChangeEventArguments) -> None:
         """Handle JWT Auth checkbox changes"""
         enabled = event.value