Fix workflowRun real time updates (#13605)

as title
This commit is contained in:
martmull
2025-08-04 17:28:22 +02:00
committed by GitHub
parent 99f8891f3a
commit b12fad533d
@@ -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,
}),
]
: []),