better check for reset

temporalio · Sep 30, 2024 · e4b3d31 · e4b3d31
1 parent 629c51a
commit e4b3d31
Show file tree

Hide file tree

Showing 2 changed files with 6 additions and 5 deletions.
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
@@ -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
@@ -270,11 +270,12 @@ export const isPureWorkflowTaskFailedEvent =
   hasAttributes<WorkflowTaskFailedEvent>('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
   );
 };