(fetch_days: int)
| 1261 | return papers |
| 1262 | |
| 1263 | def fetch_journal_papers(fetch_days: int) -> List[Dict]: |
| 1264 | if not journals: |
| 1265 | print("Skipping journal fetch: no journals selected") |
| 1266 | return [] |
| 1267 | print(f"Fetching from journals ({journals}) in the last {fetch_days} days...") |
| 1268 | papers = journal_fetch_recent( |
| 1269 | journals=journals, |
| 1270 | days=fetch_days, |
| 1271 | limit_per_journal=limit_per_source |
| 1272 | ) or [] |
| 1273 | for paper in papers: |
| 1274 | paper["source"] = "journal" |
| 1275 | print(f" Fetched {len(papers)} papers from journals") |
| 1276 | emit({"phase": "source_complete", "source": "journal", "count": len(papers)}) |
| 1277 | emit_fetched("journal", papers) |
| 1278 | return papers |
| 1279 | |
| 1280 | def fetch_cached_arxiv_papers() -> List[Dict]: |
| 1281 | if not arxiv_categories: |
no test coverage detected