Store history for iterator (#14771)

As title
This commit is contained in:
Thomas Trompette
2025-09-30 10:32:40 +02:00
committed by GitHub
parent bbe2733bc0
commit 123202df41
@@ -147,28 +147,48 @@ export class IteratorWorkflowAction implements WorkflowActionInterface {
});
const stepInfos = workflowRunToUpdate.state.stepInfos;
const subStepsInfos = stepIdsToReset.reduce(
(acc, stepId) => {
acc[stepId] = {
status: StepStatus.NOT_STARTED,
result: undefined,
error: undefined,
history: [
...(stepInfos[stepId]?.history ?? []),
{
result: stepInfos[stepId]?.result,
error: stepInfos[stepId]?.error,
status: stepInfos[stepId]?.status,
},
],
};
return acc;
},
{} as Record<string, WorkflowRunStepInfo>,
);
const iteratorStepInfo = stepInfos[iteratorStepId];
const stepInfosToUpdate = {
...subStepsInfos,
[iteratorStepId]: {
...iteratorStepInfo,
result: undefined,
error: undefined,
history: [
...(iteratorStepInfo?.history ?? []),
{
result: iteratorStepInfo?.result,
error: iteratorStepInfo?.error,
status: iteratorStepInfo?.status,
},
],
},
};
await this.workflowRunWorkspaceService.updateWorkflowRunStepInfos({
stepInfos: stepIdsToReset.reduce(
(acc, stepId) => {
acc[stepId] = {
status: StepStatus.NOT_STARTED,
result: undefined,
error: undefined,
history: [
...(stepInfos[stepId]?.history ?? []),
{
result: stepInfos[stepId]?.result,
error: stepInfos[stepId]?.error,
status: stepInfos[stepId]?.status,
},
],
};
return acc;
},
{} as Record<string, WorkflowRunStepInfo>,
),
stepInfos: stepInfosToUpdate,
workflowRunId,
workspaceId,
});