When a TaskClaim is received, the coordinator only prints "Task claim received!!" to stdout. There is no:
- Deduplication of multiple claims for the same task
- Worker selection strategy (first-come, lowest estimated duration, capability match)
TaskAssignment message sent back to the selected worker
- Task status update from
Pending → Running
Location
src/node.rs, lines 500–503
Message::TaskClaim(task_claim) => {
task_claim.validate()?;
println!("Task claim received!!");
}
Suggested approach
- Add a
TaskAssignment message variant to the Message enum.
- Track pending claims per
TaskId in the coordinator.
- After a configurable claim window, select a worker and send
TaskAssignment.
- Update
TaskStatus accordingly.
When a
TaskClaimis received, the coordinator only prints"Task claim received!!"to stdout. There is no:TaskAssignmentmessage sent back to the selected workerPending→RunningLocation
src/node.rs, lines 500–503Suggested approach
TaskAssignmentmessage variant to theMessageenum.TaskIdin the coordinator.TaskAssignment.TaskStatusaccordingly.