anchor.diff:      make_stage_tasks(Stage, Grouping, Rest, S2,
                        {TaskNum + 1, [NextTaskId | Acc]}).
   
  + -spec add_inputs_to_data_map(state(), [{input_id(), data_input()}]) -> state().
   add_inputs_to_data_map(#state{data_map = OldDataMap} = S, Inputs) ->
       DataMap = lists:foldl(
                   fun({InputId, DataInput}, DM) ->
  
positive.code:             TaskSpec#task_spec{all_inputs = true}
          end).
  
  send_outputs_to_consumer(S, TaskId, {_, Inputs}) ->
      #state{tasks = Tasks} = S1 = add_inputs_to_spec(S, TaskId, Inputs),
      TaskInfo = jc_utils:task_info(TaskId, Tasks),
  
negative.code:     TaskList = gb_trees:to_list(GroupMap),
      send_outputs_to_consumers(S, TaskList, ModifiedGroups).
  
  -spec send_outputs_to_consumers(state(), [task_id()], [grouped_output()]) -> state().
  send_outputs_to_consumers(S, _, []) ->
      S;
  
  