From 54075e0cbdce63743f86bc9182064c65a800d536 Mon Sep 17 00:00:00 2001
From: Paul Elliott <paul@vizworkshop.com>
Date: Tue, 3 Feb 2026 09:21:14 -0500
Subject: [PATCH 1/4] Use VSnackbarQueue for stacking notifications

---
 align_app/app/alerts_controller.py | 15 +++++----------
 align_app/app/ui.py                | 16 ++++------------
 2 files changed, 9 insertions(+), 22 deletions(-)

diff --git a/align_app/app/alerts_controller.py b/align_app/app/alerts_controller.py
index 304981c..797b719 100644
--- a/align_app/app/alerts_controller.py
+++ b/align_app/app/alerts_controller.py
@@ -5,15 +5,10 @@
 class AlertsController:
     def __init__(self, server):
         self.server = server
-        self.server.state.alert_message = ""
-        self.server.state.alert_visible = False
-        self.server.state.alert_timeout = -1
+        self.server.state.alert_messages = []
 
     def show(self, message: str, timeout: int = -1):
-        with self.server.state:
-            self.server.state.alert_message = message
-            self.server.state.alert_timeout = timeout
-            self.server.state.alert_visible = True
-
-    def hide(self):
-        self.server.state.alert_visible = False
+        self.server.state.alert_messages = [
+            *self.server.state.alert_messages,
+            {"text": message, "timeout": timeout},
+        ]
diff --git a/align_app/app/ui.py b/align_app/app/ui.py
index 742e59c..019c715 100644
--- a/align_app/app/ui.py
+++ b/align_app/app/ui.py
@@ -1541,20 +1541,12 @@ def __init__(
                             )
 
             with layout.content:
