improvement(knowledge): add Trigger.dev tags for connector sync and document processing tasks

This commit is contained in:
Waleed Latif
2026-03-24 20:46:37 -07:00
parent 74ff2b5804
commit 85d9fcb216
2 changed files with 9 additions and 5 deletions

View File

@@ -150,11 +150,14 @@ export async function dispatchSync(
const requestId = options?.requestId ?? crypto.randomUUID()
if (isTriggerAvailable()) {
await knowledgeConnectorSync.trigger({
connectorId,
fullSync: options?.fullSync,
requestId,
})
await knowledgeConnectorSync.trigger(
{
connectorId,
fullSync: options?.fullSync,
requestId,
},
{ tags: [`connector:${connectorId}`] }
)
logger.info(`Dispatched connector sync to Trigger.dev`, { connectorId, requestId })
} else {
executeSync(connectorId, { fullSync: options?.fullSync }).catch((error) => {

View File

@@ -687,6 +687,7 @@ export async function processDocumentsWithTrigger(
payload: doc,
options: {
idempotencyKey: `doc-process-${doc.documentId}-${requestId}`,
tags: [`kb:${doc.knowledgeBaseId}`, `doc:${doc.documentId}`],
},
}))
)