anchor.diff:              process_task_result_for_item = ProcessTaskResultForItemStepMockSpec,
   
               handle_task_execution_stopped = #atm_step_mock_spec{
  +                before_step_exp_state_diff = fun(#atm_mock_call_ctx{
  +                    workflow_execution_exp_state = ExpState0,
  +                    call_args = [_AtmWorkflowExecutionId, _AtmWorkflowExecutionEnv, AtmTaskExecutionId]
  +                }) ->
  +                    AssertExpTaskStatsFun(AtmTaskExecutionId, {0, 0, 6}, {0, 3, 6}, ExpState0),
  +                    false
  +                end,
                   after_step_exp_state_diff = fun(#atm_mock_call_ctx{
                       workflow_execution_exp_state = ExpState,
                       call_args = [_AtmWorkflowExecutionId, _AtmWorkflowExecutionEnv, AtmTaskExecutionId]
  
positive.code:                         run_task_for_item = #atm_step_mock_spec{
                              strategy = fun(#atm_mock_call_ctx{call_args = [_, _, _, _, [Item]]}) ->
                                  case lists:member(Item, [4, 5, 6]) of
                                      true -> {passthrough_with_delay, timer:seconds(1)};
                                      false -> passthrough
                                  end
  
negative.code:         end
      },
  
      AssertExpTaskStatsFun = fun(AtmTaskExecutionId, ExpTask1Stats, ExpTask2Stats, ExpState0) ->
          ExpTaskStats = case atm_workflow_execution_exp_state_builder:get_task_selector(
              AtmTaskExecutionId, ExpState0
          ) of
              {_, _, <<"task1">>} -> ExpTask1Stats;
              _ -> ExpTask2Stats
          end,
          ?assertEqual(ExpTaskStats, atm_workflow_execution_exp_state_builder:get_task_stats(
              AtmTaskExecutionId, ExpState0
          ))
      end,
  
      BuildAtmLaneRunTestSpecFun = fun(AtmLaneRunSelector, ExpExceptionStoreContent, IsLastExpLaneRun) ->
          #atm_lane_run_execution_test_spec{
              selector = AtmLaneRunSelector,
  