Skip to content

Commit c66d595

Browse files
authored
Format decision task cause field (#863)
* format decision task cause field * lint
1 parent fd6edf1 commit c66d595

File tree

3 files changed

+9
-2
lines changed

3 files changed

+9
-2
lines changed

src/utils/data-formatters/format-workflow-history-event/__tests__/index.test.ts.snapshot

Lines changed: 2 additions & 2 deletions
Original file line numberDiff line numberDiff line change
@@ -283,7 +283,7 @@ exports[`formatWorkflowHistoryEvent should format workflow decisionTaskFailedEve
283283
{
284284
"baseRunId": "",
285285
"binaryChecksum": "ffc875a4c3571872881f79c939921e00398ab360",
286-
"cause": "DECISION_TASK_FAILED_CAUSE_BAD_START_CHILD_EXECUTION_ATTRIBUTES",
286+
"cause": "BAD_START_CHILD_EXECUTION_ATTRIBUTES",
287287
"details": "WorkflowId exceeds length limit.",
288288
"eventId": 5,
289289
"eventType": "DecisionTaskFailed",
@@ -332,7 +332,7 @@ exports[`formatWorkflowHistoryEvent should format workflow decisionTaskStartedEv
332332
exports[`formatWorkflowHistoryEvent should format workflow decisionTaskTimedOutEventAttributes to match snapshot 1`] = `
333333
{
334334
"baseRunId": "",
335-
"cause": "DECISION_TASK_TIMED_OUT_CAUSE_TIMEOUT",
335+
"cause": "TIMEOUT",
336336
"eventId": 6,
337337
"eventType": "DecisionTaskTimedOut",
338338
"forkEventVersion": 0,

src/utils/data-formatters/format-workflow-history-event/format-decision-task-failed-event.ts

Lines changed: 3 additions & 0 deletions
Original file line numberDiff line numberDiff line change
@@ -1,3 +1,4 @@
1+
import formatEnum from '../format-enum';
12
import formatFailureDetails from '../format-failure-details';
23

34
import formatWorkflowCommonEventFields from './format-workflow-common-event-fields';
@@ -9,6 +10,7 @@ const formatDecisionTaskFailedEvent = ({
910
forkEventVersion,
1011
scheduledEventId,
1112
startedEventId,
13+
cause,
1214
...eventAttributes
1315
},
1416
...eventFields
@@ -19,6 +21,7 @@ const formatDecisionTaskFailedEvent = ({
1921
details: formatFailureDetails(failure),
2022
forkEventVersion: parseInt(forkEventVersion),
2123
reason: failure?.reason || '',
24+
cause: formatEnum(cause, 'DECISION_TASK_FAILED_CAUSE'),
2225
scheduledEventId: parseInt(scheduledEventId),
2326
startedEventId: parseInt(startedEventId),
2427
};

src/utils/data-formatters/format-workflow-history-event/format-decision-timed-out-event.ts

Lines changed: 4 additions & 0 deletions
Original file line numberDiff line numberDiff line change
@@ -1,3 +1,5 @@
1+
import formatEnum from '../format-enum';
2+
13
import formatWorkflowCommonEventFields from './format-workflow-common-event-fields';
24
import { type DecisionTaskTimedOutEvent } from './format-workflow-history-event.type';
35

@@ -6,13 +8,15 @@ const formatDecisionTaskTimedOutEvent = ({
68
forkEventVersion,
79
scheduledEventId,
810
startedEventId,
11+
cause,
912
...eventAttributes
1013
},
1114
...eventFields
1215
}: DecisionTaskTimedOutEvent) => {
1316
return {
1417
...formatWorkflowCommonEventFields(eventFields),
1518
...eventAttributes,
19+
cause: formatEnum(cause, 'DECISION_TASK_TIMED_OUT_CAUSE'),
1620
forkEventVersion: parseInt(forkEventVersion),
1721
scheduledEventId: parseInt(scheduledEventId),
1822
startedEventId: parseInt(startedEventId),

0 commit comments

Comments
 (0)