mirror of
https://github.com/eigent-ai/eigent.git
synced 2026-05-03 06:00:17 +00:00
fix(taskcard, workflow): resolve disagree status mismatch
This commit is contained in:
parent
d3b648ffe0
commit
5a5b334dc5
2 changed files with 9 additions and 7 deletions
|
|
@ -88,7 +88,7 @@ export function TaskCard({
|
|||
});
|
||||
setFilterTasks(newFiltered);
|
||||
}
|
||||
}, [selectedState, taskInfo]);
|
||||
}, [selectedState, taskInfo,taskRunning]);
|
||||
|
||||
const isAllTaskFinished = useMemo(() => {
|
||||
return (
|
||||
|
|
|
|||
|
|
@ -489,7 +489,7 @@ const chatStore = create<ChatStore>()(
|
|||
|
||||
}
|
||||
if (targetTaskIndex !== -1) {
|
||||
console.log("targetTaskIndex", targetTaskIndex,state)
|
||||
console.log("targetTaskIndex", targetTaskIndex, state)
|
||||
taskRunning[targetTaskIndex].status = state === "DONE" ? "completed" : "failed";
|
||||
}
|
||||
setTaskRunning(taskId, taskRunning)
|
||||
|
|
@ -618,11 +618,10 @@ const chatStore = create<ChatStore>()(
|
|||
taskAssigning[assigneeAgentIndex].tasks.push(task ?? { id: task_id, content, status: "waiting" });
|
||||
}
|
||||
setTaskAssigning(taskId, [...taskAssigning]);
|
||||
return; // Return early, do not add to the running queue
|
||||
}
|
||||
|
||||
}
|
||||
// The following logic is for when the task actually starts executing (running)
|
||||
if (taskAssigning && taskAssigning[assigneeAgentIndex]) {
|
||||
else if (taskAssigning && taskAssigning[assigneeAgentIndex]) {
|
||||
// Check if task already exists in the agent's task list
|
||||
const existingTaskIndex = taskAssigning[assigneeAgentIndex].tasks.findIndex(item => item.id === task_id);
|
||||
|
||||
|
|
@ -649,11 +648,14 @@ const chatStore = create<ChatStore>()(
|
|||
// Only update or add to taskRunning, never duplicate
|
||||
if (taskRunningIndex === -1) {
|
||||
// Task not in taskRunning, add it
|
||||
if(task){
|
||||
task.status = taskState === "waiting" ? "waiting" : "running";
|
||||
}
|
||||
taskRunning!.push(
|
||||
task ?? {
|
||||
id: task_id,
|
||||
content,
|
||||
status: "",
|
||||
status: taskState === "waiting" ? "waiting" : "running",
|
||||
agent: JSON.parse(JSON.stringify(taskAgent)),
|
||||
}
|
||||
);
|
||||
|
|
@ -661,7 +663,7 @@ const chatStore = create<ChatStore>()(
|
|||
// Task already in taskRunning, update it
|
||||
taskRunning![taskRunningIndex] = {
|
||||
...taskRunning![taskRunningIndex],
|
||||
status: "",
|
||||
status: taskState === "waiting" ? "waiting" : "running",
|
||||
agent: JSON.parse(JSON.stringify(taskAgent)),
|
||||
};
|
||||
}
|
||||
|
|
|
|||
Loading…
Add table
Add a link
Reference in a new issue