julienfroidefond/stripstream-librarian
1
0
Fork 0
Code Issues 5 Pull Requests Actions Packages Projects 1 Releases Wiki Activity

fix: retry once after 10s on AniList 429 before aborting job

Browse Source 
On rate limit, wait 10 seconds and retry the same series. If the retry
also returns 429, the job stops. Otherwise it continues normally.

Co-Authored-By: Claude Sonnet 4.6 <noreply@anthropic.com>
This commit is contained in:
Julien Froidefond
2026-03-25 09:08:27 +01:00
parent 31538fac24
commit 9eea43ce99
1 changed files with 20 additions and 5 deletions
Download Patch File Download Diff File Expand all files Collapse all files

21
apps/api/src/reading_status_match.rs
View File

@@ -368,12 +368,27 @@ pub(crate) async fn process_reading_status_match(
Ok(Outcome::Ambiguous) => {
insert_result(pool, job_id, library_id, series_name, "ambiguous", None, None, None, None).await;
}
Err(e) => {
if e.contains("429") || e.contains("Too Many Requests") {
Err(e) if e.contains("429") || e.contains("Too Many Requests") => {
warn!("[READING_STATUS_MATCH] rate limit hit for '{series_name}', waiting 10s before retry");
tokio::time::sleep(Duration::from_secs(10)).await;
match search_and_link(pool, library_id, series_name, &token).await {
Ok(Outcome::Linked { anilist_id, anilist_title, anilist_url }) => {
insert_result(pool, job_id, library_id, series_name, "linked", Some(anilist_id), anilist_title.as_deref(), anilist_url.as_deref(), None).await;
}
Ok(Outcome::NoResults) => {
insert_result(pool, job_id, library_id, series_name, "no_results", None, None, None, None).await;
}
Ok(Outcome::Ambiguous) => {
insert_result(pool, job_id, library_id, series_name, "ambiguous", None, None, None, None).await;
}
Err(e2) => {
return Err(format!(
"AniList rate limit exceeded (429) — job stopped after {processed}/{total} series"
"AniList rate limit exceeded (429) — job stopped after {processed}/{total} series: {e2}"
));
}
}
}
Err(e) => {
warn!("[READING_STATUS_MATCH] series '{series_name}': {e}");
insert_result(pool, job_id, library_id, series_name, "error", None, None, None, Some(&e)).await;
}