Current content
' } + const { pass } = await runPass({ databaseTime, access: 'admin' }) + expect(pass.checkpoint.startedAt).toBe(databaseTime.toISOString()) + expect(mocks.onPage).toHaveBeenCalledWith(expect.any(Array), databaseTime) + }) + + it('passes the durable generation start to ACL updates when resuming with a later worker clock', async () => { + const checkpoint = beginListingCheckpoint({ + fingerprint: 'a'.repeat(64), + generationId: 'previous-run', + startedAt: new Date('2026-09-08T11:00:00Z'), + }) + sourceBody = { value: 'Current content
' } + await runPass({ checkpoint, access: 'admin' }) + expect(mocks.onPage).toHaveBeenCalledWith(expect.any(Array), new Date(checkpoint.startedAt)) + }) + it.each([ { name: 'full', incrementalSince: undefined }, { name: 'incremental', incrementalSince: new Date('2026-09-07T12:00:00Z') }, diff --git a/apps/sim/lib/knowledge/connectors/sync-content-pass.ts b/apps/sim/lib/knowledge/connectors/sync-content-pass.ts index 94c1e338cb5..2031682028f 100644 --- a/apps/sim/lib/knowledge/connectors/sync-content-pass.ts +++ b/apps/sim/lib/knowledge/connectors/sync-content-pass.ts @@ -57,7 +57,7 @@ interface ContentPassInput { forceRehydrate: boolean fullSync?: boolean deadlineAt: number - onPage?: (documents: ExternalDocument[]) => Promise