Skip to content

Commit

Permalink
Fix cancellation, feedback
Browse files Browse the repository at this point in the history
Signed-off-by: Luca Della Vedova <[email protected]>
  • Loading branch information
luca-della-vedova committed Dec 9, 2024
1 parent fb67a79 commit 2e5b29e
Show file tree
Hide file tree
Showing 2 changed files with 4 additions and 2 deletions.
2 changes: 1 addition & 1 deletion nexus_system_orchestrator/src/system_orchestrator.cpp
Original file line number Diff line number Diff line change
Expand Up @@ -868,7 +868,7 @@ void SystemOrchestrator::_halt_job(const std::string& job_id)
std::make_shared<endpoints::RemovePendingTaskService::ServiceType::Request>();
req->task_id = task_id;
const auto resp =
this->_workcell_sessions.at(task_id)->remove_pending_task_client->
this->_workcell_sessions.at(wc_id)->remove_pending_task_client->
send_request(req);
if (!resp->success)
{
Expand Down
4 changes: 3 additions & 1 deletion nexus_system_orchestrator/src/workcell_request.cpp
Original file line number Diff line number Diff line change
Expand Up @@ -107,7 +107,9 @@ WorkcellRequest::make_goal()
void WorkcellRequest::on_feedback(
endpoints::WorkcellRequestAction::ActionType::Feedback::ConstSharedPtr msg)
{
this->_ctx->task_states.at(this->_task.id) = msg->state;
// Will insert a new state if one was not created at work order creation time
// i.e. for transportation requests that are done after task assignments
this->_ctx->task_states[this->_task.id] = msg->state;
this->_on_task_progress(this->_ctx->task_states);
}

Expand Down

0 comments on commit 2e5b29e

Please sign in to comment.