Skip to content

Commit

Permalink
Print out existing states?
Browse files Browse the repository at this point in the history
  • Loading branch information
lukemartinlogan committed Oct 19, 2023
1 parent a1648bd commit 5c18679
Show file tree
Hide file tree
Showing 2 changed files with 4 additions and 1 deletion.
3 changes: 3 additions & 0 deletions hrun/src/worker.cc
Original file line number Diff line number Diff line change
Expand Up @@ -77,6 +77,9 @@ void Worker::PollGrouped(WorkEntry &work_entry) {
TaskState *&exec = rctx.exec_;
exec = HRUN_TASK_REGISTRY->GetTaskState(task->task_state_);
if (!exec) {
for (std::pair<std::string, TaskStateId> entries : HRUN_TASK_REGISTRY->task_state_ids_) {
HILOG(kInfo, "Task state: {} id: {}", entries.first, entries.second)
}
HELOG(kFatal, "(node {}) Could not find the task state: {}",
HRUN_CLIENT->node_id_, task->task_state_);
entry->complete_ = true;
Expand Down
Original file line number Diff line number Diff line change
Expand Up @@ -125,7 +125,7 @@ struct SetBucketMdmTask : public Task, TaskFlags<TF_SRL_SYM | TF_REPLICA> {
template<typename Ar>
void SerializeStart(Ar &ar) {
task_serialize<Ar>(ar);
ar(bkt_mdm_, stager_mdm_);
ar(bkt_mdm_, stager_mdm_, op_mdm_);
}

/** (De)serialize message return */
Expand Down

0 comments on commit 5c18679

Please sign in to comment.