diff --git a/src/core/task/Task.ts b/src/core/task/Task.ts
index 4af3372941..46da7485ed 100644
--- a/src/core/task/Task.ts
+++ b/src/core/task/Task.ts
@@ -375,18 +375,13 @@ export class Task extends EventEmitter<ClineEvents> {
 		await provider?.postMessageToWebview({ type: "messageUpdated", clineMessage: message })
 		this.emit("message", { action: "updated", message })
 
-		// Only check for telemetry if the message is complete and CloudService is enabled
-		if (message.partial !== true && CloudService.isEnabled()) {
-			// Now check if this message was already captured
-			const previousMessage = this.clineMessages.find((m) => m.ts === message.ts)
-			const wasAlreadyCaptured = previousMessage && previousMessage.partial !== true
+		const shouldCaptureMessage = message.partial !== true && CloudService.isEnabled()
 
-			if (!wasAlreadyCaptured) {
-				CloudService.instance.captureEvent({
-					event: TelemetryEventName.TASK_MESSAGE,
-					properties: { taskId: this.taskId, message },
-				})
-			}
+		if (shouldCaptureMessage) {
+			CloudService.instance.captureEvent({
+				event: TelemetryEventName.TASK_MESSAGE,
+				properties: { taskId: this.taskId, message },
+			})
 		}
 	}