From b12fad533d4a8034d9d6d6b7865e5a275e54aed2 Mon Sep 17 00:00:00 2001
From: martmull <martmull@hotmail.fr>
Date: Mon, 4 Aug 2025 17:28:22 +0200
Subject: [PATCH] Fix workflowRun real time updates (#13605)

as title
---
 .../listeners/entity-events-to-db.listener.ts | 28 +++++++++----------
 1 file changed, 14 insertions(+), 14 deletions(-)

diff --git a/packages/twenty-server/src/engine/api/graphql/workspace-query-runner/listeners/entity-events-to-db.listener.ts b/packages/twenty-server/src/engine/api/graphql/workspace-query-runner/listeners/entity-events-to-db.listener.ts
index a2c8e64087..09c98d3539 100644
--- a/packages/twenty-server/src/engine/api/graphql/workspace-query-runner/listeners/entity-events-to-db.listener.ts
+++ b/packages/twenty-server/src/engine/api/graphql/workspace-query-runner/listeners/entity-events-to-db.listener.ts
@@ -63,14 +63,10 @@ export class EntityEventsToDbListener {
     batchEvent: WorkspaceEventBatch<T>,
     action: DatabaseEventAction,
   ) {
-    const filteredEvents = batchEvent.events.filter(
+    const auditLogsEvents = batchEvent.events.filter(
       (event) => event.objectMetadata?.isAuditLogged,
     );
 
-    if (filteredEvents.length === 0) {
-      return;
-    }
-
     const batchEventEventsForWebhook: ObjectRecordEventForWebhook[] =
       batchEvent.events.map((event) => ({
         ...event,
@@ -95,20 +91,24 @@ export class EntityEventsToDbListener {
           retryLimit: 3,
         },
       ),
-      this.entityEventsToDbQueueService.add<WorkspaceEventBatch<T>>(
-        CreateAuditLogFromInternalEvent.name,
-        {
-          ...batchEvent,
-          events: filteredEvents,
-        },
-      ),
-      ...(action !== DatabaseEventAction.DESTROYED
+      ...(auditLogsEvents.length > 0
+        ? [
+            this.entityEventsToDbQueueService.add<WorkspaceEventBatch<T>>(
+              CreateAuditLogFromInternalEvent.name,
+              {
+                ...batchEvent,
+                events: auditLogsEvents,
+              },
+            ),
+          ]
+        : []),
+      ...(action !== DatabaseEventAction.DESTROYED && auditLogsEvents.length > 0
         ? [
             this.entityEventsToDbQueueService.add<
               WorkspaceEventBatch<ObjectRecordNonDestructiveEvent>
             >(UpsertTimelineActivityFromInternalEvent.name, {
               ...batchEvent,
-              events: filteredEvents,
+              events: auditLogsEvents,
             }),
           ]
         : []),