Align dcm test/refresh progress UI and unify the DCM blue

test and refresh now render the shared phase checklist (a single
TEST / REFRESH phase driven by DeployProgressTracker.run_loader_phase)
instead of the legacy generic spinner, matching plan/compile/deploy.

- progress: add single-phase "test" and "refresh" operation modes and
  guard complete_upload() so operations without an UPLOAD phase don't
  KeyError when run_loader_phase calls it.
- styles: collapse the two divergent blues (#a0a8fe and the named
  "blue") onto a single terminal-default BLUE constant, and route the
  hardcoded style="blue" literals in progress.py through it, so every
  blue in DCM output renders the same hue.

Co-authored-by: Cursor <cursoragent@cursor.com>

Author: sfc-gh-jsommerfeld

src/snowflake/cli/_plugins/dcm/commands.py

@@ -847,9 +847,13 @@ def refresh(
     context = _resolve_context_with_optional_manifest(from_location, identifier, target)
     project_id = context.project_identifier
 
-    with cli_console.spinner() as spinner:
-        spinner.add_task(description=f"Refreshing dcm project {project_id}", total=None)
-        result = DCMProjectManager().refresh(project_identifier=project_id)
+    manager = DCMProjectManager()
+    tracker = DeployProgressTracker(conn=manager.connection, operation="refresh")
+    with tracker.session():
+        result = tracker.run_loader_phase(
+            lambda: manager.refresh(project_identifier=project_id),
+            phase_name="REFRESH",
+        )
 
     reporter = RefreshReporter(save_output=save_output)
     return reporter.process(result)
@@ -872,9 +876,13 @@ def test(
     context = _resolve_context_with_optional_manifest(from_location, identifier, target)
     project_id = context.project_identifier
 
-    with cli_console.spinner() as spinner:
-        spinner.add_task(description=f"Testing dcm project {project_id}", total=None)
-        result = DCMProjectManager().test(project_identifier=project_id)
+    manager = DCMProjectManager()
+    tracker = DeployProgressTracker(conn=manager.connection, operation="test")
+    with tracker.session():
+        result = tracker.run_loader_phase(
+            lambda: manager.test(project_identifier=project_id),
+            phase_name="TEST",
+        )
 
     reporter = TestReporter(save_output=save_output)
     return reporter.process(result)

src/snowflake/cli/_plugins/dcm/progress.py

@@ -45,17 +45,20 @@
 # after COMPILE (there are no server-side progress phases to poll, so RENDER is
 # fast-forwarded and COMPILE shows the live spinner while the server works).
 COMPILE_OPERATION_PHASES = ["RENDER", "COMPILE"]
-OperationMode = Literal["deploy", "plan", "compile", "purge"]
+OperationMode = Literal["deploy", "plan", "compile", "purge", "test", "refresh"]
 
 # Server-side phase list per operation mode. UPLOAD is first for operations
-# that sync local files; purge runs entirely on the server (no local upload),
-# so it has no UPLOAD phase. Every operation uses the same
-# RENDER → COMPILE → PLAN → DEPLOY/PURGE vocabulary.
+# that sync local files; purge/test/refresh run entirely on the server against
+# already-deployed objects (no local upload), so they have no UPLOAD phase.
+# Deploy-family operations share the RENDER → COMPILE → PLAN → DEPLOY/PURGE
+# vocabulary; test/refresh are single-phase since they neither render nor plan.
 _PHASES_BY_OPERATION: dict[OperationMode, list[str]] = {
     "deploy": [UPLOAD_PHASE, *BACKEND_PHASES],
     "plan": [UPLOAD_PHASE, *PLAN_OPERATION_PHASES],
     "compile": [UPLOAD_PHASE, *COMPILE_OPERATION_PHASES],
     "purge": [*BACKEND_PHASES],
+    "test": ["TEST"],
+    "refresh": ["REFRESH"],
 }
 
 # Only PLAN and DEPLOY emit a meaningful 0-100 progress value.
@@ -273,6 +276,11 @@ def advance_upload(self, count: int = 1) -> None:
             self._refresh_display()
 
     def complete_upload(self) -> None:
+        # Operations that don't sync local files (purge/test/refresh) have no
+        # UPLOAD phase; nothing to complete. ``run_loader_phase`` calls this
+        # unconditionally, so the guard keeps single-phase modes working.
+        if not self._has_upload_phase():
+            return
         if self._upload_file_total > 0:
             self._get_phase(UPLOAD_PHASE).observe_running(100, datetime.now())
         self._get_phase(UPLOAD_PHASE).observe_done(datetime.now())
@@ -457,14 +465,14 @@ def _append_progress_bar(self, out: Text, progress: int) -> None:
         in_progress = 0 < filled < _BAR_WIDTH
 
         if in_progress:
-            out.append(_BAR_CELL * filled + _BAR_LEADING_EDGE, style="blue")
+            out.append(_BAR_CELL * filled + _BAR_LEADING_EDGE, style=styles.BLUE)
             out.append(_BAR_CELL * (_BAR_WIDTH - filled - 1), style="dim")
         elif filled == 0:
             out.append(_BAR_CELL * _BAR_WIDTH, style="dim")
         else:
-            out.append(_BAR_CELL * _BAR_WIDTH, style="blue")
+            out.append(_BAR_CELL * _BAR_WIDTH, style=styles.BLUE)
 
-        out.append(f" {progress:>3}%", style="blue")
+        out.append(f" {progress:>3}%", style=styles.BLUE)
 
     def _append_upload_details(self, out: Text) -> None:
         """Render the stage-creation message and folder counters indented
@@ -509,7 +517,7 @@ def _render_phase_line(self, out: Text, phase: _Phase) -> None:
                 # Blue matches the active-indicator color used by the
                 # pip-style progress bar so all "this phase is in flight"
                 # signals share the same hue.
-                out.append(_spinner_glyph(), style="blue")
+                out.append(_spinner_glyph(), style=styles.BLUE)
             out.append(duration_str + "\n", style="dim")
         else:  # PENDING
             out.append(name_col + "·\n", style="dim")

src/snowflake/cli/_plugins/dcm/styles.py

@@ -13,13 +13,17 @@
 # limitations under the License.
 from rich.style import Style
 
-_COLOR_BLUE = "#a0a8fe"
+# Single source of truth for the DCM "blue" hue. Use the terminal-default
+# named color (not a fixed hex) so it respects the user's theme and stays
+# identical everywhere it's used: progress spinner/bar, running phase,
+# analyze INFO findings / file headers, refresh status, and unknown rows.
+BLUE = "blue"
 
 DOMAIN_STYLE = Style(color="cyan")
 BOLD_STYLE = Style(bold=True)
 
 # Refresh
-STATUS_STYLE = Style(color=_COLOR_BLUE)
+STATUS_STYLE = Style(color=BLUE)
 REMOVED_STYLE = Style(color="red", italic=True)
 INSERTED_STYLE = Style(color="green", italic=True)
 
@@ -28,18 +32,18 @@
 FAIL_STYLE = Style(color="red")
 WARNING_STYLE = Style(color="yellow")
 # INFO-severity analyze findings: plain blue (distinct from bold-blue file headers).
-INFO_STYLE = Style(color="blue")
+INFO_STYLE = Style(color=BLUE)
 
 # Plan
 CREATE_STYLE = Style(color="green")
 ALTER_STYLE = Style(color="yellow")
 DROP_STYLE = Style(color="red")
-UNKNOWN_STYLE = Style(color=_COLOR_BLUE)
+UNKNOWN_STYLE = Style(color=BLUE)
 
 # Deploy progress phases
 PHASE_DONE_STYLE = Style(color="green", bold=True)
-PHASE_RUNNING_STYLE = Style(color="blue", bold=True)
+PHASE_RUNNING_STYLE = Style(color=BLUE, bold=True)
 PHASE_FAILED_STYLE = Style(color="red", bold=True)
 
 # Analyze (file/source path headers stand out in bold blue).
-FILE_PATH_STYLE = Style(color="blue", bold=True)
+FILE_PATH_STYLE = Style(color=BLUE, bold=True)

tests/dcm/__snapshots__/test_commands.ambr

@@ -2,6 +2,7 @@
 # name: TestDCMRefresh.test_refresh_with_fresh_tables
   '''
 
+  REFRESH   ✓  (0.0s)
 
   UP-TO-DATE        0       0 JW_DCM_TESTALL.ANALYTICS.DYNAMIC_EMPLOYEES
 
@@ -13,6 +14,7 @@
 # name: TestDCMRefresh.test_refresh_with_no_dynamic_tables
   '''
 
+  REFRESH   ✓  (0.0s)
 
 
   No dynamic tables found in the project.
@@ -23,6 +25,7 @@
 # name: TestDCMRefresh.test_refresh_with_outdated_tables
   '''
 
+  REFRESH   ✓  (0.0s)
 
   REFRESHED    +12.3k   -999B JW_DCM_TESTALL.ANALYTICS.DYNAMIC_EMPLOYEES
 
@@ -34,6 +37,7 @@
 # name: TestDCMTest.test_test_all_passing
   '''
 
+  TEST      ✓  (0.0s)
 
   ✓ PASS      DB.SCHEMA.EMPLOYEES (ROW_COUNT_CHECK)
   ✓ PASS      DB.SCHEMA.ORDERS (NULL_CHECK)
@@ -46,6 +50,7 @@
 # name: TestDCMTest.test_test_no_expectations
   '''
 
+  TEST      ✓  (0.0s)
 
 
   No expectations found in the project.
@@ -56,6 +61,7 @@
 # name: TestDCMTest.test_test_with_failures
   '''
 
+  TEST      ✓  (0.0s)
 
   ✓ PASS      DB.SCHEMA.EMPLOYEES (ROW_COUNT_CHECK)
   ✗ FAIL      DB.SCHEMA.ORDERS (NULL_CHECK)