revert(knowledge): drop the stale-deferred Retry action and its wire fields

Restores the document list, contract, serializer, and Retry condition to staging; Retry stays failed-only.

Author: waleedlatif1

apps/sim/app/workspace/[workspaceId]/knowledge/[id]/base.tsx

@@ -49,7 +49,6 @@ import {
   KNOWLEDGE_DOCUMENT_PROCESSING_STALE_THRESHOLD_MS,
 } from '@/lib/knowledge/constants'
 import {
-  canRetryDocumentProcessing,
   type DocumentSortField,
   getDocumentIndexingStatus,
   type SortOrder,
@@ -1570,7 +1569,7 @@ export function KnowledgeBase({
         }
         onRetry={
           contextMenuDocument &&
-          canRetryDocumentProcessing(contextMenuDocument) &&
+          getDocumentIndexingStatus(contextMenuDocument) === 'failed' &&
           selectedDocumentCount === 1 &&
           userPermissions.canEdit
             ? () => handleRetryDocument(contextMenuDocument.id)

apps/sim/lib/api/contracts/knowledge/documents.ts

@@ -293,8 +293,6 @@ export const documentDataSchema = z
     processingOutcome: z.literal('skipped').nullable().default(null),
     /** When indexing was last dispatched to a worker, which precedes a worker starting it. */
     processingQueuedAt: nullableWireDateSchema.optional(),
-    /** When a deferred retry of a `pending` document is due. */
-    processingDeferredUntil: nullableWireDateSchema.optional(),
     processingStartedAt: nullableWireDateSchema.optional(),
     processingCompletedAt: nullableWireDateSchema.optional(),
     processingError: z.string().nullable().optional(),

apps/sim/lib/knowledge/api/internal-route.test.ts

@@ -13,7 +13,6 @@ import {
   internalKnowledgeProvenanceUserId,
   resolveInternalKnowledgeBillingAttribution,
   toInternalKnowledgeConnector,
-  toInternalKnowledgeDocument,
 } from '@/lib/knowledge/api/internal-route'
 import { resolveKnowledgeAttributedUserId } from '@/lib/knowledge/application/billing'
 
@@ -134,30 +133,6 @@ describe('internal Knowledge execution attribution', () => {
   })
 })
 
-describe('toInternalKnowledgeDocument', () => {
-  it('presents when a deferred retry is due, so the Retry action can match the API', () => {
-    const deferredUntil = new Date('2026-09-01T12:00:00.000Z')
-    const presented = toInternalKnowledgeDocument({
-      id: 'doc-1',
-      knowledgeBaseId: 'kb-1',
-      filename: 'a.txt',
-      fileUrl: 'https://example.com/a.txt',
-      fileSize: 1,
-      mimeType: 'text/plain',
-      chunkCount: 0,
-      tokenCount: 0,
-      characterCount: 0,
-      processingStatus: 'pending',
-      enabled: true,
-      uploadedAt: new Date('2026-08-01T00:00:00.000Z'),
-      processingQueuedAt: new Date('2026-08-01T00:00:00.000Z'),
-      processingDeferredUntil: deferredUntil,
-    })
-    expect(presented.processingDeferredUntil).toBe(deferredUntil.toISOString())
-    expect(presented.processingQueuedAt).toBe('2026-08-01T00:00:00.000Z')
-  })
-})
-
 describe('toInternalKnowledgeConnector', () => {
   const row = {
     id: 'connector-1',

apps/sim/lib/knowledge/api/internal-route.ts

@@ -89,7 +89,6 @@ export function toInternalKnowledgeDocument<
   T extends {
     uploadedAt: Date | string
     processingQueuedAt?: Date | string | null
-    processingDeferredUntil?: Date | string | null
     processingStartedAt?: Date | string | null
     processingCompletedAt?: Date | string | null
     date1?: Date | string | null
@@ -100,7 +99,6 @@ export function toInternalKnowledgeDocument<
     ...document,
     uploadedAt: serializeDate(document.uploadedAt),
     processingQueuedAt: serializeNullableDate(document.processingQueuedAt ?? null),
-    processingDeferredUntil: serializeNullableDate(document.processingDeferredUntil ?? null),
     processingStartedAt: serializeNullableDate(document.processingStartedAt ?? null),
     processingCompletedAt: serializeNullableDate(document.processingCompletedAt ?? null),
     date1: serializeNullableDate(document.date1 ?? null),

apps/sim/lib/knowledge/documents/service.test.ts

@@ -35,38 +35,6 @@ describe('getDocuments pagination', () => {
     expect(dbChainMockFns.limit).toHaveBeenCalledWith(5)
   })
 
-  it('lists when a pending document was queued and when its deferred retry is due', async () => {
-    const queuedAt = new Date('2026-08-01T00:00:00.000Z')
-    const deferredUntil = new Date('2026-08-01T00:02:00.000Z')
-    queueTableRows(document, [{ count: 1 }])
-    queueTableRows(document, [
-      {
-        id: 'document-1',
-        processingStatus: 'pending',
-        processingQueuedAt: queuedAt,
-        processingDeferredUntil: deferredUntil,
-      },
-    ])
-
-    const result = await getDocuments(
-      'knowledge-1',
-      { limit: 5 },
-      'request-1',
-      WORKSPACE_ACCESS_SCOPE
-    )
-
-    expect(dbChainMockFns.select).toHaveBeenCalledWith(
-      expect.objectContaining({
-        processingQueuedAt: document.processingQueuedAt,
-        processingDeferredUntil: document.processingDeferredUntil,
-      })
-    )
-    expect(result.documents[0]).toMatchObject({
-      processingQueuedAt: queuedAt,
-      processingDeferredUntil: deferredUntil,
-    })
-  })
-
   it('reads a newly admitted candidate even when the earlier count admitted no documents', async () => {
     const identity: KnowledgeAccessScope = { kind: 'user', userId: 'reader', tokens: [] }
     const resolve = vi.fn(async () => identity)

apps/sim/lib/knowledge/documents/service.ts

@@ -2771,8 +2771,6 @@ export async function getDocuments(
         characterCount: document.characterCount,
         processingStatus: document.processingStatus,
         processingOutcome: documentProcessingOutcomeSelection(),
-        processingQueuedAt: document.processingQueuedAt,
-        processingDeferredUntil: document.processingDeferredUntil,
         processingStartedAt: document.processingStartedAt,
         processingCompletedAt: document.processingCompletedAt,
         processingError: document.processingError,
@@ -2889,8 +2887,6 @@ export async function getDocuments(
       characterCount: doc.characterCount,
       processingStatus: doc.processingStatus as DocumentProcessingStatus,
       processingOutcome: doc.processingOutcome,
-      processingQueuedAt: doc.processingQueuedAt,
-      processingDeferredUntil: doc.processingDeferredUntil,
       processingStartedAt: doc.processingStartedAt,
       processingCompletedAt: doc.processingCompletedAt,
       processingError: doc.processingError,

apps/sim/lib/knowledge/documents/types.test.ts

@@ -106,33 +106,6 @@ export function getDocumentIndexingStatus(document: {
   return document.processingOutcome ?? document.processingStatus
 }
 
-/**
- * Whether a user may retry a document's processing: it failed, or it is `pending` behind a
- * dispatch or a deferred retry that is more than {@link QUEUED_DISPATCH_GRACE_MS} past due, the
- * same cutoff the retry API applies before it replaces a queued generation. The API still makes
- * the final call; this only decides whether to offer the action.
- */
-export function canRetryDocumentProcessing(
-  document: {
-    processingStatus: string
-    processingOutcome?: DocumentProcessingOutcome
-    processingQueuedAt?: Date | string | null
-    processingDeferredUntil?: Date | string | null
-    uploadedAt: Date | string
-  },
-  now: number = Date.now()
-): boolean {
-  const status = getDocumentIndexingStatus(document)
-  if (status === 'failed') return true
-  if (status !== 'pending') return false
-  const cutoff = now - QUEUED_DISPATCH_GRACE_MS
-  const queuedAt = new Date(document.processingQueuedAt ?? document.uploadedAt).getTime()
-  const deferredUntil = document.processingDeferredUntil
-    ? new Date(document.processingDeferredUntil).getTime()
-    : null
-  return queuedAt < cutoff && (deferredUntil === null || deferredUntil < cutoff)
-}
-
 /**
  * Narrows a stored `processing_status` onto the union.
  *

apps/sim/lib/knowledge/documents/types.ts

@@ -148,8 +148,6 @@ export interface DocumentData {
   characterCount: number
   processingStatus: DocumentProcessingStatus
   processingOutcome?: DocumentProcessingOutcome
-  processingQueuedAt?: string | null
-  processingDeferredUntil?: string | null
   processingStartedAt?: string | null
   processingCompletedAt?: string | null
   processingError?: string | null