anchor.diff:      ),
       {true, case TaskSelector of
           {AtmLaneRunSelector, _, ?ATM_TASK1_SCHEMA_ID} ->
  +            record_items_processed(TestcaseId, AtmLaneRunSelector, ItemBatch),
  +
               FailedItemCount = case FilterOutNotFailedItemsFun(ItemBatch) of
                   [] ->
                       % Batch can be processed further (by following parallel boxes)
  
positive.code:         incarnations = [#atm_workflow_execution_incarnation_test_spec{
              incarnation_num = 1,
              lane_runs = [
                  AtmLaneRunTestSpec#atm_lane_run_execution_test_spec{
                      selector = {1, 1},
                      handle_lane_execution_ended = #atm_step_mock_spec{
                          after_step_exp_state_diff = fun(AtmMockCallCtx = #atm_mock_call_ctx{
                              workflow_execution_exp_state = ExpState0
                          }) ->
                              check_exception_store_content(TestcaseId, {1, 1}, AtmMockCallCtx),
                              ExpState1 = atm_workflow_execution_exp_state_builder:expect_lane_run_failed({1, 1}, true, ExpState0),
                              {true, atm_workflow_execution_exp_state_builder:expect_lane_run_automatic_retry_scheduled({1, 2}, ExpState1)}
                          end
                      }
                  },
                  AtmLaneRunTestSpec#atm_lane_run_execution_test_spec{
                      selector = {1, 2},
                      handle_lane_execution_ended = #atm_step_mock_spec{
                          after_step_exp_state_diff = fun(AtmMockCallCtx = #atm_mock_call_ctx{
                              workflow_execution_exp_state = ExpState0
                          }) ->
                              check_exception_store_content(TestcaseId, {1, 2}, AtmMockCallCtx),
                              ExpState1 = atm_workflow_execution_exp_state_builder:expect_lane_run_failed({1, 2}, true, ExpState0),
                              {true, atm_workflow_execution_exp_state_builder:expect_lane_run_automatic_retry_scheduled({1, 3}, ExpState1)}
                          end
                      }
                  },
                  AtmLaneRunTestSpec#atm_lane_run_execution_test_spec{
                      selector = {1, 3},
                      handle_lane_execution_ended = #atm_step_mock_spec{
                          after_step_exp_state_diff = fun(AtmMockCallCtx = #atm_mock_call_ctx{
                              workflow_execution_exp_state = ExpState
                          }) ->
                              check_exception_store_content(TestcaseId, {1, 3}, AtmMockCallCtx),
                              {true, atm_workflow_execution_exp_state_builder:expect_lane_run_failed({1, 3}, true, ExpState)}
                          end
                      }
                  }
              ],
              handle_workflow_execution_ended = #atm_step_mock_spec{
                  after_step_exp_state_diff = fun(#atm_mock_call_ctx{workflow_execution_exp_state = ExpState0}) ->
  
negative.code: 
  
  %% @private
  -spec job_failure_expect_t1_failed(
      atm_task_execution:id(),
      atm_workflow_execution_test_runner:exp_state()
  