Skip to content

Commit

Permalink
Fixup
Browse files Browse the repository at this point in the history
  • Loading branch information
Levi-Armstrong committed Sep 18, 2023
1 parent 7fc216b commit dfcdc67
Show file tree
Hide file tree
Showing 2 changed files with 9 additions and 3 deletions.
Original file line number Diff line number Diff line change
Expand Up @@ -459,10 +459,12 @@ TaskComposerNodeInfo::UPtr RasterMotionTask::runImpl(TaskComposerContext& contex
TaskComposerFuture::UPtr future = executor.value().get().run(task_graph, context.problem, context.data_storage);
future->wait();

/** @todo Need to merge child context into parent */
// Merge child context data into parent context
context.task_infos.mergeInfoMap(future->context->task_infos);
if (future->context->isAborted())
context.abort(future->context->task_infos.getAbortingNode());

auto info_map = context.task_infos.getInfoMap();

if (context.problem->dotgraph)
{
std::stringstream dot_graph;
Expand Down
Original file line number Diff line number Diff line change
Expand Up @@ -366,8 +366,12 @@ TaskComposerNodeInfo::UPtr RasterOnlyMotionTask::runImpl(TaskComposerContext& co
TaskComposerFuture::UPtr future = executor.value().get().run(task_graph, context.problem, context.data_storage);
future->wait();

auto info_map = context.task_infos.getInfoMap();
// Merge child context data into parent context
context.task_infos.mergeInfoMap(future->context->task_infos);
if (future->context->isAborted())
context.abort(future->context->task_infos.getAbortingNode());

auto info_map = context.task_infos.getInfoMap();
if (context.problem->dotgraph)
{
std::stringstream dot_graph;
Expand Down

0 comments on commit dfcdc67

Please sign in to comment.