Skip to content

Commit d2a87fe

Browse files
committed
Save new request body when retrying request
1 parent 6529a60 commit d2a87fe

1 file changed

Lines changed: 9 additions & 3 deletions

File tree

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

Lines changed: 9 additions & 3 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-
const bodyAccessKey = await saveRequestBody(request);
95+
let bodyAccessKey = await saveRequestBody(request);
9696

9797
throwIfExecutionTimeExceeded();
9898
await makeHttpRequest(
@@ -107,9 +107,15 @@ const sendUpdateRunRequest = async (flowRunId: FlowRunId): Promise<void> => {
107107
} as BodyAccessKeyRequest,
108108
{
109109
retries: MAX_RETRIES,
110-
retryCondition: (error: AxiosError) => {
110+
retryCondition: async (error: AxiosError) => {
111111
throwIfExecutionTimeExceeded();
112-
return isRetryableError(error);
112+
113+
if (isRetryableError(error)) {
114+
bodyAccessKey = await saveRequestBody(request);
115+
return true;
116+
}
117+
118+
return false;
113119
},
114120
retryDelay: (retryCount: number) => (retryCount + 1) * 200, // 200ms, 400ms, 600ms
115121
},

0 commit comments

Comments
 (0)