anchor.diff:      GOutputs = pipeline_utils:group_outputs(Grouping, PrevStageOutputs),
       make_stage_tasks(Stage, Grouping, GOutputs, S, {0, []}).
   
  +-spec make_stage_tasks(stage_name(), label_grouping(),
  +                       [grouped_output()], state(),
  +                       {non_neg_integer(), [task_id()]}) -> {[task_id()], state()}.
   make_stage_tasks(Stage, _Grouping, [],
                    #state{stage_info = SI} = S, {TaskNum, Tasks}) ->
       StageInfo1 = case jc_utils:stage_info_opt(Stage, SI) of
  
positive.code:                     end
                  end, S2, Pending).
  
  start_next_stage(PrevStageOutputs, Stage, Grouping,
                   #state{jobinfo = #jobinfo{jobname = JobName}} = S) ->
      {Tasks, S1} = setup_stage_tasks(PrevStageOutputs, Stage, Grouping, S),
  
negative.code:     end,
      S3.
  
  -spec maybe_start_pending(state()) -> state().
  maybe_start_pending(#state{pending = AllPending} = S) ->
      lists:foldl(
          fun({TaskId, Mode}, S1) ->
  