fix(connectors): forward rehydrate flag through the Trigger.dev worker

executeConnectorSyncJob (the production async sync path) destructured only
fullSync from the payload and forwarded only fullSync to executeSync, silently
dropping rehydrate. A manual Full resync would therefore never re-hydrate on the
default Trigger.dev path. Forward rehydrate too.

Author: waleedlatif1

apps/sim/background/knowledge-connector-sync.test.ts

@@ -72,6 +72,29 @@ describe('knowledge connector sync worker', () => {
     expect(mockExecuteSync).toHaveBeenCalledWith('connector-1', {
       billingAttribution: BILLING_ATTRIBUTION,
       fullSync: true,
+      rehydrate: undefined,
+    })
+  })
+
+  it('forwards the rehydrate flag to the sync engine (async worker path)', async () => {
+    mockAssertConnectorSyncPayload.mockReturnValue({
+      connectorId: 'connector-1',
+      requestId: 'request-1',
+      rehydrate: true,
+      billingAttribution: BILLING_ATTRIBUTION,
+    })
+
+    await executeConnectorSyncJob({
+      connectorId: 'connector-1',
+      requestId: 'request-1',
+      rehydrate: true,
+      billingAttribution: BILLING_ATTRIBUTION,
+    })
+
+    expect(mockExecuteSync).toHaveBeenCalledWith('connector-1', {
+      billingAttribution: BILLING_ATTRIBUTION,
+      fullSync: undefined,
+      rehydrate: true,
     })
   })
 })

apps/sim/background/knowledge-connector-sync.ts

@@ -9,13 +9,13 @@ import { executeSync } from '@/lib/knowledge/connectors/sync-engine'
 const logger = createLogger('TriggerKnowledgeConnectorSync')
 
 export async function executeConnectorSyncJob(payload: unknown) {
-  const { connectorId, fullSync, requestId, billingAttribution } =
+  const { connectorId, fullSync, rehydrate, requestId, billingAttribution } =
     assertConnectorSyncPayload(payload)
 
   logger.info(`[${requestId}] Starting connector sync: ${connectorId}`)
 
   try {
-    const result = await executeSync(connectorId, { billingAttribution, fullSync })
+    const result = await executeSync(connectorId, { billingAttribution, fullSync, rehydrate })
 
     logger.info(`[${requestId}] Connector sync completed`, {
       connectorId,