diff --git a/packages/core/src/automations/automationSchedule.test.ts b/packages/core/src/automations/automationSchedule.test.ts
new file mode 100644
index 0000000000..5deb2487a0
--- /dev/null
+++ b/packages/core/src/automations/automationSchedule.test.ts
@@ -0,0 +1,223 @@
+import { describe, expect, it } from "vitest";
+import {
+  type AutomationScheduleDraft,
+  buildCronExpression,
+  createDefaultScheduleDraft,
+  deriveAutomationName,
+  formatAutomationScheduleSummary,
+  formatScheduleSummary,
+  parseCronExpression,
+  sanitizeHour,
+  sanitizeMinute,
+  WEEKDAY_OPTIONS,
+} from "./automationSchedule";
+
+describe("automationSchedule", () => {
+  it("creates the default daily schedule draft", () => {
+    expect(createDefaultScheduleDraft()).toEqual({
+      mode: "daily",
+      hour: "09",
+      minute: "00",
+      weekday: "1",
+      rawCron: "0 9 * * *",
+    });
+  });
+
+  it("provides cron weekday values in display order", () => {
+    expect(WEEKDAY_OPTIONS).toEqual([
+      { value: "1", label: "Mon" },
+      { value: "2", label: "Tue" },
+      { value: "3", label: "Wed" },
+      { value: "4", label: "Thu" },
+      { value: "5", label: "Fri" },
+      { value: "6", label: "Sat" },
+      { value: "0", label: "Sun" },
+    ]);
+  });
+
+  it.each([
+    ["", ""],
+    ["a", ""],
+    ["7", "07"],
+    ["09", "09"],
+    ["2x3", "23"],
+    ["24", "23"],
+    ["999", "23"],
+  ])("sanitizes hour input %j to %j", (input, expected) => {
+    expect(sanitizeHour(input)).toBe(expected);
+  });
+
+  it.each([
+    ["", ""],
+    ["a", ""],
+    ["7", "07"],
+    ["09", "09"],
+    ["5x9", "59"],
+    ["60", "59"],
+    ["999", "59"],
+  ])("sanitizes minute input %j to %j", (input, expected) => {
+    expect(sanitizeMinute(input)).toBe(expected);
+  });
+
+  it.each<{
+    name: string;
+    changes: Partial<AutomationScheduleDraft>;
+    expected: string;
+  }>([
+    {
+      name: "hourly",
+      changes: { mode: "hourly", minute: "15" },
+      expected: "15 * * * *",
+    },
+    {
+      name: "daily",
+      changes: { mode: "daily", hour: "09", minute: "15" },
+      expected: "15 9 * * *",
+    },
+    {
+      name: "weekdays",
+      changes: { mode: "weekdays", hour: "10", minute: "00" },
+      expected: "0 10 * * 1-5",
+    },
+    {
+      name: "weekly",
+      changes: {
+        mode: "weekly",
+        hour: "11",
+        minute: "30",
+        weekday: "4",
+      },
+      expected: "30 11 * * 4",
+    },
+    {
+      name: "weekly with a missing weekday",
+      changes: { mode: "weekly", weekday: "" },
+      expected: "0 9 * * 1",
+    },
+    {
+      name: "preset with missing time values",
+      changes: { mode: "daily", hour: "", minute: "" },
+      expected: "0 9 * * *",
+    },
+    {
+      name: "custom",
+      changes: { mode: "custom", rawCron: "  */15 * * * *  " },
+      expected: "*/15 * * * *",
+    },
+  ])("builds the $name cron expression", ({ changes, expected }) => {
+    expect(
+      buildCronExpression({ ...createDefaultScheduleDraft(), ...changes }),
+    ).toBe(expected);
+  });
+
+  it.each([
+    [
+      "15 * * * *",
+      {
+        mode: "hourly",
+        hour: "09",
+        minute: "15",
+        weekday: "*",
+        rawCron: "15 * * * *",
+      },
+    ],
+    [
+      "0 9 * * *",
+      {
+        mode: "daily",
+        hour: "09",
+        minute: "00",
+        weekday: "*",
+        rawCron: "0 9 * * *",
+      },
+    ],
+    [
+      "0 9 * * 1-5",
+      {
+        mode: "weekdays",
+        hour: "09",
+        minute: "00",
+        weekday: "1",
+        rawCron: "0 9 * * 1-5",
+      },
+    ],
+    [
+      "30 14 * * 2",
+      {
+        mode: "weekly",
+        hour: "14",
+        minute: "30",
+        weekday: "2",
+        rawCron: "30 14 * * 2",
+      },
+    ],
+  ] as const)("parses %s into a schedule draft", (cron, expected) => {
+    expect(parseCronExpression(cron)).toEqual(expected);
+  });
+
+  it.each(["*/15 * * * *", "0 9 1 * *", "0 9 * 1 *", "0 9 * * 1,3"])(
+    "keeps unsupported cron expression %s in custom mode",
+    (cron) => {
+      expect(parseCronExpression(cron)).toMatchObject({
+        mode: "custom",
+        rawCron: cron,
+      });
+    },
+  );
+
+  it("normalizes surrounding and repeated cron whitespace", () => {
+    expect(parseCronExpression("  5   8  * * *  ")).toEqual({
+      mode: "daily",
+      hour: "08",
+      minute: "05",
+      weekday: "*",
+      rawCron: "5   8  * * *",
+    });
+  });
+
+  it("uses default draft fields for a cron expression with the wrong arity", () => {
+    expect(parseCronExpression("0 9 * *")).toEqual({
+      mode: "custom",
+      hour: "09",
+      minute: "00",
+      weekday: "1",
+      rawCron: "0 9 * *",
+    });
+  });
+
+  it("derives a compact name from the first non-empty prompt line", () => {
+    expect(
+      deriveAutomationName(
+        "\n  Review   every open PostHog PR for stale comments \nIgnore this line",
+      ),
+    ).toBe("Review every open PostHog PR for stale comments");
+  });
+
+  it("returns an empty name for a blank prompt", () => {
+    expect(deriveAutomationName(" \n\t\n ")).toBe("");
+  });
+
+  it("limits derived names to 80 characters", () => {
+    expect(deriveAutomationName("a".repeat(100))).toBe("a".repeat(80));
+  });
+
+  it.each([
+    ["15 * * * *", "Europe/London", "Every hour at :15 · Europe/London"],
+    ["0 9 * * *", null, "Daily at 09:00"],
+    ["0 9 * * 1-5", "UTC", "Weekdays at 09:00 · UTC"],
+    ["30 14 * * 2", undefined, "Tue at 14:30"],
+    ["30 14 * * 7", "UTC", "Weekly at 14:30 · UTC"],
+    ["*/15 * * * *", "UTC", "Custom schedule · UTC"],
+  ])("formats %s with timezone %j", (cronExpression, timezone, expected) => {
+    expect(formatScheduleSummary(cronExpression, timezone)).toBe(expected);
+  });
+
+  it("formats a schedule from an automation-shaped input", () => {
+    expect(
+      formatAutomationScheduleSummary({
+        cron_expression: "0 18 * * 0",
+        timezone: "America/New_York",
+      }),
+    ).toBe("Sun at 18:00 · America/New_York");
+  });
+});
diff --git a/packages/core/src/automations/automationSchedule.ts b/packages/core/src/automations/automationSchedule.ts
new file mode 100644
index 0000000000..527e8da497
--- /dev/null
+++ b/packages/core/src/automations/automationSchedule.ts
@@ -0,0 +1,216 @@
+export type AutomationScheduleMode =
+  | "hourly"
+  | "daily"
+  | "weekdays"
+  | "weekly"
+  | "custom";
+
+export interface AutomationScheduleDraft {
+  mode: AutomationScheduleMode;
+  hour: string;
+  minute: string;
+  weekday: string;
+  rawCron: string;
+}
+
+export interface AutomationScheduleSummaryInput {
+  cron_expression: string;
+  timezone?: string | null;
+}
+
+export const WEEKDAY_OPTIONS = [
+  { value: "1", label: "Mon" },
+  { value: "2", label: "Tue" },
+  { value: "3", label: "Wed" },
+  { value: "4", label: "Thu" },
+  { value: "5", label: "Fri" },
+  { value: "6", label: "Sat" },
+  { value: "0", label: "Sun" },
+] as const;
+
+export function createDefaultScheduleDraft(): AutomationScheduleDraft {
+  return {
+    mode: "daily",
+    hour: "09",
+    minute: "00",
+    weekday: "1",
+    rawCron: "0 9 * * *",
+  };
+}
+
+function padTimePart(value: string): string {
+  return value.padStart(2, "0");
+}
+
+export function sanitizeHour(value: string): string {
+  const digitsOnly = value.replace(/\D/g, "").slice(0, 2);
+  if (!digitsOnly) {
+    return "";
+  }
+
+  return String(Math.min(23, Number(digitsOnly))).padStart(2, "0");
+}
+
+export function sanitizeMinute(value: string): string {
+  const digitsOnly = value.replace(/\D/g, "").slice(0, 2);
+  if (!digitsOnly) {
+    return "";
+  }
+
+  return String(Math.min(59, Number(digitsOnly))).padStart(2, "0");
+}
+
+export function buildCronExpression(draft: AutomationScheduleDraft): string {
+  if (draft.mode === "custom") {
+    return draft.rawCron.trim();
+  }
+
+  const minute = draft.minute ? String(Number(draft.minute)) : "0";
+  const hour = draft.hour ? String(Number(draft.hour)) : "9";
+
+  switch (draft.mode) {
+    case "hourly":
+      return `${minute} * * * *`;
+    case "weekdays":
+      return `${minute} ${hour} * * 1-5`;
+    case "weekly":
+      return `${minute} ${hour} * * ${draft.weekday || "1"}`;
+    default:
+      return `${minute} ${hour} * * *`;
+  }
+}
+
+export function parseCronExpression(
+  cronExpression: string,
+): AutomationScheduleDraft {
+  const normalized = cronExpression.trim();
+  const parts = normalized.split(/\s+/);
+
+  if (parts.length !== 5) {
+    return {
+      ...createDefaultScheduleDraft(),
+      mode: "custom",
+      rawCron: normalized,
+    };
+  }
+
+  const [minute, hour, dayOfMonth, month, dayOfWeek] = parts;
+  const isNumericMinute = /^\d{1,2}$/.test(minute);
+  const isNumericHour = /^\d{1,2}$/.test(hour);
+  const draftBase = {
+    hour: padTimePart(hour),
+    minute: padTimePart(minute),
+    weekday: dayOfWeek,
+    rawCron: normalized,
+  };
+
+  if (
+    isNumericMinute &&
+    hour === "*" &&
+    dayOfMonth === "*" &&
+    month === "*" &&
+    dayOfWeek === "*"
+  ) {
+    return {
+      ...draftBase,
+      mode: "hourly",
+      hour: "09",
+    };
+  }
+
+  if (
+    isNumericMinute &&
+    isNumericHour &&
+    dayOfMonth === "*" &&
+    month === "*" &&
+    dayOfWeek === "*"
+  ) {
+    return {
+      ...draftBase,
+      mode: "daily",
+    };
+  }
+
+  if (
+    isNumericMinute &&
+    isNumericHour &&
+    dayOfMonth === "*" &&
+    month === "*" &&
+    dayOfWeek === "1-5"
+  ) {
+    return {
+      ...draftBase,
+      mode: "weekdays",
+      weekday: "1",
+    };
+  }
+
+  if (
+    isNumericMinute &&
+    isNumericHour &&
+    dayOfMonth === "*" &&
+    month === "*" &&
+    /^\d$/.test(dayOfWeek)
+  ) {
+    return {
+      ...draftBase,
+      mode: "weekly",
+    };
+  }
+
+  return {
+    ...draftBase,
+    mode: "custom",
+  };
+}
+
+export function deriveAutomationName(prompt: string): string {
+  const normalized = prompt
+    .split("\n")
+    .map((line) => line.trim())
+    .find(Boolean);
+
+  if (!normalized) {
+    return "";
+  }
+
+  return normalized.replace(/\s+/g, " ").slice(0, 80);
+}
+
+function formatTime(hour: string, minute: string): string {
+  return `${padTimePart(hour)}:${padTimePart(minute)}`;
+}
+
+export function formatScheduleSummary(
+  cronExpression: string,
+  timezone: string | null | undefined,
+): string {
+  const draft = parseCronExpression(cronExpression);
+  const suffix = timezone ? ` · ${timezone}` : "";
+
+  switch (draft.mode) {
+    case "hourly":
+      return `Every hour at :${padTimePart(draft.minute)}${suffix}`;
+    case "weekdays":
+      return `Weekdays at ${formatTime(draft.hour, draft.minute)}${suffix}`;
+    case "weekly": {
+      const label =
+        WEEKDAY_OPTIONS.find((option) => option.value === draft.weekday)
+          ?.label ?? "Weekly";
+      return `${label} at ${formatTime(draft.hour, draft.minute)}${suffix}`;
+    }
+    case "custom":
+      return `Custom schedule${suffix}`;
+    default:
+      return `Daily at ${formatTime(draft.hour, draft.minute)}${suffix}`;
+  }
+}
+
+export function formatAutomationScheduleSummary(
+  automation: AutomationScheduleSummaryInput,
+): string {
+  return formatScheduleSummary(
+    automation.cron_expression,
+    automation.timezone ?? null,
+  );
+}
diff --git a/packages/core/src/automations/automationStatus.test.ts b/packages/core/src/automations/automationStatus.test.ts
new file mode 100644
index 0000000000..862fc3c0b5
--- /dev/null
+++ b/packages/core/src/automations/automationStatus.test.ts
@@ -0,0 +1,80 @@
+import { describe, expect, it } from "vitest";
+import {
+  type AutomationStatusPresentation,
+  type AutomationTaskRunStatus,
+  getAutomationStatusPresentation,
+} from "./automationStatus";
+
+describe("automationStatus", () => {
+  it.each<{
+    status: AutomationTaskRunStatus;
+    expected: AutomationStatusPresentation | null;
+  }>([
+    {
+      status: "not_started",
+      expected: { label: "Queued", tone: "warning", iconKind: "queued" },
+    },
+    {
+      status: "queued",
+      expected: { label: "Queued", tone: "warning", iconKind: "queued" },
+    },
+    { status: "started", expected: null },
+    { status: "in_progress", expected: null },
+    {
+      status: "completed",
+      expected: { label: "Success", tone: "success", iconKind: "success" },
+    },
+    {
+      status: "failed",
+      expected: { label: "Failed", tone: "error", iconKind: "failed" },
+    },
+    {
+      status: "cancelled",
+      expected: { label: "Failed", tone: "error", iconKind: "failed" },
+    },
+  ])(
+    "maps task-run status $status to renderer-neutral presentation data",
+    ({ status, expected }) => {
+      expect(
+        getAutomationStatusPresentation({
+          lastRunStatus: "success",
+          lastTaskRunStatus: status,
+        }),
+      ).toEqual(expected);
+    },
+  );
+
+  it.each([
+    ["running", null],
+    ["success", { label: "Success", tone: "success", iconKind: "success" }],
+    ["failed", { label: "Failed", tone: "error", iconKind: "failed" }],
+    [null, { label: "Never run", tone: "neutral", iconKind: "never-run" }],
+    ["unknown", { label: "Never run", tone: "neutral", iconKind: "never-run" }],
+  ] as const)(
+    "falls back from automation status %j to semantic presentation data",
+    (lastRunStatus, expected) => {
+      expect(getAutomationStatusPresentation({ lastRunStatus })).toEqual(
+        expected,
+      );
+    },
+  );
+
+  it("prioritizes linked task-run detail over the automation-level status", () => {
+    expect(
+      getAutomationStatusPresentation({
+        lastRunStatus: "failed",
+        lastTaskRunStatus: "completed",
+      }),
+    ).toEqual({
+      label: "Success",
+      tone: "success",
+      iconKind: "success",
+    });
+  });
+
+  it("does not expose renderer-specific class names", () => {
+    expect(
+      getAutomationStatusPresentation({ lastRunStatus: "success" }),
+    ).not.toHaveProperty("className");
+  });
+});
diff --git a/packages/core/src/automations/automationStatus.ts b/packages/core/src/automations/automationStatus.ts
new file mode 100644
index 0000000000..4bcc13735e
--- /dev/null
+++ b/packages/core/src/automations/automationStatus.ts
@@ -0,0 +1,83 @@
+export type AutomationTaskRunStatus =
+  | "not_started"
+  | "queued"
+  | "started"
+  | "in_progress"
+  | "completed"
+  | "failed"
+  | "cancelled";
+
+export interface AutomationStatusInput {
+  lastRunStatus: string | null;
+  lastTaskRunStatus?: AutomationTaskRunStatus | null;
+}
+
+export type AutomationStatusTone = "neutral" | "warning" | "success" | "error";
+
+export type AutomationStatusIconKind =
+  | "queued"
+  | "success"
+  | "failed"
+  | "never-run";
+
+export interface AutomationStatusPresentation {
+  label: string;
+  tone: AutomationStatusTone;
+  iconKind: AutomationStatusIconKind;
+}
+
+export function getAutomationStatusPresentation({
+  lastRunStatus,
+  lastTaskRunStatus,
+}: AutomationStatusInput): AutomationStatusPresentation | null {
+  switch (lastTaskRunStatus) {
+    case "not_started":
+    case "queued":
+      return {
+        label: "Queued",
+        tone: "warning",
+        iconKind: "queued",
+      };
+    case "started":
+    case "in_progress":
+      return null;
+    case "completed":
+      return {
+        label: "Success",
+        tone: "success",
+        iconKind: "success",
+      };
+    case "failed":
+    case "cancelled":
+      return {
+        label: "Failed",
+        tone: "error",
+        iconKind: "failed",
+      };
+    default:
+      break;
+  }
+
+  switch (lastRunStatus) {
+    case "running":
+      return null;
+    case "success":
+      return {
+        label: "Success",
+        tone: "success",
+        iconKind: "success",
+      };
+    case "failed":
+      return {
+        label: "Failed",
+        tone: "error",
+        iconKind: "failed",
+      };
+    default:
+      return {
+        label: "Never run",
+        tone: "neutral",
+        iconKind: "never-run",
+      };
+  }
+}
diff --git a/packages/core/src/inbox/artefacts.test.ts b/packages/core/src/inbox/artefacts.test.ts
index a4e972613e..3d733ffbd3 100644
--- a/packages/core/src/inbox/artefacts.test.ts
+++ b/packages/core/src/inbox/artefacts.test.ts
@@ -1,11 +1,43 @@
-import type { SuggestedReviewer } from "@posthog/shared/types";
+import type {
+  AvailableSuggestedReviewer,
+  SuggestedReviewer,
+} from "@posthog/shared/types";
 import { describe, expect, it } from "vitest";
 import {
+  buildReviewerOptions,
   extractSuggestedReviewers,
+  orderSuggestedReviewers,
   reviewerInitials,
+  reviewerMatchesAvailable,
+  reviewerOptionLabel,
   suggestedReviewerDisplayName,
+  toSuggestedReviewerWriteContent,
 } from "./artefacts";
 
