melosh/mal
1
0
Fork 0
Code Issues Pull Requests Actions Packages Projects Releases Wiki Activity

refactor: streamline relation sync worker

Browse Source
This commit is contained in:
mkelvers
2026-04-14 22:23:17 +02:00
parent 165963c9d2
commit ec9f93fa98
1 changed files with 6 additions and 20 deletions
Download Patch File Download Diff File Expand all files Collapse all files

16
internal/worker/relations.go
View File

@@ -81,16 +81,6 @@ func retryBackoff(attempts int64) string {
} }
func (w *Worker) processAnimeFetchRetries(ctx context.Context) { func (w *Worker) processAnimeFetchRetries(ctx context.Context) {
pending, err := w.db.CountPendingAnimeFetchRetries(ctx)
if err != nil {
log.Printf("worker: failed to count pending anime fetch retries: %v", err)
return
}
if pending == 0 {
return
}
retries, err := w.db.GetDueAnimeFetchRetries(ctx, 20) retries, err := w.db.GetDueAnimeFetchRetries(ctx, 20)
if err != nil { if err != nil {
log.Printf("worker: failed to load due anime fetch retries: %v", err) log.Printf("worker: failed to load due anime fetch retries: %v", err)
@@ -190,17 +180,13 @@ func (w *Worker) syncRelations(ctx context.Context) {
} }
} }
// Also update the status of the anime itself so we know if it's Not yet aired, etc.
animeDetails, err := w.client.GetAnimeByID(ctx, int(a.ID))
if err == nil {
err = w.db.UpdateAnimeStatus(ctx, database.UpdateAnimeStatusParams{ err = w.db.UpdateAnimeStatus(ctx, database.UpdateAnimeStatusParams{
Status: sql.NullString{String: animeDetails.Status, Valid: true}, Status: sql.NullString{String: animeData.Status, Valid: true},
ID: a.ID, ID: a.ID,
}) })
if err != nil { if err != nil {
log.Printf("worker: failed to update status for %d: %v", a.ID, err) log.Printf("worker: failed to update status for %d: %v", a.ID, err)
} }
}
}() }()
} }
} }