From 5b50777c6021301bd0b8324119e192027661ab11 Mon Sep 17 00:00:00 2001
From: Misha Savelyev <mikhail@crowd.dev>
Date: Wed, 10 Jan 2024 08:21:36 +0000
Subject: [PATCH] Improve find-existing-acitivty query in data-sink-worker

This change makes it use:

    CREATE UNIQUE INDEX activities_tenant_segment_source_id_idx
    ON activities ("tenantId", "segmentId", "sourceId")
    WHERE ("deletedAt" IS NULL);

instead of:

    CREATE UNIQUE INDEX ix_unique_activities_tenantid_platform_type_sourceid_segmentid
    ON activities ("tenantId", platform, type, "sourceId", "segmentId");
---
 services/apps/data_sink_worker/src/repo/activity.repo.ts | 1 +
 1 file changed, 1 insertion(+)

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;
     `,
       {