ivanch/recommender
1
0
Fork 0
Code Issues Pull Requests Actions Packages Projects Releases Wiki Activity

fixes!
All checks were successful
Recommender Build and Deploy (internal) / Build Recommender Image (push) Successful in 4m6s
Details
Recommender Build and Deploy (internal) / Deploy Recommender (internal) (push) Successful in 30s
Details

Browse Source
This commit is contained in:
Jose Henrique
2026-04-03 11:48:17 -03:00
parent 0944ec62bb
commit 910d26add3
2 changed files with 8 additions and 6 deletions
Download Patch File Download Diff File Expand all files Collapse all files

13
packages/backend/src/pipelines/recommendation.ts
View File

@@ -121,12 +121,13 @@ async function runSubPipeline(ctx: SubPipelineCtx): Promise<CuratorOutput[]> {
runRanking(interpreterOutput, { candidates: bucket }, mediaType, useHardRequirements)
)
);
const dedupTitles = (titles: string[]) => [...new Map(titles.map((t) => [t.toLowerCase(), t])).values()];
const rankingOutput: RankingOutput = {
full_match: rankingBuckets.flatMap((r) => r.full_match),
definitely_like: rankingBuckets.flatMap((r) => r.definitely_like),
might_like: rankingBuckets.flatMap((r) => r.might_like),
questionable: rankingBuckets.flatMap((r) => r.questionable),
will_not_like: rankingBuckets.flatMap((r) => r.will_not_like),
full_match: dedupTitles(rankingBuckets.flatMap((r) => r.full_match)),
definitely_like: dedupTitles(rankingBuckets.flatMap((r) => r.definitely_like)),
might_like: dedupTitles(rankingBuckets.flatMap((r) => r.might_like)),
questionable: dedupTitles(rankingBuckets.flatMap((r) => r.questionable)),
will_not_like: dedupTitles(rankingBuckets.flatMap((r) => r.will_not_like)),
};
log(recId, `${stagePrefix}Ranking: done (${Date.now() - t2}ms) — ${rankBucketCount} buckets`, {
full_match: rankingOutput.full_match.length,
@@ -163,7 +164,7 @@ async function runSubPipeline(ctx: SubPipelineCtx): Promise<CuratorOutput[]> {
runCurator(ranking, interpreterOutput, mediaType, useWebSearch)
)
);
const curatorOutput = curatorBucketOutputs.flat();
const curatorOutput = curatorBucketOutputs.reduce((acc, bucket) => mergeCuratorOutputs(acc, bucket), [] as CuratorOutput[]);
log(recId, `${stagePrefix}Curator: done (${Date.now() - t3}ms) — ${curatorOutput.length} items curated (${curatorBucketCount} buckets)`);
sseWrite({ stage: p('curator'), status: 'done', data: curatorOutput });