fix: log silent gaps in fetchRelationResults
This commit is contained in:
@@ -237,6 +237,16 @@ func (c *Client) fetchRelationResults(ctx context.Context, entries []watchorder.
|
|||||||
if errors.Is(err, context.Canceled) || errors.Is(err, context.DeadlineExceeded) {
|
if errors.Is(err, context.Canceled) || errors.Is(err, context.DeadlineExceeded) {
|
||||||
return nil
|
return nil
|
||||||
}
|
}
|
||||||
|
observability.Warn(
|
||||||
|
"relations_fetch_entry_failed",
|
||||||
|
"jikan",
|
||||||
|
"",
|
||||||
|
map[string]any{
|
||||||
|
"anime_id": entry.ID,
|
||||||
|
"index": i,
|
||||||
|
},
|
||||||
|
err,
|
||||||
|
)
|
||||||
c.EnqueueAnimeFetchRetry(gCtx, entry.ID, err)
|
c.EnqueueAnimeFetchRetry(gCtx, entry.ID, err)
|
||||||
return nil
|
return nil
|
||||||
}
|
}
|
||||||
@@ -260,6 +270,20 @@ func (c *Client) fetchRelationResults(ctx context.Context, entries []watchorder.
|
|||||||
fetched = append(fetched, res)
|
fetched = append(fetched, res)
|
||||||
}
|
}
|
||||||
|
|
||||||
|
if len(fetched) < len(entries) {
|
||||||
|
observability.Warn(
|
||||||
|
"relations_fetch_incomplete",
|
||||||
|
"jikan",
|
||||||
|
"",
|
||||||
|
map[string]any{
|
||||||
|
"expected": len(entries),
|
||||||
|
"fetched": len(fetched),
|
||||||
|
"missing": len(entries) - len(fetched),
|
||||||
|
},
|
||||||
|
nil,
|
||||||
|
)
|
||||||
|
}
|
||||||
|
|
||||||
sort.Slice(fetched, func(i, j int) bool {
|
sort.Slice(fetched, func(i, j int) bool {
|
||||||
return fetched[i].index < fetched[j].index
|
return fetched[i].index < fetched[j].index
|
||||||
})
|
})
|
||||||
|
|||||||
Reference in New Issue
Block a user