(fetch_days: int)
| 1242 | return papers |
| 1243 | |
| 1244 | def fetch_openreview_papers(fetch_days: int) -> List[Dict]: |
| 1245 | if not conferences: |
| 1246 | print("Skipping OpenReview fetch: no conferences selected") |
| 1247 | return [] |
| 1248 | start_date = (today - timedelta(days=max(1, int(fetch_days or 1)) - 1)).strftime("%Y%m%d") |
| 1249 | print(f"Fetching from OpenReview (conferences: {conferences})...") |
| 1250 | papers = openreview_fetch_by_date( |
| 1251 | start_date=start_date, |
| 1252 | end_date=end_date, |
| 1253 | conferences=conferences, |
| 1254 | limit=limit_per_source |
| 1255 | ) or [] |
| 1256 | for paper in papers: |
| 1257 | paper["source"] = "openreview" |
| 1258 | print(f" Fetched {len(papers)} papers from OpenReview") |
| 1259 | emit({"phase": "source_complete", "source": "openreview", "count": len(papers)}) |
| 1260 | emit_fetched("openreview", papers) |
| 1261 | return papers |
| 1262 | |
| 1263 | def fetch_journal_papers(fetch_days: int) -> List[Dict]: |
| 1264 | if not journals: |
no test coverage detected