Duplicate Detection Job
Component Detail
Infrastructure
low complexity
backend
1
Dependencies
0
Dependents
1
Entities
0
Integrations
Description
Scheduled or event-triggered infrastructure job that invokes the Duplicate Detection Service on activity insert events. Ensures the deduplication scan runs asynchronously without blocking the activity registration response path.
duplicate-detection-job
Responsibilities
- Listen for activity_created events or run on a short polling interval
- Invoke duplicate detection scan for each new activity
- Handle job failures gracefully without blocking activity persistence
- Log job execution and detection outcomes for observability
Interfaces
onActivityCreated(activityId)
schedulePeriodicScan(intervalMs)
cancelJob(jobId)
getJobStatus()
retryFailedDetection(activityId)