diff --git a/integrations/jikan/relations.go b/integrations/jikan/relations.go index d1e10e6..f5caed2 100644 --- a/integrations/jikan/relations.go +++ b/integrations/jikan/relations.go @@ -237,6 +237,16 @@ func (c *Client) fetchRelationResults(ctx context.Context, entries []watchorder. if errors.Is(err, context.Canceled) || errors.Is(err, context.DeadlineExceeded) { 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) return nil } @@ -260,6 +270,20 @@ func (c *Client) fetchRelationResults(ctx context.Context, entries []watchorder. 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 { return fetched[i].index < fetched[j].index })