don't use deduplication id for streamProcessed events (#1385)

Uros Marolt · web-flow · commit fa7e44d414fc · 2023-08-28T13:59:17.000+02:00
diff --git a/services/libs/sqs/src/instances/integrationRunWorker.ts b/services/libs/sqs/src/instances/integrationRunWorker.ts
@@ -47,6 +47,6 @@ export class IntegrationRunWorkerEmitter extends SqsQueueEmitter {
   }
 
   public async streamProcessed(tenantId: string, platform: string, runId: string): Promise<void> {
-    await this.sendMessage(runId, new StreamProcessedQueueMessage(runId), runId)
+    await this.sendMessage(runId, new StreamProcessedQueueMessage(runId))
   }
 }

Original file line number	Diff line number	Diff line change
`@@ -47,6 +47,6 @@ export class IntegrationRunWorkerEmitter extends SqsQueueEmitter {`
`47`	`47`	`}`
`48`	`48`
`49`	`49`	`public async streamProcessed(tenantId: string, platform: string, runId: string): Promise<void> {`
`50`		`- await this.sendMessage(runId, new StreamProcessedQueueMessage(runId), runId)`
	`50`	`+ await this.sendMessage(runId, new StreamProcessedQueueMessage(runId))`
`51`	`51`	`}`
`52`	`52`	`}`