From e3ba8c12c7b1758492ec502d51f9baa9226bcb23 Mon Sep 17 00:00:00 2001 From: alexcos20 Date: Wed, 4 Mar 2026 06:54:41 +0200 Subject: [PATCH 1/2] fix query --- src/components/database/sqliteCompute.ts | 2 +- 1 file changed, 1 insertion(+), 1 deletion(-) diff --git a/src/components/database/sqliteCompute.ts b/src/components/database/sqliteCompute.ts index 4b1d0bebf..9d87bd16f 100644 --- a/src/components/database/sqliteCompute.ts +++ b/src/components/database/sqliteCompute.ts @@ -462,7 +462,7 @@ export class SQLiteCompute implements ComputeDatabaseProvider { if (consumerAddrs && consumerAddrs.length > 0) { const placeholders = consumerAddrs.map(() => '?').join(',') - conditions.push(`owner NOT IN (${placeholders})`) + conditions.push(`owner IN (${placeholders})`) params.push(...consumerAddrs) } From 65448730319063aed462627194c3549dfb1f6a30 Mon Sep 17 00:00:00 2001 From: alexcos20 Date: Wed, 4 Mar 2026 07:16:53 +0200 Subject: [PATCH 2/2] fix test --- src/test/integration/getJobs.test.ts | 6 +++--- 1 file changed, 3 insertions(+), 3 deletions(-) diff --git a/src/test/integration/getJobs.test.ts b/src/test/integration/getJobs.test.ts index 0f405a66b..58aba7857 100644 --- a/src/test/integration/getJobs.test.ts +++ b/src/test/integration/getJobs.test.ts @@ -131,7 +131,7 @@ describe('GetJobsHandler integration', () => { expect(filtered.every((j) => Number(j.dateFinished) >= Number(fromTs))).to.equal(true) }) - it('should exclude jobs owned by specified consumer addresses', async function () { + it('should include jobs owned by specified consumer addresses', async function () { this.timeout(DEFAULT_TEST_TIMEOUT) const resp = await handler.handle({ @@ -144,7 +144,7 @@ describe('GetJobsHandler integration', () => { const jobs = (await streamToObject(resp.stream as Readable)) as any[] const owners = jobs.filter((j) => j.environment === uniqueEnv).map((j) => j.owner) - expect(owners.includes(ownerA)).to.equal(false) - expect(owners.includes(ownerB)).to.equal(true) + expect(owners.includes(ownerA)).to.equal(true) + expect(owners.includes(ownerB)).to.equal(false) }) })