| 210 | ) |
| 211 | |
| 212 | class FakeRows: |
| 213 | def fetchall(self): |
| 214 | return [ |
| 215 | { |
| 216 | "src_id": "paper:1", |
| 217 | "dst_id": "topic:rag", |
| 218 | "relation": "same_topic", |
| 219 | "weight": 0.9, |
| 220 | "metadata_json": '{"reason": "keyword"}', |
| 221 | "created_at": "2026-06-01", |
| 222 | }, |
| 223 | { |
| 224 | "src_id": "user:user_test", |
| 225 | "dst_id": "paper:1", |
| 226 | "relation": "interested_in", |
| 227 | "weight": 1.0, |
| 228 | "metadata_json": "{}", |
| 229 | "created_at": "2026-06-01", |
| 230 | }, |
| 231 | ] |
| 232 | |
| 233 | class FakeConnection: |
| 234 | def execute(self, *_args, **_kwargs): |