diff --git a/src/lib/models/event-groups/get-event-in-group.test.ts b/src/lib/models/event-groups/get-event-in-group.test.ts index 13334aa98..f59f715fd 100644 --- a/src/lib/models/event-groups/get-event-in-group.test.ts +++ b/src/lib/models/event-groups/get-event-in-group.test.ts @@ -85,10 +85,10 @@ describe('eventIsFailureOrTimedOut', () => { expect(eventIsFailureOrTimedOut(event)).toBe(false); }); - it('should return false if provided an event with workflowTaskFailedEventAttributes and has ResetWorkflow message', () => { + it('should return false if provided an event with workflowTaskFailedEventAttributes and has resetWorkflowFailureInfo', () => { const event = { workflowTaskFailedEventAttributes: { - failure: { message: 'ResetWorkflow' }, + failure: { resetWorkflowFailureInfo: {} }, }, } as unknown as WorkflowEvent; expect(eventIsFailureOrTimedOut(event)).toBe(false); diff --git a/src/lib/utilities/is-event-type.ts b/src/lib/utilities/is-event-type.ts index 6784f6752..51eca4ca0 100644 --- a/src/lib/utilities/is-event-type.ts +++ b/src/lib/utilities/is-event-type.ts @@ -270,11 +270,12 @@ export const isPureWorkflowTaskFailedEvent = hasAttributes('workflowTaskFailedEventAttributes'); export const isWorkflowTaskFailedEvent = (event: WorkflowEvent) => { + console.log(event); return ( isPureWorkflowTaskFailedEvent(event) && - !['UnhandledCommand', 'ResetWorkflow'].includes( - event.workflowTaskFailedEventAttributes?.failure?.message, - ) + event.workflowTaskFailedEventAttributes?.failure?.message !== + 'UnhandledCommand' && + !event.workflowTaskFailedEventAttributes?.failure?.resetWorkflowFailureInfo ); };