Co-Authored-By: Claude Opus 5.5 <noreply@anthropic.com>

@@ -308,6 +308,7 @@ The steps have the numbers of the inside diagram.
    a large file goes as an excerpt, see [`[excerpt]`](#excerpt).
 8. Run the PR-Agent reviewer with all settings forced by werkrevisor, except in classifier mode.

@@ -591,6 +592,9 @@ Optional, host only: only the operator knows whether a repository deploys throug
 
 werkrevisor splits Liquibase formatted SQL at `--changeset` lines

@@ -153,11 +175,28 @@ def collect(files, diffs, fetch_head, fetch_base):
             elif previous.text != current.text:

@@ -161,0 +193,4 @@
+    lines += [f"- released, changed or removed: {r}" for r in run.released]
+    if not lines:
+        return ""
+    return ("werkrevisor compared the Liquibase changesets of this PR with its base branch; "

@@ -175,1 +175,3 @@
-    _judge_db_schema(config, deps, use_llm, result, rules, diffs, fetch, pr_data.get("merge_base") or pr.base_sha)
+    base_ref = (pr_data.get("base") or {}).get("ref") or pr.base_ref
+    default_branch = _default_branch(deps.gitea, pr_data)
+    stacked_on = default_branch if base_ref and default_branch and base_ref != default_branch else ""

@@ -175,1 +175,3 @@
-    _judge_db_schema(config, deps, use_llm, result, rules, diffs, fetch, pr_data.get("merge_base") or pr.base_sha)
+    base_ref = (pr_data.get("base") or {}).get("ref") or pr.base_ref
+    default_branch = _default_branch(deps.gitea, pr_data)
+    stacked_on = default_branch if base_ref and default_branch and base_ref != default_branch else ""

@@ -120,3 +122,2 @@
 
-def collect(files, diffs, fetch_head, fetch_base):
-    """Returns (units, released changes, unjudgeable files); fetch_base returns None for a file missing at the base."""
+def _on_default(fetch_default, path):

@@ -146,3 +163,3 @@
             units.append(Unit(f.path, "", f.added, _diff_text(diffs.get(f.path))))
             continue
-        released += [f"{f.path}: changeset {cs} removed" for cs in base_sets if cs not in head_sets]
+        on_default = _on_default(fetch_default, f.previous_path or f.path)

@@ -146,3 +163,3 @@
             units.append(Unit(f.path, "", f.added, _diff_text(diffs.get(f.path))))
             continue
-        released += [f"{f.path}: changeset {cs} removed" for cs in base_sets if cs not in head_sets]
+        on_default = _on_default(fetch_default, f.previous_path or f.path)

@@ -404,0 +416,4 @@
+    """
+    try:
+        by_head = {}
+        for p in gitea.list_open_prs() or ():

@@ -161,0 +196,4 @@
+              ("changed, repeatable (runOnChange, runAlways or validCheckSum ANY)",
+               [u for u in run.units if u.changeset and not u.new and not u.unreleased]),
+              (f"changed, not on `{target}` yet", [u for u in run.units if u.unreleased]))
+    lines = [f"- {label}: {', '.join(f'`{u.changeset}` in `{u.path}`' for u in units)}"

@@ -404,0 +419,4 @@
+        for p in gitea.list_open_prs() or ():
+            head, base = p.get("head") or {}, p.get("base") or {}
+            if ((head.get("repo") or {}).get("id") or 0) == ((base.get("repo") or {}).get("id") or -1):
+                ref = head.get("ref") or ""

@@ -404,0 +424,4 @@
+                    ambiguous.add(ref)
+                by_head.setdefault(ref, p)
+        numbers, added, ref = [], set(), base_ref
+        while ref in by_head and len(numbers) < MAX_STACK: