Add new fields to event group getters

Signed-off-by: Adhitya Mamallan <[email protected]>

Author: adhityamamallan

src/views/workflow-history/helpers/get-history-group-from-events/__tests__/get-activity-group-from-events.test.ts

@@ -395,6 +395,7 @@ describe('getActivityGroupFromEvents', () => {
     expect(group.eventsMetadata[1].summaryFields).toEqual([
       'heartbeatDetails',
       'lastHeartbeatTime',
+      'attempt',
     ]);
 
     // The completed event should also have summaryFields
@@ -522,6 +523,7 @@ describe('getActivityGroupFromEvents', () => {
     expect(pendingStartEventMetadata?.summaryFields).toEqual([
       'lastFailureReason',
       'lastFailureDetails',
+      'attempt',
     ]);
 
     // Other events should not have the same summaryFields

src/views/workflow-history/helpers/get-history-group-from-events/__tests__/get-decision-group-from-events.test.ts

@@ -370,6 +370,7 @@ describe('getDecisionGroupFromEvents', () => {
     );
     expect(scheduledEventMetadata?.summaryFields).toEqual([
       'startToCloseTimeoutSeconds',
+      'attempt',
     ]);
 
     // Other events should not have summaryFields
@@ -380,4 +381,27 @@ describe('getDecisionGroupFromEvents', () => {
       expect(metadata.summaryFields).toBeUndefined();
     });
   });
+
+  it('should include summaryFields for pending decision start events', () => {
+    const events: ExtendedDecisionHistoryEvent[] = [
+      scheduleDecisionTaskEvent,
+      pendingDecisionTaskStartEvent,
+    ];
+    const group = getDecisionGroupFromEvents(events);
+
+    // The pending start event should have summaryFields
+    const pendingStartEventMetadata = group.eventsMetadata.find(
+      (metadata) => metadata.label === 'Starting'
+    );
+    expect(pendingStartEventMetadata?.summaryFields).toEqual(['attempt']);
+
+    // Other events should not have the same summaryFields
+    const scheduledEventMetadata = group.eventsMetadata.find(
+      (metadata) => metadata.label === 'Scheduled'
+    );
+    expect(scheduledEventMetadata?.summaryFields).toEqual([
+      'startToCloseTimeoutSeconds',
+      'attempt',
+    ]);
+  });
 });

src/views/workflow-history/helpers/get-history-group-from-events/__tests__/get-single-event-group-from-events.test.ts

@@ -186,6 +186,7 @@ describe('getSingleEventGroupFromEvents', () => {
     expect(eventMetadata.summaryFields).toEqual([
       'input',
       'executionStartToCloseTimeoutSeconds',
+      'attempt',
     ]);
   });
 

src/views/workflow-history/helpers/get-history-group-from-events/get-activity-group-from-events.ts

@@ -165,10 +165,12 @@ export default function getActivityGroupFromEvents(
       pendingActivityTaskStartEventAttributes: [
         'lastFailureReason',
         'lastFailureDetails',
+        'attempt',
       ],
       activityTaskStartedEventAttributes: [
         'heartbeatDetails',
         'lastHeartbeatTime',
+        'attempt',
       ],
       activityTaskCompletedEventAttributes: ['result'],
       activityTaskFailedEventAttributes: ['details', 'reason'],

src/views/workflow-history/helpers/get-history-group-from-events/get-decision-group-from-events.ts

@@ -122,7 +122,11 @@ export default function getDecisionGroupFromEvents(
 
   const eventToSummaryFields: HistoryGroupEventToSummaryFieldsMap<DecisionHistoryGroup> =
     {
-      decisionTaskScheduledEventAttributes: ['startToCloseTimeoutSeconds'],
+      decisionTaskScheduledEventAttributes: [
+        'startToCloseTimeoutSeconds',
+        'attempt',
+      ],
+      pendingDecisionTaskStartEventAttributes: ['attempt'],
     };
 
   return {

src/views/workflow-history/helpers/get-history-group-from-events/get-single-event-group-from-events.ts

@@ -99,6 +99,7 @@ export default function getSingleEventGroupFromEvents(
       workflowExecutionStartedEventAttributes: [
         'input',
         'executionStartToCloseTimeoutSeconds',
+        'attempt',
       ],
       workflowExecutionCompletedEventAttributes: ['result'],
       workflowExecutionFailedEventAttributes: ['details', 'reason'],