diff --git a/diagnostics/activity_feed_api.py b/diagnostics/activity_feed_api.py
index a21beb6..a33a17c 100644
--- a/diagnostics/activity_feed_api.py
+++ b/diagnostics/activity_feed_api.py
@@ -83,7 +83,8 @@ def _build_events():
     try:
         rows = conn.execute("""
             SELECT p.number, p.branch, p.domain, p.agent, p.submitted_by,
-                   p.merged_at, p.description, p.commit_type, p.cost_usd
+                   p.merged_at, p.description, p.commit_type, p.cost_usd,
+                   p.source_channel
             FROM prs p
             WHERE p.status = 'merged'
               AND p.commit_type = 'knowledge'
@@ -139,6 +140,7 @@ def _build_events():
                     "ci_earned": round(ci_earned, 2),
                     "summary": summary_text,
                     "pr_number": row["number"],
+                    "source_channel": row["source_channel"] or "unknown",
                 })
 
         return events, claim_activity