Skip to content

Commit 7d54f9e

Browse files
committed
Save new body on each retry
1 parent 81df4de commit 7d54f9e

1 file changed

Lines changed: 11 additions & 5 deletions

File tree

packages/engine/src/lib/services/progress.service.ts

Lines changed: 11 additions & 5 deletions
Original file line numberDiff line numberDiff line change
@@ -92,7 +92,7 @@ const sendUpdateRunRequest = async (flowRunId: FlowRunId): Promise<void> => {
9292
);
9393

9494
try {
95-
let bodyAccessKey = await saveRequestBody(request);
95+
const bodyAccessKey = await saveRequestBody(request);
9696

9797
throwIfExecutionTimeExceeded();
9898
await makeHttpRequest(
@@ -110,12 +110,18 @@ const sendUpdateRunRequest = async (flowRunId: FlowRunId): Promise<void> => {
110110
retryCondition: async (error: AxiosError) => {
111111
throwIfExecutionTimeExceeded();
112112

113-
if (isRetryableError(error)) {
114-
bodyAccessKey = await saveRequestBody(request);
115-
return true;
113+
if (!isRetryableError(error)) {
114+
return false;
116115
}
117116

118-
return false;
117+
if (error.config) {
118+
const newBodyAccessKey = await saveRequestBody(request);
119+
error.config.data = JSON.stringify({
120+
bodyAccessKey: newBodyAccessKey,
121+
});
122+
}
123+
124+
return true;
119125
},
120126
retryDelay: (retryCount: number) => (retryCount + 1) * 200, // 200ms, 400ms, 600ms
121127
},

0 commit comments

Comments
 (0)