diff --git a/services/apps/data_sink_worker/src/repo/activity.repo.ts b/services/apps/data_sink_worker/src/repo/activity.repo.ts
index 847f306c72..b6840a1a68 100644
--- a/services/apps/data_sink_worker/src/repo/activity.repo.ts
+++ b/services/apps/data_sink_worker/src/repo/activity.repo.ts
@@ -103,6 +103,7 @@ export default class ActivityRepository extends RepositoryBase<ActivityRepositor
         and "segmentId" = $(segmentId)
         and "sourceId" = $(sourceId)
         and channel = $(channel)
+        and "deletedAt" IS NULL
       limit 1;
     `,
       {