anchor.diff:                          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
  +                                    % Delay execution of last batch to ensure it happens after execution is paused
                                       true -> {passthrough_with_delay, timer:seconds(1)};
                                       false -> passthrough
                                   end
  
positive.code:         end
      },
  
      BuildAtmLaneRunTestSpecFun = fun(AtmLaneRunSelector, ExpExceptionStoreContent, IsLastExpLaneRun) ->
          #atm_lane_run_execution_test_spec{
              selector = AtmLaneRunSelector,
  
negative.code:                                 workflow_execution_exp_state = ExpState0,
                                  call_args = [_AtmWorkflowExecutionId, _AtmWorkflowExecutionEnv, AtmTaskExecutionId]
                              }) ->
                                  AssertExpTaskStatsFun(AtmTaskExecutionId, {0, 0, 6}, {0, 1, 3}, ExpState0),
                                  {true, expect_execution_stopping_while_processing_lane1(ExpState0, pause)}
                              end,
                              after_step_exp_state_diff = fun(#atm_mock_call_ctx{
  