Skip to content

Commit 5564c50

Browse files
committed
Add try catch
1 parent 7d54f9e commit 5564c50

1 file changed

Lines changed: 17 additions & 7 deletions

File tree

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

Lines changed: 17 additions & 7 deletions
Original file line numberDiff line numberDiff line change
@@ -114,13 +114,7 @@ const sendUpdateRunRequest = async (flowRunId: FlowRunId): Promise<void> => {
114114
return false;
115115
}
116116

117-
if (error.config) {
118-
const newBodyAccessKey = await saveRequestBody(request);
119-
error.config.data = JSON.stringify({
120-
bodyAccessKey: newBodyAccessKey,
121-
});
122-
}
123-
117+
await updateRequestBody(request, error);
124118
return true;
125119
},
126120
retryDelay: (retryCount: number) => (retryCount + 1) * 200, // 200ms, 400ms, 600ms
@@ -141,6 +135,22 @@ const sendUpdateRunRequest = async (flowRunId: FlowRunId): Promise<void> => {
141135
logger.debug(`Progress update request for ${flowRunId} took ${duration}ms`);
142136
};
143137

138+
async function updateRequestBody(
139+
request: UpdateRunProgressRequest,
140+
error: AxiosError,
141+
): Promise<void> {
142+
try {
143+
if (error.config) {
144+
const newBodyAccessKey = await saveRequestBody(request);
145+
error.config.data = JSON.stringify({
146+
bodyAccessKey: newBodyAccessKey,
147+
});
148+
}
149+
} catch (e) {
150+
logger.info('Failed to update progress request body.', e);
151+
}
152+
}
153+
144154
type UpdateStepProgressParams = {
145155
engineConstants: EngineConstants;
146156
flowExecutorContext: FlowExecutorContext;

0 commit comments

Comments
 (0)