+function makeReviewer(
+  partial: Partial<SuggestedReviewer> = {},
+): SuggestedReviewer {
+  return {
+    github_login: "octocat",
+    github_name: "The Octocat",
+    relevant_commits: [],
+    user: null,
+    ...partial,
+  };
+}
+
+function makeAvailableReviewer(
+  partial: Partial<AvailableSuggestedReviewer> = {},
+): AvailableSuggestedReviewer {
+  return {
+    uuid: "uuid-1",
+    name: "Ada Lovelace",
+    email: "ada@example.com",
+    github_login: "ada",
+    ...partial,
+  };
+}
+
 describe("artefacts", () => {
   it("extracts suggested reviewers from artefacts", () => {
     const reviewers: SuggestedReviewer[] = [
@@ -46,4 +78,129 @@ describe("artefacts", () => {
     expect(reviewerInitials("Ben W.", null)).toBe("BW");
     expect(reviewerInitials("", "ben@posthog.com")).toBe("BE");
   });
+
+  it("moves the current user to the front", () => {
+    const reviewers = [
+      makeReviewer({
+        github_login: "a",
+        user: {
+          id: 1,
+          uuid: "uuid-a",
+          email: "a@posthog.com",
+          first_name: "a",
+          last_name: "",
+        },
+      }),
+      makeReviewer({
+        github_login: "me",
+        user: {
+          id: 2,
+          uuid: "uuid-me",
+          email: "me@posthog.com",
+          first_name: "me",
+          last_name: "",
+        },
+      }),
+    ];
+
+    expect(
+      orderSuggestedReviewers(reviewers, "uuid-me").map(
+        (reviewer) => reviewer.github_login,
+      ),
+    ).toEqual(["me", "a"]);
+  });
+
+  it("deduplicates reviewer options and pins the current user first", () => {
+    const options = buildReviewerOptions(
+      [
+        makeAvailableReviewer({ uuid: "b", name: "Bob" }),
+        makeAvailableReviewer({ uuid: "a", name: "Ada" }),
+        makeAvailableReviewer({ uuid: "a", name: "Ada duplicate" }),
+      ],
+      "b",
+    );
+
+    expect(options.map((option) => option.uuid)).toEqual(["b", "a"]);
+  });
+
+  it("labels the current reviewer", () => {
+    expect(
+      reviewerOptionLabel({
+        uuid: "uuid-me",
+        name: "Ada",
+        email: "ada@example.com",
+        github_login: "ada",
+        isMe: true,
+      }),
+    ).toBe("Ada (Me)");
+  });
+
+  it.each([
+    {
+      name: "user uuid",
+      reviewer: makeReviewer({
+        github_login: "",
+        user: {
+          id: 1,
+          uuid: "uuid-1",
+          email: "",
+          first_name: "",
+          last_name: "",
+        },
+      }),
+      expected: true,
+    },
+    {
+      name: "case-insensitive GitHub login",
+      reviewer: makeReviewer({ github_login: "ADA" }),
+      expected: true,
+    },
+    {
+      name: "different reviewer",
+      reviewer: makeReviewer(),
+      expected: false,
+    },
+  ])("matches an available reviewer by $name", ({ reviewer, expected }) => {
+    expect(reviewerMatchesAvailable(reviewer, makeAvailableReviewer())).toBe(
+      expected,
+    );
+  });
+
+  it.each([
+    {
+      name: "GitHub login",
+      reviewer: makeReviewer({
+        github_login: "ada",
+        user: {
+          id: 1,
+          uuid: "uuid-1",
+          email: "",
+          first_name: "",
+          last_name: "",
+        },
+      }),
+      expected: [{ github_login: "ada" }],
+    },
+    {
+      name: "user uuid fallback",
+      reviewer: makeReviewer({
+        github_login: "",
+        user: {
+          id: 1,
+          uuid: "uuid-1",
+          email: "",
+          first_name: "",
+          last_name: "",
+        },
+      }),
+      expected: [{ user_uuid: "uuid-1" }],
+    },
+    {
+      name: "unresolved reviewer",
+      reviewer: makeReviewer({ github_login: "" }),
+      expected: [],
+    },
+  ])("builds write content from the $name", ({ reviewer, expected }) => {
+    expect(toSuggestedReviewerWriteContent([reviewer])).toEqual(expected);
+  });
 });
diff --git a/packages/core/src/inbox/artefacts.ts b/packages/core/src/inbox/artefacts.ts
index 1978f710bc..dc5b2eddb2 100644
--- a/packages/core/src/inbox/artefacts.ts
+++ b/packages/core/src/inbox/artefacts.ts
@@ -1,8 +1,18 @@
 import type {
+  AvailableSuggestedReviewer,
   RepoSelectionArtefact,
   SuggestedReviewer,
+  SuggestedReviewerWriteEntry,
 } from "@posthog/shared/types";
 
+export interface ReviewerOption {
+  uuid: string;
+  name: string;
+  email: string;
+  github_login: string;
+  isMe: boolean;
+}
+
 function hasRepositoryContent(
   content: unknown,
 ): content is RepoSelectionArtefact["content"] {
@@ -48,6 +58,82 @@ export function extractSuggestedReviewers(
   return artefact?.content ?? [];
 }
 
+export function orderSuggestedReviewers(
+  reviewers: SuggestedReviewer[],
+  currentUserUuid: string | null | undefined,
+): SuggestedReviewer[] {
+  if (!currentUserUuid) return reviewers;
+  const currentUserIndex = reviewers.findIndex(
+    (reviewer) => reviewer.user?.uuid === currentUserUuid,
+  );
+  if (currentUserIndex <= 0) return reviewers;
+  return [
+    reviewers[currentUserIndex],
+    ...reviewers.filter((_, index) => index !== currentUserIndex),
+  ];
+}
+
+export function buildReviewerOptions(
+  reviewers: AvailableSuggestedReviewer[],
+  currentUserUuid: string | undefined,
+): ReviewerOption[] {
+  const seen = new Set<string>();
+  const options: ReviewerOption[] = [];
+
+  for (const reviewer of reviewers) {
+    if (!reviewer.uuid || seen.has(reviewer.uuid)) continue;
+    seen.add(reviewer.uuid);
+    options.push({
+      uuid: reviewer.uuid,
+      name: reviewer.name?.trim() || "",
+      email: reviewer.email?.trim() || "",
+      github_login: reviewer.github_login?.trim() || "",
+      isMe: reviewer.uuid === currentUserUuid,
+    });
+  }
+
+  options.sort((first, second) => {
+    if (first.isMe && !second.isMe) return -1;
+    if (!first.isMe && second.isMe) return 1;
+    return (first.name || first.email).localeCompare(
+      second.name || second.email,
+    );
+  });
+
+  return options;
+}
+
+export function reviewerOptionLabel(reviewer: ReviewerOption): string {
+  const base = reviewer.name || reviewer.email || "Unknown user";
+  return reviewer.isMe ? `${base} (Me)` : base;
+}
+
+export function reviewerMatchesAvailable(
+  reviewer: SuggestedReviewer,
+  available: AvailableSuggestedReviewer,
+): boolean {
+  if (reviewer.user?.uuid && reviewer.user.uuid === available.uuid) {
+    return true;
+  }
+  return (
+    !!reviewer.github_login &&
+    !!available.github_login &&
+    reviewer.github_login.toLowerCase() === available.github_login.toLowerCase()
+  );
+}
+
+export function toSuggestedReviewerWriteContent(
+  reviewers: SuggestedReviewer[],
+): SuggestedReviewerWriteEntry[] {
+  return reviewers
+    .map((reviewer): SuggestedReviewerWriteEntry | null => {
+      if (reviewer.github_login) return { github_login: reviewer.github_login };
+      if (reviewer.user?.uuid) return { user_uuid: reviewer.user.uuid };
+      return null;
+    })
+    .filter((entry): entry is SuggestedReviewerWriteEntry => entry !== null);
+}
+
 const AVATAR_PALETTE = [
   "bg-(--orange-9) text-white",
   "bg-(--blue-9) text-white",
diff --git a/packages/core/src/inbox/reportFiltering.test.ts b/packages/core/src/inbox/reportFiltering.test.ts
index f2be318fac..3362ca5cde 100644
--- a/packages/core/src/inbox/reportFiltering.test.ts
+++ b/packages/core/src/inbox/reportFiltering.test.ts
@@ -6,8 +6,18 @@ import {
   buildSignalReportListOrdering,
   buildSuggestedReviewerFilterParam,
   filterReportsBySearch,
+  INBOX_PIPELINE_STATUS_FILTER,
+  INBOX_PIPELINE_STATUSES,
 } from "./reportFiltering";
 
+describe("inbox pipeline statuses", () => {
+  it("derives the API filter from the typed status list", () => {
+    expect(INBOX_PIPELINE_STATUS_FILTER).toBe(
+      INBOX_PIPELINE_STATUSES.join(","),
+    );
+  });
+});
+
 function makeReport(overrides: Partial<SignalReport> = {}): SignalReport {
   return {
     id: "1",
diff --git a/packages/core/src/inbox/reportFiltering.ts b/packages/core/src/inbox/reportFiltering.ts
index 06d36038b5..2a8271b2cb 100644
--- a/packages/core/src/inbox/reportFiltering.ts
+++ b/packages/core/src/inbox/reportFiltering.ts
@@ -5,12 +5,20 @@ import type {
   SignalReportStatus,
 } from "@posthog/shared/types";
 
+export const INBOX_PIPELINE_STATUSES = [
+  "ready",
+  "pending_input",
+  "in_progress",
+  "failed",
+  "candidate",
+  "potential",
+] as const satisfies readonly SignalReportStatus[];
+
 /**
  * Comma-separated statuses for the inbox query. We pull `failed` so the Runs
  * tab can surface failed runs in its Recently finished section.
  */
-export const INBOX_PIPELINE_STATUS_FILTER =
-  "potential,candidate,in_progress,ready,pending_input,failed";
+export const INBOX_PIPELINE_STATUS_FILTER = INBOX_PIPELINE_STATUSES.join(",");
 
 /**
  * Status filter for the Archive tab — the two terminal, not-in-inbox states:
diff --git a/packages/core/src/sessions/cloudSessionConfig.ts b/packages/core/src/sessions/cloudSessionConfig.ts
index ecb989b446..b6a9e4f8f4 100644
--- a/packages/core/src/sessions/cloudSessionConfig.ts
+++ b/packages/core/src/sessions/cloudSessionConfig.ts
@@ -1,6 +1,10 @@
 import type { SessionConfigOption } from "@agentclientprotocol/sdk";
 import type { Adapter, StoredLogEntry } from "@posthog/shared";
-import { getAvailableCodexModes, getAvailableModes } from "./executionModes";
+import {
+  DEFAULT_CLAUDE_EXECUTION_MODE,
+  getAvailableCodexModes,
+  getAvailableModes,
+} from "./executionModes";
 
 /**
  * Pure derivations of cloud session config options. No store or host access —
@@ -54,7 +58,8 @@ export function buildCloudDefaultConfigOptions(
 ): SessionConfigOption[] {
   const modes =
     adapter === "codex" ? getAvailableCodexModes() : getAvailableModes();
-  const fallbackMode = adapter === "codex" ? "auto" : "plan";
+  const fallbackMode =
+    adapter === "codex" ? "auto" : DEFAULT_CLAUDE_EXECUTION_MODE;
   const currentMode =
     typeof initialMode === "string" &&
     modes.some((mode) => mode.id === initialMode)
diff --git a/packages/core/src/sessions/executionModes.ts b/packages/core/src/sessions/executionModes.ts
index 4a32413c12..2ccbadf354 100644
--- a/packages/core/src/sessions/executionModes.ts
+++ b/packages/core/src/sessions/executionModes.ts
@@ -1,4 +1,4 @@
-import { CODEX_MODE_PRESETS } from "@posthog/shared";
+import { CODEX_MODE_PRESETS, type ExecutionMode } from "@posthog/shared";
 
 export interface ModeInfo {
   id: string;
@@ -6,6 +6,8 @@ export interface ModeInfo {
   description: string;
 }
 
+export const DEFAULT_CLAUDE_EXECUTION_MODE: ExecutionMode = "plan";
+
 const availableModes: ModeInfo[] = [
   {
     id: "default",
diff --git a/packages/core/src/sessions/portableSessionEvents.test.ts b/packages/core/src/sessions/portableSessionEvents.test.ts
new file mode 100644
index 0000000000..d777a0ec8b
--- /dev/null
+++ b/packages/core/src/sessions/portableSessionEvents.test.ts
@@ -0,0 +1,71 @@
+import type { StoredLogEntry } from "@posthog/shared";
+import { describe, expect, it, vi } from "vitest";
+import {
+  convertStoredEntriesToPortableSessionEvents,
+  inferStoredLogEntryDirection,
+} from "./portableSessionEvents";
+
+describe("inferStoredLogEntryDirection", () => {
+  it.each([
+    [
+      "client requests",
+      { notification: { id: 1, method: "session/prompt" } },
+      "client",
+    ],
+    ["agent responses", { notification: { id: 1, result: {} } }, "agent"],
+    [
+      "agent notifications",
+      { notification: { method: "session/update" } },
+      "agent",
+    ],
+    ["missing messages", {}, "agent"],
+  ] as const)("classifies %s", (_name, entry, expected) => {
+    expect(inferStoredLogEntryDirection(entry as StoredLogEntry)).toBe(
+      expected,
+    );
+  });
+});
+
+describe("convertStoredEntriesToPortableSessionEvents", () => {
+  it("projects session updates alongside their raw ACP message", () => {
+    const notification = {
+      update: {
+        sessionUpdate: "user_message_chunk",
+        content: { type: "text", text: "hello" },
+      },
+    };
+    const events = convertStoredEntriesToPortableSessionEvents([
+      {
+        type: "notification",
+        timestamp: "2026-07-21T12:00:00.000Z",
+        notification: { method: "session/update", params: notification },
+      },
+    ]);
+
+    expect(events).toEqual([
+      {
+        type: "acp_message",
+        direction: "agent",
+        ts: 1_784_635_200_000,
+        message: { method: "session/update", params: notification },
+      },
+      {
+        type: "session_update",
+        ts: 1_784_635_200_000,
+        notification,
+      },
+    ]);
+  });
+
+  it("uses the current time when an entry has no timestamp", () => {
+    vi.useFakeTimers();
+    vi.setSystemTime(new Date("2026-07-21T12:00:00.000Z"));
+
+    const events = convertStoredEntriesToPortableSessionEvents([
+      { type: "response", notification: { id: 1, result: {} } },
+    ]);
+
+    expect(events[0]?.ts).toBe(1_784_635_200_000);
+    vi.useRealTimers();
+  });
+});
diff --git a/packages/core/src/sessions/portableSessionEvents.ts b/packages/core/src/sessions/portableSessionEvents.ts
new file mode 100644
index 0000000000..5ee36c7642
--- /dev/null
+++ b/packages/core/src/sessions/portableSessionEvents.ts
@@ -0,0 +1,98 @@
+import type { JsonRpcMessage, StoredLogEntry } from "@posthog/shared";
+
+export type PortableSessionToolCallStatus =
+  | "pending"
+  | "in_progress"
+  | "completed"
+  | "failed"
+  | null;
+
+export interface PortableSessionUpdate {
+  sessionUpdate?: string;
+  content?: { type: string; text: string };
+  attachments?: Array<{
+    kind: "image" | "document";
+    uri: string;
+    fileName: string;
+    mimeType?: string;
+  }>;
+  title?: string;
+  toolCallId?: string;
+  status?: PortableSessionToolCallStatus;
+  rawInput?: Record<string, unknown>;
+  rawOutput?: unknown;
+  entries?: Array<{
+    content: string;
+    status: "pending" | "in_progress" | "completed" | "failed";
+    priority: string;
+  }>;
+  _meta?: {
+    claudeCode?: {
+      toolName?: string;
+      parentToolCallId?: string;
+    };
+  };
+}
+
+export interface PortableSessionNotification {
+  update?: PortableSessionUpdate;
+}
+
+export interface PortableSessionAcpMessage {
+  type: "acp_message";
+  direction: "client" | "agent";
+  ts: number;
+  message: JsonRpcMessage;
+}
+
+export interface PortableSessionUpdateEvent {
+  type: "session_update";
+  ts: number;
+  notification: PortableSessionNotification;
+}
+
+export type PortableSessionEvent =
+  | PortableSessionAcpMessage
+  | PortableSessionUpdateEvent;
+
+export function inferStoredLogEntryDirection(
+  entry: StoredLogEntry,
+): "client" | "agent" {
+  const message = entry.notification;
+  if (!message) return "agent";
+  if (message.id !== undefined && message.method !== undefined) return "client";
+  return "agent";
+}
+
+export function convertStoredEntriesToPortableSessionEvents(
+  entries: readonly StoredLogEntry[],
+): PortableSessionEvent[] {
+  const events: PortableSessionEvent[] = [];
+
+  for (const entry of entries) {
+    const ts = entry.timestamp
+      ? new Date(entry.timestamp).getTime()
+      : Date.now();
+
+    events.push({
+      type: "acp_message",
+      direction: inferStoredLogEntryDirection(entry),
+      ts,
+      message: (entry.notification ?? {}) as JsonRpcMessage,
+    });
+
+    if (
+      entry.type === "notification" &&
+      entry.notification?.method === "session/update" &&
+      entry.notification.params
+    ) {
+      events.push({
+        type: "session_update",
+        ts,
+        notification: entry.notification.params as PortableSessionNotification,
+      });
+    }
+  }
+
+  return events;
+}
diff --git a/packages/core/src/sessions/sessionActivity.test.ts b/packages/core/src/sessions/sessionActivity.test.ts
new file mode 100644
index 0000000000..db795f2118
--- /dev/null
+++ b/packages/core/src/sessions/sessionActivity.test.ts
@@ -0,0 +1,152 @@
+import { describe, expect, it } from "vitest";
+import type {
+  PortableSessionEvent,
+  PortableSessionToolCallStatus,
+} from "./portableSessionEvents";
+import {
+  countUserMessages,
+  getSessionActivityPhase,
+  isSessionAwaitingUserInput,
+} from "./sessionActivity";
+
+function userMessage(ts = 1): PortableSessionEvent {
+  return {
+    type: "session_update",
+    ts,
+    notification: {
+      update: {
+        sessionUpdate: "user_message_chunk",
+        content: { type: "text", text: "Yes" },
+      },
+    },
+  };
+}
+
+function questionToolCall(
+  status: PortableSessionToolCallStatus,
+  sessionUpdate = "tool_call",
+): PortableSessionEvent {
+  return {
+    type: "session_update",
+    ts: 1,
+    notification: {
+      update: {
+        sessionUpdate,
+        toolCallId: "question-1",
+        status,
+        rawInput: { questions: [{ question: "Proceed?", options: [] }] },
+        _meta: { claudeCode: { toolName: "AskUserQuestion" } },
+      },
+    },
+  };
+}
+
+function acpNotification(method: string): PortableSessionEvent {
+  return {
+    type: "acp_message",
+    direction: "agent",
+    ts: 1,
+    message: { method },
+  };
+}
+
+describe("isSessionAwaitingUserInput", () => {
+  it("tracks question tools until a metadata-free completion update", () => {
+    const completion: PortableSessionEvent = {
+      type: "session_update",
+      ts: 2,
+      notification: {
+        update: {
+          sessionUpdate: "tool_call_update",
+          toolCallId: "question-1",
+          status: "completed",
+        },
+      },
+    };
+
+    expect(
+      isSessionAwaitingUserInput([questionToolCall("pending"), completion]),
+    ).toBe(false);
+  });
+
+  it("clears questions when the user responds", () => {
+    expect(
+      isSessionAwaitingUserInput([questionToolCall("pending"), userMessage(2)]),
+    ).toBe(false);
+  });
+
+  it("honors explicit waiting and terminal backend markers", () => {
+    expect(
+      isSessionAwaitingUserInput([
+        acpNotification("_posthog/awaiting_user_input"),
+      ]),
+    ).toBe(true);
+    expect(
+      isSessionAwaitingUserInput([
+        acpNotification("_posthog/awaiting_user_input"),
+        acpNotification("_posthog/turn_complete"),
+      ]),
+    ).toBe(false);
+  });
+});
+
+describe("countUserMessages", () => {
+  it("counts only projected user message updates", () => {
+    expect(
+      countUserMessages([
+        userMessage(),
+        questionToolCall("pending"),
+        userMessage(2),
+      ]),
+    ).toBe(2);
+  });
+});
+
+describe("getSessionActivityPhase", () => {
+  it.each([
+    ["retrying", true, undefined, "connecting"],
+    [
+      "awaiting agent output",
+      false,
+      { isPromptPending: true, awaitingAgentOutput: true },
+      "connecting",
+    ],
+    [
+      "working",
+      false,
+      { isPromptPending: true, awaitingAgentOutput: false },
+      "working",
+    ],
+    [
+      "not pending",
+      false,
+      { isPromptPending: false, awaitingAgentOutput: false },
+      "idle",
+    ],
+    [
+      "terminal",
+      false,
+      {
+        isPromptPending: true,
+        awaitingAgentOutput: false,
+        terminalStatus: "completed" as const,
+      },
+      "idle",
+    ],
+    [
+      "waiting for user",
+      false,
+      {
+        isPromptPending: true,
+        awaitingAgentOutput: false,
+        events: [questionToolCall("pending")],
+      },
+      "idle",
+    ],
+  ] as const)(
+    "returns the expected phase while %s",
+    (_name, retrying, session, expected) => {
+      expect(getSessionActivityPhase({ retrying, session })).toBe(expected);
+    },
+  );
+});
diff --git a/packages/core/src/sessions/sessionActivity.ts b/packages/core/src/sessions/sessionActivity.ts
new file mode 100644
index 0000000000..6e2804ff47
--- /dev/null
+++ b/packages/core/src/sessions/sessionActivity.ts
@@ -0,0 +1,129 @@
+import { isNotification, POSTHOG_NOTIFICATIONS } from "./acpNotifications";
+import type {
+  PortableSessionEvent,
+  PortableSessionNotification,
+  PortableSessionToolCallStatus,
+} from "./portableSessionEvents";
+
+export type SessionActivityPhase = "idle" | "connecting" | "working";
+
+export interface SessionActivityState {
+  isPromptPending?: boolean;
+  awaitingAgentOutput?: boolean;
+  terminalStatus?: "failed" | "completed";
+  events?: readonly PortableSessionEvent[];
+}
+
+function isQuestionNotification(
+  notification: PortableSessionNotification,
+): boolean {
+  const update = notification.update;
+  if (!update) return false;
+
+  const rawToolName = update._meta?.claudeCode?.toolName;
+  if (typeof rawToolName === "string" && /question/i.test(rawToolName)) {
+    return true;
+  }
+
+  const rawInput = update.rawInput;
+  if (!rawInput) return false;
+  if (Array.isArray(rawInput.questions)) return true;
+
+  const nestedInput = rawInput.input;
+  return (
+    typeof nestedInput === "object" &&
+    nestedInput !== null &&
+    Array.isArray((nestedInput as { questions?: unknown }).questions)
+  );
+}
+
+function isPendingQuestionStatus(
+  status: PortableSessionToolCallStatus | undefined,
+): boolean {
+  return status === null || status === "pending" || status === "in_progress";
+}
+
+export function isSessionAwaitingUserInput(
+  events: readonly PortableSessionEvent[] = [],
+): boolean {
+  let awaitingUserInput = false;
+  const questionStatuses = new Map<
+    string,
+    PortableSessionToolCallStatus | undefined
+  >();
+
+  for (const event of events) {
+    if (event.type === "session_update") {
+      const update = event.notification.update;
+      const sessionUpdate = update?.sessionUpdate;
+
+      if (sessionUpdate === "user_message_chunk") {
+        awaitingUserInput = false;
+        questionStatuses.clear();
+        continue;
+      }
+
+      if (
+        sessionUpdate === "tool_call" ||
+        sessionUpdate === "tool_call_update"
+      ) {
+        const toolCallId = update?.toolCallId;
+        const isKnownQuestion = toolCallId
+          ? questionStatuses.has(toolCallId)
+          : false;
+        if (!isKnownQuestion && !isQuestionNotification(event.notification)) {
+          continue;
+        }
+
+        questionStatuses.set(
+          toolCallId ?? `question-${event.ts}`,
+          update?.status,
+        );
+        awaitingUserInput = [...questionStatuses.values()].some(
+          isPendingQuestionStatus,
+        );
+      }
+
+      continue;
+    }
+
+    const method = "method" in event.message ? event.message.method : undefined;
+    if (method === "_posthog/awaiting_user_input") {
+      awaitingUserInput = true;
+      continue;
+    }
+
+    if (
+      isNotification(method, POSTHOG_NOTIFICATIONS.TURN_COMPLETE) ||
+      isNotification(method, POSTHOG_NOTIFICATIONS.TASK_COMPLETE) ||
+      isNotification(method, POSTHOG_NOTIFICATIONS.ERROR)
+    ) {
+      awaitingUserInput = false;
+      questionStatuses.clear();
+    }
+  }
+
+  return awaitingUserInput;
+}
+
+export function countUserMessages(
+  events: readonly PortableSessionEvent[] = [],
+): number {
+  return events.filter(
+    (event) =>
+      event.type === "session_update" &&
+      event.notification.update?.sessionUpdate === "user_message_chunk",
+  ).length;
+}
+
+export function getSessionActivityPhase(args: {
+  retrying: boolean;
+  session?: SessionActivityState | null;
+}): SessionActivityPhase {
+  const { retrying, session } = args;
+
+  if (retrying) return "connecting";
+  if (!session?.isPromptPending || session.terminalStatus) return "idle";
+  if (isSessionAwaitingUserInput(session.events)) return "idle";
+  return session.awaitingAgentOutput ? "connecting" : "working";
+}
diff --git a/packages/core/src/tasks/taskActivity.test.ts b/packages/core/src/tasks/taskActivity.test.ts
new file mode 100644
index 0000000000..35d1eadaff
--- /dev/null
+++ b/packages/core/src/tasks/taskActivity.test.ts
@@ -0,0 +1,132 @@
+import type { Task } from "@posthog/shared/domain-types";
+import { describe, expect, it } from "vitest";
+import { filterAndSortTasks, taskActivityTimestamp } from "./taskActivity";
+
+function makeTask(overrides: Partial<Task> = {}): Task {
+  return {
+    id: "task-1",
+    task_number: 1,
+    slug: "task-1",
+    title: "A real task",
+    description: "Do the thing",
+    created_at: "2026-01-01T00:00:00Z",
+    updated_at: "2026-01-02T00:00:00Z",
+    origin_product: "tasks",
+    ...overrides,
+  };
+}
+
+describe("taskActivityTimestamp", () => {
+  it("uses creation time in created mode", () => {
+    const task = makeTask({
+      created_at: "2026-01-01T00:00:00Z",
+      updated_at: "2026-01-03T00:00:00Z",
+    });
+
+    expect(taskActivityTimestamp(task, "created")).toBe(
+      new Date("2026-01-01T00:00:00Z").getTime(),
+    );
+  });
+
+  it("uses the latest task or run update in updated mode", () => {
+    const task = makeTask({
+      updated_at: "2026-01-02T00:00:00Z",
+      latest_run: {
+        id: "run-1",
+        task: "task-1",
+        team: 1,
+        branch: null,
+        status: "completed",
+        log_url: "",
+        error_message: null,
+        output: null,
+        state: {},
+        created_at: "2026-01-01T00:00:00Z",
+        updated_at: "2026-01-04T00:00:00Z",
+        completed_at: "2026-01-04T00:00:00Z",
+      },
+    });
+
+    expect(taskActivityTimestamp(task, "updated")).toBe(
+      new Date("2026-01-04T00:00:00Z").getTime(),
+    );
+  });
+});
+
+describe("filterAndSortTasks", () => {
+  it.each([
+    { title: "", description: "" },
+    { title: "   ", description: "\n\t" },
+  ])("hides contentless placeholder tasks", ({ title, description }) => {
+    const placeholder = makeTask({ id: "placeholder", title, description });
+    const realTask = makeTask({ id: "real" });
+
+    expect(
+      filterAndSortTasks([placeholder, realTask], "updated", false, "").map(
+        (task) => task.id,
+      ),
+    ).toEqual(["real"]);
+  });
+
+  it("selects internal or external tasks", () => {
+    const externalTask = makeTask({ id: "external", internal: false });
+    const internalTask = makeTask({ id: "internal", internal: true });
+
+    expect(
+      filterAndSortTasks(
+        [externalTask, internalTask],
+        "updated",
+        false,
+        "",
+      ).map((task) => task.id),
+    ).toEqual(["external"]);
+    expect(
+      filterAndSortTasks([externalTask, internalTask], "updated", true, "").map(
+        (task) => task.id,
+      ),
+    ).toEqual(["internal"]);
+  });
+
+  it.each([
+    ["title", { title: "Fix Login" }],
+    ["slug", { slug: "fix-login" }],
+    ["description", { description: "Fix Login" }],
+  ] as const)("matches a case-insensitive %s filter", (_field, overrides) => {
+    const matchingTask = makeTask({ id: "matching", ...overrides });
+    const otherTask = makeTask({ id: "other", title: "Unrelated" });
+
+    expect(
+      filterAndSortTasks(
+        [otherTask, matchingTask],
+        "updated",
+        false,
+        "LOGIN",
+      ).map((task) => task.id),
+    ).toEqual(["matching"]);
+  });
+
+  it("sorts by the selected activity timestamp without mutating input", () => {
+    const olderCreated = makeTask({
+      id: "older-created",
+      created_at: "2026-01-01T00:00:00Z",
+      updated_at: "2026-01-04T00:00:00Z",
+    });
+    const newerCreated = makeTask({
+      id: "newer-created",
+      created_at: "2026-01-02T00:00:00Z",
+      updated_at: "2026-01-03T00:00:00Z",
+    });
+    const tasks = [olderCreated, newerCreated];
+
+    expect(
+      filterAndSortTasks(tasks, "created", false, "").map((task) => task.id),
+    ).toEqual(["newer-created", "older-created"]);
+    expect(
+      filterAndSortTasks(tasks, "updated", false, "").map((task) => task.id),
+    ).toEqual(["older-created", "newer-created"]);
+    expect(tasks.map((task) => task.id)).toEqual([
+      "older-created",
+      "newer-created",
+    ]);
+  });
+});
diff --git a/packages/core/src/tasks/taskActivity.ts b/packages/core/src/tasks/taskActivity.ts
new file mode 100644
index 0000000000..6a52168e63
--- /dev/null
+++ b/packages/core/src/tasks/taskActivity.ts
@@ -0,0 +1,45 @@
+import { isContentlessTask, type Task } from "@posthog/shared/domain-types";
+
+export type TaskActivitySortMode = "created" | "updated";
+
+export function taskActivityTimestamp(
+  task: Pick<Task, "created_at" | "updated_at" | "latest_run">,
+  sortMode: TaskActivitySortMode,
+): number {
+  if (sortMode === "created") {
+    return new Date(task.created_at).getTime();
+  }
+
+  const runUpdatedAt = task.latest_run?.updated_at;
+  return Math.max(
+    runUpdatedAt ? new Date(runUpdatedAt).getTime() : 0,
+    new Date(task.updated_at ?? task.created_at).getTime(),
+  );
+}
+
+export function filterAndSortTasks(
+  tasks: readonly Task[],
+  sortMode: TaskActivitySortMode,
+  showInternal: boolean,
+  filter: string,
+): Task[] {
+  const normalizedFilter = filter.toLowerCase();
+
+  return tasks
+    .filter((task) => !isContentlessTask(task))
+    .filter((task) =>
+      showInternal ? task.internal === true : task.internal !== true,
+    )
+    .filter(
+      (task) =>
+        !normalizedFilter ||
+        task.title.toLowerCase().includes(normalizedFilter) ||
+        task.slug.toLowerCase().includes(normalizedFilter) ||
+        task.description?.toLowerCase().includes(normalizedFilter),
+    )
+    .sort(
+      (firstTask, secondTask) =>
+        taskActivityTimestamp(secondTask, sortMode) -
+        taskActivityTimestamp(firstTask, sortMode),
+    );
+}
diff --git a/packages/core/src/tasks/taskArchive.test.ts b/packages/core/src/tasks/taskArchive.test.ts
new file mode 100644
index 0000000000..ab22bbd459
--- /dev/null
+++ b/packages/core/src/tasks/taskArchive.test.ts
@@ -0,0 +1,44 @@
+import type { Task, TaskRunStatus } from "@posthog/shared/domain-types";
+import { describe, expect, it } from "vitest";
+import { isTaskRunning } from "./taskArchive";
+
+function makeTask(status?: TaskRunStatus): Pick<Task, "latest_run"> {
+  return {
+    latest_run: status
+      ? {
+          id: "run-1",
+          task: "task-1",
+          team: 1,
+          branch: null,
+          status,
+          log_url: "",
+          error_message: null,
+          output: null,
+          state: {},
+          created_at: "2026-01-01T00:00:00Z",
+          updated_at: "2026-01-01T00:00:00Z",
+          completed_at: null,
+        }
+      : undefined,
+  };
+}
+
+describe("isTaskRunning", () => {
+  it("returns false when a task has no run", () => {
+    expect(isTaskRunning(makeTask())).toBe(false);
+  });
+
+  it.each(["not_started", "queued", "in_progress"] as const)(
+    "returns true for %s",
+    (status) => {
+      expect(isTaskRunning(makeTask(status))).toBe(true);
+    },
+  );
+
+  it.each(["completed", "failed", "cancelled"] as const)(
+    "returns false for %s",
+    (status) => {
+      expect(isTaskRunning(makeTask(status))).toBe(false);
+    },
+  );
+});
diff --git a/packages/core/src/tasks/taskArchive.ts b/packages/core/src/tasks/taskArchive.ts
new file mode 100644
index 0000000000..db52bb6310
--- /dev/null
+++ b/packages/core/src/tasks/taskArchive.ts
@@ -0,0 +1,6 @@
+import { isTerminalStatus, type Task } from "@posthog/shared/domain-types";
+
+export function isTaskRunning(task: Pick<Task, "latest_run">): boolean {
+  const status = task.latest_run?.status;
+  return status !== undefined && !isTerminalStatus(status);
+}
diff --git a/packages/core/src/tasks/taskStatusPresentation.test.ts b/packages/core/src/tasks/taskStatusPresentation.test.ts
new file mode 100644
index 0000000000..a7895cf59e
--- /dev/null
+++ b/packages/core/src/tasks/taskStatusPresentation.test.ts
@@ -0,0 +1,69 @@
+import type { Task, TaskRun } from "@posthog/shared/domain-types";
+import { describe, expect, it } from "vitest";
+import { getTaskStatusPresentationKind } from "./taskStatusPresentation";
+
+function makeTask(latestRun?: Partial<TaskRun>): Pick<Task, "latest_run"> {
+  return {
+    latest_run: latestRun
+      ? {
+          id: "run-1",
+          task: "task-1",
+          team: 1,
+          branch: null,
+          status: "not_started",
+          log_url: "",
+          error_message: null,
+          output: null,
+          state: {},
+          created_at: "2026-01-01T00:00:00Z",
+          updated_at: "2026-01-01T00:00:00Z",
+          completed_at: null,
+          ...latestRun,
+        }
+      : undefined,
+  };
+}
+
+describe("getTaskStatusPresentationKind", () => {
+  it("prioritizes a pull request over cloud presentation", () => {
+    expect(
+      getTaskStatusPresentationKind(
+        makeTask({
+          environment: "cloud",
+          status: "in_progress",
+          output: { pr_url: "https://github.com/PostHog/code/pull/123" },
+        }),
+      ),
+    ).toBe("pr");
+  });
+
+  it.each([
+    "not_started",
+    "queued",
+    "in_progress",
+    "completed",
+    "failed",
+    "cancelled",
+  ] as const)("uses chat presentation for cloud status %s", (status) => {
+    expect(
+      getTaskStatusPresentationKind(makeTask({ environment: "cloud", status })),
+    ).toBe("chat");
+  });
+
+  it.each([
+    ["completed", "completed"],
+    ["failed", "failed"],
+    ["in_progress", "running"],
+    ["queued", "started"],
+    ["not_started", "chat"],
+    ["cancelled", "chat"],
+  ] as const)("maps local status %s to %s", (status, expected) => {
+    expect(
+      getTaskStatusPresentationKind(makeTask({ environment: "local", status })),
+    ).toBe(expected);
+  });
+
+  it("falls back to chat when a task has no run", () => {
+    expect(getTaskStatusPresentationKind(makeTask())).toBe("chat");
+  });
+});
diff --git a/packages/core/src/tasks/taskStatusPresentation.ts b/packages/core/src/tasks/taskStatusPresentation.ts
new file mode 100644
index 0000000000..968a17bb76
--- /dev/null
+++ b/packages/core/src/tasks/taskStatusPresentation.ts
@@ -0,0 +1,37 @@
+import { readPrUrls } from "@posthog/shared";
+import type { Task } from "@posthog/shared/domain-types";
+
+export type TaskStatusPresentationKind =
+  | "pr"
+  | "completed"
+  | "failed"
+  | "running"
+  | "started"
+  | "chat";
+
+export function getTaskStatusPresentationKind(
+  task: Pick<Task, "latest_run">,
+): TaskStatusPresentationKind {
+  const latestRun = task.latest_run;
+
+  if (readPrUrls(latestRun?.output)[0]) {
+    return "pr";
+  }
+
+  if (latestRun?.environment === "cloud") {
+    return "chat";
+  }
+
+  switch (latestRun?.status) {
+    case "completed":
+      return "completed";
+    case "failed":
+      return "failed";
+    case "in_progress":
+      return "running";
+    case "queued":
+      return "started";
+    default:
+      return "chat";
+  }
+}