-                with vuetify3.VSnackbar(
-                    v_model=("alert_visible", False),
-                    text=("alert_message", ""),
-                    location="bottom left",
+                vuetify3.VSnackbarQueue(
+                    v_model=("alert_messages", []),
+                    location="bottom right",
                     color="white",
-                    timeout=("alert_timeout", -1),
                     content_class="text-h6 font-weight-medium",
-                ):
-                    with vuetify3.Template(v_slot_actions=""):
-                        vuetify3.VBtn(
-                            icon="mdi-close",
-                            variant="text",
-                            click="alert_visible = false",
-                        )
+                )
                 html.Div(
                     v_html=(
                         "'<style>"

From 4ad9103edf9be555ee7e29e1234e939d57e22922 Mon Sep 17 00:00:00 2001
From: Paul Elliott <paul@vizworkshop.com>
Date: Tue, 3 Feb 2026 14:04:44 -0500
Subject: [PATCH 2/4] Move snackbar to bottom right with replace behavior

---
 align_app/app/alerts_controller.py | 12 +++++++-----
 align_app/app/ui.py                | 14 +++++++++++---
 2 files changed, 18 insertions(+), 8 deletions(-)

diff --git a/align_app/app/alerts_controller.py b/align_app/app/alerts_controller.py
index 797b719..8e55279 100644
--- a/align_app/app/alerts_controller.py
+++ b/align_app/app/alerts_controller.py
@@ -5,10 +5,12 @@
 class AlertsController:
     def __init__(self, server):
         self.server = server
-        self.server.state.alert_messages = []
+        self.server.state.alert_message = ""
+        self.server.state.alert_visible = False
+        self.server.state.alert_timeout = -1
 
     def show(self, message: str, timeout: int = -1):
-        self.server.state.alert_messages = [
-            *self.server.state.alert_messages,
-            {"text": message, "timeout": timeout},
-        ]
+        with self.server.state:
+            self.server.state.alert_message = message
+            self.server.state.alert_timeout = timeout
+            self.server.state.alert_visible = True
diff --git a/align_app/app/ui.py b/align_app/app/ui.py
index 019c715..79a55c6 100644
--- a/align_app/app/ui.py
+++ b/align_app/app/ui.py
@@ -1541,12 +1541,20 @@ def __init__(
                             )
 
             with layout.content:
-                vuetify3.VSnackbarQueue(
-                    v_model=("alert_messages", []),
+                with vuetify3.VSnackbar(
+                    v_model=("alert_visible", False),
+                    text=("alert_message", ""),
                     location="bottom right",
                     color="white",
+                    timeout=("alert_timeout", -1),
                     content_class="text-h6 font-weight-medium",
-                )
+                ):
+                    with vuetify3.Template(v_slot_actions=""):
+                        vuetify3.VBtn(
+                            icon="mdi-close",
+                            variant="text",
+                            click="alert_visible = false",
+                        )
                 html.Div(
                     v_html=(
                         "'<style>"

From 2c762bd67fb43aa262889beae4fb541ae15f2773 Mon Sep 17 00:00:00 2001
From: Paul Elliott <paul@vizworkshop.com>
Date: Tue, 3 Feb 2026 16:09:52 -0500
Subject: [PATCH 3/4] Improve decision notification messages

---
 align_app/app/runs_state_adapter.py | 9 ++++-----
 1 file changed, 4 insertions(+), 5 deletions(-)

diff --git a/align_app/app/runs_state_adapter.py b/align_app/app/runs_state_adapter.py
index 5049d8f..1a2bd66 100644
--- a/align_app/app/runs_state_adapter.py
+++ b/align_app/app/runs_state_adapter.py
@@ -617,11 +617,10 @@ async def _execute_run_decision(self, run_id: str):
             self._add_pending_cache_key(cache_key)
 
         is_cached = self.runs_registry.has_cached_decision(run_id)
-        if not is_cached:
-            self._alerts.show("Loading model...")
-            await self.server.network_completion
-
-        self._alerts.show("Making decision...")
+        if is_cached:
+            self._alerts.show("Deciding...")
+        else:
+            self._alerts.show("Loading model and deciding...")
         await self.server.network_completion
 
         try:

From 8980227b0becfecb66426912f94e9852c0849d66 Mon Sep 17 00:00:00 2001
From: Paul Elliott <paul@vizworkshop.com>
Date: Fri, 6 Feb 2026 14:38:40 -0500
Subject: [PATCH 4/4] Check worker model cache for decision loading
 notifications

---
 align_app/adm/decider/__init__.py   |  3 ++-
 align_app/adm/decider/client.py     |  7 +++++++
 align_app/adm/decider/decider.py    |  9 ++++++++-
 align_app/adm/decider/worker.py     | 18 ++++++++++++++++++
 align_app/app/runs_registry.py      |  7 -------
 align_app/app/runs_state_adapter.py |  5 +++--
 6 files changed, 38 insertions(+), 11 deletions(-)

diff --git a/align_app/adm/decider/__init__.py b/align_app/adm/decider/__init__.py
index c711656..9fbc8a8 100644
--- a/align_app/adm/decider/__init__.py
+++ b/align_app/adm/decider/__init__.py
@@ -1,11 +1,12 @@
 from align_utils.models import ADMResult, Decision, ChoiceInfo
 from .decider import MultiprocessDecider
-from .client import get_decision
+from .client import get_decision, is_model_cached
 from .types import DeciderParams
 
 __all__ = [
     "MultiprocessDecider",
     "get_decision",
+    "is_model_cached",
     "DeciderParams",
     "ADMResult",
     "Decision",
diff --git a/align_app/adm/decider/client.py b/align_app/adm/decider/client.py
index 67746be..0f955b5 100644
--- a/align_app/adm/decider/client.py
+++ b/align_app/adm/decider/client.py
@@ -4,6 +4,7 @@
 """
 
 import atexit
+from typing import Dict, Any
 from align_utils.models import ADMResult
 from .decider import MultiprocessDecider
 from .types import DeciderParams
@@ -19,6 +20,12 @@ def _get_process_manager():
     return _decider
 
 
+async def is_model_cached(resolved_config: Dict[str, Any]) -> bool:
+    """Check if model for this config is already loaded in worker."""
+    process_manager = _get_process_manager()
+    return await process_manager.is_model_cached(resolved_config)
+
+
 async def get_decision(params: DeciderParams) -> ADMResult:
     """Get a decision using DeciderParams.
 
diff --git a/align_app/adm/decider/decider.py b/align_app/adm/decider/decider.py
index d4ccbe6..4540645 100644
--- a/align_app/adm/decider/decider.py
+++ b/align_app/adm/decider/decider.py
@@ -1,6 +1,7 @@
+from typing import Dict, Any
 from align_utils.models import ADMResult
 from .types import DeciderParams
-from .worker import decider_worker_func
+from .worker import decider_worker_func, CacheQuery, CacheQueryResult
 from .multiprocess_worker import (
     WorkerHandle,
     create_worker,
@@ -13,6 +14,12 @@ class MultiprocessDecider:
     def __init__(self):
         self.worker: WorkerHandle = create_worker(decider_worker_func)
 
+    async def is_model_cached(self, resolved_config: Dict[str, Any]) -> bool:
+        self.worker, result = await send(self.worker, CacheQuery(resolved_config))
+        if isinstance(result, CacheQueryResult):
+            return result.is_cached
+        return False
+
     async def get_decision(self, params: DeciderParams) -> ADMResult:
         self.worker, result = await send(self.worker, params)
 
diff --git a/align_app/adm/decider/worker.py b/align_app/adm/decider/worker.py
index c80af6b..5ed5749 100644
--- a/align_app/adm/decider/worker.py
+++ b/align_app/adm/decider/worker.py
@@ -3,6 +3,7 @@
 import json
 import logging
 import traceback
+from dataclasses import dataclass
 from typing import Dict, Tuple, Callable, Any
 from multiprocessing import Queue
 from align_utils.models import ADMResult
@@ -15,6 +16,16 @@ def extract_cache_key(resolved_config: Dict[str, Any]) -> str:
     return hashlib.md5(cache_str.encode()).hexdigest()
 
 
+@dataclass
+class CacheQuery:
+    resolved_config: Dict[str, Any]
+
+
+@dataclass
+class CacheQueryResult:
+    is_cached: bool
+
+
 def decider_worker_func(task_queue: Queue, result_queue: Queue):
     root_logger = logging.getLogger()
     root_logger.setLevel("WARNING")
@@ -24,6 +35,13 @@ def decider_worker_func(task_queue: Queue, result_queue: Queue):
     try:
         for task in iter(task_queue.get, None):
             try:
+                if isinstance(task, CacheQuery):
+                    cache_key = extract_cache_key(task.resolved_config)
+                    result_queue.put(
+                        CacheQueryResult(is_cached=cache_key in model_cache)
+                    )
+                    continue
+
                 params: DeciderParams = task
                 cache_key = extract_cache_key(params.resolved_config)
 
diff --git a/align_app/app/runs_registry.py b/align_app/app/runs_registry.py
index f29ba55..1264179 100644
--- a/align_app/app/runs_registry.py
+++ b/align_app/app/runs_registry.py
@@ -103,13 +103,6 @@ async def execute_run_decision(self, run_id: str) -> Optional[Run]:
 
         return await self._execute_with_cache(run, probe.choices or [])
 
-    def has_cached_decision(self, run_id: str) -> bool:
-        run = runs_core.get_run(self._runs, run_id)
-        if not run:
-            return False
-        cache_key = run.compute_cache_key()
-        return runs_core.get_cached_decision(self._runs, cache_key) is not None
-
     def get_run(self, run_id: str) -> Optional[Run]:
         run = runs_core.get_run(self._runs, run_id)
         if run:
diff --git a/align_app/app/runs_state_adapter.py b/align_app/app/runs_state_adapter.py
index 1a2bd66..5b2c0ec 100644
--- a/align_app/app/runs_state_adapter.py
+++ b/align_app/app/runs_state_adapter.py
@@ -6,6 +6,7 @@
 from .runs_registry import RunsRegistry
 from .runs_table_filter import RunsTableFilter
 from ..adm.decider.types import DeciderParams
+from ..adm.decider import is_model_cached
 from ..adm.system_adm_discovery import discover_system_adms
 from ..utils.utils import get_id
 from .runs_presentation import extract_base_scenarios
@@ -616,8 +617,8 @@ async def _execute_run_decision(self, run_id: str):
         with self.state:
             self._add_pending_cache_key(cache_key)
 
-        is_cached = self.runs_registry.has_cached_decision(run_id)
-        if is_cached:
+        run = self.runs_registry.get_run(run_id)
+        if run and await is_model_cached(run.decider_params.resolved_config):
             self._alerts.show("Deciding...")
         else:
             self._alerts.show("Loading model and deciding...")