apunkt/rowboat
1
0
Fork 0
mirror of https://github.com/rowboatlabs/rowboat.git synced 2026-06-06 19:35:44 +02:00
Code Issues Projects Releases Packages Wiki Activity Actions

fix rag worker queries

Browse source
This commit is contained in:
Ramnique Singh 2025-05-07 11:43:13 +05:30 • committed by akhisud3195
parent 070dfa7a9b
commit bdc7f01ea2
3 changed files with 3 additions and 0 deletions
Download patch file Download diff file Expand all files Collapse all files

1
apps/rowboat/app/scripts/rag_files_worker.ts
View file

@ -216,6 +216,7 @@ async function runDeletionPipeline(_logger: PrefixLogger, job: WithId<z.infer<ty
// first try to find a job that needs deleting
job = await dataSourcesCollection.findOneAndUpdate({
status: "deleted",
"data.type": { $in: ["files_local", "files_s3"] },
$or: [
{ attempts: { $exists: false } },
{ attempts: { $lte: 3 } }

1
apps/rowboat/app/scripts/rag_text_worker.ts
View file

@ -118,6 +118,7 @@ async function runDeletionPipeline(_logger: PrefixLogger, job: WithId<z.infer<ty
// first try to find a job that needs deleting
job = await dataSourcesCollection.findOneAndUpdate({
status: "deleted",
"data.type": "text",
$or: [
{ attempts: { $exists: false } },
{ attempts: { $lte: 3 } }

1
apps/rowboat/app/scripts/rag_urls_worker.ts
View file

@ -149,6 +149,7 @@ async function runDeletionPipeline(_logger: PrefixLogger, job: WithId<z.infer<ty
// first try to find a job that needs deleting
job = await dataSourcesCollection.findOneAndUpdate({
status: "deleted",
"data.type": "urls",
$or: [
{ attempts: { $exists: false } },
{ attempts: { $lte: 3 } }