diff --git a/src/controllers/episodes/getEpisodeUrl/index.ts b/src/controllers/episodes/getEpisodeUrl/index.ts index f80b43c..2560d83 100644 --- a/src/controllers/episodes/getEpisodeUrl/index.ts +++ b/src/controllers/episodes/getEpisodeUrl/index.ts @@ -183,8 +183,10 @@ app.openapi(route, async (c) => { const isAnifyEnabled = readEnvVariable(c.env, "ENABLE_ANIFY"); let result: FetchUrlResponse | null; if (provider) { + console.log(`Fetching sources from ${provider} for ${aniListId}`); result = await fetchEpisodeUrl(provider, id, aniListId, isAnifyEnabled); } else { + console.log(`Fetching sources from all providers for ${aniListId}`); const { fetchUrlResult } = await fetchEpisodeUrlFromAllProviders( aniListId, episodeNumber!, diff --git a/src/libs/maybeScheduleNextAiringEpisode.ts b/src/libs/maybeScheduleNextAiringEpisode.ts index 1c311c8..59b2239 100644 --- a/src/libs/maybeScheduleNextAiringEpisode.ts +++ b/src/libs/maybeScheduleNextAiringEpisode.ts @@ -43,7 +43,7 @@ export async function maybeScheduleNextAiringEpisode( const { messageId } = await client.publishJSON({ url: `${domain}/internal/new-episode`, body: { aniListId, episodeNumber: nextEpisode }, - retries: 6, + retries: 3, notBefore: airingAt, }); await Promise.allSettled([ diff --git a/src/scripts/initializeNextEpisodeQueue.ts b/src/scripts/initializeNextEpisodeQueue.ts index 94751b4..0fdd177 100644 --- a/src/scripts/initializeNextEpisodeQueue.ts +++ b/src/scripts/initializeNextEpisodeQueue.ts @@ -92,7 +92,7 @@ async function triggerNextEpisodeRoute(titleId: number) { aniListId: titleId, episodeNumber: mostRecentEpisodeNumber, }, - retries: 6, + retries: 3, }) .then(() => true) .catch((error) => { @@ -124,7 +124,7 @@ async function triggerNextEpisodeRoute(titleId: number) { aniListId: titleId, episodeNumber: title.nextAiringEpisode.episode, }, - retries: 6, + retries: 3, notBefore: title.nextAiringEpisode.airingAt, }) .then(() => true)